ROsReadoutAlg.cc

Go to the documentation of this file.

#include "ROsReadoutAlg.h"
#include "ReadoutSim/IROsReadoutTool.h"
#include "ReadoutSim/IROsTriggerDataPackerTool.h"

#include "Event/SimReadoutHeader.h"
#include "Event/ReadoutTriggerDataPkg.h"
#include "Event/SimTrigHeader.h"
#include "Event/ElecHeader.h"

#include <vector>

ROsReadoutAlg::ROsReadoutAlg(const std::string& name, ISvcLocator* pSvcLocator)
    : DybAlgorithm<DayaBay::SimReadoutHeader>(name,pSvcLocator)
{
    m_roToolNames.push_back("ROsFeeReadoutTool");
    m_roToolNames.push_back("ROsFecReadoutTool");
    declareProperty("RoTools",m_roToolNames,
                    "Tools to generate Triggers");
    declareProperty("RoName", m_roName = "ReadoutAlg",
                    "Name of this Trigger Algorithm for book keeping purposes.");
    declareProperty("TrigPackagerTool",m_roTrigPackName="ROsTriggerDataPackerTool",
                    "Tool to convert trigger commands from TrigSim to TriggerDataPackage");
    declareProperty("TrigLocation",m_trigLocation=DayaBay::SimTrigHeaderLocation::Default,
                    "Location in the TES where the output SimTrigHeader is to be found.");
    declareProperty("ElecLocation",m_elecLocation=DayaBay::ElecHeaderLocation::Default,
                    "Location in the TES where the input ElecHeader is to be found.");
}

ROsReadoutAlg::~ROsReadoutAlg()
{
}

StatusCode ROsReadoutAlg::initialize()
{

    try{
        m_roTrigPackTool = tool<IROsTriggerDataPackerTool>(m_roTrigPackName);
    }catch(const GaudiException& exg){
        fatal() << "Failed to get Readout Trigger Package Tool: \""
                << m_roTrigPackName << "\"" << endreq;
        return StatusCode::FAILURE;
    }

    for (size_t ind=0; ind < m_roToolNames.size(); ++ind) {
        std::string rotool = m_roToolNames[ind];
        try{
                m_roTools.push_back(tool<IROsReadoutTool>(rotool));
        }catch(const GaudiException& exg) {
            fatal() << "Failed to get Readout Tool: \"" << rotool
                    << "\"" << endreq;
            return StatusCode::FAILURE;
        }
        info () << "Added readout tool " << rotool << endreq;
    }

    return StatusCode::SUCCESS;
}

StatusCode ROsReadoutAlg::execute()
{
    debug() << "Entering ROsReadoutAlg.execute()" << endreq;
    // Look for pre-existing header object or make new one
    DayaBay::SimReadoutHeader* roHeader = MakeHeaderObject();

    //set readouts to have same validity range as the crate its read out from.
    // This can be refined later.
    DayaBay::ElecHeader* elecHeader = getTES<DayaBay::ElecHeader>(m_elecLocation);
    DayaBay::SimTrigHeader* trigHeader = getTES<DayaBay::SimTrigHeader>(m_trigLocation);

    //roHeader->setTimeStamp(elecHeader->timeStamp()); // this seems redundant (and duplicating) when one looks at the line 78
    TimeStamp earliest = elecHeader->earliest();
    TimeStamp latest = elecHeader->latest();

    roHeader->setEarliest(earliest);
    roHeader->setLatest(latest);
    roHeader->setContext(elecHeader->context());

    debug() << "Applying Trigger Data Packer Tool" << endreq;

    std::vector<DayaBay::ReadoutTriggerDataPkg*> trigPkgs;

    m_roTrigPackTool->fillDataPackages(trigPkgs,*trigHeader);

    // Let each tool do its thing on the event
    for (size_t ind = 0; ind< m_roTools.size(); ++ind) {
        debug () << "Running trigger tool #" << ind << " " << m_roToolNames[ind] << endreq;
        if (m_roTools[ind]->mutate(roHeader,trigPkgs,*elecHeader).isFailure()) {
            fatal() << "Readout Tool " << m_roToolNames[ind]
                    << " failed" << endreq;
            return StatusCode::FAILURE;
        }
    }

    verbose() << *roHeader << endreq;
    // HeaderObject base
    return StatusCode::SUCCESS;
}

StatusCode ROsReadoutAlg::finalize()
{
    m_roTools.clear();

    return this->GaudiAlgorithm::finalize();
}