namespace Friendica\Core\Lock;
-use Friendica\Core\Cache\IMemoryCacheDriver;
+use Friendica\Core\Cache;
+use Friendica\Core\Cache\IMemoryCache;
-class CacheLockDriver extends AbstractLockDriver
+class CacheLockDriver extends AbstractLock
{
/**
- * @var \Friendica\Core\Cache\ICacheDriver;
+ * @var \Friendica\Core\Cache\ICache;
*/
private $cache;
/**
* CacheLockDriver constructor.
*
- * @param IMemoryCacheDriver $cache The CacheDriver for this type of lock
+ * @param IMemoryCache $cache The CacheDriver for this type of lock
*/
- public function __construct(IMemoryCacheDriver $cache)
+ public function __construct(IMemoryCache $cache)
{
$this->cache = $cache;
}
/**
* (@inheritdoc)
*/
- public function acquireLock($key, $timeout = 120)
+ public function acquireLock($key, $timeout = 120, $ttl = Cache::FIVE_MINUTES)
{
$got_lock = false;
- $start = time();
+ $start = time();
$cachekey = self::getLockKey($key);
// At first initialize it with "0"
$this->cache->add($cachekey, 0);
// Now the value has to be "0" because otherwise the key was used by another process meanwhile
- if ($this->cache->compareSet($cachekey, 0, getmypid(), 300)) {
+ if ($this->cache->compareSet($cachekey, 0, getmypid(), $ttl)) {
$got_lock = true;
$this->markAcquire($key);
}
/**
* (@inheritdoc)
*/
- public function releaseLock($key)
+ public function releaseLock($key, $override = false)
{
$cachekey = self::getLockKey($key);
- $this->cache->compareDelete($cachekey, getmypid());
+ if ($override) {
+ $return = $this->cache->delete($cachekey);
+ } else {
+ $return = $this->cache->compareDelete($cachekey, getmypid());
+ }
$this->markRelease($key);
+
+ return $return;
}
/**
public function isLocked($key)
{
$cachekey = self::getLockKey($key);
- $lock = $this->cache->get($cachekey);
+ $lock = $this->cache->get($cachekey);
return isset($lock) && ($lock !== false);
}
/**
- * @param string $key The original key
- * @return string The cache key used for the cache
+ * @param string $key The original key
+ *
+ * @return string The cache key used for the cache
*/
- private static function getLockKey($key) {
+ private static function getLockKey($key)
+ {
return "lock:" . $key;
}
}