In This Package:

DybEvtSelector.cc

Go to the documentation of this file.

#include "DybEvtSelector.h"

//#include "TBaseEvent/RegistrationSequenceCnv.h"
//using namespace DayaBay;

#include "DybIO/IDybIODaqSvc.h"
#include "RootIOSvc/IRootIOSvc.h"
#include "RootIOSvc/RootInputStream.h"
#include "Event/RegistrationSequence.h"

#include "GaudiKernel/IDataManagerSvc.h"
#include "GaudiKernel/MsgStream.h"

#include <string>

DybEvtSelector::DybEvtSelector(const std::string& name, ISvcLocator* svcloc)
    : Service(name,svcloc)
    , RootIOEvtSelector(name,svcloc)
    , m_reqSeqName("")
    , m_daqSvc(0)
    , m_controlStream(0)/*, m_regCnv(0)*/
{
    m_reqSeqName = DayaBay::RegistrationSequenceLocation::Default;
    declareProperty("ReqSeq",m_reqSeqName,
                    "TES/TFile path where to find the RegistrationSequence");

}

DybEvtSelector::~DybEvtSelector()
{
}

StatusCode DybEvtSelector::initialize()
{
    StatusCode sc = RootIOEvtSelector::initialize();
    if (sc.isFailure()) {
      return sc;
    }

    IService* isvc=0;
    sc = serviceLocator()->service("DybIODaqSvc","DybIODaqSvc", isvc);
    if (sc.isFailure()) {
      m_daqSvc = 0;
    } else {
      sc = isvc->queryInterface(IDybIODaqSvc::interfaceID(), (void**)&m_daqSvc);
      if (sc.isFailure()) {
        m_daqSvc = 0;
      }
    }
    return StatusCode::SUCCESS;
}

StatusCode DybEvtSelector::finalize()
{
    if (0 != m_daqSvc) {
        m_daqSvc->release();
    }
    return RootIOEvtSelector::finalize();
}

StatusCode DybEvtSelector::setEntry(RootIOEvtSelector::Context& rc, int entry) const
{
    MsgStream log(msgSvc(), "DybEvtSelector");

    if (!m_controlStream) {
        IRootIOSvc::InputStreamMap& ism = m_rioSvc->inputStreams();
        m_controlStream = ism[m_reqSeqName];
        if (!m_controlStream) {
            log << MSG::WARNING << "failed to get control stream at " 
                << m_reqSeqName << endreq;
            return StatusCode::FAILURE;
        }
    }

    log << MSG::DEBUG << "Loading control stream (RegistrationSequence) entry " << entry << endreq;

    // Set entry to the RegistrationSequence
    if (0 != m_daqSvc) {
        StatusCode sc = m_daqSvc->setEventEntry(entry);
        if (sc.isFailure()) {
            log << MSG::INFO
                << "No more DAQ blocks are available"
                << endreq;
        }
    }

    bool okay = m_controlStream->setEntry(entry,false); // false == do not read TObject
    if (!okay) {
        log << MSG::WARNING << "Failed to set entry " << 
            entry << " for control input stream " << m_reqSeqName << endreq;
        log << MSG::WARNING << "End of the input stream?" << endreq;
        return StatusCode::FAILURE;
    }

    //IRootIOSvc::InputStreamMap& ism = m_rioSvc->inputStreams();

    rc.m_entry = entry;
    return StatusCode::SUCCESS;
}

---