QDriver.cc

Go to the documentation of this file.

#include "QDriver.hh"
#include "QEventAssembler.hh"
#include "QError.hh"
#include "QBool.hh"
 
Q_BEGIN_NAMESPACE
 
 
QDriver::Action QDriver::Init(QEventAssembler& eva) 
{ 
    Panic("Missing method: \"Action Init(QEvent& ev)\" or  \"Action Init(QEventAssembler& eva)\" not implemented");
    return ACT_NEXTEV;
}
 
 
QDriver::Action QDriver::Do(QEventAssembler& eva) 
{
    Panic("Missing method: \"void Do(QEvent& ev)\" or  \"void Do(QEvent& ev, const QEventList& neigh)\" not implemented");
    return ACT_NEXTEV;
}
 
QDriver::Action QDriver::Do(QEventAssembler& eva, const QEventList& neigh) 
{ 
    return Do(eva); 
}
 
void QDriver::Begin(QEventAssembler& ev) 
{ 
 
    fLastAction = Init(ev); 
    fSkipEvents = GetBool("SkipEvents",false,false);
    if(!fSkipEvents) {
        Info("Skip events set to false");
        ev.GetEvent().Add<QBool>("SkipEvent").SetWrite(false);
    }
 
    if(fLastAction.fActionId == ACT_PREVEV) {
        Error("go to previous event not supported before the event loop start");
        fLastAction.fActionId = ACT_NEXTEV;
    }
 
    HandleAction(fLastAction);
    SetNeedNeighbours(false);
}
 
void QDriver::End() 
{ 
    if(fLastAction.fActionId != ACT_RERUN && fLastAction.fActionId != ACT_QUIT) {
        fLastAction = Done(); 
        HandleAction(fLastAction);
    }
}
 
bool QDriver::Process(QEventAssembler& eva, QEventList& neigh,const bool exec,QEventList& oneigh)
{
    if(!fSkipEvents) eva.GetEvent().Get<QBool>("SkipEvent") = !exec;
 
    if((!fSkipEvents || exec ) && fLastAction.fActionId != ACT_RERUN && fLastAction.fActionId != ACT_QUIT) {
        QEvent& ev = eva.GetEvent();
        if(fSkipEvents) fLastAction = Do(eva,oneigh);
        else fLastAction = Do(eva,neigh);
        fExecuted = true;
        fCurrentEventNumber = ev.GetReadNumber();
        HandleAction(fLastAction);
    }
 
    if(fSkip) return false;
    return exec;
}
 
void QDriver::HandleAction(Action action)
{
    fStopRun = false;
    fSkip = false;
 
    switch (action.fActionId) {
        case ACT_NEXTEV:
            break;
        case ACT_SKIP:
            fSkip = true;
            break;
        case ACT_PREVEV:
            {
                QError err =  JumpToEvent(fCurrentEventNumber - 1);
                if(err != QERR_SUCCESS) 
                    Error("Error on go to previous event: %s",err.GetDescription().c_str());
                break;
            }
        case ACT_GOTOEV:
            {
                QError err =  JumpToEvent(action.fEventNumber);
                if(err != QERR_SUCCESS) 
                    Error("Action go to event %d: %s",action.fEventNumber,err.GetDescription().c_str());
                break;
            }
        case ACT_RERUN:
            {
                fStopRun = true;
                SetRunAgain(true);
                break;
            }
        case ACT_QUIT:
        default:
            {
                fStopRun = true;
                SetRunAgain(false);
                break;
            }
    };
}
 
Q_END_NAMESPACE