Concurrency::mutexReserve() - Code Metrics - nc-music/music - Measure and Improve Code Quality continuously with Scrutinizer

Concurrency::mutexReserve() A
last analyzed 2026-01-28 21:56 UTC

↳ Parent: Concurrency

Complexity

Conditions	3
Paths	3

Size

Total Lines	16
Code Lines	10

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
cc	3
eloc	10
c	0
b	0
f	0
nc	3
nop	2
dl	0
loc	16
rs	9.9332

<?php declare(strict_types=1);

/**
 * ownCloud - Music app
 *
 * This file is licensed under the Affero General Public License version 3 or
 * later. See the COPYING file.
 *
 * @author Pauli Järvinen <[email protected]>
 * @copyright Pauli Järvinen 2026
 */

namespace OCA\Music\Utility;

use OCA\Music\AppFramework\Core\Logger;
use OCA\Music\Db\Cache;

class Concurrency {
	private const SEMAPHORE_KEY_BASE = 0xa5e63947; // arbitrarily selected 32-bit base value

	public function __construct(private Cache $cache, private Logger $logger) {
	}

	public function mutexReserve(string $userId, string $key) : false|\SysvSemaphore {
		if (!\extension_loaded('sysvsem')) {
			$this->logger->warning('PHP extension sysvsem should be installed to guarantee correct behavior');
			return false;
		}

		$mutexKey = self::SEMAPHORE_KEY_BASE + $this->cache->forcedGetId($userId, "mutex_key.$key");
		$mutex = \sem_get($mutexKey);

		if ($mutex !== false) {
			\sem_acquire($mutex);
		} else {
			$this->logger->warning('Failed to acquire the semaphore');
		}

		return $mutex;

	}

	public function mutexRelease(false|\SysvSemaphore $mutex) : void {
		if ($mutex !== false) {
			\sem_release($mutex);
		}
	}
}

1			<?php declare(strict_types=1);
2
3			/**
4			* ownCloud - Music app
5			*
6			* This file is licensed under the Affero General Public License version 3 or
7			* later. See the COPYING file.
8			*
9			* @author Pauli Järvinen <[email protected]>
10			* @copyright Pauli Järvinen 2026
11			*/
12
13			namespace OCA\Music\Utility;
14
15			use OCA\Music\AppFramework\Core\Logger;
16			use OCA\Music\Db\Cache;
17
18			class Concurrency {
19			private const SEMAPHORE_KEY_BASE = 0xa5e63947; // arbitrarily selected 32-bit base value
20
21			public function __construct(private Cache $cache, private Logger $logger) {
22			}
23
24			public function mutexReserve(string $userId, string $key) : false\|\SysvSemaphore {
25			if (!\extension_loaded('sysvsem')) {
26			$this->logger->warning('PHP extension sysvsem should be installed to guarantee correct behavior');
27			return false;
28			}
29
30			$mutexKey = self::SEMAPHORE_KEY_BASE + $this->cache->forcedGetId($userId, "mutex_key.$key");
31			$mutex = \sem_get($mutexKey);
32
33			if ($mutex !== false) {
34			\sem_acquire($mutex);
35			} else {
36			$this->logger->warning('Failed to acquire the semaphore');
37			}
38
39			return $mutex;
			0 ignored issues – show Bug Best Practice introduced 2026-01-25 14:50 UTC by Report Bug Copy Issue Report The expression `return $mutex` could return the type `resource` which is incompatible with the type-hinted return `SysvSemaphore\|false`. Consider adding an additional type-check to rule them out. Loading history...
40			}
41
42			public function mutexRelease(false\|\SysvSemaphore $mutex) : void {
43			if ($mutex !== false) {
44			\sem_release($mutex);
45			}
46			}
47			}

nc-music / music

Concurrency::mutexReserve() A last analyzed 2026-01-28 21:56 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

Concurrency::mutexReserve() A
last analyzed 2026-01-28 21:56 UTC