rector/vendor/symfony/console/Command/LockableTrait.php
Tomas Votruba 8883574049 Updated Rector to commit 6f1f047087a496a41745c1ea994273e3bc8dcdb4
6f1f047087 add RenameParamValueObjectInterface to trusted downgrade widening types
2021-07-09 23:00:32 +00:00

61 lines
2.1 KiB
PHP

<?php
/*
* This file is part of the Symfony package.
*
* (c) Fabien Potencier <fabien@symfony.com>
*
* For the full copyright and license information, please view the LICENSE
* file that was distributed with this source code.
*/
namespace RectorPrefix20210709\Symfony\Component\Console\Command;
use RectorPrefix20210709\Symfony\Component\Console\Exception\LogicException;
use RectorPrefix20210709\Symfony\Component\Lock\Lock;
use RectorPrefix20210709\Symfony\Component\Lock\LockFactory;
use RectorPrefix20210709\Symfony\Component\Lock\Store\FlockStore;
use RectorPrefix20210709\Symfony\Component\Lock\Store\SemaphoreStore;
/**
* Basic lock feature for commands.
*
* @author Geoffrey Brier <geoffrey.brier@gmail.com>
*/
trait LockableTrait
{
/** @var Lock */
private $lock;
/**
* Locks a command.
*/
private function lock(string $name = null, bool $blocking = \false) : bool
{
if (!\class_exists(\RectorPrefix20210709\Symfony\Component\Lock\Store\SemaphoreStore::class)) {
throw new \RectorPrefix20210709\Symfony\Component\Console\Exception\LogicException('To enable the locking feature you must install the symfony/lock component.');
}
if (null !== $this->lock) {
throw new \RectorPrefix20210709\Symfony\Component\Console\Exception\LogicException('A lock is already in place.');
}
if (\RectorPrefix20210709\Symfony\Component\Lock\Store\SemaphoreStore::isSupported()) {
$store = new \RectorPrefix20210709\Symfony\Component\Lock\Store\SemaphoreStore();
} else {
$store = new \RectorPrefix20210709\Symfony\Component\Lock\Store\FlockStore();
}
$this->lock = (new \RectorPrefix20210709\Symfony\Component\Lock\LockFactory($store))->createLock($name ?: $this->getName());
if (!$this->lock->acquire($blocking)) {
$this->lock = null;
return \false;
}
return \true;
}
/**
* Releases the command lock if there is one.
*/
private function release()
{
if ($this->lock) {
$this->lock->release();
$this->lock = null;
}
}
}