|
|
|
|
@ -764,6 +764,7 @@ abstract class Common implements Storage, ILockingStorage, IWriteStreamStorage {
|
|
|
|
|
try {
|
|
|
|
|
$provider->acquireLock('files/' . md5($this->getId() . '::' . trim($path, '/')), $type, $this->getId() . '::' . $path);
|
|
|
|
|
} catch (LockedException $e) {
|
|
|
|
|
$e = new LockedException($e->getPath(), $e, $e->getExistingLock(), $path);
|
|
|
|
|
if ($logger) {
|
|
|
|
|
$logger->info($e->getMessage(), ['exception' => $e]);
|
|
|
|
|
}
|
|
|
|
|
@ -796,6 +797,7 @@ abstract class Common implements Storage, ILockingStorage, IWriteStreamStorage {
|
|
|
|
|
try {
|
|
|
|
|
$provider->releaseLock('files/' . md5($this->getId() . '::' . trim($path, '/')), $type);
|
|
|
|
|
} catch (LockedException $e) {
|
|
|
|
|
$e = new LockedException($e->getPath(), $e, $e->getExistingLock(), $path);
|
|
|
|
|
if ($logger) {
|
|
|
|
|
$logger->info($e->getMessage(), ['exception' => $e]);
|
|
|
|
|
}
|
|
|
|
|
@ -828,6 +830,7 @@ abstract class Common implements Storage, ILockingStorage, IWriteStreamStorage {
|
|
|
|
|
try {
|
|
|
|
|
$provider->changeLock('files/' . md5($this->getId() . '::' . trim($path, '/')), $type);
|
|
|
|
|
} catch (LockedException $e) {
|
|
|
|
|
$e = new LockedException($e->getPath(), $e, $e->getExistingLock(), $path);
|
|
|
|
|
if ($logger) {
|
|
|
|
|
$logger->info($e->getMessage(), ['exception' => $e]);
|
|
|
|
|
}
|
|
|
|
|
|