In This Package:

RegistrationSequenceCnv.cc

Go to the documentation of this file.

#include "RootIOSvc/RootIOAddress.h"
#include "PerBaseEvent/RegistrationSequenceCnv.h"
#include "PerBaseEvent/TemporalDataObjectCnv.h"

#include "Event/HeaderObject.h"

#include "DybKernel/ObjectReg.h"
#include "GaudiKernel/IDataManagerSvc.h"
#include "GaudiKernel/IDataProviderSvc.h"

using namespace DayaBay;
using namespace std;

RegistrationSequenceCnv::RegistrationSequenceCnv(ISvcLocator* svc)
    : RootIOTypedCnv<PerRegistrationSequence,RegistrationSequence>("PerRegistrationSequence",
                                                                 classID(),svc)
{
}

RegistrationSequenceCnv::~RegistrationSequenceCnv()
{
}


StatusCode RegistrationSequenceCnv::PerToTran(const PerRegistrationSequence& perobj, 
                                              RegistrationSequence& tranobj)
{
    MsgStream log(msgSvc(), "RegistrationSequenceCnv::PerToTran");

    StatusCode sc = TemporalDataObjectCnv::toTran(perobj,tranobj);    
    if (sc.isFailure()) {
        log<<MSG::ERROR<<"Failed in PerToTran"<<endreq;
    } else {
        log<<MSG::DEBUG<<"RegistrationSequence converted"<<endreq;
    }
    return sc;
}

StatusCode RegistrationSequenceCnv::fillObjRefs(IOpaqueAddress* /* addr */,
                                                DataObject* tranobj)
{
    MsgStream log(msgSvc(), "RegistrationSequenceCnv::fillObjRefs");

    RegistrationSequence* rs = dynamic_cast<RegistrationSequence*>(tranobj);
    if (!rs) return StatusCode::FAILURE;

    unsigned int skipped = 0;

    PerRegistrationSequence& trs = getPerInputObject();
    size_t siz = trs.reglist.size();
    log << MSG::DEBUG << siz << " registrations" << endreq;
    for (size_t ind = 0; ind < siz; ++ind) {

        const PerRegSeqReg& reg = trs.reglist[ind];

        if (reg.path == "/Event/Random/RandomHeader") {
            ++skipped;
            log << MSG::DEBUG
                << "Not retrieving '/Event/Random/RandomHeader'" 
                << endreq;
            continue;
        }

        RootInputAddress* ria = new RootInputAddress(reg.clid,reg.path);

        ria->setEntry(reg.entry);
        ria->setFileNumber(m_ris->fileNumber());

        RootInputStream* ris = m_rioSvc->inputStream(*ria);
        if (!ris) {
          log << MSG::WARNING
              << "No input stream for " << reg.path
              << " will not register anything in the TES"
              << endreq;
          delete ria;
          continue;
        }
        ria->setStream(ris);

        // register address
        log << MSG::DEBUG << "registering " << reg.path
            << " entry " << reg.entry << " fileNum " << m_ris->fileNumber() 
            << endreq;

        StatusCode sc = m_rioSvc->dataMgrSvc()->registerAddress(reg.path,ria);
        
        if(sc.getCode()==IDataProviderSvc::DOUBL_OBJ_PATH) {
          // Two data objects in the same location.
          log << MSG::DEBUG << "IDataProviderSvc::DOUBL_OBJ_PATH Catched "<<endreq;
          DataObject* exist_obj=0;
          // Since it exist unregister it first, then register the address again.
          // It is in AES now if AES is in use.
          sc = m_rioSvc->dataSvc()->findObject(reg.path,exist_obj);
          if(sc.isSuccess() && exist_obj) {
            m_rioSvc->dataSvc()->unregisterObject(exist_obj);       
            exist_obj->release(); // why release, check DybDataSvc.cpp and DocDB 3242, page 2 memo
            sc = m_rioSvc->dataMgrSvc()->registerAddress(reg.path,ria);
          }
        }

        if (sc.isFailure()) {
          log << MSG::ERROR
              << "failed to register address at " << reg.path
              << endreq;
          return sc;
        }

        DataObject* other_tranobj = 0;
        // This should trigger an RS registration.
        sc = m_rioSvc->dataSvc()->retrieveObject(reg.path,other_tranobj);
        if (!other_tranobj || sc.isFailure()) {
            log << MSG::WARNING << "failed to retrieve object at " 
                << reg.path << ", continuing...." << endreq;
            continue;
        }
        log << MSG::DEBUG << "retrieved " << reg.path 
            << " registration #" << rs->size()
            << endreq;

        log << MSG::DEBUG << "inputaddress "<<ria->entry()<<"\t"<<ria->tespath()<<endreq;

        TemporalDataObject* tdo=dynamic_cast<TemporalDataObject*>(other_tranobj);
        log << MSG::DEBUG <<tdo<<endreq;
        if(tdo!=0) tdo->setInputAddress(ria);
    }
    log << MSG::DEBUG << "copied " << rs->size()
        << " registrations" << endreq;
    if (siz - rs->size() > skipped) {
        log << MSG::WARNING << "have " << siz
            << " registrations from file but only converted " 
            << rs->size() 
            << " (" << skipped << " skipped on purpose)"
            << endreq;
    }
    return StatusCode::SUCCESS;
}

StatusCode RegistrationSequenceCnv::TranToPer(const RegistrationSequence& tranobj, 
                                              PerRegistrationSequence& perobj)
{
    StatusCode sc = TemporalDataObjectCnv::toPer(tranobj,perobj);    
    if (sc.isFailure()) return sc;

    perobj.reglist.clear();
    return StatusCode::SUCCESS;
}

StatusCode RegistrationSequenceCnv::fillRepRefs(IOpaqueAddress* /* addr */,
                                                DataObject* tranobj)
{
    RegistrationSequence* rs = dynamic_cast<RegistrationSequence*>(tranobj);
    if (!rs) return StatusCode::FAILURE;

    PerRegistrationSequence& trs = getPerOutputObject();

    const IRegistrationSequence::Registrations &rlist = rs->registrations();
    IRegistrationSequence::Registrations::const_iterator it, done = rlist.end();
    for (it = rlist.begin(); it != done; ++it) {
        const ObjectReg& oreg = *it;
        if( oreg.store() ){
          trs.reglist.push_back(PerRegSeqReg(oreg.path(),oreg.entry(),
                                             oreg.object()->clID()));
        }
    }

    return StatusCode::SUCCESS;
}

---