DataObjectCnv.cc

Go to the documentation of this file.

#include "PerBaseEvent/DataObjectCnv.h"
#include "Event/RegistrationSequence.h"

#include "RootIOSvc/IRootIOSvc.h"
#include "RootIOSvc/RootIOAddress.h"

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

#include <string>
using namespace std;

DataObjectCnv::DataObjectCnv(ISvcLocator* svc)
    : Converter(ROOT_StorageType,CLID_DataObject,svc)
    
{
}

DataObjectCnv::~DataObjectCnv()
{
}

StatusCode DataObjectCnv::initialize()
{
    StatusCode sc = Converter::initialize();
    if (sc.isFailure()) return sc;

    MsgStream log(msgSvc(), "DataObjectCnv::initialize()");

    IService* isvc=0;
    sc = serviceLocator()->service("RootIOCnvSvc", isvc, false);
    if (sc.isFailure()) {
        log << MSG::ERROR << "Conversion service RootIOCnvSvc"
            << " could not be retrieved" << endreq;
        return sc;
    }
    isvc->addRef();

    sc = isvc->queryInterface(IRootIOSvc::interfaceID(), (void**)&m_rioSvc);
    if (sc.isFailure()) {
        log << MSG::ERROR << "Conversion service RootIOCnvSvc"
            << " does not implement IRootIOCnvSvc" << endreq;
    }

    return sc;
}

// --- input --- //

StatusCode DataObjectCnv::createObj(IOpaqueAddress* /*addr*/,
                                    DataObject*& dat)
{
    dat = new DataObject;
    return StatusCode::SUCCESS;
}


StatusCode DataObjectCnv::fillObjRefs(IOpaqueAddress* addr,
                                      DataObject* /*pObject*/)
{
    // check if everything looks kosher.  

    MsgStream log(msgSvc(), "DataObjectCnv::fillObjRefs()");
    RootInputAddress* ria = dynamic_cast<RootInputAddress*>(addr);
    if (!ria) return StatusCode::FAILURE;

    log << MSG::DEBUG
        << " addr is a RIA @ " << ria->tespath() 
        << " clID=" << ria->clID() << endreq;

    if (ria->clID() != CLID_DataObject) {
        log << MSG::WARNING << "given unexpected class ID "
            << ria->clID() << endreq;
        return StatusCode::SUCCESS;
    }

    string location = ria->registry()->identifier();

    if (location != "/Event") {
        log << MSG::WARNING << "fillObjRefs() called with unexpected location "
            << location << endreq;
        return StatusCode::SUCCESS;
    }


    // Register address for RegistrationSequence.

    // Fixme: needs to be configurable?
    string rsloc = DayaBay::RegistrationSequence::defaultLocation();
    int rsclid = DayaBay::RegistrationSequence::classID();
    RootInputAddress* rsria = 0;
    rsria = new RootInputAddress(rsclid,rsloc);
    rsria->setEntry(ria->entry());
    RootInputStream* rsris = m_rioSvc->inputStream(*rsria);
    rsria->setStream(rsris);
    m_rioSvc->dataMgrSvc()->registerAddress(rsloc,rsria);

    // Pull RegistrationSequence out of TES to trigger its converter
    DataObject* rsobj = 0;
    return m_rioSvc->dataSvc()->
        retrieveObject(DayaBay::RegistrationSequence::defaultLocation(),rsobj);
}