X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=src%2FCore%2FLock%2FSemaphoreLockDriver.php;h=781e110b1708a83633d1497296448ba639632595;hb=c713c2bf622257dbecf223b5f58bf8a98dde9d65;hp=250a75fbfe92030d513ff33b8e55b3a7c608df25;hpb=906bb25972bf3f23e6cc3b98a50c0f3fa0990964;p=friendica.git diff --git a/src/Core/Lock/SemaphoreLockDriver.php b/src/Core/Lock/SemaphoreLockDriver.php index 250a75fbfe..781e110b17 100644 --- a/src/Core/Lock/SemaphoreLockDriver.php +++ b/src/Core/Lock/SemaphoreLockDriver.php @@ -2,6 +2,8 @@ namespace Friendica\Core\Lock; +use Friendica\Core\Cache; + class SemaphoreLockDriver extends AbstractLockDriver { private static $semaphore = []; @@ -20,7 +22,7 @@ class SemaphoreLockDriver extends AbstractLockDriver { $temp = get_temppath(); - $file = $temp.'/'.$key.'.sem'; + $file = $temp . '/' . $key . '.sem'; if (!file_exists($file)) { file_put_contents($file, $key); @@ -30,10 +32,9 @@ class SemaphoreLockDriver extends AbstractLockDriver } /** - * * (@inheritdoc) */ - public function acquire($key, $timeout = 120) + public function acquireLock($key, $timeout = 120, $ttl = Cache::FIVE_MINUTES) { self::$semaphore[$key] = sem_get(self::semaphoreKey($key)); if (self::$semaphore[$key]) { @@ -49,7 +50,7 @@ class SemaphoreLockDriver extends AbstractLockDriver /** * (@inheritdoc) */ - public function release($key) + public function releaseLock($key, $override = false) { if (empty(self::$semaphore[$key])) { return false; @@ -66,6 +67,6 @@ class SemaphoreLockDriver extends AbstractLockDriver */ public function isLocked($key) { - return @sem_get(self::$semaphore[$key]) !== false; + return isset(self::$semaphore[$key]); } }