@ -33,6 +33,13 @@ abstract class AbstractLockingProvider implements ILockingProvider {
'exclusive' => []
];
/**
* Check if we've locally acquired a lock
*
* @param string $path
* @param int $type
* @return bool
*/
protected function hasAcquiredLock($path, $type) {
if ($type === self::LOCK_SHARED) {
return isset($this->acquiredLocks['shared'][$path]) && $this->acquiredLocks['shared'][$path] > 0;
@ -51,6 +51,12 @@ class DBLockingProvider extends AbstractLockingProvider {
const TTL = 3600; // how long until we clear stray locks in seconds
* Check if we have an open shared lock for a path
protected function isLocallyLocked($path) {
return isset($this->sharedLocks[$path]) && $this->sharedLocks[$path];
}