1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
|
<?php
namespace Illuminate\Tests\Integration\Cache;
use Exception;
use Illuminate\Foundation\Testing\Concerns\InteractsWithRedis;
use Illuminate\Support\Carbon;
use Illuminate\Support\Facades\Cache;
use Orchestra\Testbench\TestCase;
/**
* @group integration
*/
class RedisCacheLockTest extends TestCase
{
use InteractsWithRedis;
protected function setUp(): void
{
parent::setUp();
$this->setUpRedis();
}
protected function tearDown(): void
{
parent::tearDown();
$this->tearDownRedis();
}
public function testRedisLocksCanBeAcquiredAndReleased()
{
Cache::store('redis')->lock('foo')->forceRelease();
$lock = Cache::store('redis')->lock('foo', 10);
$this->assertTrue($lock->get());
$this->assertFalse(Cache::store('redis')->lock('foo', 10)->get());
$lock->release();
$lock = Cache::store('redis')->lock('foo', 10);
$this->assertTrue($lock->get());
$this->assertFalse(Cache::store('redis')->lock('foo', 10)->get());
Cache::store('redis')->lock('foo')->release();
}
public function testRedisLocksCanBlockForSeconds()
{
Carbon::setTestNow();
Cache::store('redis')->lock('foo')->forceRelease();
$this->assertSame('taylor', Cache::store('redis')->lock('foo', 10)->block(1, function () {
return 'taylor';
}));
Cache::store('redis')->lock('foo')->forceRelease();
$this->assertTrue(Cache::store('redis')->lock('foo', 10)->block(1));
}
public function testConcurrentRedisLocksAreReleasedSafely()
{
Cache::store('redis')->lock('foo')->forceRelease();
$firstLock = Cache::store('redis')->lock('foo', 1);
$this->assertTrue($firstLock->get());
sleep(2);
$secondLock = Cache::store('redis')->lock('foo', 10);
$this->assertTrue($secondLock->get());
$firstLock->release();
$this->assertFalse(Cache::store('redis')->lock('foo')->get());
}
public function testRedisLocksWithFailedBlockCallbackAreReleased()
{
Cache::store('redis')->lock('foo')->forceRelease();
$firstLock = Cache::store('redis')->lock('foo', 10);
try {
$firstLock->block(1, function () {
throw new Exception('failed');
});
} catch (Exception $e) {
// Not testing the exception, just testing the lock
// is released regardless of the how the exception
// thrown by the callback was handled.
}
$secondLock = Cache::store('redis')->lock('foo', 1);
$this->assertTrue($secondLock->get());
}
public function testRedisLocksCanBeReleasedUsingOwnerToken()
{
Cache::store('redis')->lock('foo')->forceRelease();
$firstLock = Cache::store('redis')->lock('foo', 10);
$this->assertTrue($firstLock->get());
$owner = $firstLock->owner();
$secondLock = Cache::store('redis')->restoreLock('foo', $owner);
$secondLock->release();
$this->assertTrue(Cache::store('redis')->lock('foo')->get());
}
}
|
