RootCnvSvc Class Reference

Root Event Conversion Service which coordinates all of our converters. More...

#include <RootCnvSvc.h>

Inheritance diagram for RootCnvSvc:

Classes
class	Leaf
	object regrouping CLID and pathname with treename/branchname More...

Public Member Functions
RootInterface *	getRootInterface ()
virtual StatusCode	initialize ()
virtual StatusCode	finalize ()
virtual StatusCode	updateServiceState (IOpaqueAddress *pAddress)
	Update state of the service.
virtual StatusCode	queryInterface (const InterfaceID &riid, void **ppvInterface)
	Override inherited queryInterface due to enhanced interface.
virtual StatusCode	declareObject (const Leaf &leaf)
	Associates a path on TDS with a particular converter.
virtual StatusCode	commitOutput (const std::string &output, bool do_commit)
	Commit pending output (fill the TTrees).
virtual StatusCode	createAddress (long int svc_type, const CLID &clid, const std::string *par, const unsigned long *ip, IOpaqueAddress *&refpAddress)
	create address containing ROOT treename, branchname, entry number
virtual StatusCode	createAddress (DataObject *obj, IOpaqueAddress *&refpAddress)
virtual StatusCode	createAddress (std::string path, IOpaqueAddress *&refpAddress)
DigiCnv *	getDigiCnv ()
DstCnv *	getDstCnv ()
McCnv *	getMcCnv ()
TrigCnv *	getTrigCnv ()
HltCnv *	getHltCnv ()
EvtRecCnv *	getEvtRecCnv ()
void	setDigiCnv (DigiCnv *reccnv)
void	setDstCnv (DstCnv *dstcnv)
void	setMcCnv (McCnv *mccnv)
void	setTrigCnv (TrigCnv *trigcnv)
void	setHltCnv (HltCnv *hltcnv)
void	setEvtRecCnv (EvtRecCnv *evtreccnv)
void	setRecTrackCnv (RecTrackCnv *rectrackcnv)
void	setEvtHeaderCnv (EvtHeaderCnv *evtheadercnv)
void	setEvtNavigatorCnv (EvtNavigatorCnv *evtnavigatorcnv)
void	setEventCnv (EventCnv *eventCnv)
RecTrackCnv *	getRecTrackCnv ()
EvtHeaderCnv *	getEvtHeaderCnv ()
EvtNavigatorCnv *	getEvtNavigatorCnv ()
EventCnv *	getEventCnv ()

Protected Member Functions
	RootCnvSvc (const std::string &name, ISvcLocator *svc)
virtual	~RootCnvSvc ()

Friends
class	SvcFactory< RootCnvSvc >

Detailed Description

Root Event Conversion Service which coordinates all of our converters.

When a component requests an item not yet available on the TDS, the RootcnvSvc is called to find the appropriiate converter to gain access to the data and put it on the TDS. Based on SICb service written by Markus Frank. If an item is mentioned in the jobOptions as one to be written out, it will be converted from TDS to ROOT by the appropriate converter

Based on the RootCnvSvc of GLast.

Definition at line 40 of file RootCnvSvc.h.

Constructor & Destructor Documentation

RootCnvSvc()

RootCnvSvc::RootCnvSvc ( const std::string &  name, ISvcLocator *  svc  )

protected

Definition at line 100 of file RootCnvSvc.cxx.

  : ConversionSvc(name, svc, ROOT_StorageType), m_minSplit(1), m_evtsel(0)              
{
  StatusCode sc;
  MsgStream log(msgSvc(), "RootCnvSvc");
  log << MSG::DEBUG << "RootCnvSvc::constructor" << endreq;
  
  IService* isvc = 0;
  sc = serviceLocator()->getService ("RootEvtSelector", isvc, false);
  if (!sc.isSuccess())  sc = serviceLocator()->getService ("EventSelector", isvc, false);
  if (sc.isSuccess()) {
    sc = isvc->queryInterface(IID_IRootEvtSelector, (void**)&m_evtsel);
  }
  if(sc.isFailure()) {
    log << MSG::WARNING << "Unable to start event selector service within RootCnvSvc" << endreq;
  }
  
  m_rootInterface= RootInterface::Instance(log);
  if (!m_rootInterface)      log << MSG::ERROR << "Unable to start Root service within RootCnvSvc" << endreq;
 
 
  
    //Digi
  declareProperty("digiTreeName", m_dtreeName="Event"); //"Rec"->"Event" 
  
  declareProperty("digiRootInputFile",m_difileName);
  //if (m_difileName.size()==0){
  //  m_difileName.push_back("digi.root");
  //}
  declareProperty("digiRootOutputFile",m_dofileName = "");
 
  // Split mode for writing the TTree [0,99] 
  declareProperty("digiSplitMode", m_dsplitMode=m_minSplit);
     // Buffer size for writing ROOT data
  declareProperty("digiBufferSize", m_dbufSize=3200000);
    // ROOT default compression
  declareProperty("digiCompressionLevel", m_dcompressionLevel=1);
  declareProperty("selectFromTag", m_selectFromTag=0);
  declareProperty("tagInputFile", m_tagInputFile);
  //declareProperty("tagFileFormat", m_tagFileFormat=1);
  
  declareProperty("readETS", m_readETS = false);
}

~RootCnvSvc()

virtual RootCnvSvc::~RootCnvSvc ( )

inlineprotectedvirtual

Definition at line 182 of file RootCnvSvc.h.

{ };

Member Function Documentation

commitOutput()

StatusCode RootCnvSvc::commitOutput ( const std::string &  output, bool  do_commit  )

virtual

Commit pending output (fill the TTrees).

Definition at line 401 of file RootCnvSvc.cxx.

  {
 
 
 
    MsgStream log( msgSvc(), name() );
    log << MSG::INFO << "RootCnvSvc::commitOutput starts." << endreq;
 
    StatusCode sc=m_rootInterface->fillTrees();
    if (sc.isFailure()) 
      log << MSG::ERROR << "No Root tree was filled" << endreq;
 
    // objects must be cleared after fill
    else{
      TObject*   oEvtHeader = m_evtheaderCnv->getWriteObject();
      if (oEvtHeader) oEvtHeader->Clear();
      TObject*   oEvtNavigator = m_evtnavigatorCnv->getWriteObject();
      if (oEvtNavigator) oEvtNavigator->Clear();
      TObject*   o=m_dCnv->getWriteObject();
      if (o)    o->Clear();
      TObject*   oDst=m_dstCnv->getWriteObject();
      if (oDst)    oDst->Clear(); 
      TObject*   oMc=m_mcCnv->getWriteObject();
      if (oMc)    oMc->Clear();
      TObject*   oRecTrack=m_rectrackCnv->getWriteObject();
      if (oRecTrack) oRecTrack->Clear();  
      TObject*   oEvtRecEvent = m_evtRecCnv->getWriteObject();
      if (oEvtRecEvent) oEvtRecEvent->Clear();
      TObject*   oTrig = m_trigCnv->getWriteObject();
      if(oTrig) oTrig->Clear();
      TObject*   oHlt = m_hltCnv->getWriteObject();
      if(oHlt) oHlt->Clear();
    }
    m_common.clear();
 
    return sc;
  }

createAddress() [1/3]

StatusCode RootCnvSvc::createAddress ( DataObject *  obj, IOpaqueAddress *&  refpAddress  )

virtual

Definition at line 439 of file RootCnvSvc.cxx.

                                                                                  {
 
    //    create address for this object
    MsgStream log(msgSvc(), name());
 
 
    log << MSG::DEBUG << "RootCnvSvc::createAddress"<<endreq;
 
    StatusCode status = INVALID_ADDRESS;
    IRegistry* ent = obj->registry();
 
    if ( 0 != ent )   {
      SmartIF<IDataManagerSvc> iaddrReg(dataProvider());
      std::string path = ent->identifier();
      LeafMap::iterator itm = m_leaves.find(path);
 
 
      if ( itm != m_leaves.end() )    {
    Leaf* leaf = (*itm).second;
    if ( 0 != leaf )    {
      std::string spars[3] ;
      spars[0]=path;
      spars[1]=leaf->treename;
      spars[2]=leaf->branchname;
 
 
      unsigned long ipars[2] ={0,0};  
      if (m_evtsel)  ipars[0]=m_evtsel->getRecId();
 
      status=addressCreator()->createAddress(ROOT_StorageType,leaf->clid,spars,ipars,newAddr);
      if ( status.isSuccess() )   {
        status = iaddrReg->registerAddress((IRegistry*)0,path, newAddr);
        if ( !status.isSuccess() )    {
          newAddr->release();
        }
      }
      return StatusCode::SUCCESS;
    }
      }
    }
    return status;
  }

createAddress() [2/3]

StatusCode RootCnvSvc::createAddress ( long int  svc_type, const CLID &  clid, const std::string *  par, const unsigned long *  ip, IOpaqueAddress *&  refpAddress  )

virtual

create address containing ROOT treename, branchname, entry number

Definition at line 376 of file RootCnvSvc.cxx.

  {
    MsgStream log( msgSvc(), name() );
 
    if (svc_type != repSvcType() ) {
      log << MSG::ERROR << "RootCnvSvc::bad storage type" << svc_type << endreq;
      return StatusCode::FAILURE;
    }
 
    std::string path = spars[0];
    std::string treename = spars[1];
    std::string branchname = spars[2];
    int entry=ipars[0];
    if (path.size()==0) path="/Event";  
    refpAddress = new RootAddress(ROOT_StorageType,
    clid,
    path,treename,branchname,entry);
    return StatusCode::SUCCESS;
  }

Referenced by RootEventBaseCnv::createRep(), and updateServiceState().

createAddress() [3/3]

StatusCode RootCnvSvc::createAddress ( std::string  path, IOpaqueAddress *&  refpAddress  )

virtual

Definition at line 482 of file RootCnvSvc.cxx.

                                                                                 {
 
    //    create address for this object
    MsgStream log(msgSvc(), name());
 
    StatusCode status;
    LeafMap::iterator itm = m_leaves.find(path);
    SmartIF<IDataManagerSvc> iaddrReg(dataProvider());
    if ( itm != m_leaves.end() )    {
      Leaf* leaf = (*itm).second;
      if ( 0 != leaf )    {
    std::string spars[3] ;
    spars[0]=path;
    spars[1]=leaf->treename;
    spars[2]=leaf->branchname;
 
    unsigned long ipars[2] = {0,0};
    if (m_evtsel) ipars[0]=m_evtsel->getRecId();  
    status=addressCreator()->createAddress(ROOT_StorageType,leaf->clid,spars,ipars,newAddr);
    if ( status.isSuccess() )   {
      status = iaddrReg->registerAddress((IRegistry*)0,path, newAddr);
      if ( !status.isSuccess() )    {
        newAddr->release();
      }
    }
    return StatusCode::SUCCESS;
      }
    }
 
 
    return StatusCode::FAILURE;
  }

declareObject()

StatusCode RootCnvSvc::declareObject ( const Leaf &  leaf )

virtual

Associates a path on TDS with a particular converter.

Definition at line 301 of file RootCnvSvc.cxx.

                                                       {
  // Purpose and Method:  Callback from each of the individual converters that allows
  //  association of TDS path and converter.
  MsgStream log(msgSvc(), name());
  log << MSG::DEBUG << "RootCnvSvc::declareObject " << leaf.path << " classid: " << leaf.clid << endreq;
  Leaf* ll = new Leaf(leaf);
  std::pair<LeafMap::iterator, bool> p = m_leaves.insert(LeafMap::value_type( leaf.path, ll) );
  if( p.second )    {
    return StatusCode::SUCCESS;
  }
  delete ll;
  return StatusCode::FAILURE;
}

finalize()

StatusCode RootCnvSvc::finalize ( )

virtual

Definition at line 202 of file RootCnvSvc.cxx.

                                    {
  MsgStream log(msgSvc(), name());
  log << MSG::DEBUG << "RootCnvSvc::finalize" << endreq;
 
  ConversionSvc::finalize();
  // log << MSG::INFO<<"this is the end of RootCnvsvc finalize"<<endreq;
  for (LeafMap::iterator k = m_leaves.begin(); k != m_leaves.end(); k++ )   {
    delete (*k).second;
  }
  m_leaves.erase(m_leaves.begin(), m_leaves.end());
 
  return m_rootInterface->finalize();
}

getDigiCnv()

DigiCnv * RootCnvSvc::getDigiCnv ( )

inline

Definition at line 154 of file RootCnvSvc.h.

{return m_dCnv;}

Referenced by EmcDigiCnv::DataObjectToTObject(), LumiDigiCnv::DataObjectToTObject(), MdcDigiCnv::DataObjectToTObject(), MucDigiCnv::DataObjectToTObject(), and TofDigiCnv::DataObjectToTObject().

getDstCnv()

DstCnv * RootCnvSvc::getDstCnv ( )

inline

Definition at line 155 of file RootCnvSvc.h.

{return m_dstCnv;}

Referenced by EmcTrackCnv::DataObjectToTObject(), ExtTrackCnv::DataObjectToTObject(), MdcDedxCnv::DataObjectToTObject(), MdcKalTrackCnv::DataObjectToTObject(), MdcTrackCnv::DataObjectToTObject(), MucTrackCnv::DataObjectToTObject(), and TofTrackCnv::DataObjectToTObject().

getEventCnv()

EventCnv * RootCnvSvc::getEventCnv ( )

inline

Definition at line 176 of file RootCnvSvc.h.

{return m_eventCnv;}

getEvtHeaderCnv()

EvtHeaderCnv * RootCnvSvc::getEvtHeaderCnv ( )

inline

Definition at line 174 of file RootCnvSvc.h.

{return m_evtheaderCnv;}

getEvtNavigatorCnv()

EvtNavigatorCnv * RootCnvSvc::getEvtNavigatorCnv ( )

inline

Definition at line 175 of file RootCnvSvc.h.

{return m_evtnavigatorCnv;}

getEvtRecCnv()

EvtRecCnv * RootCnvSvc::getEvtRecCnv ( )

inline

Definition at line 159 of file RootCnvSvc.h.

{ return m_evtRecCnv; } //zoujh

Referenced by EvtRecDTagCnv::DataObjectToTObject(), EvtRecEtaToGGCnv::DataObjectToTObject(), EvtRecEventCnv::DataObjectToTObject(), EvtRecPi0Cnv::DataObjectToTObject(), EvtRecPrimaryVertexCnv::DataObjectToTObject(), EvtRecTrackCnv::DataObjectToTObject(), and EvtRecVeeVertexCnv::DataObjectToTObject().

getHltCnv()

HltCnv * RootCnvSvc::getHltCnv ( )

inline

Definition at line 158 of file RootCnvSvc.h.

{ return m_hltCnv; } //fucd

Referenced by DstHltInfCnv::DataObjectToTObject(), HltInfCnv::DataObjectToTObject(), and HltRawCnv::DataObjectToTObject().

getMcCnv()

McCnv * RootCnvSvc::getMcCnv ( )

inline

Definition at line 156 of file RootCnvSvc.h.

{return m_mcCnv;}

Referenced by EmcMcHitCnv::DataObjectToTObject(), McParticleCnv::DataObjectToTObject(), MdcMcHitCnv::DataObjectToTObject(), MucMcHitCnv::DataObjectToTObject(), and TofMcHitCnv::DataObjectToTObject().

getRecTrackCnv()

RecTrackCnv * RootCnvSvc::getRecTrackCnv ( )

inline

Definition at line 173 of file RootCnvSvc.h.

{return m_rectrackCnv;}   //*******liangyt

Referenced by RecEmcClusterCnv::DataObjectToTObject(), RecEmcHitCnv::DataObjectToTObject(), RecEmcShowerCnv::DataObjectToTObject(), RecEvTimeCnv::DataObjectToTObject(), RecExtTrackCnv::DataObjectToTObject(), RecMdcDedxCnv::DataObjectToTObject(), RecMdcDedxHitCnv::DataObjectToTObject(), RecMdcHitCnv::DataObjectToTObject(), RecMdcKalHelixSegCnv::DataObjectToTObject(), RecMdcKalTrackCnv::DataObjectToTObject(), RecMdcTrackCnv::DataObjectToTObject(), RecMucTrackCnv::DataObjectToTObject(), RecTofTrackCnv::DataObjectToTObject(), and RecZddChannelCnv::DataObjectToTObject().

getRootInterface()

RootInterface * RootCnvSvc::getRootInterface ( )

inline

Definition at line 127 of file RootCnvSvc.h.

{return m_rootInterface;}

getTrigCnv()

TrigCnv * RootCnvSvc::getTrigCnv ( )

inline

Definition at line 157 of file RootCnvSvc.h.

{ return m_trigCnv; } //caogf

Referenced by TrigDataCnv::DataObjectToTObject().

initialize()

StatusCode RootCnvSvc::initialize ( )

virtual

Definition at line 144 of file RootCnvSvc.cxx.

                                      {
  // Purpose and Method:  Setup GLAST's Event Converter Service.
  //   Associate RootCnvSvc with the EventDataSvc
  //   Associate the list of known converters with this RootCnvSvc
  //   configure map of leaves
 
  MsgStream log(msgSvc(), name());
  log << MSG::DEBUG << "RootCnvSvc::initialize" << endreq;
  StatusCode status = ConversionSvc::initialize();
  if ( status.isSuccess() )   {
    //        ISvcLocator* svclocator = serviceLocator();  [unused for now]
    IDataProviderSvc *pIDP = 0;
    // Set event data service
    status = service("EventDataSvc", pIDP, true);
    if ( status.isSuccess() )   {
      status = setDataProvider ( pIDP );
    }
    else    {
      return status;
    }
 
    
    // Add converters to the service 
    status = addConverters();
    if ( !status.isSuccess() )   {
      log << MSG::ERROR << "Unable to add converters to the service" << endreq;
      return status;
    }
 
      
    // Now we have to configure the map of leaves
    // Which should contain the association of converters with 
    // paths on the TDS
    for (LeafMap::iterator k = m_leaves.begin(); k != m_leaves.end(); k++ )   {
      std::string path = (*k).first;
      for (LeafMap::iterator j = m_leaves.begin(); j != m_leaves.end(); j++ )   {
        std::string path2 = (*j).first;
        std::string pp = (*j).first.substr(0, (*j).first.rfind("/"));
        if ( path == pp && path != (*j).first )   {
          (*k).second->push_back((*j).second);
        }
      }
    }   
  }
 
  // get properties and tell RootInterface about files
  status=initFiles();
 
  m_rootInterface->setSelectFromTag(m_selectFromTag);
  if ( m_selectFromTag && m_tagInputFile.empty() ) {
      m_tagInputFile = m_difileName;
  }
  m_rootInterface->setTagInputFile(m_tagInputFile);
  //m_rootInterface->setTagFileFormat(m_tagFileFormat);
   
  return status;
}

queryInterface()

StatusCode RootCnvSvc::queryInterface ( const InterfaceID &  riid, void **  ppvInterface  )

virtual

Override inherited queryInterface due to enhanced interface.

Definition at line 363 of file RootCnvSvc.cxx.

                                                                                     {
 
    if ( IID_IRootCnvSvc == riid )  {
      *ppvInterface = (RootCnvSvc*)this;
    }
    else  {
      // Interface is not directly availible: try out a base class
      return ConversionSvc::queryInterface(riid, ppvInterface);
    }
    addRef();
    return StatusCode::SUCCESS;
  }

setDigiCnv()

void RootCnvSvc::setDigiCnv ( DigiCnv *  reccnv )

inline

Definition at line 161 of file RootCnvSvc.h.

{m_dCnv=reccnv;}

Referenced by DigiCnv::initialize().

setDstCnv()

void RootCnvSvc::setDstCnv ( DstCnv *  dstcnv )

inline

Definition at line 162 of file RootCnvSvc.h.

{m_dstCnv=dstcnv;}

Referenced by DstCnv::initialize().

setEventCnv()

void RootCnvSvc::setEventCnv ( EventCnv *  eventCnv )

inline

Definition at line 170 of file RootCnvSvc.h.

{m_eventCnv=eventCnv;}

setEvtHeaderCnv()

void RootCnvSvc::setEvtHeaderCnv ( EvtHeaderCnv *  evtheadercnv )

inline

Definition at line 168 of file RootCnvSvc.h.

{m_evtheaderCnv=evtheadercnv;}

Referenced by EvtHeaderCnv::initialize().

setEvtNavigatorCnv()

void RootCnvSvc::setEvtNavigatorCnv ( EvtNavigatorCnv *  evtnavigatorcnv )

inline

Definition at line 169 of file RootCnvSvc.h.

{m_evtnavigatorCnv=evtnavigatorcnv;}

Referenced by EvtNavigatorCnv::initialize().

setEvtRecCnv()

void RootCnvSvc::setEvtRecCnv ( EvtRecCnv *  evtreccnv )

inline

Definition at line 166 of file RootCnvSvc.h.

{ m_evtRecCnv = evtreccnv; } //zoujh

Referenced by EvtRecCnv::initialize().

setHltCnv()

void RootCnvSvc::setHltCnv ( HltCnv *  hltcnv )

inline

Definition at line 165 of file RootCnvSvc.h.

{ m_hltCnv = hltcnv; } //fucd

Referenced by HltCnv::initialize().

setMcCnv()

void RootCnvSvc::setMcCnv ( McCnv *  mccnv )

inline

Definition at line 163 of file RootCnvSvc.h.

{m_mcCnv=mccnv;}

Referenced by McCnv::initialize().

setRecTrackCnv()

void RootCnvSvc::setRecTrackCnv ( RecTrackCnv *  rectrackcnv )

inline

Definition at line 167 of file RootCnvSvc.h.

{m_rectrackCnv=rectrackcnv;}

Referenced by RecTrackCnv::initialize().

setTrigCnv()

void RootCnvSvc::setTrigCnv ( TrigCnv *  trigcnv )

inline

Definition at line 164 of file RootCnvSvc.h.

{ m_trigCnv = trigcnv; } //caogf

Referenced by TrigCnv::initialize().

updateServiceState()

StatusCode RootCnvSvc::updateServiceState ( IOpaqueAddress *  pAddress )

virtual

Update state of the service.

Definition at line 316 of file RootCnvSvc.cxx.

                                                                     {
 
  // not sure about the use of recid or bank...
  MsgStream log(msgSvc(), name());
 
  log << MSG::DEBUG << "RootCnvSvc::updateServiceState" << endreq;
 
  StatusCode status = INVALID_ADDRESS;
  IRegistry* ent = pAddress->registry();
  if ( 0 != ent )   {
    SmartIF<IDataManagerSvc> iaddrReg(dataProvider());
    //       if ( 0 != iaddrReg )   {
    status = StatusCode::SUCCESS;
    std::string path = ent->identifier();
    LeafMap::iterator itm = m_leaves.find(path);
    if ( itm != m_leaves.end() )    {
      Leaf* leaf = (*itm).second;
      if ( 0 != leaf )    {
    for ( Leaf::iterator il = leaf->begin(); il != leaf->end(); il++ )   {
      IOpaqueAddress* newAddr = 0;
      unsigned long ipars[2] = {0, 0}; //
      if (m_evtsel)  ipars[0]=m_evtsel->getRecId();
 
      std::string spars[3]={(*il)->path,(*il)->treename,(*il)->branchname}; 
 
      StatusCode ir =createAddress(ROOT_StorageType, 
          (*il)->clid, 
          spars, 
          ipars,
          newAddr);
      log << MSG::DEBUG << "RootCnvSvc::updateService " << " *****  " << 
        (*il)->clid << " *****  " << (*il)->path <<endreq;
 
      if ( ir.isSuccess() )   {
        ir = iaddrReg->registerAddress((*il)->path, newAddr);
        if ( !ir.isSuccess() )    {
          newAddr->release();
          status = ir;
        }
      }    
    }
      }
    }
  }
  return StatusCode::SUCCESS;
  }

Friends And Related Function Documentation

SvcFactory< RootCnvSvc >

friend class SvcFactory< RootCnvSvc >

friend

Definition at line 25 of file RootCnvSvc.h.

---

The documentation for this class was generated from the following files:

• RootCnvSvc.h
• RootCnvSvc.cxx