Some code hardenings for semaphore locking
This commit is contained in:
parent
720534a82b
commit
de7c026590
|
@ -39,8 +39,8 @@ class SemaphoreLock extends Lock
|
||||||
public function acquireLock($key, $timeout = 120, $ttl = Cache\Cache::FIVE_MINUTES)
|
public function acquireLock($key, $timeout = 120, $ttl = Cache\Cache::FIVE_MINUTES)
|
||||||
{
|
{
|
||||||
self::$semaphore[$key] = sem_get(self::semaphoreKey($key));
|
self::$semaphore[$key] = sem_get(self::semaphoreKey($key));
|
||||||
if (self::$semaphore[$key]) {
|
if (!empty(self::$semaphore[$key])) {
|
||||||
if (sem_acquire(self::$semaphore[$key], ($timeout == 0))) {
|
if ((bool)sem_acquire(self::$semaphore[$key], ($timeout === 0))) {
|
||||||
$this->markAcquire($key);
|
$this->markAcquire($key);
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in a new issue