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