QModule.cc

Go to the documentation of this file.

#include "QModule.hh"
#include "QBool.hh"
#include "QEventAssembler.hh"
 
Q_BEGIN_NAMESPACE
 
QModule::QModule() : QBaseModule(Module)
{
}
 
QModule::~QModule()
{
}
 
void QModule::Begin(QEventAssembler& eva) 
{ 
    fRunOnIteration = GetInt("RunOnIteration",0,false);
    if(fRunOnIteration > 2) Panic("Controlling sequence iterations > 2 is not implemented!");
    if(fRunOnIteration > 0 && fRunOnIteration != GetIteration()) return;
    Init(eva.GetEvent()); 
    fSkipEvents = GetBool("SkipEvents",true,false);
    if(!fSkipEvents) {
        Info("Skip events set to false");
        eva.GetEvent().Add<QBool>("SkipEvent").SetWrite(false);
    }
    fFirstCall = true;
    SetNeedNeighbours(true); 
    fSkipRequiredNotValid = GetBool("SkipRequiredNotValid",false,false);
   
    if(fSkipRequiredNotValid) {
        Info("Skipping events with non valid but required objects");
        eva.GetEvent().Add<QBool>("RequiredAreValid").SetWrite(false);
    } else {
        Debug("NOT skipping events with non valid but required objects");
    }
 
}
 
bool QModule::Process( QEventAssembler& eva, QEventList& neigh, const bool exec, QEventList& oneigh) 
{
    
    if(fRunOnIteration > 0 && fRunOnIteration != GetIteration()) return exec;
 
    if(!fSkipEvents) eva.GetEvent().Get<QBool>("SkipEvent") = !exec;
    if(!fSkipEvents || exec) { 
        bool requiredAreValid = true;
        if(fSkipRequiredNotValid) {
            const std::vector<QEventLabel>& labels = GetRequiredLabels();
            for(size_t  l = 0; l < labels.size(); l++) {
                const char* owner = labels[l].owner.c_str();
                const char* name = labels[l].name.c_str();
                ReadHandle<QObject> rHandle(name);
                eva.GetEvent().Get(owner,rHandle);
                if(!rHandle.IsValid() && labels[l].owner != fLabel){
                    requiredAreValid = false;
                    l = labels.size();
                }
            }
 
            eva.GetEvent().Get<QBool>("RequiredAreValid") = requiredAreValid;
        }
        if(requiredAreValid) {
            Do(eva.GetEvent(),oneigh); 
            fExecuted = true;
        }
    }
    // modules do not control wheter skip or not other modules
    return exec; 
} 
 
void QModule::Do(QEvent& ev)
{
    Panic("Missing method: \"void Do(QEvent& ev)\" or  \"void Do(QEvent& ev, const QEventList& neigh)\" not implemented");
}
 
 
void QModule::Do( QEvent& ev, const QEventList& neighbours) 
{ 
    if(fFirstCall) {
        SetNeedNeighbours(false); 
        fFirstCall = false;
    }
    Do(ev); 
}
 
 
void QModule::End() 
{ 
    if(fRunOnIteration > 0 && fRunOnIteration != GetIteration()) {
        if(fRunOnIteration > GetIteration()) {
            SetRunAgain(true);
        }
        return;
    } 
    Done(); 
}
Q_END_NAMESPACE