* * 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:----b0Q7VBBWib+wREa5C/1G7PfBzzGMChXRUw7ETmrHdo9/RTUq07ykxIOWPZdS089Nk2CAX88IAypFNWqXj1D1haMhdbFQJUYKTDfEcE7k/d31d+2YXDcEe6BXQtXdUAbOwr91vpuFYb3JpKfPKYNXO3aD4IdE9sciHX24WstXvdyom66fGEcjmkW7qAVU15+rXqLP3vF9RBzqSchlsez2S0/0TgmZQHhZru6VHW5425AXNQwTuY+XYhTlAVpAjeNh0TuHWYZHeB/JkfSZ93M3/hW5eeqWnCFuJs1aLUjx2+8lFAZaD2zWjmkFgFOx35JtMSEC70s9GSwNr7Q7ZZBNZU9QW6Xvog9INxKMmBZo3jhn4AubxOSTOC6Lcj2W+ULWlue6SwabnLhVA2TUXx2gW09olNkbsPP8SDvBfN+zZxP9cpusQQP7Z7xz5JLlufhiakYLxZjPKVvh3U4VQHi7bWMukm16b7stlf0R5PuU0PKfi8JvxvvuObYrAqdg6ZagyCO8hb7YnsL2k0chFC7UMQHRsYOf5PKagPnyorkUfcUvZ5Q8mgLfswuwoOCuxE4KJQEG2NI5Iw15J4QburKAHxTlx9H7PvooKlVimpLsC27B+CoVIv9/lYYSO0zlyPvjhOXgIIR3I/VvwIf8TDJSV64XhfdnFKIvxr7IbrnhQD8=----ATTACHMENT:----ODgxOTk3MTQ4NTE3NzA0OSA4MDE2ODg5NDg0ODQyODIwIDk1MzY1MDE0ODIwNjE3ODg=