The Gaudi Framework  v39r2 (37c0b60a)
RootHistCnv::RDirectoryCnv Class Reference

#include </builds/gaudi/Gaudi/RootHistCnv/src/RDirectoryCnv.h>

Inheritance diagram for RootHistCnv::RDirectoryCnv:
Collaboration diagram for RootHistCnv::RDirectoryCnv:

Public Member Functions

StatusCode createObj (IOpaqueAddress *pAddr, DataObject *&refpObj) override
 Create the transient representation of an object. More...
 
StatusCode fillObjRefs (IOpaqueAddress *pAddr, DataObject *refpObj) override
 Update the transient object from the other representation. More...
 
StatusCode createRep (DataObject *pObj, IOpaqueAddress *&refpAddr) override
 Convert the transient object to the requested representation. More...
 
StatusCode updateRep (IOpaqueAddress *pAddr, DataObject *pObject) override
 Convert the transient object to the requested representation. More...
 
 RDirectoryCnv (ISvcLocator *svc)
 Standard constructor. More...
 
 RDirectoryCnv (ISvcLocator *svc, const CLID &clid)
 Standard constructor. More...
 
- Public Member Functions inherited from RootHistCnv::RConverter
StatusCode createRep (DataObject *pObj, IOpaqueAddress *&refpAddr) override
 Convert the transient object to the requested representation. More...
 
long repSvcType () const override
 
StatusCode error (const std::string &msg)
 
StatusCode regTFile (const std::string &, const TFile *)
 
StatusCode findTFile (const std::string &, TFile *&)
 
std::string diskDirectory (const std::string &loc)
 
std::string directory (const std::string &loc)
 
void setDirectory (const std::string &loc)
 
void setDiskDirectory (const std::string &loc)
 
StatusCode createDirectory (const std::string &loc)
 
StatusCode createDiskDirectory (const std::string &loc)
 
std::string getDirectory ()
 
std::string convertId (const std::string &) const
 
- Public Member Functions inherited from Converter
StatusCode initialize () override
 Initialize the converter. More...
 
StatusCode finalize () override
 Initialize the converter. More...
 
StatusCode setDataProvider (IDataProviderSvc *svc) override
 Set Data provider service. More...
 
SmartIF< IDataProviderSvc > & dataProvider () const override
 Get Data provider service. More...
 
StatusCode setConversionSvc (IConversionSvc *svc) override
 Set conversion service the converter is connected to. More...
 
SmartIF< IConversionSvc > & conversionSvc () const override
 Get conversion service the converter is connected to. More...
 
StatusCode setAddressCreator (IAddressCreator *creator) override
 Set address creator facility. More...
 
SmartIF< IAddressCreator > & addressCreator () const override
 Retrieve address creator facility. More...
 
const CLIDobjType () const override
 Retrieve the class type of objects the converter produces. More...
 
virtual long i_repSvcType () const
 Retrieve the class type of the data store the converter uses. More...
 
StatusCode createObj (IOpaqueAddress *pAddress, DataObject *&refpObject) override
 Create the transient representation of an object. More...
 
StatusCode fillObjRefs (IOpaqueAddress *pAddress, DataObject *pObject) override
 Resolve the references of the created transient object. More...
 
StatusCode updateObj (IOpaqueAddress *pAddress, DataObject *refpObject) override
 Update the transient object from the other representation. More...
 
StatusCode updateObjRefs (IOpaqueAddress *pAddress, DataObject *pObject) override
 Update the references of an updated transient object. More...
 
StatusCode createRep (DataObject *pObject, IOpaqueAddress *&refpAddress) override
 Convert the transient object to the requested representation. More...
 
StatusCode fillRepRefs (IOpaqueAddress *pAddress, DataObject *pObject) override
 Resolve the references of the converted object. More...
 
StatusCode updateRep (IOpaqueAddress *pAddress, DataObject *pObject) override
 Update the converted representation of a transient object. More...
 
StatusCode updateRepRefs (IOpaqueAddress *pAddress, DataObject *pObject) override
 Update the references of an already converted object. More...
 
 Converter (long storage_type, const CLID &class_type, ISvcLocator *svc=0)
 Standard Constructor. More...
 
template<class T >
StatusCode service (const std::string &name, T *&psvc, bool createIf=false) const
 Access a service by name, creating it if it doesn't already exist. More...
 
template<class T >
StatusCode service (const std::string &type, const std::string &name, T *&psvc) const
 Access a service by name, type creating it if it doesn't already exist. More...
 
SmartIF< IServiceservice (const std::string &name, const bool createIf=true) const
 Return a pointer to the service identified by name (or "type/name") More...
 
- Public Member Functions inherited from implements< IConverter >
void * i_cast (const InterfaceID &tid) const override
 Implementation of IInterface::i_cast. More...
 
StatusCode queryInterface (const InterfaceID &ti, void **pp) override
 Implementation of IInterface::queryInterface. More...
 
std::vector< std::stringgetInterfaceNames () const override
 Implementation of IInterface::getInterfaceNames. More...
 
 implements ()=default
 Default constructor. More...
 
 implements (const implements &)
 Copy constructor (zero the reference count) More...
 
implementsoperator= (const implements &)
 Assignment operator (do not touch the reference count). More...
 
unsigned long addRef () override
 Reference Interface instance
More...
 
unsigned long release () override
 Release Interface instance
More...
 
unsigned long refCount () const override
 Current reference count
More...
 

Static Public Member Functions

static const CLIDclassID ()
 Inquire class type. More...
 
- Static Public Member Functions inherited from RootHistCnv::RConverter
static long storageType ()
 Inquire storage type. More...
 

Additional Inherited Members

- Public Types inherited from Converter
using Factory = Gaudi::PluginService::Factory< IConverter *(ISvcLocator *)>
 
- Public Types inherited from implements< IConverter >
using base_class = implements< Interfaces... >
 Typedef to this class. More...
 
using extend_interfaces_base = extend_interfaces< Interfaces... >
 Typedef to the base of this class. More...
 
using iids = typename extend_interfaces_base::ext_iids
 
- Public Types inherited from extend_interfaces< Interfaces... >
using ext_iids = typename Gaudi::interface_list_cat< typename Interfaces::ext_iids... >::type
 take union of the ext_iids of all Interfaces... More...
 
- Protected Member Functions inherited from RootHistCnv::RConverter
 RConverter (const CLID &clid, ISvcLocator *svc)
 Standard constructor. More...
 
virtual StatusCode readObject (IOpaqueAddress *pAddr, DataObject *&refpObj)
 Create the transient representation of an object. More...
 
virtual TObject * createPersistent (DataObject *pObj)
 Create the persistent representation of an object. More...
 
StatusCode createAddress (DataObject *pObject, TDirectory *pDir, TObject *pTObject, IOpaqueAddress *&refpAddr)
 Create address of the transient object according to the requested representation. More...
 
StatusCode createAddress (const std::string &rzdir, const CLID &clid, long id, TObject *pTobj, IOpaqueAddress *&refpAddress)
 
StatusCode createAddress (const std::string &rzdir, const CLID &clid, const std::string &title, TObject *pTobj, IOpaqueAddress *&refpAddress)
 
TDirectory * changeDirectory (DataObject *pObject)
 Switch to object directory (=Parent directory) More...
 
- Protected Member Functions inherited from Converter
SmartIF< ISvcLocator > & serviceLocator () const
 Retrieve pointer to service locator. More...
 
SmartIF< IMessageSvc > & msgSvc () const
 Retrieve pointer to message service. More...
 
SmartIF< IDataManagerSvc > & dataManager () const
 Get Data Manager service. More...
 
- Protected Attributes inherited from implements< IConverter >
std::atomic_ulong m_refCount
 Reference counter
More...
 

Detailed Description

Create persistent and transient representations of data store directories

Author
Charles Leggett

Definition at line 26 of file RDirectoryCnv.h.

Constructor & Destructor Documentation

◆ RDirectoryCnv() [1/2]

RootHistCnv::RDirectoryCnv::RDirectoryCnv ( ISvcLocator svc)
inline

Standard constructor.

Definition at line 39 of file RDirectoryCnv.h.

39 : RConverter( CLID_NTupleDirectory, svc ) {}

◆ RDirectoryCnv() [2/2]

RootHistCnv::RDirectoryCnv::RDirectoryCnv ( ISvcLocator svc,
const CLID clid 
)
inline

Standard constructor.

Definition at line 41 of file RDirectoryCnv.h.

41 : RConverter( clid, svc ) {}

Member Function Documentation

◆ classID()

static const CLID& RootHistCnv::RDirectoryCnv::classID ( )
inlinestatic

Inquire class type.

Definition at line 37 of file RDirectoryCnv.h.

37 { return CLID_NTupleDirectory; }

◆ createObj()

StatusCode RootHistCnv::RDirectoryCnv::createObj ( IOpaqueAddress pAddr,
DataObject *&  refpObj 
)
override

Create the transient representation of an object.

Definition at line 46 of file RDirectoryCnv.cpp.

48 {
49  refpObject = new NTuple::Directory();
50  return StatusCode::SUCCESS;
51 }

◆ createRep()

StatusCode RootHistCnv::RDirectoryCnv::createRep ( DataObject pObj,
IOpaqueAddress *&  refpAddr 
)
override

Convert the transient object to the requested representation.

Definition at line 54 of file RDirectoryCnv.cpp.

56 {
57  const std::string& loc = pObject->registry()->identifier();
58  if ( createDirectory( loc ).isSuccess() ) {
59  setDirectory( loc );
60  setDiskDirectory( loc );
61  // return createAddress(pObject, pObject->registry()->name(), refpAddress);
62  return createAddress( pObject, gDirectory, nullptr, refpAddress );
63  }
64  refpAddress = nullptr;
65  return StatusCode::FAILURE;
66 }

◆ fillObjRefs()

StatusCode RootHistCnv::RDirectoryCnv::fillObjRefs ( IOpaqueAddress pAddr,
DataObject refpObj 
)
override

Update the transient object from the other representation.

Definition at line 81 of file RDirectoryCnv.cpp.

81  {
82  MsgStream log( msgSvc(), "RDirectoryCnv" );
83  IRegistry* pReg = pObj->registry();
84  std::string full = pReg->identifier();
85  const std::string& fname = pAddr->par()[0];
86 
87  TFile* tf = nullptr;
88  findTFile( full, tf ).ignore();
89 
90  // cd to TFile:
91  setDirectory( full );
92  TIter nextkey( gDirectory->GetListOfKeys() );
93  while ( TKey* key = (TKey*)nextkey() ) {
94  IOpaqueAddress* pA = nullptr;
95  TObject* obj = key->ReadObj();
96  std::string title = obj->GetTitle();
97  std::string sid = obj->GetName();
98  std::string f2 = full + "/" + sid;
99  int idh = maybe_stol( sid ).value_or( 0 );
100  // introduced by Grigori Rybkine
101  std::string clname = key->GetClassName();
102  std::string clnm = clname.substr( 0, 3 );
103  TClass* isa = obj->IsA();
104  if ( isa->InheritsFrom( "TTree" ) ) {
105  createAddress( full, CLID_ColumnWiseTuple, idh, obj, pA ).ignore();
106  TTree* tree = (TTree*)obj;
107  tree->Print();
108  log << MSG::DEBUG << "Reg CWNT \"" << obj->GetTitle() << "\" as " << f2 << endmsg;
109  title = "/" + sid;
110  } else if ( isa->InheritsFrom( "TDirectory" ) ) {
111  createAddress( full, CLID_NTupleDirectory, title, obj, pA ).ignore();
112  } else if ( isa == TProfile::Class() ) {
113  createAddress( full, CLID_ProfileH, idh, obj, pA ).ignore();
114  title = sid;
115  } else if ( isa == TProfile2D::Class() ) {
116  createAddress( full, CLID_ProfileH2, idh, obj, pA ).ignore();
117  title = sid;
118  } else if ( isa == TH1C::Class() ) {
119  createAddress( full, CLID_H1D, idh, obj, pA ).ignore();
120  title = sid;
121  } else if ( isa == TH1S::Class() ) {
122  createAddress( full, CLID_H1D, idh, obj, pA ).ignore();
123  title = sid;
124  } else if ( isa == TH1I::Class() ) {
125  createAddress( full, CLID_H1D, idh, obj, pA ).ignore();
126  title = sid;
127  } else if ( isa == TH1F::Class() ) {
128  createAddress( full, CLID_H1D, idh, obj, pA ).ignore();
129  title = sid;
130  } else if ( isa == TH1D::Class() ) {
131  createAddress( full, CLID_H1D, idh, obj, pA ).ignore();
132  title = sid;
133  } else if ( isa == TH2C::Class() ) {
134  createAddress( full, CLID_H2D, idh, obj, pA ).ignore();
135  title = sid;
136  } else if ( isa == TH2S::Class() ) {
137  createAddress( full, CLID_H2D, idh, obj, pA ).ignore();
138  title = sid;
139  } else if ( isa == TH2I::Class() ) {
140  createAddress( full, CLID_H2D, idh, obj, pA ).ignore();
141  title = sid;
142  } else if ( isa == TH2F::Class() ) {
143  createAddress( full, CLID_H2D, idh, obj, pA ).ignore();
144  title = sid;
145  } else if ( isa == TH2D::Class() ) {
146  createAddress( full, CLID_H2D, idh, obj, pA ).ignore();
147  title = sid;
148  } else if ( isa == TH3C::Class() ) {
149  createAddress( full, CLID_H3D, idh, obj, pA ).ignore();
150  title = sid;
151  } else if ( isa == TH3S::Class() ) {
152  createAddress( full, CLID_H3D, idh, obj, pA ).ignore();
153  title = sid;
154  } else if ( isa == TH3I::Class() ) {
155  createAddress( full, CLID_H3D, idh, obj, pA ).ignore();
156  title = sid;
157  } else if ( isa == TH3F::Class() ) {
158  createAddress( full, CLID_H3D, idh, obj, pA ).ignore();
159  title = sid;
160  } else if ( isa == TH3D::Class() ) {
161  createAddress( full, CLID_H3D, idh, obj, pA ).ignore();
162  title = sid;
163  } else {
164  log << MSG::ERROR << "Encountered an unknown object with key: " << obj->GetName() << " in ROOT file " << fname
165  << endmsg;
166  return StatusCode::FAILURE;
167  }
168  if ( pA ) {
169  StatusCode sc = dataManager()->registerAddress( pReg, title, pA );
170  if ( !sc.isSuccess() ) {
171  log << MSG::ERROR << "Failed to register address for " << full << endmsg;
172  return sc;
173  }
174  log << MSG::VERBOSE << "Created address for " << clnm << "'" << title << "' in " << full << endmsg;
175  }
176  }
177  return StatusCode::SUCCESS;
178 }

◆ updateRep()

StatusCode RootHistCnv::RDirectoryCnv::updateRep ( IOpaqueAddress pAddr,
DataObject pObject 
)
override

Convert the transient object to the requested representation.

Definition at line 69 of file RDirectoryCnv.cpp.

71 {
72  const std::string& loc = pObject->registry()->identifier();
73  if ( createDirectory( loc ).isSuccess() ) {
74  setDirectory( loc );
75  return StatusCode::SUCCESS;
76  }
77  return StatusCode::FAILURE;
78 }

The documentation for this class was generated from the following files:
MSG::DEBUG
@ DEBUG
Definition: IMessageSvc.h:25
std::string
STL class.
IOpaqueAddress::par
virtual const std::string * par() const =0
Retrieve String parameters.
Gaudi.Configuration.log
log
Definition: Configuration.py:28
StatusCode::isSuccess
bool isSuccess() const
Definition: StatusCode.h:314
NTuple::Directory
Small class representing an N tuple directory in the transient store.
Definition: NTuple.h:914
Gaudi::Accumulators::atomicity::full
@ full
IOpaqueAddress
Definition: IOpaqueAddress.h:33
RootHistCnv::RConverter::RConverter
RConverter(const CLID &clid, ISvcLocator *svc)
Standard constructor.
Definition: RConverter.h:65
RootHistCnv::RConverter::findTFile
StatusCode findTFile(const std::string &, TFile *&)
Definition: RConverter.cpp:289
IRegistry
Definition: IRegistry.h:32
RootHistCnv::RConverter::setDirectory
void setDirectory(const std::string &loc)
Definition: RConverter.cpp:118
Converter::dataManager
SmartIF< IDataManagerSvc > & dataManager() const
Get Data Manager service.
Definition: Converter.cpp:81
StatusCode
Definition: StatusCode.h:65
RootHistCnv::RConverter::createAddress
StatusCode createAddress(DataObject *pObject, TDirectory *pDir, TObject *pTObject, IOpaqueAddress *&refpAddr)
Create address of the transient object according to the requested representation.
Definition: RConverter.cpp:165
endmsg
MsgStream & endmsg(MsgStream &s)
MsgStream Modifier: endmsg. Calls the output method of the MsgStream.
Definition: MsgStream.h:202
MsgStream
Definition: MsgStream.h:33
StatusCode::ignore
const StatusCode & ignore() const
Allow discarding a StatusCode without warning.
Definition: StatusCode.h:139
std::string::substr
T substr(T... args)
RootHistCnv::RConverter::setDiskDirectory
void setDiskDirectory(const std::string &loc)
Definition: RConverter.cpp:151
MSG::VERBOSE
@ VERBOSE
Definition: IMessageSvc.h:25
StatusCode::SUCCESS
constexpr static const auto SUCCESS
Definition: StatusCode.h:100
MSG::ERROR
@ ERROR
Definition: IMessageSvc.h:25
RootHistCnv::RConverter::createDirectory
StatusCode createDirectory(const std::string &loc)
Definition: RConverter.cpp:34
IRegistry::identifier
virtual const id_type & identifier() const =0
Full identifier (or key)
Converter::msgSvc
SmartIF< IMessageSvc > & msgSvc() const
Retrieve pointer to message service.
Definition: Converter.cpp:105
StatusCode::FAILURE
constexpr static const auto FAILURE
Definition: StatusCode.h:101
ProduceConsume.key
key
Definition: ProduceConsume.py:84
DataObject::registry
IRegistry * registry() const
Get pointer to Registry.
Definition: DataObject.h:78