X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=src%2FCore%2FLock%2FAbstractLockDriver.php;h=0aedeeb1b09ab61cdf71c144c7df3b6cd02e6263;hb=c713c2bf622257dbecf223b5f58bf8a98dde9d65;hp=033d6f356e74ce263f9909877e276db80ddb597a;hpb=ff5ee74ecfbd39b630433c6e1d7cfcd9611d4660;p=friendica.git diff --git a/src/Core/Lock/AbstractLockDriver.php b/src/Core/Lock/AbstractLockDriver.php index 033d6f356e..0aedeeb1b0 100644 --- a/src/Core/Lock/AbstractLockDriver.php +++ b/src/Core/Lock/AbstractLockDriver.php @@ -23,7 +23,8 @@ abstract class AbstractLockDriver extends BaseObject implements ILockDriver * @param string key The Name of the lock * @return bool Returns true if the lock is set */ - protected function hasAcquiredLock($key) { + protected function hasAcquiredLock($key) + { return isset($this->acquireLock[$key]) && $this->acquiredLocks[$key] === true; } @@ -32,7 +33,8 @@ abstract class AbstractLockDriver extends BaseObject implements ILockDriver * * @param string $key The Name of the lock */ - protected function markAcquire($key) { + protected function markAcquire($key) + { $this->acquiredLocks[$key] = true; } @@ -41,18 +43,26 @@ abstract class AbstractLockDriver extends BaseObject implements ILockDriver * * @param string $key The Name of the lock */ - protected function markRelease($key) { + protected function markRelease($key) + { unset($this->acquiredLocks[$key]); } /** * Releases all lock that were set by us * - * @return void + * @return boolean Was the unlock of all locks successful? */ - public function releaseAll() { + public function releaseAll() + { + $return = true; + foreach ($this->acquiredLocks as $acquiredLock => $hasLock) { - $this->releaseLock($acquiredLock); + if (!$this->releaseLock($acquiredLock)) { + $return = false; + } } + + return $return; } }