Merge pull request #5730 from nupplaphil/friendica-5716
CacheLockDriverTest Fixings
This commit is contained in:
commit
164c05e953
6 changed files with 31 additions and 80 deletions
|
@ -8,21 +8,9 @@ use Friendica\Core\Lock\CacheLockDriver;
|
||||||
|
|
||||||
class ArrayCacheLockDriverTest extends LockTest
|
class ArrayCacheLockDriverTest extends LockTest
|
||||||
{
|
{
|
||||||
/**
|
|
||||||
* @var \Friendica\Core\Cache\IMemoryCacheDriver
|
|
||||||
*/
|
|
||||||
private $cache;
|
|
||||||
|
|
||||||
protected function getInstance()
|
protected function getInstance()
|
||||||
{
|
{
|
||||||
$this->cache = new ArrayCache();
|
return new CacheLockDriver(new ArrayCache());
|
||||||
return new CacheLockDriver($this->cache);
|
|
||||||
}
|
|
||||||
|
|
||||||
public function tearDown()
|
|
||||||
{
|
|
||||||
$this->cache->clear();
|
|
||||||
parent::tearDown();
|
|
||||||
}
|
}
|
||||||
|
|
||||||
public function testLockTTL()
|
public function testLockTTL()
|
||||||
|
|
|
@ -19,6 +19,7 @@ abstract class LockTest extends DatabaseTest
|
||||||
{
|
{
|
||||||
parent::setUp();
|
parent::setUp();
|
||||||
$this->instance = $this->getInstance();
|
$this->instance = $this->getInstance();
|
||||||
|
$this->instance->releaseAll();
|
||||||
|
|
||||||
// Reusable App object
|
// Reusable App object
|
||||||
$this->app = BaseObject::getApp();
|
$this->app = BaseObject::getApp();
|
||||||
|
@ -31,11 +32,18 @@ abstract class LockTest extends DatabaseTest
|
||||||
Config::set('system', 'theme', 'system_theme');
|
Config::set('system', 'theme', 'system_theme');
|
||||||
}
|
}
|
||||||
|
|
||||||
|
protected function tearDown()
|
||||||
|
{
|
||||||
|
parent::tearDown();
|
||||||
|
$this->instance->releaseAll();
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @small
|
* @small
|
||||||
*/
|
*/
|
||||||
public function testLock() {
|
public function testLock() {
|
||||||
$this->instance->acquireLock('foo', 1);
|
$this->assertFalse($this->instance->isLocked('foo'));
|
||||||
|
$this->assertTrue($this->instance->acquireLock('foo', 1));
|
||||||
$this->assertTrue($this->instance->isLocked('foo'));
|
$this->assertTrue($this->instance->isLocked('foo'));
|
||||||
$this->assertFalse($this->instance->isLocked('bar'));
|
$this->assertFalse($this->instance->isLocked('bar'));
|
||||||
}
|
}
|
||||||
|
@ -44,7 +52,8 @@ abstract class LockTest extends DatabaseTest
|
||||||
* @small
|
* @small
|
||||||
*/
|
*/
|
||||||
public function testDoubleLock() {
|
public function testDoubleLock() {
|
||||||
$this->instance->acquireLock('foo', 1);
|
$this->assertFalse($this->instance->isLocked('foo'));
|
||||||
|
$this->assertTrue($this->instance->acquireLock('foo', 1));
|
||||||
$this->assertTrue($this->instance->isLocked('foo'));
|
$this->assertTrue($this->instance->isLocked('foo'));
|
||||||
// We already locked it
|
// We already locked it
|
||||||
$this->assertTrue($this->instance->acquireLock('foo', 1));
|
$this->assertTrue($this->instance->acquireLock('foo', 1));
|
||||||
|
@ -54,7 +63,8 @@ abstract class LockTest extends DatabaseTest
|
||||||
* @small
|
* @small
|
||||||
*/
|
*/
|
||||||
public function testReleaseLock() {
|
public function testReleaseLock() {
|
||||||
$this->instance->acquireLock('foo', 1);
|
$this->assertFalse($this->instance->isLocked('foo'));
|
||||||
|
$this->assertTrue($this->instance->acquireLock('foo', 1));
|
||||||
$this->assertTrue($this->instance->isLocked('foo'));
|
$this->assertTrue($this->instance->isLocked('foo'));
|
||||||
$this->instance->releaseLock('foo');
|
$this->instance->releaseLock('foo');
|
||||||
$this->assertFalse($this->instance->isLocked('foo'));
|
$this->assertFalse($this->instance->isLocked('foo'));
|
||||||
|
@ -64,9 +74,9 @@ abstract class LockTest extends DatabaseTest
|
||||||
* @small
|
* @small
|
||||||
*/
|
*/
|
||||||
public function testReleaseAll() {
|
public function testReleaseAll() {
|
||||||
$this->instance->acquireLock('foo', 1);
|
$this->assertTrue($this->instance->acquireLock('foo', 1));
|
||||||
$this->instance->acquireLock('bar', 1);
|
$this->assertTrue($this->instance->acquireLock('bar', 1));
|
||||||
$this->instance->acquireLock('nice', 1);
|
$this->assertTrue($this->instance->acquireLock('nice', 1));
|
||||||
|
|
||||||
$this->assertTrue($this->instance->isLocked('foo'));
|
$this->assertTrue($this->instance->isLocked('foo'));
|
||||||
$this->assertTrue($this->instance->isLocked('bar'));
|
$this->assertTrue($this->instance->isLocked('bar'));
|
||||||
|
@ -83,9 +93,12 @@ abstract class LockTest extends DatabaseTest
|
||||||
* @small
|
* @small
|
||||||
*/
|
*/
|
||||||
public function testReleaseAfterUnlock() {
|
public function testReleaseAfterUnlock() {
|
||||||
$this->instance->acquireLock('foo', 1);
|
$this->assertFalse($this->instance->isLocked('foo'));
|
||||||
$this->instance->acquireLock('bar', 1);
|
$this->assertFalse($this->instance->isLocked('bar'));
|
||||||
$this->instance->acquireLock('nice', 1);
|
$this->assertFalse($this->instance->isLocked('nice'));
|
||||||
|
$this->assertTrue($this->instance->acquireLock('foo', 1));
|
||||||
|
$this->assertTrue($this->instance->acquireLock('bar', 1));
|
||||||
|
$this->assertTrue($this->instance->acquireLock('nice', 1));
|
||||||
|
|
||||||
$this->instance->releaseLock('foo');
|
$this->instance->releaseLock('foo');
|
||||||
|
|
||||||
|
@ -103,10 +116,12 @@ abstract class LockTest extends DatabaseTest
|
||||||
* @medium
|
* @medium
|
||||||
*/
|
*/
|
||||||
function testLockTTL() {
|
function testLockTTL() {
|
||||||
|
$this->assertFalse($this->instance->isLocked('foo'));
|
||||||
|
$this->assertFalse($this->instance->isLocked('bar'));
|
||||||
|
|
||||||
// TODO [nupplaphil] - Because of the Datetime-Utils for the database, we have to wait a FULL second between the checks to invalidate the db-locks/cache
|
// TODO [nupplaphil] - Because of the Datetime-Utils for the database, we have to wait a FULL second between the checks to invalidate the db-locks/cache
|
||||||
$this->instance->acquireLock('foo', 1, 1);
|
$this->assertTrue($this->instance->acquireLock('foo', 2, 1));
|
||||||
$this->instance->acquireLock('bar', 1, 3);
|
$this->assertTrue($this->instance->acquireLock('bar', 2, 3));
|
||||||
|
|
||||||
$this->assertTrue($this->instance->isLocked('foo'));
|
$this->assertTrue($this->instance->isLocked('foo'));
|
||||||
$this->assertTrue($this->instance->isLocked('bar'));
|
$this->assertTrue($this->instance->isLocked('bar'));
|
||||||
|
|
|
@ -3,7 +3,6 @@
|
||||||
|
|
||||||
namespace Friendica\Test\src\Core\Lock;
|
namespace Friendica\Test\src\Core\Lock;
|
||||||
|
|
||||||
|
|
||||||
use Friendica\Core\Cache\CacheDriverFactory;
|
use Friendica\Core\Cache\CacheDriverFactory;
|
||||||
use Friendica\Core\Lock\CacheLockDriver;
|
use Friendica\Core\Lock\CacheLockDriver;
|
||||||
|
|
||||||
|
@ -12,20 +11,8 @@ use Friendica\Core\Lock\CacheLockDriver;
|
||||||
*/
|
*/
|
||||||
class MemcacheCacheLockDriverTest extends LockTest
|
class MemcacheCacheLockDriverTest extends LockTest
|
||||||
{
|
{
|
||||||
/**
|
|
||||||
* @var \Friendica\Core\Cache\IMemoryCacheDriver
|
|
||||||
*/
|
|
||||||
private $cache;
|
|
||||||
|
|
||||||
protected function getInstance()
|
protected function getInstance()
|
||||||
{
|
{
|
||||||
$this->cache = CacheDriverFactory::create('memcache');
|
return new CacheLockDriver(CacheDriverFactory::create('memcache'));
|
||||||
return new CacheLockDriver($this->cache);
|
|
||||||
}
|
|
||||||
|
|
||||||
public function tearDown()
|
|
||||||
{
|
|
||||||
$this->cache->clear();
|
|
||||||
parent::tearDown();
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -3,7 +3,6 @@
|
||||||
|
|
||||||
namespace Friendica\Test\src\Core\Lock;
|
namespace Friendica\Test\src\Core\Lock;
|
||||||
|
|
||||||
|
|
||||||
use Friendica\Core\Cache\CacheDriverFactory;
|
use Friendica\Core\Cache\CacheDriverFactory;
|
||||||
use Friendica\Core\Lock\CacheLockDriver;
|
use Friendica\Core\Lock\CacheLockDriver;
|
||||||
|
|
||||||
|
@ -12,20 +11,8 @@ use Friendica\Core\Lock\CacheLockDriver;
|
||||||
*/
|
*/
|
||||||
class MemcachedCacheLockDriverTest extends LockTest
|
class MemcachedCacheLockDriverTest extends LockTest
|
||||||
{
|
{
|
||||||
/**
|
|
||||||
* @var \Friendica\Core\Cache\IMemoryCacheDriver
|
|
||||||
*/
|
|
||||||
private $cache;
|
|
||||||
|
|
||||||
protected function getInstance()
|
protected function getInstance()
|
||||||
{
|
{
|
||||||
$this->cache = CacheDriverFactory::create('memcached');
|
return new CacheLockDriver(CacheDriverFactory::create('memcached'));
|
||||||
return new CacheLockDriver($this->cache);
|
|
||||||
}
|
|
||||||
|
|
||||||
public function tearDown()
|
|
||||||
{
|
|
||||||
$this->cache->clear();
|
|
||||||
parent::tearDown();
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -3,7 +3,6 @@
|
||||||
|
|
||||||
namespace Friendica\Test\src\Core\Lock;
|
namespace Friendica\Test\src\Core\Lock;
|
||||||
|
|
||||||
|
|
||||||
use Friendica\Core\Cache\CacheDriverFactory;
|
use Friendica\Core\Cache\CacheDriverFactory;
|
||||||
use Friendica\Core\Lock\CacheLockDriver;
|
use Friendica\Core\Lock\CacheLockDriver;
|
||||||
|
|
||||||
|
@ -12,21 +11,9 @@ use Friendica\Core\Lock\CacheLockDriver;
|
||||||
*/
|
*/
|
||||||
class RedisCacheLockDriverTest extends LockTest
|
class RedisCacheLockDriverTest extends LockTest
|
||||||
{
|
{
|
||||||
/**
|
|
||||||
* @var \Friendica\Core\Cache\IMemoryCacheDriver
|
|
||||||
*/
|
|
||||||
private $cache;
|
|
||||||
|
|
||||||
protected function getInstance()
|
protected function getInstance()
|
||||||
{
|
{
|
||||||
$this->cache = CacheDriverFactory::create('redis');
|
return new CacheLockDriver(CacheDriverFactory::create('redis'));
|
||||||
return new CacheLockDriver($this->cache);
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
public function tearDown()
|
|
||||||
{
|
|
||||||
$this->cache->clear();
|
|
||||||
parent::tearDown();
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
|
@ -2,26 +2,13 @@
|
||||||
|
|
||||||
namespace Friendica\Test\src\Core\Lock;
|
namespace Friendica\Test\src\Core\Lock;
|
||||||
|
|
||||||
|
|
||||||
use Friendica\Core\Lock\SemaphoreLockDriver;
|
use Friendica\Core\Lock\SemaphoreLockDriver;
|
||||||
|
|
||||||
class SemaphoreLockDriverTest extends LockTest
|
class SemaphoreLockDriverTest extends LockTest
|
||||||
{
|
{
|
||||||
/**
|
|
||||||
* @var \Friendica\Core\Lock\SemaphoreLockDriver
|
|
||||||
*/
|
|
||||||
private $semaphoreLockDriver;
|
|
||||||
|
|
||||||
protected function getInstance()
|
protected function getInstance()
|
||||||
{
|
{
|
||||||
$this->semaphoreLockDriver = new SemaphoreLockDriver();
|
return new SemaphoreLockDriver();
|
||||||
return $this->semaphoreLockDriver;
|
|
||||||
}
|
|
||||||
|
|
||||||
public function tearDown()
|
|
||||||
{
|
|
||||||
$this->semaphoreLockDriver->releaseAll();
|
|
||||||
parent::tearDown();
|
|
||||||
}
|
}
|
||||||
|
|
||||||
function testLockTTL()
|
function testLockTTL()
|
||||||
|
|
Loading…
Reference in a new issue