class.ilTestProcessLockerFile.php

Go to the documentation of this file.

<?php
/* Copyright (c) 1998-2013 ILIAS open source, Extended GPL, see docs/LICENSE */
 
require_once 'Modules/TestQuestionPool/classes/class.ilAssQuestionProcessLocker.php';
 
class ilTestProcessLockerFile extends ilTestProcessLocker
{
    const PROCESS_NAME_TEST_START_LOCK_CHECK = 'testStartLockCheck';
    const PROCESS_NAME_RANDOM_PASS_BUILD = 'randomPassBuild';
    const PROCESS_NAME_TEST_FINISH = 'testFinish';
    
    protected $lockFileStorage;
 
    protected $lockFileHandles;
 
    public function __construct(ilTestProcessLockFileStorage $lockFileStorage)
    {
        $this->lockFileStorage = $lockFileStorage;
        $this->lockFileHandles = array();
    }
 
    protected function onBeforeExecutingTestStartOperation()
    {
        parent::onBeforeExecutingTestStartOperation();
        $this->requestLock(self::PROCESS_NAME_TEST_START_LOCK_CHECK);
    }
 
    protected function onAfterExecutingTestStartOperation()
    {
        $this->releaseLock(self::PROCESS_NAME_TEST_START_LOCK_CHECK);
        parent::onAfterExecutingTestStartOperation();
    }
 
    protected function onBeforeExecutingRandomPassBuildOperation($withTaxonomyTables = false)
    {
        parent::onBeforeExecutingRandomPassBuildOperation($withTaxonomyTables);
        $this->requestLock(self::PROCESS_NAME_RANDOM_PASS_BUILD);
    }
 
    protected function onAfterExecutingRandomPassBuildOperation($withTaxonomyTables = false)
    {
        $this->releaseLock(self::PROCESS_NAME_RANDOM_PASS_BUILD);
        parent::onAfterExecutingRandomPassBuildOperation($withTaxonomyTables);
    }
    
    protected function onBeforeExecutingTestFinishOperation()
    {
        parent::onBeforeExecutingTestStartOperation();
        $this->requestLock(self::PROCESS_NAME_TEST_FINISH);
    }
    
    protected function onAfterExecutingTestFinishOperation()
    {
        $this->releaseLock(self::PROCESS_NAME_TEST_FINISH);
        parent::onAfterExecutingTestStartOperation();
    }
 
    protected function onBeforeExecutingNamedOperation(string $operationDescriptor) : void
    {
        $this->requestLock($operationDescriptor);
        parent::onBeforeExecutingNamedOperation($operationDescriptor);
    }
 
    protected function onAfterExecutingNamedOperation(string $operationDescriptor) : void
    {
        $this->releaseLock($operationDescriptor);
        parent::onAfterExecutingNamedOperation($operationDescriptor);
    }
 
    private function requestLock($processName)
    {
        $lockFilePath = $this->getLockFilePath($processName);
        $this->lockFileHandles[$processName] = fopen($lockFilePath, 'w');
        flock($this->lockFileHandles[$processName], LOCK_EX);
    }
    
    private function getLockFilePath($processName)
    {
        $path = $this->lockFileStorage->getPath();
        return $path . '/' . $processName . '.lock';
    }
    
    private function releaseLock($processName)
    {
        flock($this->lockFileHandles[$processName], LOCK_UN);
        fclose($this->lockFileHandles[$processName]);
    }
}