LockerProcess.php

Go to the documentation of this file.

<?php
namespace Magento\Framework\View\Asset;

use Magento\Framework\App\Filesystem\DirectoryList;
use Magento\Framework\App\ObjectManager;
use Magento\Framework\App\State;
use Magento\Framework\Exception\FileSystemException;
use Magento\Framework\Filesystem;
use Magento\Framework\Filesystem\Directory\WriteInterface;

class LockerProcess implements LockerProcessInterface
{
    const LOCK_EXTENSION = '.lock';

    const MAX_LOCK_TIME = 30;

    private $filesystem;

    private $lockFilePath;

    private $tmpDirectory;

    private $state;

    public function __construct(Filesystem $filesystem)
    {
        $this->filesystem = $filesystem;
    }

    public function lockProcess($lockName)
    {
        if ($this->getState()->getMode() == State::MODE_PRODUCTION) {
            return;
        }

        $this->tmpDirectory = $this->filesystem->getDirectoryWrite(DirectoryList::VAR_DIR);
        $this->lockFilePath = $this->getFilePath($lockName);

        while ($this->isProcessLocked()) {
            usleep(1000);
        }

        $this->tmpDirectory->writeFile($this->lockFilePath, time());
    }

    public function unlockProcess()
    {
        if ($this->getState()->getMode() == State::MODE_PRODUCTION) {
            return;
        }

        $this->tmpDirectory->delete($this->lockFilePath);
    }

    private function isProcessLocked()
    {
        if ($this->tmpDirectory->isExist($this->lockFilePath)) {
            try {
                $lockTime = (int)$this->tmpDirectory->readFile($this->lockFilePath);
                if ((time() - $lockTime) >= self::MAX_LOCK_TIME) {
                    $this->tmpDirectory->delete($this->lockFilePath);

                    return false;
                }
            } catch (FileSystemException $e) {
                return false;
            }

            return true;
        }

        return false;
    }

    private function getFilePath($name)
    {
        return DirectoryList::TMP . DIRECTORY_SEPARATOR . $name . self::LOCK_EXTENSION;
    }

    private function getState()
    {
        if (null === $this->state) {
            $this->state = ObjectManager::getInstance()->get(State::class);
        }
        return $this->state;
    }
}