namespace Friendica\Core\Lock;
-class SemaphoreLockDriver implements ILockDriver
+use Friendica\Core\Cache;
+
+class SemaphoreLockDriver extends AbstractLockDriver
{
- /**
- * @var array stored semaphores
- */
private static $semaphore = [];
+ public function __construct()
+ {
+ if (!function_exists('sem_get')) {
+ throw new \Exception('Semaphore lock not supported');
+ }
+ }
+
/**
- * @brief Creates a semaphore key
- *
- * @param string $key Name of the lock
- *
- * @return integer the semaphore key
+ * (@inheritdoc)
*/
private static function semaphoreKey($key)
{
$temp = get_temppath();
- $file = $temp.'/'.$key.'.sem';
+ $file = $temp . '/' . $key . '.sem';
if (!file_exists($file)) {
file_put_contents($file, $key);
}
/**
- *
- * @brief Sets a lock for a given name
- *
- * @param string $key The Name of the lock
- * @param integer $timeout Seconds until we give up
- *
- * @return boolean Was the lock successful?
+ * (@inheritdoc)
*/
- public function acquireLock($key, $timeout = 120)
+ public function acquireLock($key, $timeout = 120, $ttl = Cache::FIVE_MINUTES)
{
- // The second parameter for "sem_acquire" doesn't exist before 5.6.1
- if (function_exists('sem_get') && version_compare(PHP_VERSION, '5.6.1', '>=')) {
- self::$semaphore[$key] = sem_get(self::semaphoreKey($key));
- if (self::$semaphore[$key]) {
- return sem_acquire(self::$semaphore[$key], ($timeout == 0));
+ self::$semaphore[$key] = sem_get(self::semaphoreKey($key));
+ if (self::$semaphore[$key]) {
+ if (sem_acquire(self::$semaphore[$key], ($timeout == 0))) {
+ $this->markAcquire($key);
+ return true;
}
}
+
+ return false;
}
/**
- * @brief Removes a lock if it was set by us
- *
- * @param string $key Name of the lock
- *
- * @return mixed
+ * (@inheritdoc)
*/
- public function releaseLock($key)
+ public function releaseLock($key, $override = false)
{
- if (function_exists('sem_get') && version_compare(PHP_VERSION, '5.6.1', '>=')) {
- if (empty(self::$semaphore[$key])) {
- return false;
- } else {
- $success = @sem_release(self::$semaphore[$key]);
- unset(self::$semaphore[$key]);
- return $success;
- }
+ if (empty(self::$semaphore[$key])) {
+ return false;
+ } else {
+ $success = @sem_release(self::$semaphore[$key]);
+ unset(self::$semaphore[$key]);
+ $this->markRelease($key);
+ return $success;
}
}
/**
- * @brief Removes all lock that were set by us
- *
- * @return void
+ * (@inheritdoc)
*/
- public function releaseAll()
+ public function isLocked($key)
{
- // not needed/supported
- return;
+ return isset(self::$semaphore[$key]);
}
-}
\ No newline at end of file
+}