aboutsummaryrefslogtreecommitdiffstats
path: root/apps/testing/lib/Locking
diff options
context:
space:
mode:
Diffstat (limited to 'apps/testing/lib/Locking')
-rw-r--r--apps/testing/lib/Locking/FakeDBLockingProvider.php48
1 files changed, 48 insertions, 0 deletions
diff --git a/apps/testing/lib/Locking/FakeDBLockingProvider.php b/apps/testing/lib/Locking/FakeDBLockingProvider.php
new file mode 100644
index 00000000000..f77bacc7a63
--- /dev/null
+++ b/apps/testing/lib/Locking/FakeDBLockingProvider.php
@@ -0,0 +1,48 @@
+<?php
+
+/**
+ * SPDX-FileCopyrightText: 2017-2024 Nextcloud GmbH and Nextcloud contributors
+ * SPDX-FileCopyrightText: 2016 ownCloud, Inc.
+ * SPDX-License-Identifier: AGPL-3.0-only
+ */
+namespace OCA\Testing\Locking;
+
+use OC\Lock\DBLockingProvider;
+use OCP\AppFramework\Utility\ITimeFactory;
+use OCP\IDBConnection;
+
+class FakeDBLockingProvider extends DBLockingProvider {
+ // Lock for 10 hours just to be sure
+ public const TTL = 36000;
+
+ /**
+ * Need a new child, because parent::connection is private instead of protected...
+ */
+ protected IDBConnection $db;
+
+ public function __construct(
+ IDBConnection $connection,
+ ITimeFactory $timeFactory,
+ ) {
+ parent::__construct($connection, $timeFactory);
+ $this->db = $connection;
+ }
+
+ /** @inheritDoc */
+ public function releaseLock(string $path, int $type): void {
+ // we DONT keep shared locks till the end of the request
+ if ($type === self::LOCK_SHARED) {
+ $this->db->executeUpdate(
+ 'UPDATE `*PREFIX*file_locks` SET `lock` = 0 WHERE `key` = ? AND `lock` = 1',
+ [$path]
+ );
+ }
+
+ parent::releaseLock($path, $type);
+ }
+
+ public function __destruct() {
+ // Prevent cleaning up at the end of the live time.
+ // parent::__destruct();
+ }
+}