optimize releaselock for memcache based locking backends
This commit is contained in:
parent
5b45f0f914
commit
49ad0fcfa9
2 changed files with 11 additions and 2 deletions
|
@ -116,4 +116,8 @@ abstract class AbstractLockingProvider implements ILockingProvider {
|
|||
$this->releaseLock($path, self::LOCK_EXCLUSIVE);
|
||||
}
|
||||
}
|
||||
|
||||
protected function getOwnSharedLockCount($path) {
|
||||
return isset($this->acquiredLocks['shared'][$path]) ? $this->acquiredLocks['shared'][$path] : 0;
|
||||
}
|
||||
}
|
||||
|
|
|
@ -88,9 +88,14 @@ class MemcacheLockingProvider extends AbstractLockingProvider {
|
|||
*/
|
||||
public function releaseLock($path, $type) {
|
||||
if ($type === self::LOCK_SHARED) {
|
||||
if (isset($this->acquiredLocks['shared'][$path]) and $this->acquiredLocks['shared'][$path] > 0) {
|
||||
if ($this->getOwnSharedLockCount($path) === 1) {
|
||||
$removed = $this->memcache->cad($path, 1); // if we're the only one having a shared lock we can remove it in one go
|
||||
if (!$removed) { //someone else also has a shared lock, decrease only
|
||||
$this->memcache->dec($path);
|
||||
}
|
||||
} else {
|
||||
// if we own more than one lock ourselves just decrease
|
||||
$this->memcache->dec($path);
|
||||
$this->memcache->cad($path, 0);
|
||||
}
|
||||
} else if ($type === self::LOCK_EXCLUSIVE) {
|
||||
$this->memcache->cad($path, 'exclusive');
|
||||
|
|
Loading…
Reference in a new issue