aboutsummaryrefslogtreecommitdiffstats
path: root/lib/private/Files/Lock/LockManager.php
diff options
context:
space:
mode:
Diffstat (limited to 'lib/private/Files/Lock/LockManager.php')
-rw-r--r--lib/private/Files/Lock/LockManager.php45
1 files changed, 37 insertions, 8 deletions
diff --git a/lib/private/Files/Lock/LockManager.php b/lib/private/Files/Lock/LockManager.php
index e2af532a01c..978c378e506 100644
--- a/lib/private/Files/Lock/LockManager.php
+++ b/lib/private/Files/Lock/LockManager.php
@@ -1,5 +1,9 @@
<?php
+/**
+ * SPDX-FileCopyrightText: 2022 Nextcloud GmbH and Nextcloud contributors
+ * SPDX-License-Identifier: AGPL-3.0-or-later
+ */
namespace OC\Files\Lock;
use OCP\Files\Lock\ILock;
@@ -7,8 +11,11 @@ use OCP\Files\Lock\ILockManager;
use OCP\Files\Lock\ILockProvider;
use OCP\Files\Lock\LockContext;
use OCP\PreConditionNotMetException;
+use Psr\Container\ContainerExceptionInterface;
+use Psr\Container\NotFoundExceptionInterface;
class LockManager implements ILockManager {
+ private ?string $lockProviderClass = null;
private ?ILockProvider $lockProvider = null;
private ?LockContext $lockInScope = null;
@@ -20,12 +27,34 @@ class LockManager implements ILockManager {
$this->lockProvider = $lockProvider;
}
+ public function registerLazyLockProvider(string $lockProviderClass): void {
+ if ($this->lockProviderClass || $this->lockProvider) {
+ throw new PreConditionNotMetException('There is already a registered lock provider');
+ }
+
+ $this->lockProviderClass = $lockProviderClass;
+ }
+
+ private function getLockProvider(): ?ILockProvider {
+ if ($this->lockProvider) {
+ return $this->lockProvider;
+ }
+ if ($this->lockProviderClass) {
+ try {
+ $this->lockProvider = \OCP\Server::get($this->lockProviderClass);
+ } catch (NotFoundExceptionInterface|ContainerExceptionInterface $e) {
+ }
+ }
+
+ return $this->lockProvider;
+ }
+
public function isLockProviderAvailable(): bool {
- return $this->lockProvider !== null;
+ return $this->getLockProvider() !== null;
}
public function runInScope(LockContext $lock, callable $callback): void {
- if (!$this->lockProvider) {
+ if (!$this->getLockProvider()) {
$callback();
return;
}
@@ -47,26 +76,26 @@ class LockManager implements ILockManager {
}
public function getLocks(int $fileId): array {
- if (!$this->lockProvider) {
+ if (!$this->getLockProvider()) {
throw new PreConditionNotMetException('No lock provider available');
}
- return $this->lockProvider->getLocks($fileId);
+ return $this->getLockProvider()->getLocks($fileId);
}
public function lock(LockContext $lockInfo): ILock {
- if (!$this->lockProvider) {
+ if (!$this->getLockProvider()) {
throw new PreConditionNotMetException('No lock provider available');
}
- return $this->lockProvider->lock($lockInfo);
+ return $this->getLockProvider()->lock($lockInfo);
}
public function unlock(LockContext $lockInfo): void {
- if (!$this->lockProvider) {
+ if (!$this->getLockProvider()) {
throw new PreConditionNotMetException('No lock provider available');
}
- $this->lockProvider->unlock($lockInfo);
+ $this->getLockProvider()->unlock($lockInfo);
}
}