3#include "GaudiKernel/SmartIF.h"
4#include "GaudiKernel/SvcFactory.h"
6#include "GaudiKernel/MsgStream.h"
7#include "GaudiKernel/ISvcLocator.h"
8#include "GaudiKernel/IDataProviderSvc.h"
9#include "GaudiKernel/IDataManagerSvc.h"
10#include "GaudiKernel/RegistryEntry.h"
11#include "GaudiKernel/GenericAddress.h"
13#include "RawEvent/DigiEvent.h"
14#include "DstEvent/DstEvent.h"
15#include "McTruth/McEvent.h"
16#include "TrigEvent/TrigEvent.h"
17#include "HltEvent/HltEvent.h"
18#include "RootCnvSvc/RootInterface.h"
20#include "RootCnvSvc/RootAddress.h"
21#include "RootCnvSvc/RootCnvSvc.h"
22#include "RootCnvSvc/RootEvtSelector.h"
25#include "RootCnvSvc/Dst/MdcDedxCnv.h"
26#include "RootCnvSvc/Dst/DstCnv.h"
27#include "RootCnvSvc/Digi/EmcDigiCnv.h"
28#include "RootCnvSvc/Mc/EmcMcHitCnv.h"
29#include "RootCnvSvc/Dst/EmcTrackCnv.h"
30#include "RootCnvSvc/EventCnv.h"
31#include "RootCnvSvc/Dst/ExtTrackCnv.h"
32#include "RootCnvSvc/Mc/McCnv.h"
33#include "RootCnvSvc/Mc/McParticleCnv.h"
34#include "RootCnvSvc/Digi/MdcDigiCnv.h"
35#include "RootCnvSvc/Dst/MdcKalTrackCnv.h"
36#include "RootCnvSvc/Mc/MdcMcHitCnv.h"
37#include "RootCnvSvc/Dst/MdcTrackCnv.h"
38#include "RootCnvSvc/Digi/MucDigiCnv.h"
39#include "RootCnvSvc/Mc/MucMcHitCnv.h"
40#include "RootCnvSvc/Dst/MucTrackCnv.h"
41#include "RootCnvSvc/Digi/DigiCnv.h"
42#include "RootCnvSvc/Digi/TofDigiCnv.h"
43#include "RootCnvSvc/Mc/TofMcHitCnv.h"
44#include "RootCnvSvc/Dst/TofTrackCnv.h"
45#include "RootCnvSvc/Digi/LumiDigiCnv.h"
47#include "RootCnvSvc/Rec/RecMucTrackCnv.h"
48#include "RootCnvSvc/Rec/RecMdcTrackCnv.h"
49#include "RootCnvSvc/Rec/RecMdcHitCnv.h"
50#include "RootCnvSvc/Rec/RecMdcKalTrackCnv.h"
51#include "RootCnvSvc/Rec/RecMdcKalHelixSegCnv.h"
52#include "RootCnvSvc/Rec/RecMdcDedxCnv.h"
53#include "RootCnvSvc/Rec/RecMdcDedxHitCnv.h"
54#include "RootCnvSvc/Rec/RecTofTrackCnv.h"
55#include "RootCnvSvc/Rec/RecBTofCalHitCnv.h"
56#include "RootCnvSvc/Rec/RecETofCalHitCnv.h"
57#include "RootCnvSvc/Rec/RecMucRecHitCnv.h"
58#include "RootCnvSvc/Rec/RecEmcHitCnv.h"
59#include "RootCnvSvc/Rec/RecEmcClusterCnv.h"
60#include "RootCnvSvc/Rec/RecEmcShowerCnv.h"
61#include "RootCnvSvc/Rec/RecEvTimeCnv.h"
62#include "RootCnvSvc/Rec/RecExtTrackCnv.h"
63#include "RootCnvSvc/Rec/RecTrackCnv.h"
65#include "RootCnvSvc/EvtRec/EvtRecCnv.h"
66#include "RootCnvSvc/EvtRec/EvtRecEventCnv.h"
67#include "RootCnvSvc/EvtRec/EvtRecTrackCnv.h"
68#include "RootCnvSvc/EvtRec/EvtRecPrimaryVertexCnv.h"
69#include "RootCnvSvc/EvtRec/EvtRecVeeVertexCnv.h"
70#include "RootCnvSvc/EvtRec/EvtRecPi0Cnv.h"
71#include "RootCnvSvc/EvtRec/EvtRecEtaToGGCnv.h"
72#include "RootCnvSvc/EvtRec/EvtRecDTagCnv.h"
73#include "RootCnvSvc/Rec/RecZddChannelCnv.h"
76#include "RootCnvSvc/Trig/TrigCnv.h"
77#include "RootCnvSvc/Trig/TrigDataCnv.h"
79#include "RootCnvSvc/Hlt/HltCnv.h"
80#include "RootCnvSvc/Hlt/HltRawCnv.h"
81#include "RootCnvSvc/Hlt/HltInfCnv.h"
82#include "RootCnvSvc/Hlt/DstHltInfCnv.h"
84#include "RootCnvSvc/EvtHeaderCnv.h"
85#include "RootCnvSvc/EvtNavigatorCnv.h"
92static const char* rcsid =
"$Id: RootCnvSvc.cxx,v 1.68 2015/06/17 03:12:16 dengzy Exp $";
104 MsgStream log(
msgSvc(),
"RootCnvSvc");
105 log << MSG::DEBUG <<
"RootCnvSvc::constructor" << endreq;
108 sc = serviceLocator()->getService (
"RootEvtSelector", isvc,
false);
109 if (!sc.isSuccess()) sc = serviceLocator()->getService (
"EventSelector", isvc,
false);
110 if (sc.isSuccess()) {
111 sc = isvc->queryInterface(IID_IRootEvtSelector, (
void**)&m_evtsel);
114 log << MSG::WARNING <<
"Unable to start event selector service within RootCnvSvc" << endreq;
118 if (!m_rootInterface) log << MSG::ERROR <<
"Unable to start Root service within RootCnvSvc" << endreq;
123 declareProperty(
"digiTreeName", m_dtreeName=
"Event");
125 declareProperty(
"digiRootInputFile",m_difileName);
129 declareProperty(
"digiRootOutputFile",m_dofileName =
"");
132 declareProperty(
"digiSplitMode", m_dsplitMode=m_minSplit);
134 declareProperty(
"digiBufferSize", m_dbufSize=3200000);
136 declareProperty(
"digiCompressionLevel", m_dcompressionLevel=1);
137 declareProperty(
"selectFromTag", m_selectFromTag=0);
138 declareProperty(
"tagInputFile", m_tagInputFile);
149 MsgStream log(
msgSvc(), name());
150 log << MSG::DEBUG <<
"RootCnvSvc::initialize" << endreq;
151 StatusCode status = ConversionSvc::initialize();
152 if ( status.isSuccess() ) {
154 IDataProviderSvc *pIDP = 0;
156 status = service(
"EventDataSvc", pIDP,
true);
157 if ( status.isSuccess() ) {
158 status = setDataProvider ( pIDP );
166 status = addConverters();
167 if ( !status.isSuccess() ) {
168 log << MSG::ERROR <<
"Unable to add converters to the service" << endreq;
176 for (LeafMap::iterator k = m_leaves.begin(); k != m_leaves.end(); k++ ) {
177 std::string path = (*k).first;
178 for (LeafMap::iterator j = m_leaves.begin(); j != m_leaves.end(); j++ ) {
179 std::string path2 = (*j).first;
180 std::string pp = (*j).first.substr(0, (*j).first.rfind(
"/"));
181 if ( path == pp && path != (*j).first ) {
182 (*k).second->push_back((*j).second);
199 MsgStream log(
msgSvc(), name());
200 log << MSG::DEBUG <<
"RootCnvSvc::finalize" << endreq;
202 ConversionSvc::finalize();
204 for (LeafMap::iterator k = m_leaves.begin(); k != m_leaves.end(); k++ ) {
207 m_leaves.erase(m_leaves.begin(), m_leaves.end());
212StatusCode RootCnvSvc::initFiles () {
213 MsgStream log(
msgSvc(), name());
214 log << MSG::DEBUG <<
"RootCnvSvc::initFiles" << endreq;
215 StatusCode sc=StatusCode::SUCCESS;
222 int nSize = m_difileName.size();
223 log<<MSG::INFO<<
"Root Input files "<<nSize<<endreq;
225 log<<MSG::INFO<<
"Unable to find input file"<<endreq;
229 for(
int i = 0;i<nSize;i++){
231 std::string
s=m_difileName[i];
232 std::vector<int> wildcardPos;
233 for(
int pos=0;pos<
s.size();pos++) {
234 pos=
s.find_first_of(
'?',pos);
236 wildcardPos.push_back(pos);
242 if(wildcardPos.size()!=0) {
244 int maxNo=pow(10.,(
int)wildcardPos.size());
245 if(nEnd!=0&&nEnd<maxNo) maxNo=nEnd;
248 if(nStart!=-1) i=nStart;
249 if(nStart>nEnd) log<<MSG::WARNING<<
"file's StartNo>EndNo"<<endreq;
251 std::vector<int>::iterator it=wildcardPos.end();
253 while(it!=wildcardPos.begin()){
257 s.replace((*it),1,1,c);
259 if(access(
s.c_str(),0)!=-1) {
260 sc = m_rootInterface->
addInput(m_dtreeName,
s);
261 if (sc.isFailure())
return sc;
266 sc = m_rootInterface->
addInput(m_dtreeName,m_difileName[i]);
267 if (sc.isFailure())
return sc;
282 if (m_dsplitMode<m_minSplit) {
283 log << MSG::WARNING <<
"RootCnvSvc::initFiles Recon splitlevel cant be lower than "<<m_minSplit<<
", reset" << endreq;
284 m_dsplitMode=m_minSplit;
287 if(
"" != m_dofileName ){
288 sc=m_rootInterface->
addOutput(m_dtreeName,m_dofileName,m_dsplitMode,m_dbufSize,m_dcompressionLevel);
290 log << MSG::WARNING <<
"No specified digiRootOutputFile!" << endreq;
300 MsgStream log(
msgSvc(), name());
301 log << MSG::DEBUG <<
"RootCnvSvc::declareObject " << leaf.
path <<
" classid: " << leaf.
clid << endreq;
303 std::pair<LeafMap::iterator, bool> p = m_leaves.insert(LeafMap::value_type( leaf.
path, ll) );
305 return StatusCode::SUCCESS;
308 return StatusCode::FAILURE;
315 MsgStream log(
msgSvc(), name());
317 log << MSG::DEBUG <<
"RootCnvSvc::updateServiceState" << endreq;
319 StatusCode status = INVALID_ADDRESS;
320 IRegistry* ent = pAddress->registry();
322 SmartIF<IDataManagerSvc> iaddrReg(dataProvider());
324 status = StatusCode::SUCCESS;
325 std::string path = ent->identifier();
326 LeafMap::iterator itm = m_leaves.find(path);
327 if ( itm != m_leaves.end() ) {
328 Leaf* leaf = (*itm).second;
330 for ( Leaf::iterator il = leaf->begin(); il != leaf->end(); il++ ) {
331 IOpaqueAddress* newAddr = 0;
332 unsigned long ipars[2] = {0, 0};
333 if (m_evtsel) ipars[0]=m_evtsel->
getRecId();
335 std::string spars[3]={(*il)->path,(*il)->treename,(*il)->branchname};
342 log << MSG::DEBUG <<
"RootCnvSvc::updateService " <<
" ***** " <<
343 (*il)->clid <<
" ***** " << (*il)->path <<endreq;
345 if ( ir.isSuccess() ) {
346 ir = iaddrReg->registerAddress((*il)->path, newAddr);
347 if ( !ir.isSuccess() ) {
356 return StatusCode::SUCCESS;
366 return ConversionSvc::queryInterface(riid, ppvInterface);
369 return StatusCode::SUCCESS;
374 const std::string* spars,
375 const unsigned long* ipars,
376 IOpaqueAddress*& refpAddress)
378 MsgStream log(
msgSvc(), name() );
380 if (svc_type != repSvcType() ) {
381 log << MSG::ERROR <<
"RootCnvSvc::bad storage type" << svc_type << endreq;
382 return StatusCode::FAILURE;
385 std::string path = spars[0];
386 std::string treename = spars[1];
387 std::string branchname = spars[2];
389 if (path.size()==0) path=
"/Event";
392 path,treename,branchname,entry);
393 return StatusCode::SUCCESS;
402 MsgStream log(
msgSvc(), name() );
403 log << MSG::INFO <<
"RootCnvSvc::commitOutput starts." << endreq;
405 StatusCode sc=m_rootInterface->
fillTrees();
407 log << MSG::ERROR <<
"No Root tree was filled" << endreq;
412 if (oEvtHeader) oEvtHeader->
Clear();
414 if (oEvtNavigator) oEvtNavigator->
Clear();
418 if (oDst) oDst->
Clear();
420 if (oMc) oMc->
Clear();
422 if (oRecTrack) oRecTrack->
Clear();
424 if (oEvtRecEvent) oEvtRecEvent->
Clear();
426 if(oTrig) oTrig->
Clear();
428 if(oHlt) oHlt->
Clear();
438 MsgStream log(
msgSvc(), name());
441 log << MSG::DEBUG <<
"RootCnvSvc::createAddress"<<endreq;
443 StatusCode status = INVALID_ADDRESS;
444 IRegistry* ent = obj->registry();
447 SmartIF<IDataManagerSvc> iaddrReg(dataProvider());
448 std::string path = ent->identifier();
449 LeafMap::iterator itm = m_leaves.find(path);
452 if ( itm != m_leaves.end() ) {
453 Leaf* leaf = (*itm).second;
455 std::string spars[3] ;
461 unsigned long ipars[2] ={0,0};
462 if (m_evtsel) ipars[0]=m_evtsel->
getRecId();
465 if ( status.isSuccess() ) {
466 status = iaddrReg->registerAddress((IRegistry*)0,path, newAddr);
467 if ( !status.isSuccess() ) {
471 return StatusCode::SUCCESS;
481 MsgStream log(
msgSvc(), name());
484 LeafMap::iterator itm = m_leaves.find(path);
485 SmartIF<IDataManagerSvc> iaddrReg(dataProvider());
486 if ( itm != m_leaves.end() ) {
487 Leaf* leaf = (*itm).second;
489 std::string spars[3] ;
494 unsigned long ipars[2] = {0,0};
495 if (m_evtsel) ipars[0]=m_evtsel->
getRecId();
497 if ( status.isSuccess() ) {
498 status = iaddrReg->registerAddress((IRegistry*)0,path, newAddr);
499 if ( !status.isSuccess() ) {
503 return StatusCode::SUCCESS;
508 return StatusCode::FAILURE;
513 StatusCode RootCnvSvc::addConverters () {
514 MsgStream log(
msgSvc(), name());
578 return StatusCode::SUCCESS;
const long int ROOT_StorageType
*******INTEGER m_nBinMax INTEGER m_NdiMax !No of bins in histogram for cell exploration division $ !Last vertex $ !Last active cell $ !Last cell in buffer $ !No of sampling when dividing cell $ !No of function total $ !Flag for random ceel for $ !Flag for type of for WtMax $ !Flag which decides whether vertices are included in the sampling $ entire domain is hyp !Maximum effective eevents per saves r n generator level $ !Flag for chat level in output
const InterfaceID IID_IRootCnvSvc
static const CLID & classID()
static TDigiEvent * getWriteObject()
returns object to be written (maintained here for all DIGI-converters)
static const CLID & classID()
static TDstEvent * getWriteObject()
returns object to be written (maintained here for all DIGI-converters)
static const CLID & classID()
static const CLID & classID()
static const CLID & classID()
static const CLID & classID()
static const CLID & classID()
static TEvtNavigator * getWriteObject()
returns object to be written (maintained here for all DIGI-converters)
static const CLID & classID()
static TEvtRecObject * getWriteObject()
static const CLID & classID()
static const CLID & classID()
static const CLID & classID()
static const CLID & classID()
static const CLID & classID()
static const CLID & classID()
static const CLID & classID()
static const CLID & classID()
static const CLID & classID()
static THltEvent * getWriteObject()
returns object to be written (maintained here for all DIGI-converters)
static const CLID & classID()
static const CLID & classID()
static const CLID & classID()
static const CLID & classID()
static TMcEvent * getWriteObject()
returns object to be written (maintained here for all DIGI-converters)
static const CLID & classID()
static const CLID & classID()
static const CLID & classID()
static const CLID & classID()
static const CLID & classID()
static const CLID & classID()
static const CLID & classID()
static const CLID & classID()
static const CLID & classID()
static const CLID & classID()
static const CLID & classID()
static const CLID & classID()
static const CLID & classID()
static const CLID & classID()
static const CLID & classID()
static const CLID & classID()
static const CLID & classID()
static const CLID & classID()
static const CLID & classID()
static const CLID & classID()
static const CLID & classID()
static const CLID & classID()
static const CLID & classID()
static const CLID & classID()
static const CLID & classID()
static const CLID & classID()
static TRecTrackEvent * getWriteObject()
returns object to be written (maintained here for all DIGI-converters)
static const CLID & classID()
static const CLID & classID()
Definition of a Root address, derived from IOpaqueAddress.
object regrouping CLID and pathname with treename/branchname
Root Event Conversion Service which coordinates all of our converters.
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 initialize()
virtual StatusCode updateServiceState(IOpaqueAddress *pAddress)
Update state of the service.
virtual StatusCode commitOutput(const std::string &output, bool do_commit)
Commit pending output (fill the TTrees).
RootCnvSvc(const std::string &name, ISvcLocator *svc)
virtual StatusCode declareObject(const Leaf &leaf)
Associates a path on TDS with a particular converter.
virtual StatusCode finalize()
virtual StatusCode queryInterface(const InterfaceID &riid, void **ppvInterface)
Override inherited queryInterface due to enhanced interface.
virtual StatusCode finalize()
virtual void setTagInputFile(std::vector< std::string > input)
virtual StatusCode addInput(const std::string &treename, const std::string &file)
add input tree to the list
static RootInterface * Instance(MsgStream log)
singleton behaviour
virtual StatusCode addOutput(const std::string &treename, const std::string &file, int splitx, int bufsize, int compression)
add output tree to the list
virtual StatusCode fillTrees()
fill in all trees
virtual void setSelectFromTag(bool temp)
void Clear(Option_t *option="")
void Clear(Option_t *option="")
void Clear(Option_t *option="")
void Clear(Option_t *option="")
void Clear(Option_t *option="")
void Clear(Option_t *option="")
void Clear(Option_t *option="")
void Clear(Option_t *option="")
static const CLID & classID()
static const CLID & classID()
static const CLID & classID()
static const CLID & classID()
static TTrigEvent * getWriteObject()
returns object to be written (maintained here for all DIGI-converters)
static const CLID & classID()
static int expandEnvVar(std::string *toExpand, const std::string &openDel=std::string("$("), const std::string &closeDel=std::string(")"))
static int catchOptionVal(std::string *toCatch, const int ops=0, const std::string &openDel=std::string("#("), const std::string &closeDel=std::string(")"))
_EXTERN_ std::string Event
_EXTERN_ std::string MdcDigiCol
_EXTERN_ std::string MucDigiCol
_EXTERN_ std::string LumiDigiCol
_EXTERN_ std::string EmcDigiCol
_EXTERN_ std::string TofDigiCol
_EXTERN_ std::string Event
_EXTERN_ std::string DstEmcShowerCol
_EXTERN_ std::string DstMdcKalTrackCol
_EXTERN_ std::string DstExtTrackCol
_EXTERN_ std::string DstMdcDedxCol
_EXTERN_ std::string DstTofTrackCol
_EXTERN_ std::string DstMdcTrackCol
_EXTERN_ std::string DstMucTrackCol
_EXTERN_ std::string EvtRecPi0Col
_EXTERN_ std::string Event
_EXTERN_ std::string EvtRecPrimaryVertex
_EXTERN_ std::string EvtRecEvent
_EXTERN_ std::string EvtRecVeeVertexCol
_EXTERN_ std::string EvtRecEtaToGGCol
_EXTERN_ std::string EvtRecDTagCol
_EXTERN_ std::string EvtRecTrackCol
_EXTERN_ std::string Event
_EXTERN_ std::string HltInf
_EXTERN_ std::string HltRawCol
_EXTERN_ std::string DstHltInf
_EXTERN_ std::string EmcMcHitCol
_EXTERN_ std::string MucMcHitCol
_EXTERN_ std::string MdcMcHitCol
_EXTERN_ std::string TofMcHitCol
_EXTERN_ std::string McParticleCol
_EXTERN_ std::string Event
_EXTERN_ std::string RecMdcKalHelixSegCol
_EXTERN_ std::string RecEmcClusterCol
_EXTERN_ std::string MucRecHitCol
_EXTERN_ std::string RecETofCalHitCol
_EXTERN_ std::string RecBTofCalHitCol
_EXTERN_ std::string RecExtTrackCol
_EXTERN_ std::string RecMdcDedxCol
_EXTERN_ std::string RecZddChannelCol
_EXTERN_ std::string RecTofTrackCol
_EXTERN_ std::string RecEsTimeCol
_EXTERN_ std::string RecEmcHitCol
_EXTERN_ std::string RecMdcTrackCol
_EXTERN_ std::string RecMdcDedxHitCol
_EXTERN_ std::string Event
_EXTERN_ std::string RecMdcKalTrackCol
_EXTERN_ std::string RecMucTrackCol
_EXTERN_ std::string RecMdcHitCol
_EXTERN_ std::string RecEmcShowerCol
_EXTERN_ std::string TrigData
_EXTERN_ std::string Event