class.ilAssQuestionProcessLockerFile.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 ilAssQuestionProcessLockerFile extends ilAssQuestionProcessLocker
{
    const PROCESS_NAME_QUESTION_WORKING_STATE_UPDATE = 'questionWorkingStateUpdate';
    
    protected $lockFileStorage;

    protected $lockFileHandles;

    public function __construct(ilAssQuestionProcessLockFileStorage $lockFileStorage)
    {
        $this->lockFileStorage = $lockFileStorage;
        $this->lockFileHandles = array();
    }

    protected function onBeforeExecutingPersistWorkingStateOperation()
    {
        $this->requestLock(self::PROCESS_NAME_QUESTION_WORKING_STATE_UPDATE);
    }

    protected function onAfterExecutingPersistWorkingStateOperation()
    {
        $this->releaseLock(self::PROCESS_NAME_QUESTION_WORKING_STATE_UPDATE);
    }

    protected function onBeforeExecutingUserSolutionAdoptOperation()
    {
        $this->requestLock(self::PROCESS_NAME_QUESTION_WORKING_STATE_UPDATE);
    }

    protected function onAfterExecutingUserSolutionAdoptOperation()
    {
        $this->releaseLock(self::PROCESS_NAME_QUESTION_WORKING_STATE_UPDATE);
    }

    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]);
    }
}