@@ 114-126 (lines=13) @@ | ||
111 | /** |
|
112 | * @test |
|
113 | */ |
|
114 | public function shouldConnectAndAcquireALock() |
|
115 | { |
|
116 | $subject = uniqid(); |
|
117 | $mutex = sprintf('lock:mutex:%s', $subject); |
|
118 | ||
119 | $locker = $this->getLocker($subject); |
|
120 | ||
121 | $redis = $this->getRedisClient(); |
|
122 | ||
123 | self::assertTrue($redis->exists($mutex)); |
|
124 | ||
125 | self::assertTrue($locker->acquire()); |
|
126 | } |
|
127 | ||
128 | /** |
|
129 | * @test |
|
@@ 145-157 (lines=13) @@ | ||
142 | /** |
|
143 | * @test |
|
144 | */ |
|
145 | public function shouldConnectAndDestroyALock() |
|
146 | { |
|
147 | $subject = uniqid(); |
|
148 | $mutex = sprintf('lock:mutex:%s', $subject); |
|
149 | ||
150 | $locker = $this->getLocker($subject); |
|
151 | ||
152 | $redis = $this->getRedisClient(); |
|
153 | ||
154 | $locker->destroy(); |
|
155 | ||
156 | self::assertFalse($redis->exists($mutex)); |
|
157 | } |
|
158 | ||
159 | /** |
|
160 | * @test |