MQPulseManager.cc

Go to the documentation of this file.

#include "MQPulseManager.hh"
#include "QEventAssembler.hh"
#include "QRawEvent.hh"
#include <iostream>
 
using namespace Diana;
 
REGISTER_MODULE(MQPulseManager)
 
MQPulseManager::MQPulseManager()
{
    // called once in a sequence
}
 
MQPulseManager::~MQPulseManager()
{
    // called once in a sequence
}
 
QDriver::Action MQPulseManager::Init(QEventAssembler& eva)
{
    std::vector<QEventLabel> evDataLabels = eva.GetWriteLabels();
    std::vector<QEventLabel>::const_iterator evLabelIter = evDataLabels.begin();
    bool inclusive = GetBool("InclusiveMode",true);
    fAction = GetString("Action","Consolidate",true);
    while(evLabelIter != evDataLabels.end()) {
        QEventLabel label = *evLabelIter;
        if(GetBool(label.GetStringLabel(),inclusive,false) ) {
            QObject** peventData = eva.Get(label.owner.c_str(),label.name.c_str());
            QObject* eventData = (*peventData);
            std::string type = eventData->GetName();
            if(type == "QPulse") {
                fLabelsToStore.push_back(label);
                eva.GetEvent().RequireByLabel<QPulse>(label);
            }
        }
        evLabelIter++;
    }
 
 
    return ACT_NEXTEV;
}
 
QDriver::Action MQPulseManager::Do(QEventAssembler& eva)
{
    // called event by event
    std::vector<QEventLabel>::const_iterator iter = fLabelsToStore.begin();
    while(iter != fLabelsToStore.end()) {
        QPulse& pulse = eva.Get<QPulse>(iter->owner.c_str(),iter->name.c_str());
        if(fAction == "Consolidate") {
            pulse.Consolidate();
        } else if(fAction == "DeleteADC") {
            pulse.DeleteADC();
        } else {
            Panic("Action %s is not valid",fAction.c_str());
        }
        iter++;
    }
 
    return ACT_NEXTEV;
}
 
QDriver::Action MQPulseManager::Done()
{
    // called at the end of the event loop
    return ACT_NEXTEV;
}