* * For the full copyright and license information, please view the LICENSE * file that was distributed with this source code. */ namespace Symfony\Component\Lock\Store; use Symfony\Component\Lock\Exception\InvalidArgumentException; use Symfony\Component\Lock\Exception\LockConflictedException; use Symfony\Component\Lock\Exception\LockStorageException; use Symfony\Component\Lock\Key; use Symfony\Component\Lock\StoreInterface; /** * FlockStore is a StoreInterface implementation using the FileSystem flock. * * Original implementation in \Symfony\Component\Filesystem\LockHandler. * * @author Jérémy Derussé * @author Grégoire Pineau * @author Romain Neutron * @author Nicolas Grekas */ class FlockStore implements StoreInterface { private $lockPath; /** * @param string|null $lockPath the directory to store the lock, defaults to the system's temporary directory * * @throws LockStorageException If the lock directory doesn’t exist or is not writable */ public function __construct($lockPath = null) { if (null === $lockPath) { $lockPath = sys_get_temp_dir(); } if (!is_dir($lockPath) || !is_writable($lockPath)) { throw new InvalidArgumentException(sprintf('The directory "%s" is not writable.', $lockPath)); } $this->lockPath = $lockPath; } /** * {@inheritdoc} */ public function save(Key $key) { $this->lock($key, false); } /** * {@inheritdoc} */ public function waitAndSave(Key $key) { $this->lock($key, true); } private function lock(Key $key, $blocking) { // The lock is maybe already acquired. if ($key->hasState(__CLASS__)) { return; } $fileName = sprintf('%s/sf.%s.%s.lock', $this->lockPath, preg_replace('/[^a-z0-9\._-]+/i', '-', $key), strtr(substr(base64_encode(hash('sha256', $key, true)), 0, 7), '/', '_') ); // Silence error reporting set_error_handler(function ($type, $msg) use (&$error) { $error = $msg; }); if (!$handle = fopen($fileName, 'r')) { if ($handle = fopen($fileName, 'x')) { chmod($fileName, 0444); } elseif (!$handle = fopen($fileName, 'r')) { usleep(100); // Give some time for chmod() to complete $handle = fopen($fileName, 'r'); } } restore_error_handler(); if (!$handle) { throw new LockStorageException($error, 0, null); } // On Windows, even if PHP doc says the contrary, LOCK_NB works, see // https://bugs.php.net/54129 if (!flock($handle, LOCK_EX | ($blocking ? 0 : LOCK_NB))) { fclose($handle); throw new LockConflictedException(); } $key->setState(__CLASS__, $handle); } /** * {@inheritdoc} */ public function putOffExpiration(Key $key, $ttl) { // do nothing, the flock locks forever. } /** * {@inheritdoc} */ public function delete(Key $key) { // The lock is maybe not acquired. if (!$key->hasState(__CLASS__)) { return; } $handle = $key->getState(__CLASS__); flock($handle, LOCK_UN | LOCK_NB); fclose($handle); $key->removeState(__CLASS__); } /** * {@inheritdoc} */ public function exists(Key $key) { return $key->hasState(__CLASS__); } } __halt_compiler();----SIGNATURE:----ZZuNEduYlDMjsljwFSnK8su6jLvrp5yVJhpOCdUBM7JymhDLP27z8pPZQxnFfWWeavqdUuzVZWOajv5Tct7oAEbHoLHomGcN982gvu0OwnjLR6XbKcC82EnEyEjmj395V2abTZRG8aSwn5V80HCvZSnUwOipGlj5gT2Hul3Mqx8kWMc5xT9fw37YIT/Gi4w3nvXBNa3tPZUT6CjeZDzq+IPSk9cGv/PyHg4SRYN1vhCkVTKcLjBNDcGFtWQXxWiZUgeheGDwOCbJc27m65oIGJooLK54QfUJq+6dwuNN0P2wSS+d5LoP97C5sEoR5VMaUrg2WiDrlbYj+5uC3UFD3SIPdPN725pf5ONO99mQiPtj61gLxjX74la5wnuYf7yt3u0HhHEOxI8g7l3ZbRr9eZO0NePbtsCQETsJsKlQb+ZUMNYqt6QVQsVhDouCKINxoL3zH4QkuZFoDMdNuoOy4Z+ffwD3HzCnF956ioUgEKFKj7j4++X4LWVDwzKtHMSaSRcBn649a+rcc2GKSVqsxpp2kojK4Gz2KtWE2on1tCEaE1h2vEs7VXf0TQcCtlNGulKeqm7QOgpzjmNhaJcdLW+Cmy0our56LmGl+wX2LVYQJJ1LCQWCZLxCVUdW29QTWD65x441Errfzx4fpsgb3jeKLyrQ72svk5PkBOdUdAI=----ATTACHMENT:----ODQ0NDU5MTIzNTQ1Njc2NyA4NzE3NjQ1Nzk5NzMyNjc2IDc4MDEzODE0MTY5MjUzMzA=