ReadoutTriggerDataPkg.cc

Go to the documentation of this file.

#include "Event/ReadoutTriggerDataPkg.h"
#include "Event/ReadoutTriggerDataFrame.h"
#include <ostream>

DayaBay::ReadoutTriggerDataPkg::~ReadoutTriggerDataPkg(){
    TriggerFrameCollection::iterator it=m_frames.begin();
    for ( ; it!=m_frames.end(); it++ ) {
        if (*it && (*it)->package()==this ) delete *it;
    }
    m_frames.clear();
}

std::ostream& DayaBay::ReadoutTriggerDataPkg::fillStream(std::ostream& s) const
{
    s << "Begin ReadoutTriggerDataPkg\n"
      << "\tDet: " << m_detector.detName() << "\n"
      << "\tReadout: " << m_readout << "\n"
      << "\tTrigger Number: " << m_trigNumber << "\n"
      << "\tNumber Sub Triggers: " << m_numSubTriggers << "\n"
      << "\tStatus: " << m_boardStatus << "\n"
      << "\tLocal SN: " << m_localSN << "\n"
      << "\tFrames"<< std::endl;
    TriggerFrameCollection::const_iterator it, done = m_frames.end();
    for (it=m_frames.begin(); it != done; ++it) {
      s << **it << std::endl;
    }
    s << "End ReadoutTriggerDataPkg" << std::endl;
    return s;
}

void DayaBay::ReadoutTriggerDataPkg::addFrame(DayaBay::ReadoutTriggerDataFrame* tdf)
{
    tdf->setPackage(this);
    m_frames.push_back(tdf);
    m_numSubTriggers=m_frames.size();
}

DayaBay::ReadoutTriggerDataPkg::ReadoutTriggerDataPkg(const DayaBay::ReadoutTriggerDataPkg& rh)
{
    m_readout=0;
    m_frames.clear();

    std::vector<DayaBay::ReadoutTriggerDataFrame*> frames = rh.frames();
    std::vector<DayaBay::ReadoutTriggerDataFrame*>::iterator it, done=frames.end();

    if ( !rh.detector().isRPC() ) { // PMT frames
        for (it = frames.begin(); it != done; ++it) {
            DayaBay::ReadoutTriggerDataFrame *nf = new DayaBay::ReadoutTriggerDataFrame(**it);
            nf->setPackage(this);
            this->addFrame(nf);
        }
    } else { // need to deal with RPC frames separately
        for (it = frames.begin(); it != done; ++it) {
            DayaBay::ReadoutRpcTriggerDataFrame* rpcframe =
                dynamic_cast<DayaBay::ReadoutRpcTriggerDataFrame*>(*it);
            // FIXME: should put some check on whether we realy get RPC frame
            // and handle propery the situation when we don't
            DayaBay::ReadoutTriggerDataFrame *nf = new DayaBay::ReadoutRpcTriggerDataFrame(*rpcframe);
            nf->setPackage(this);
            this->addFrame(nf);
        }
    }

    m_detector=rh.detector();
    m_trigNumber=rh.trigNumber();
    m_boardStatus=rh.boardStatus();
    m_localSN=rh.localSN();

}

DayaBay::ReadoutTriggerDataPkg& DayaBay::ReadoutTriggerDataPkg::operator=(const DayaBay::ReadoutTriggerDataPkg& rh)
{
    if (this == &rh) return *this;

    std::vector<DayaBay::ReadoutTriggerDataFrame*> frames = rh.frames();
    std::vector<DayaBay::ReadoutTriggerDataFrame*> newframes;

    std::vector<DayaBay::ReadoutTriggerDataFrame*>::iterator it, done=frames.end();

    for (it = frames.begin(); it != done; ++it) {
        DayaBay::ReadoutTriggerDataFrame *nf = new DayaBay::ReadoutTriggerDataFrame(**it);
        nf->setPackage(this);
        this->addFrame(nf);
    }
    //this->setFrames(newframes);
    //this->setFrames(newframes);
    m_readout=0;
    m_detector=rh.detector();
    m_trigNumber=rh.trigNumber();
    m_boardStatus=rh.boardStatus();
    m_localSN=rh.localSN();

    return *this;
}

DayaBay::DaqLtb* DayaBay::ReadoutTriggerDataPkg::daqLtb() const {
    DaqLtb* result = new DaqLtb(m_trigNumber,
                                // TODO: Fix this!
                                0, //int rawTriggerTotal,
                                m_boardStatus,
                                m_detector);
    const TriggerFrameCollection::const_iterator finished = m_frames.end();
    for (TriggerFrameCollection::const_iterator frame = m_frames.begin();
         finished != frame;
         ++frame) {
        result->addFrame((*frame)->daqLtbFrame(m_detector));
    }
    return result;
}


DayaBay::DaqRtm* DayaBay::ReadoutTriggerDataPkg::daqRtm() const {
    if (!m_detector.isRPC()) {
        std::cerr<<"ERROR: ReadoutTriggerDataPkg::daqRtm(): Called for non-RPC detector."<<std::endl;
        return 0;
    }
    if (m_frames.size() == 0) {
        std::cerr<<"ERROR: ReadoutTriggerDataPkg::daqRtm(): Data package contains no frames, expected exactly 1."<<std::endl;
        return 0;
    }
    if (m_frames.size() != 1) {
        std::cerr<<"ERROR: ReadoutTriggerDataPkg::daqRtm(): Data package contains more than 1 frame, which is not expected for RPCs."<<std::endl;
        return 0;
    }

    const DayaBay::ReadoutTriggerDataFrame* trgframe = *(m_frames.begin());
    if (!trgframe) {
        std::cerr<<"ERROR: ReadoutTriggerDataPkg::daqRtm(): Zero pointer to frame found in the package."<<std::endl;
        return 0;
    }
    const DayaBay::ReadoutRpcTriggerDataFrame* rpctrgframe = trgframe->asRpcFrame();
    if (!rpctrgframe) {
        std::cerr<<"ERROR: ReadoutTriggerDataPkg::daqRtm(): The frame found in the package cannot be retrieved as an RPC trigger frame."<<std::endl;
        return 0;
    }
    return rpctrgframe->daqRtm(m_detector);
}