scheduler.cpp

Go to the documentation of this file.

// PTF - Psychological Test Framework
// http://ptf.sourceforge.net
//
// This program is free software; you can redistribute it and/or modify
// it under the terms of the GNU General Public License as published by
// the Free Software Foundation; either version 2 of the License, or
// (at your option) any later version.
//
// This program is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
// GNU Library General Public License for more details.
//
// You should have received a copy of the GNU General Public License
// along with this program; if not, write to the Free Software
// Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.

#include <ptf/core/scheduler.hpp>
#include <ptf/core/timeinterval.hpp>
#include <ptf/core/ptfcore.hpp>
#include <ptf/environment/graphic.hpp>
#include <stdexcept>

Scheduler::Scheduler() {
    quitFlag = false;  
}

Scheduler::~Scheduler() {
    // nothing to do here
}

void Scheduler::schedule() {
    // get object for easier access
    PtfCore& ptf = PtfCore::getSingleton();
    // print message
    ptf.getMessageLog() << MESSAGE("Running test.\n");
    // time interval object
    TimeInterval time;
    time.measureA();
    // main loop which runs as long as task are available
    while (!quitFlag && ptf.getSequenceIterator().hasNextTaskId()) {
        // get the id of the next task
        int taskId = ptf.getSequenceIterator().getNextTaskId();
        // check task id
        if ((taskId > (int)ptf.getTasks().size()) || (ptf.getTasks()[taskId] == 0 )) {
            ptf.getMessageLog() << ERROR("  Bad task id in sequence file.\n");
            throw std::runtime_error("Bad task id in sequence file.");
        }
        // create time interval objects used for storing execution times of
        // the three task methods being called
        TimeInterval* tprepare = new TimeInterval();
        TimeInterval* trun = new TimeInterval();
        TimeInterval* tfinish = new TimeInterval();
        // run the prepare method of the task and get execution time
        tprepare->measureA();
        ptf.getTasks()[taskId]->prepare();
        tprepare->measureB();
        wait(ptf.getTasks()[taskId]->getWaitPrepareExecute());
        // run the execute method of the task and get execution time
        trun->measureA();
        ptf.getTasks()[taskId]->run();
        trun->measureB();
        wait(ptf.getTasks()[taskId]->getWaitExecuteFinish());
        // run the execute method of the task and get execution time
        tfinish->measureA();
        ptf.getTasks()[taskId]->finish();
        tfinish->measureB();
        wait(ptf.getTasks()[taskId]->getWaitFinishNextTask());
        // put gathered info in a task record (guarded by Mutex)
        TaskRecord* trec = new TaskRecord(taskId, tprepare, trun, tfinish);
        ptf.getTaskRecordsMutex().enterMutex();
        ptf.getTaskRecords().push_back(trec);
        ptf.getTaskRecordsMutex().leaveMutex();
        // print status
        timespec delta1, delta2, delta3;
        delta1 = tprepare->getDifference();
        delta2 = trun->getDifference();
        delta3 = tfinish->getDifference();
        // task log
        ptf.getTaskLog() << "Task " << taskId << ":\n"
            << "\tPREPARE " << tprepare->toString()
            << "\tdelta " << delta1 << "\n"
            << "\tRUN     " << trun->toString()
            << "\tdelta " << delta2 << "\n"
            << "\tFINISH  " << tfinish->toString()
            << "\tdelta " << delta3 << "\n";
        // call reaction handler
        ptf.getReactionHandler().handle();
    }
    // print message
    ptf.getMessageLog() << MESSAGE("Finished test.\n");
}

void Scheduler::wait(timespec time) {
    TimeInterval duration;
    duration.measureA();
    duration.measureB();
    // perform wait
    while (duration.compareDifference(time) > 0) {
        duration.measureB();    
    } 
}

void Scheduler::quit() {
    PtfCore::getSingleton().getMessageLog() 
            << MESSAGE("Scheduler caught quit message. Exiting as soon as possible.\n");
    quitFlag = true;
}

---