Public Member Functions | Protected Member Functions | Protected Attributes | List of all members
Gaudi::RootCnvSvc Class Reference

Description: More...

#include <src/RootCnvSvc.h>

Inheritance diagram for Gaudi::RootCnvSvc:
Inheritance graph
[legend]
Collaboration diagram for Gaudi::RootCnvSvc:
Collaboration graph
[legend]

Public Member Functions

 RootCnvSvc (const std::string &name, ISvcLocator *svc)
 Standard constructor. More...
 
virtual ~RootCnvSvc ()
 Standard destructor. More...
 
virtual StatusCode updateServiceState (IOpaqueAddress *)
 Update state of the service. More...
 
StatusCode error (const std::string &msg)
 Standard way to print errors. More...
 
StatusCode connectDatabase (const std::string &dataset, int mode, RootDataConnection **con)
 Connect the output file to the service with open mode. More...
 
virtual StatusCode initialize ()
 ConversionSvc overload: initialize Db service. More...
 
virtual StatusCode finalize ()
 ConversionSvc overload: Finalize Db service. More...
 
virtual IConverter * createConverter (long typ, const CLID &wanted, const ICnvFactory *fac)
 ConversionSvc overload: Create new Converter using factory. More...
 
virtual void loadConverter (DataObject *pObj)
 ConversionSvc overload: Load the class (dictionary) for the converter. More...
 
virtual StatusCode connectOutput (const std::string &outputFile, const std::string &openMode)
 Connect the output file to the service with open mode. More...
 
virtual StatusCode connectOutput (const std::string &outputFile)
 Connect the output file to the service. More...
 
virtual StatusCode commitOutput (const std::string &outputFile, bool do_commit)
 Commit pending output. More...
 
virtual StatusCode disconnect (const std::string &dbName)
 Disconnect from an existing data stream. More...
 
virtual StatusCode createAddress (long svc_type, const CLID &clid, const std::string *par, const unsigned long *ip, IOpaqueAddress *&refpAddress)
 IAddressCreator implementation: Address creation. More...
 
virtual StatusCode createAddress (long svc_type, const CLID &clid, const std::string &refAddress, IOpaqueAddress *&refpAddress)
 IAddressCreator implementation: Creates an address in string form to object form. More...
 
virtual StatusCode createNullRep (const std::string &path)
 Insert null marker for not existent transient object. More...
 
virtual StatusCode createNullRef (const std::string &path)
 Insert null marker for not existent transient object. More...
 
virtual StatusCode i__createRep (DataObject *pObj, IOpaqueAddress *&refpAddr)
 Convert the transient object to the requested persistent representation. More...
 
virtual StatusCode i__fillRepRefs (IOpaqueAddress *pAddr, DataObject *pObj)
 Resolve the references of the converted object. More...
 
virtual StatusCode i__createObj (IOpaqueAddress *pAddr, DataObject *&refpObj)
 Create transient object from persistent data. More...
 
virtual StatusCode i__fillObjRefs (IOpaqueAddress *pAddr, DataObject *pObj)
 Resolve the references of the created transient object. More...
 
 RootCnvSvc (const std::string &name, ISvcLocator *svc)
 Standard constructor. More...
 
virtual ~RootCnvSvc ()
 Standard destructor. More...
 
virtual StatusCode updateServiceState (IOpaqueAddress *)
 Update state of the service. More...
 
StatusCode error (const std::string &msg)
 Standard way to print errors. More...
 
StatusCode connectDatabase (const std::string &dataset, int mode, RootDataConnection **con)
 Connect the output file to the service with open mode. More...
 
virtual StatusCode initialize ()
 ConversionSvc overload: initialize Db service. More...
 
virtual StatusCode finalize ()
 ConversionSvc overload: Finalize Db service. More...
 
virtual IConverter * createConverter (long typ, const CLID &wanted, const ICnvFactory *fac)
 ConversionSvc overload: Create new Converter using factory. More...
 
virtual void loadConverter (DataObject *pObj)
 ConversionSvc overload: Load the class (dictionary) for the converter. More...
 
virtual StatusCode connectOutput (const std::string &outputFile, const std::string &openMode)
 Connect the output file to the service with open mode. More...
 
virtual StatusCode connectOutput (const std::string &outputFile)
 Connect the output file to the service. More...
 
virtual StatusCode commitOutput (const std::string &outputFile, bool do_commit)
 Commit pending output. More...
 
virtual StatusCode disconnect (const std::string &dbName)
 Disconnect from an existing data stream. More...
 
virtual StatusCode createAddress (long svc_type, const CLID &clid, const std::string *par, const unsigned long *ip, IOpaqueAddress *&refpAddress)
 IAddressCreator implementation: Address creation. More...
 
virtual StatusCode createAddress (long svc_type, const CLID &clid, const std::string &refAddress, IOpaqueAddress *&refpAddress)
 IAddressCreator implementation: Creates an address in string form to object form. More...
 
virtual StatusCode createNullRep (const std::string &path)
 Insert null marker for not existent transient object. More...
 
virtual StatusCode createNullRef (const std::string &path)
 Insert null marker for not existent transient object. More...
 
virtual StatusCode i__createRep (DataObject *pObj, IOpaqueAddress *&refpAddr)
 Convert the transient object to the requested persistent representation. More...
 
virtual StatusCode i__fillRepRefs (IOpaqueAddress *pAddr, DataObject *pObj)
 Resolve the references of the converted object. More...
 
virtual StatusCode i__createObj (IOpaqueAddress *pAddr, DataObject *&refpObj)
 Create transient object from persistent data. More...
 
virtual StatusCode i__fillObjRefs (IOpaqueAddress *pAddr, DataObject *pObj)
 Resolve the references of the created transient object. More...
 
- Public Member Functions inherited from ConversionSvc
virtual long repSvcType () const
 Retrieve the class type of the data store the converter uses. More...
 
const CLID & objType () const
 Implementation of IConverter: dummy call. More...
 
virtual StatusCode setDataProvider (IDataProviderSvc *pService)
 Implementation of IConverter: Set Data provider service. More...
 
virtual SmartIF< IDataProviderSvc > & dataProvider () const
 Implementation of IConverter: Get Data provider service. More...
 
virtual StatusCode setConversionSvc (IConversionSvc *svc)
 Implementation of IConverter: Set conversion service the converter is connected to. More...
 
virtual SmartIF< IConversionSvc > & conversionSvc () const
 Implementation of IConverter: Get conversion service the converter is connected to. More...
 
virtual StatusCode setAddressCreator (IAddressCreator *creator)
 Set address creator facility. More...
 
virtual SmartIF< IAddressCreator > & addressCreator () const
 Retrieve address creator facility. More...
 
virtual StatusCode createObj (IOpaqueAddress *pAddress, DataObject *&refpObject)
 Implementation of IConverter: Create the transient representation of an object. More...
 
virtual StatusCode fillObjRefs (IOpaqueAddress *pAddress, DataObject *pObject)
 Implementation of IConverter: Resolve the references of the created transient object. More...
 
virtual StatusCode updateObj (IOpaqueAddress *pAddress, DataObject *refpObject)
 Implementation of IConverter: Update the transient object from the other representation. More...
 
virtual StatusCode updateObjRefs (IOpaqueAddress *pAddress, DataObject *pObject)
 Implementation of IConverter: Update the references of an updated transient object. More...
 
virtual StatusCode createRep (DataObject *pObject, IOpaqueAddress *&refpAddress)
 Implementation of IConverter: Convert the transient object to the requested representation. More...
 
virtual StatusCode fillRepRefs (IOpaqueAddress *pAddress, DataObject *pObject)
 Implementation of IConverter: Resolve the references of the converted object. More...
 
virtual StatusCode updateRep (IOpaqueAddress *pAddress, DataObject *pObject)
 Implementation of IConverter: Update the converted representation of a transient object. More...
 
virtual StatusCode updateRepRefs (IOpaqueAddress *pAddress, DataObject *pObject)
 Implementation of IConverter: Update the references of an already converted object. More...
 
virtual StatusCode addConverter (const CLID &clid)
 Add converter object to conversion service. More...
 
virtual StatusCode addConverter (IConverter *pConverter)
 Add converter object to conversion service. More...
 
virtual StatusCode removeConverter (const CLID &clid)
 Remove converter object from conversion service (if present). More...
 
virtual IConverter * converter (const CLID &wanted)
 Retrieve converter from list. More...
 
virtual StatusCode convertAddress (const IOpaqueAddress *pAddress, std::string &refAddress)
 Convert an address to string form. More...
 
 ConversionSvc (const std::string &name, ISvcLocator *svc, long type)
 Standard Constructor. More...
 
virtual long repSvcType () const
 Retrieve the class type of the data store the converter uses. More...
 
const CLID & objType () const
 Implementation of IConverter: dummy call. More...
 
virtual StatusCode setDataProvider (IDataProviderSvc *pService)
 Implementation of IConverter: Set Data provider service. More...
 
virtual SmartIF< IDataProviderSvc > & dataProvider () const
 Implementation of IConverter: Get Data provider service. More...
 
virtual StatusCode setConversionSvc (IConversionSvc *svc)
 Implementation of IConverter: Set conversion service the converter is connected to. More...
 
virtual SmartIF< IConversionSvc > & conversionSvc () const
 Implementation of IConverter: Get conversion service the converter is connected to. More...
 
virtual StatusCode setAddressCreator (IAddressCreator *creator)
 Set address creator facility. More...
 
virtual SmartIF< IAddressCreator > & addressCreator () const
 Retrieve address creator facility. More...
 
virtual StatusCode createObj (IOpaqueAddress *pAddress, DataObject *&refpObject)
 Implementation of IConverter: Create the transient representation of an object. More...
 
virtual StatusCode fillObjRefs (IOpaqueAddress *pAddress, DataObject *pObject)
 Implementation of IConverter: Resolve the references of the created transient object. More...
 
virtual StatusCode updateObj (IOpaqueAddress *pAddress, DataObject *refpObject)
 Implementation of IConverter: Update the transient object from the other representation. More...
 
virtual StatusCode updateObjRefs (IOpaqueAddress *pAddress, DataObject *pObject)
 Implementation of IConverter: Update the references of an updated transient object. More...
 
virtual StatusCode createRep (DataObject *pObject, IOpaqueAddress *&refpAddress)
 Implementation of IConverter: Convert the transient object to the requested representation. More...
 
virtual StatusCode fillRepRefs (IOpaqueAddress *pAddress, DataObject *pObject)
 Implementation of IConverter: Resolve the references of the converted object. More...
 
virtual StatusCode updateRep (IOpaqueAddress *pAddress, DataObject *pObject)
 Implementation of IConverter: Update the converted representation of a transient object. More...
 
virtual StatusCode updateRepRefs (IOpaqueAddress *pAddress, DataObject *pObject)
 Implementation of IConverter: Update the references of an already converted object. More...
 
virtual StatusCode addConverter (const CLID &clid)
 Add converter object to conversion service. More...
 
virtual StatusCode addConverter (IConverter *pConverter)
 Add converter object to conversion service. More...
 
virtual StatusCode removeConverter (const CLID &clid)
 Remove converter object from conversion service (if present). More...
 
virtual IConverter * converter (const CLID &wanted)
 Retrieve converter from list. More...
 
virtual StatusCode convertAddress (const IOpaqueAddress *pAddress, std::string &refAddress)
 Convert an address to string form. More...
 
 ConversionSvc (const std::string &name, ISvcLocator *svc, long type)
 Standard Constructor. More...
 
- Public Member Functions inherited from extends< BASE, Interfaces >
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::string > getInterfaceNames () const override
 Implementation of IInterface::getInterfaceNames. More...
 
 ~extends () override=default
 Virtual destructor. More...
 
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::string > getInterfaceNames () const override
 Implementation of IInterface::getInterfaceNames. More...
 
 ~extends () override=default
 Virtual destructor. More...
 
- Public Member Functions inherited from extend_interfaces< Interfaces...>
 ~extend_interfaces () override=default
 Virtual destructor. More...
 
 ~extend_interfaces () override=default
 Virtual destructor. More...
 

Protected Member Functions

TClass * getClass (DataObject *pObject)
 Helper: Get TClass for a given DataObject pointer. More...
 
MsgStream & log () const
 Helper: Use message streamer. More...
 
TClass * getClass (DataObject *pObject)
 Helper: Get TClass for a given DataObject pointer. More...
 
MsgStream & log () const
 Helper: Use message streamer. More...
 
- Protected Member Functions inherited from ConversionSvc
virtual ~ConversionSvc ()
 Standard Destructor. More...
 
virtual StatusCode configureConverter (long typ, const CLID &clid, IConverter *cnv)
 Configure the new converter before initialize is called. More...
 
virtual StatusCode initializeConverter (long typ, const CLID &clid, IConverter *cnv)
 Initialize the new converter. More...
 
virtual StatusCode activateConverter (long typ, const CLID &clid, IConverter *cnv)
 Activate the new converter after initialization. More...
 
virtual SmartIF< IAddressCreator > & addressCreator ()
 Retrieve address creation interface. More...
 
StatusCode makeCall (int typ, bool ignore_add, bool ignore_obj, bool update, IOpaqueAddress *&pAddress, DataObject *&pObject)
 
virtual ~ConversionSvc ()
 Standard Destructor. More...
 
virtual StatusCode configureConverter (long typ, const CLID &clid, IConverter *cnv)
 Configure the new converter before initialize is called. More...
 
virtual StatusCode initializeConverter (long typ, const CLID &clid, IConverter *cnv)
 Initialize the new converter. More...
 
virtual StatusCode activateConverter (long typ, const CLID &clid, IConverter *cnv)
 Activate the new converter after initialization. More...
 
virtual SmartIF< IAddressCreator > & addressCreator ()
 Retrieve address creation interface. More...
 
StatusCode makeCall (int typ, bool ignore_add, bool ignore_obj, bool update, IOpaqueAddress *&pAddress, DataObject *&pObject)
 

Protected Attributes

SmartIF< Gaudi::IIODataManager > m_ioMgr
 Reference to the I/O data manager. More...
 
SmartIF< IIncidentSvc > m_incidentSvc
 Reference to incident service. More...
 
Gaudi::RootDataConnection * m_current = nullptr
 On writing: reference to active output stream. More...
 
TClass * m_classRefs
 TClass pointer to reference class. More...
 
TClass * m_classDO
 TClass pointer to DataObject class. More...
 
std::shared_ptr< RootConnectionSetup > m_setup
 Setup structure (ref-counted) and passed to data connections. More...
 
std::string m_currSection
 Property: ROOT section name. More...
 
bool m_incidentEnabled
 Property: Flag to enable incidents on FILE_OPEN. More...
 
std::string m_shareFiles
 Property: Share files ? If set to YES, files will not be closed on finalize. More...
 
std::string m_recordName
 Property: Records name to fire incident for file records. More...
 
std::string m_ioPerfStats
 Property: Enable TTree IOperfStats if not empty; otherwise perf stat file name. More...
 
std::string m_compression
 Property: Compression-algorithm:compression-level. More...
 
int m_autoFlush
 Property: AutoFlush parameter for ROOT TTree (Number of events between auto flushes) More...
 
int m_basketSize
 Property: Basket optimization parameter for ROOT TTree (total basket size) More...
 
int m_bufferSize
 Property: Buffer size optimization parameter for ROOT TTree. More...
 
int m_splitLevel
 Property: Split level optimization parameter for ROOT TTree. More...
 
std::set< std::string > m_badFiles
 Set with bad files/tables. More...
 
std::unique_ptr< MsgStream > m_log
 Message streamer. More...
 
- Protected Attributes inherited from ConversionSvc
SmartIF< IDataProviderSvc > m_dataSvc
 Pointer to data provider service. More...
 
SmartIF< IAddressCreator > m_addressCreator
 Pointer to the address creation service interface. More...
 
SmartIF< IConversionSvc > m_cnvSvc
 Pointer to the IConversionSvc interface of this. More...
 
long m_type
 Conversion service type. More...
 
std::vector< WorkerEntry > m_workers
 List of conversion workers. More...
 

Additional Inherited Members

- Public Types inherited from extends< BASE, Interfaces >
using base_class = extends
 Typedef to this class. More...
 
using extend_interfaces_base = extend_interfaces< Interfaces...>
 Typedef to the base of this class. More...
 
using base_class = extends
 Typedef to this class. More...
 
using extend_interfaces_base = extend_interfaces< Interfaces...>
 Typedef to the base of this class. More...
 
- 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...
 
using ext_iids = typename Gaudi::interface_list_cat< typename Interfaces::ext_iids...>::type
 take union of the ext_iids of all Interfaces... More...
 

Detailed Description

Description:

RootCnvSvc class implementation definition.

Author
Markus Frank
Version
1.0
Date
20/12/2009

Definition at line 52 of file RootCnvSvc.h.

Constructor & Destructor Documentation

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

Standard constructor.

RootCnvSvc::~RootCnvSvc ( )
virtual

Standard destructor.

Definition at line 76 of file RootCnvSvc.cpp.

76  {
77 }
Gaudi::RootCnvSvc::RootCnvSvc ( const std::string &  name,
ISvcLocator *  svc 
)

Standard constructor.

virtual Gaudi::RootCnvSvc::~RootCnvSvc ( )
virtual

Standard destructor.

Member Function Documentation

virtual StatusCode Gaudi::RootCnvSvc::commitOutput ( const std::string &  outputFile,
bool  do_commit 
)
virtual

Commit pending output.

Parameters
outputFileString containig output file
do_commitif true commit the output and flush eventually pending items to the database if false, discard pending buffers. Note: The possibility to commit or rollback depends on the database technology used!
Returns
Status code indicating success or failure.

Reimplemented from ConversionSvc.

virtual StatusCode Gaudi::RootCnvSvc::commitOutput ( const std::string &  outputFile,
bool  do_commit 
)
virtual

Commit pending output.

Parameters
outputFileString containig output file
do_commitif true commit the output and flush eventually pending items to the database if false, discard pending buffers. Note: The possibility to commit or rollback depends on the database technology used!
Returns
Status code indicating success or failure.

Reimplemented from ConversionSvc.

StatusCode Gaudi::RootCnvSvc::connectDatabase ( const std::string &  dataset,
int  mode,
RootDataConnection **  con 
)

Connect the output file to the service with open mode.

Parameters
datasetString containig file name
modeString containig opening mode
Returns
Status code indicating success or failure.
StatusCode Gaudi::RootCnvSvc::connectDatabase ( const std::string &  dataset,
int  mode,
RootDataConnection **  con 
)

Connect the output file to the service with open mode.

Parameters
datasetString containig file name
modeString containig opening mode
Returns
Status code indicating success or failure.
virtual StatusCode Gaudi::RootCnvSvc::connectOutput ( const std::string &  outputFile,
const std::string &  openMode 
)
virtual

Connect the output file to the service with open mode.

Parameters
outputFileString containig output file
openModeString containig opening mode of the output file
Returns
Status code indicating success or failure.

Reimplemented from ConversionSvc.

virtual StatusCode Gaudi::RootCnvSvc::connectOutput ( const std::string &  outputFile,
const std::string &  openMode 
)
virtual

Connect the output file to the service with open mode.

Parameters
outputFileString containig output file
openModeString containig opening mode of the output file
Returns
Status code indicating success or failure.

Reimplemented from ConversionSvc.

virtual StatusCode Gaudi::RootCnvSvc::connectOutput ( const std::string &  outputFile)
virtual

Connect the output file to the service.

Parameters
outputFileString containig output file
Returns
Status code indicating success or failure.

Reimplemented from ConversionSvc.

virtual StatusCode Gaudi::RootCnvSvc::connectOutput ( const std::string &  outputFile)
virtual

Connect the output file to the service.

Parameters
outputFileString containig output file
Returns
Status code indicating success or failure.

Reimplemented from ConversionSvc.

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

IAddressCreator implementation: Address creation.

Create an address using the link infotmation together with the triple (database name/container name/object name).

Parameters
refLinkReference to abstract link information
dbNameDatabase name
containerNameObject container name
refpAddressOpaque address information to retrieve object
Returns
StatusCode indicating SUCCESS or failure

Reimplemented from ConversionSvc.

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

IAddressCreator implementation: Address creation.

Create an address using the link infotmation together with the triple (database name/container name/object name).

Parameters
refLinkReference to abstract link information
dbNameDatabase name
containerNameObject container name
refpAddressOpaque address information to retrieve object
Returns
StatusCode indicating SUCCESS or failure

Reimplemented from ConversionSvc.

Definition at line 389 of file RootCnvSvc.cpp.

394 {
395  refpAddress = new RootAddress(typ,clid,par[0],par[1],ip[0],ip[1]);
396  return S_OK;
397 }
Gaudi::RootAddress
Description:
Definition: RootAddress.h:36
S_OK
#define S_OK
Definition: RootCnvSvc.cpp:38
virtual StatusCode Gaudi::RootCnvSvc::createAddress ( long  svc_type,
const CLID &  clid,
const std::string &  refAddress,
IOpaqueAddress *&  refpAddress 
)
inlinevirtual

IAddressCreator implementation: Creates an address in string form to object form.

Parameters
svc_typeTechnology identifier encapsulated in this address.
clidClass identifier of the DataObject represented by the opaque address
addressInput address.
refpAddressOutput address in string form.
Returns
Status code indicating success or failure.

Reimplemented from ConversionSvc.

Definition at line 204 of file RootCnvSvc.h.

207  {
208  return this->ConversionSvc::createAddress(svc_type,clid,refAddress,refpAddress);
209  }
ConversionSvc::createAddress
virtual StatusCode createAddress(long svc_type, const CLID &clid, const std::string *par, const unsigned long *ip, IOpaqueAddress *&refpAddress)
Create a Generic address using explicit arguments to identify a single object.
Definition: ConversionSvc.cpp:355
virtual StatusCode Gaudi::RootCnvSvc::createAddress ( long  svc_type,
const CLID &  clid,
const std::string &  refAddress,
IOpaqueAddress *&  refpAddress 
)
inlinevirtual

IAddressCreator implementation: Creates an address in string form to object form.

Parameters
svc_typeTechnology identifier encapsulated in this address.
clidClass identifier of the DataObject represented by the opaque address
addressInput address.
refpAddressOutput address in string form.
Returns
Status code indicating success or failure.

Reimplemented from ConversionSvc.

Definition at line 204 of file RootCnvSvc.h.

207  {
208  return this->ConversionSvc::createAddress(svc_type,clid,refAddress,refpAddress);
209  }
ConversionSvc::createAddress
virtual StatusCode createAddress(long svc_type, const CLID &clid, const std::string *par, const unsigned long *ip, IOpaqueAddress *&refpAddress)
Create a Generic address using explicit arguments to identify a single object.
Definition: ConversionSvc.cpp:355
IConverter * RootCnvSvc::createConverter ( long  typ,
const CLID &  wanted,
const ICnvFactory *  fac 
)
virtual

ConversionSvc overload: Create new Converter using factory.

Reimplemented from ConversionSvc.

Definition at line 156 of file RootCnvSvc.cpp.

156  {
157  if ( wanted == CLID_StatisticsFile )
158  return new RootDatabaseCnv(typ,wanted,serviceLocator().get(),this);
159  else if ( wanted == CLID_StatisticsDirectory )
160  return new RootDirectoryCnv(typ,wanted,serviceLocator().get(),this);
161  else if ( wanted == CLID_RowWiseTuple )
162  return new RootNTupleCnv(typ,wanted,serviceLocator().get(),this);
163  else if ( wanted == CLID_ColumnWiseTuple )
164  return new RootNTupleCnv(typ,wanted,serviceLocator().get(),this);
165  else
166  return new RootConverter(typ,wanted,serviceLocator().get(),this);
167 }
Gaudi::RootDatabaseCnv
Statistics file converter class definition.
Definition: RootDatabaseCnv.h:28
Gaudi::RootNTupleCnv
NTuple converter class definition for NTuples writted/read using ROOT.
Definition: RootNTupleCnv.h:34
Gaudi::RootDirectoryCnv
Description: NTuple directory converter class definition Definition of the converter to manage the di...
Definition: RootDirectoryCnv.h:30
Gaudi::RootConverter
Description: Definition of the ROOT data converter.
Definition: RootConverter.h:32
virtual IConverter* Gaudi::RootCnvSvc::createConverter ( long  typ,
const CLID &  wanted,
const ICnvFactory *  fac 
)
virtual

ConversionSvc overload: Create new Converter using factory.

Reimplemented from ConversionSvc.

StatusCode RootCnvSvc::createNullRef ( const std::string &  path)
virtual

Insert null marker for not existent transient object.

Parameters
path[IN] Path to the (null-)object
Returns
Status code indicating success or failure.

Definition at line 408 of file RootCnvSvc.cpp.

408  {
409  RootObjectRefs* refs = nullptr;
410  size_t len = path.find('/',1);
411  string section = path.substr(1,len==string::npos ? string::npos : len-1);
412  pair<int,unsigned long> ret =
413  m_current->save(section,path+"#R",nullptr,refs,m_bufferSize,m_splitLevel);
414  if( log().level() <= MSG::VERBOSE )
415  log() << MSG::VERBOSE << "Writing object:" << path << " "
416  << ret.first << " " << hex << ret.second << dec << " [NULL]" << endmsg;
417  return S_OK;
418 }
Gaudi::RootCnvSvc::log
MsgStream & log() const
Helper: Use message streamer.
Definition: RootCnvSvc.h:99
endmsg
MsgStream & endmsg(MsgStream &s)
MsgStream Modifier: endmsg. Calls the output method of the MsgStream.
Definition: MsgStream.h:244
Gaudi::RootDataConnection::save
std::pair< int, unsigned long > save(const std::string &section, const std::string &cnt, TClass *cl, void *pObj, int buff_siz, int split_lvl, bool fill_missing=false)
Save object of a given class to section and container.
Gaudi::RootCnvSvc::m_current
Gaudi::RootDataConnection * m_current
On writing: reference to active output stream.
Definition: RootCnvSvc.h:60
EnvConfig.path
list path
Definition: __init__.py:15
Gaudi::RootObjectRefs
Persistent reference object containing all leafs and links corresponding to a Gaudi DataObject...
Definition: RootRefs.h:58
Gaudi::RootCnvSvc::m_splitLevel
int m_splitLevel
Property: Split level optimization parameter for ROOT TTree.
Definition: RootCnvSvc.h:88
S_OK
#define S_OK
Definition: RootCnvSvc.cpp:38
Gaudi::RootCnvSvc::m_bufferSize
int m_bufferSize
Property: Buffer size optimization parameter for ROOT TTree.
Definition: RootCnvSvc.h:86
virtual StatusCode Gaudi::RootCnvSvc::createNullRef ( const std::string &  path)
virtual

Insert null marker for not existent transient object.

Parameters
path[IN] Path to the (null-)object
Returns
Status code indicating success or failure.
StatusCode RootCnvSvc::createNullRep ( const std::string &  path)
virtual

Insert null marker for not existent transient object.

Parameters
path[IN] Path to the (null-)object
Returns
Status code indicating success or failure.

Definition at line 400 of file RootCnvSvc.cpp.

400  {
401  size_t len = path.find('/',1);
402  string section = path.substr(1,len==string::npos ? string::npos : len-1);
403  m_current->saveObj(section,path,nullptr,nullptr,m_bufferSize,m_splitLevel);
404  return S_OK;
405 }
Gaudi::RootCnvSvc::m_current
Gaudi::RootDataConnection * m_current
On writing: reference to active output stream.
Definition: RootCnvSvc.h:60
EnvConfig.path
list path
Definition: __init__.py:15
Gaudi::RootCnvSvc::m_splitLevel
int m_splitLevel
Property: Split level optimization parameter for ROOT TTree.
Definition: RootCnvSvc.h:88
S_OK
#define S_OK
Definition: RootCnvSvc.cpp:38
Gaudi::RootDataConnection::saveObj
std::pair< int, unsigned long > saveObj(const std::string &section, const std::string &cnt, TClass *cl, DataObject *pObj, int buff_siz, int split_lvl, bool fill_missing=false)
Save object of a given class to section and container.
Gaudi::RootCnvSvc::m_bufferSize
int m_bufferSize
Property: Buffer size optimization parameter for ROOT TTree.
Definition: RootCnvSvc.h:86
virtual StatusCode Gaudi::RootCnvSvc::createNullRep ( const std::string &  path)
virtual

Insert null marker for not existent transient object.

Parameters
path[IN] Path to the (null-)object
Returns
Status code indicating success or failure.
virtual StatusCode Gaudi::RootCnvSvc::disconnect ( const std::string &  dbName)
virtual

Disconnect from an existing data stream.

Parameters
dbNameString containing name of the database
Returns
Status code indicating success or failure.
virtual StatusCode Gaudi::RootCnvSvc::disconnect ( const std::string &  dbName)
virtual

Disconnect from an existing data stream.

Parameters
dbNameString containing name of the database
Returns
Status code indicating success or failure.
StatusCode Gaudi::RootCnvSvc::error ( const std::string &  msg)

Standard way to print errors.

after the printout an exception is thrown.

Parameters
msg[IN] Message string to be printed.
Returns
Status code returning failure.
StatusCode Gaudi::RootCnvSvc::error ( const std::string &  msg)

Standard way to print errors.

after the printout an exception is thrown.

Parameters
msg[IN] Message string to be printed.
Returns
Status code returning failure.
StatusCode RootCnvSvc::finalize ( )
virtual

ConversionSvc overload: Finalize Db service.

Reimplemented from ConversionSvc.

Definition at line 125 of file RootCnvSvc.cpp.

125  {
126  log() << MSG::INFO;
127  if ( m_ioMgr ) {
128  IIODataManager::Connections cons = m_ioMgr->connections(nullptr);
129  for(auto &i : cons ) {
130  auto pc = dynamic_cast<RootDataConnection*>(i);
131  if ( pc ) {
132  if ( pc->owner() == this && !m_ioPerfStats.empty() ) {
133  pc->saveStatistics(m_ioPerfStats);
134  }
135  if ( pc->lookupClient(this) ) {
136  size_t num_clients = pc->removeClient(this);
137  if ( num_clients == 0 ) {
138  if ( m_ioMgr->disconnect(pc).isSuccess() ) {
139  log() << "Disconnected data IO:" << pc->fid()
140  << " [" << pc->pfn() << "]" << endmsg;
141  delete pc;
142  }
143  }
144  }
145  }
146  }
147  m_ioMgr.reset();
148  }
149  m_log.reset();
150  m_incidentSvc.reset();
151  m_setup->setIncidentSvc(nullptr);
152  return ConversionSvc::finalize();
153 }
Gaudi::RootCnvSvc::log
MsgStream & log() const
Helper: Use message streamer.
Definition: RootCnvSvc.h:99
endmsg
MsgStream & endmsg(MsgStream &s)
MsgStream Modifier: endmsg. Calls the output method of the MsgStream.
Definition: MsgStream.h:244
Gaudi::RootCnvSvc::m_log
std::unique_ptr< MsgStream > m_log
Message streamer.
Definition: RootCnvSvc.h:94
Gaudi::IIODataManager::Connections
std::vector< Connection * > Connections
Definition: IIODataManager.h:94
Gaudi::Units::pc
constexpr double pc
Definition: SystemOfUnits.h:101
Gaudi::RootCnvSvc::m_ioMgr
SmartIF< Gaudi::IIODataManager > m_ioMgr
Reference to the I/O data manager.
Definition: RootCnvSvc.h:56
ConversionSvc::finalize
virtual StatusCode finalize()
stop the service.
Definition: ConversionSvc.cpp:271
Gaudi::RootCnvSvc::m_setup
std::shared_ptr< RootConnectionSetup > m_setup
Setup structure (ref-counted) and passed to data connections.
Definition: RootCnvSvc.h:66
SmartIF::reset
void reset(TYPE *ptr=nullptr)
Set the internal pointer to the passed one disposing of the old one.
Definition: SmartIF.h:88
Gaudi::RootCnvSvc::m_incidentSvc
SmartIF< IIncidentSvc > m_incidentSvc
Reference to incident service.
Definition: RootCnvSvc.h:58
Gaudi::RootCnvSvc::m_ioPerfStats
std::string m_ioPerfStats
Property: Enable TTree IOperfStats if not empty; otherwise perf stat file name.
Definition: RootCnvSvc.h:77
ana.i
list i
Definition: ana.py:128
Gaudi::RootDataConnection
Concrete implementation of the IDataConnection interface to access ROOT files.
Definition: RootDataConnection.h:92
virtual StatusCode Gaudi::RootCnvSvc::finalize ( )
virtual

ConversionSvc overload: Finalize Db service.

Reimplemented from ConversionSvc.

TClass * RootCnvSvc::getClass ( DataObject *  pObject)
protected

Helper: Get TClass for a given DataObject pointer.

Definition at line 187 of file RootCnvSvc.cpp.

187  {
188  auto i=s_classesClids.find(pObject->clID());
189  if ( i != s_classesClids.end() ) return i->second;
190  loadConverter(pObject);
191  i=s_classesClids.find(pObject->clID());
192  if ( i != s_classesClids.end() ) return i->second;
193 
194  string cname = System::typeinfoName(typeid(*pObject));
195  throw runtime_error("Unknown ROOT class for object:"+cname);
196  return nullptr;
197 }
Gaudi::RootCnvSvc::loadConverter
virtual void loadConverter(DataObject *pObj)
ConversionSvc overload: Load the class (dictionary) for the converter.
Definition: RootCnvSvc.cpp:170
System::typeinfoName
GAUDI_API const std::string typeinfoName(const std::type_info &)
Get platform independent information about the class type.
Definition: System.cpp:297
DataObject::clID
virtual const CLID & clID() const
Retrieve reference to class definition structure.
Definition: DataObject.cpp:68
ana.i
list i
Definition: ana.py:128
TClass* Gaudi::RootCnvSvc::getClass ( DataObject *  pObject)
protected

Helper: Get TClass for a given DataObject pointer.

virtual StatusCode Gaudi::RootCnvSvc::i__createObj ( IOpaqueAddress *  pAddr,
DataObject *&  refpObj 
)
virtual

Create transient object from persistent data.

Parameters
pAddr[IN] Pointer to object address.
refpObj[OUT] Location to pointer to store data object
Returns
Status code indicating success or failure.
StatusCode RootCnvSvc::i__createObj ( IOpaqueAddress *  pAddr,
DataObject *&  refpObj 
)
virtual

Create transient object from persistent data.

Parameters
pAddr[IN] Pointer to object address.
refpObj[OUT] Location to pointer to store data object
Returns
Status code indicating success or failure.

Definition at line 483 of file RootCnvSvc.cpp.

483  {
484  refpObj = nullptr;
485  if ( !pA ) return S_FAIL;
486  RootDataConnection* con = nullptr;
487  const string* par = pA->par();
488  unsigned long* ipar = const_cast<unsigned long*>(pA->ipar());
489  StatusCode sc = connectDatabase(par[0],IDataConnection::READ,&con);
490  if ( sc.isSuccess() ) {
491  ipar[0] = (unsigned long)con;
492  DataObject* pObj = nullptr;
493  size_t len = par[1].find('/',1);
494  string section = par[1].substr(1,len==string::npos ? string::npos : len-1);
495 
496  int nb = con->loadObj(section,par[1],ipar[1],pObj);
497  if ( nb > 1 || (nb == 1 && pObj->clID() == CLID_DataObject) ) {
498  refpObj = pObj;
499  return S_OK;
500  }
501  delete pObj;
502  }
503  string tag = par[0]+":"+par[1];
504  if ( m_badFiles.find(tag) == m_badFiles.end() ) {
505  m_badFiles.insert(tag);
506  return error("createObj> Cannot access the object:"+tag);
507  }
508  return S_FAIL;
509 
510 }
StatusCode::isSuccess
bool isSuccess() const
Test for a status code of SUCCESS.
Definition: StatusCode.h:76
Gaudi::RootDataConnection::loadObj
int loadObj(const std::string &section, const std::string &cnt, unsigned long entry, DataObject *&pObj)
Load object.
Gaudi::RootCnvSvc::m_badFiles
std::set< std::string > m_badFiles
Set with bad files/tables.
Definition: RootCnvSvc.h:91
merge_files.sc
int sc
Definition: merge_files.py:167
DataObject::clID
virtual const CLID & clID() const
Retrieve reference to class definition structure.
Definition: DataObject.cpp:68
Gaudi::RootCnvSvc::error
StatusCode error(const std::string &msg)
Standard way to print errors.
StatusCode
This class is used for returning status codes from appropriate routines.
Definition: StatusCode.h:26
S_OK
#define S_OK
Definition: RootCnvSvc.cpp:38
Gaudi::RootCnvSvc::connectDatabase
StatusCode connectDatabase(const std::string &dataset, int mode, RootDataConnection **con)
Connect the output file to the service with open mode.
S_FAIL
#define S_FAIL
Definition: RootCnvSvc.cpp:39
DataObject
A DataObject is the base class of any identifiable object on any data store.
Definition: DataObject.h:30
Gaudi::RootDataConnection
Concrete implementation of the IDataConnection interface to access ROOT files.
Definition: RootDataConnection.h:92
virtual StatusCode Gaudi::RootCnvSvc::i__createRep ( DataObject *  pObj,
IOpaqueAddress *&  refpAddr 
)
virtual

Convert the transient object to the requested persistent representation.

Parameters
pObj[IN] Pointer to data object
refpAddr[OUT] Location to store pointer to object address.
Returns
Status code indicating success or failure.
StatusCode RootCnvSvc::i__createRep ( DataObject *  pObj,
IOpaqueAddress *&  refpAddr 
)
virtual

Convert the transient object to the requested persistent representation.

Parameters
pObj[IN] Pointer to data object
refpAddr[OUT] Location to store pointer to object address.
Returns
Status code indicating success or failure.

Definition at line 421 of file RootCnvSvc.cpp.

421  {
422  refpAddr = nullptr;
423  if ( !pObj ) return error("createRep> Current Database is invalid!");
424  CLID clid = pObj->clID();
425  IRegistry* pR = pObj->registry();
426  string p[2] = {m_current->fid(), pR->identifier()};
427  TClass* cl = (clid == CLID_DataObject) ? m_classDO : getClass(pObj);
428  size_t len = p[1].find('/',1);
429  string sect = p[1].substr(1,len==string::npos ? string::npos : len-1);
430  pair<int,unsigned long> ret =
431  m_current->saveObj(sect,p[1],cl,pObj,m_bufferSize,m_splitLevel,true);
432  if ( ret.first > 1 || (clid == CLID_DataObject && ret.first==1) ) {
433  unsigned long ip[2] = {0,ret.second};
434  if ( m_currSection.empty() ) m_currSection = p[1];
435  return createAddress(repSvcType(),clid,p,ip,refpAddr);
436  }
437  return error("Failed to write object data for:"+p[1]);
438 }
Gaudi::IDataConnection::fid
const std::string & fid() const
Access file id.
Definition: IIODataManager.h:52
Gaudi::RootCnvSvc::m_currSection
std::string m_currSection
Property: ROOT section name.
Definition: RootCnvSvc.h:68
Gaudi::RootCnvSvc::createAddress
virtual StatusCode createAddress(long svc_type, const CLID &clid, const std::string *par, const unsigned long *ip, IOpaqueAddress *&refpAddress)
IAddressCreator implementation: Address creation.
Definition: RootCnvSvc.cpp:389
Gaudi::RootCnvSvc::m_current
Gaudi::RootDataConnection * m_current
On writing: reference to active output stream.
Definition: RootCnvSvc.h:60
DataObject::registry
IRegistry * registry() const
Get pointer to Registry.
Definition: DataObject.h:74
Gaudi::RootCnvSvc::m_splitLevel
int m_splitLevel
Property: Split level optimization parameter for ROOT TTree.
Definition: RootCnvSvc.h:88
ConversionSvc::repSvcType
virtual long repSvcType() const
Retrieve the class type of the data store the converter uses.
Definition: ConversionSvc.cpp:334
DataObject::clID
virtual const CLID & clID() const
Retrieve reference to class definition structure.
Definition: DataObject.cpp:68
Gaudi::RootCnvSvc::error
StatusCode error(const std::string &msg)
Standard way to print errors.
Gaudi::RootCnvSvc::m_classDO
TClass * m_classDO
TClass pointer to DataObject class.
Definition: RootCnvSvc.h:64
IRegistry
The IRegistry represents the entry door to the environment any data object residing in a transient da...
Definition: IRegistry.h:22
Gaudi::RootDataConnection::saveObj
std::pair< int, unsigned long > saveObj(const std::string &section, const std::string &cnt, TClass *cl, DataObject *pObj, int buff_siz, int split_lvl, bool fill_missing=false)
Save object of a given class to section and container.
IRegistry::identifier
virtual const id_type & identifier() const =0
Full identifier (or key)
CLID
unsigned int CLID
Class ID definition.
Definition: ClassID.h:8
Gaudi::RootCnvSvc::m_bufferSize
int m_bufferSize
Property: Buffer size optimization parameter for ROOT TTree.
Definition: RootCnvSvc.h:86
Gaudi::RootCnvSvc::getClass
TClass * getClass(DataObject *pObject)
Helper: Get TClass for a given DataObject pointer.
Definition: RootCnvSvc.cpp:187
virtual StatusCode Gaudi::RootCnvSvc::i__fillObjRefs ( IOpaqueAddress *  pAddr,
DataObject *  pObj 
)
virtual

Resolve the references of the created transient object.

Parameters
pAddr[IN] Pointer to object address.
pObj[IN] Pointer to data object
Returns
Status code indicating success or failure.
StatusCode RootCnvSvc::i__fillObjRefs ( IOpaqueAddress *  pAddr,
DataObject *  pObj 
)
virtual

Resolve the references of the created transient object.

Parameters
pAddr[IN] Pointer to object address.
pObj[IN] Pointer to data object
Returns
Status code indicating success or failure.

Definition at line 513 of file RootCnvSvc.cpp.

513  {
514  if ( !pA || !pObj )
515  return error("read> Cannot read object -- no valid object address present ");
516 
517  const unsigned long* ipar = pA->ipar();
518  RootDataConnection* con = (RootDataConnection*)ipar[0];
519  if ( con ) {
520  RootObjectRefs refs;
521  const string* par = pA->par();
522  size_t len = par[1].find('/',1);
523  string section = par[1].substr(1,len==string::npos ? string::npos : len-1);
524  int nb = con->loadRefs(section,par[1],ipar[1],refs);
525  if ( nb >= 1 ) {
526  string npar[3];
527  unsigned long nipar[2];
528  IRegistry* pR = pObj->registry();
529  auto dataMgr = SmartIF<IDataManagerSvc>{ pR->dataSvc() };
530  LinkManager* mgr = pObj->linkMgr();
531  for(const auto& i : refs.links ) mgr->addLink(con->getLink(i),nullptr);
532  for(auto & r : refs.refs) {
533  npar[0] = con->getDb(r.dbase);
534  npar[1] = con->getCont(r.container);
535  npar[2] = con->getLink(r.link);
536  nipar[0] = 0;
537  nipar[1] = r.entry;
538  IOpaqueAddress* nPA = nullptr;
539  StatusCode sc = addressCreator()->createAddress(r.svc,r.clid,npar,nipar,nPA);
540  if ( sc.isSuccess() ) {
541  if( log().level() <= MSG::VERBOSE )
542  log() << MSG::VERBOSE << dataMgr.as<IService>()->name()
543  << " -> Register:" << pA->registry()->identifier()
544  << "#" << npar[2] << "[" << r.entry << "]" << endmsg;
545  sc = dataMgr->registerAddress(pA->registry(),npar[2],nPA);
546  if ( sc.isSuccess() ) continue;
547  }
548  log() << MSG::ERROR << con->fid() << ": Failed to create address!!!!" << endmsg;
549  return S_FAIL;
550  }
551  return pObj->update();
552  } else if ( nb < 0 ) {
553  string tag = par[0]+":"+par[1];
554  if ( m_badFiles.find(tag) == m_badFiles.end() ) {
555  m_badFiles.insert(tag);
556  return error("createObj> Cannot access the object:"+tag+" [Corrupted file]");
557  }
558  }
559  }
560  return S_FAIL;
561 }
DataObject::update
virtual StatusCode update()
Provide empty placeholder for internal object reconfiguration callback.
Definition: DataObject.cpp:83
Gaudi::RootCnvSvc::log
MsgStream & log() const
Helper: Use message streamer.
Definition: RootCnvSvc.h:99
endmsg
MsgStream & endmsg(MsgStream &s)
MsgStream Modifier: endmsg. Calls the output method of the MsgStream.
Definition: MsgStream.h:244
Gaudi::IDataConnection::fid
const std::string & fid() const
Access file id.
Definition: IIODataManager.h:52
MsgStream::level
MSG::Level level()
Retrieve output level.
Definition: MsgStream.h:112
Gaudi::RootDataConnection::getDb
const std::string & getDb(int which) const
Access database/file name from saved index.
Definition: RootDataConnection.cpp:447
IAddressCreator::createAddress
virtual StatusCode createAddress(long svc_type, const CLID &clid, const std::string *par, const unsigned long *ipar, IOpaqueAddress *&refpAddress)=0
Create a Generic address using explicit arguments to identify a single object.
StatusCode::isSuccess
bool isSuccess() const
Test for a status code of SUCCESS.
Definition: StatusCode.h:76
Gaudi::RootCnvSvc::m_badFiles
std::set< std::string > m_badFiles
Set with bad files/tables.
Definition: RootCnvSvc.h:91
Gaudi::RootDataConnection::getLink
const std::string & getLink(int which) const
Access link name from saved index.
Definition: RootDataConnection.h:328
merge_files.sc
int sc
Definition: merge_files.py:167
Gaudi::RootObjectRefs::links
std::vector< int > links
The links of the link manager.
Definition: RootRefs.h:60
DataObject::registry
IRegistry * registry() const
Get pointer to Registry.
Definition: DataObject.h:74
Gaudi::RootDataConnection::loadRefs
int loadRefs(const std::string &section, const std::string &cnt, unsigned long entry, RootObjectRefs &refs)
Load references object.
Definition: RootDataConnection.cpp:555
Gaudi::RootObjectRefs
Persistent reference object containing all leafs and links corresponding to a Gaudi DataObject...
Definition: RootRefs.h:58
DataObject::linkMgr
LinkManager * linkMgr() const
Retrieve Link manager.
Definition: DataObject.h:78
Gaudi::RootCnvSvc::error
StatusCode error(const std::string &msg)
Standard way to print errors.
IService
General service interface definition.
Definition: IService.h:18
StatusCode
This class is used for returning status codes from appropriate routines.
Definition: StatusCode.h:26
IRegistry
The IRegistry represents the entry door to the environment any data object residing in a transient da...
Definition: IRegistry.h:22
Gaudi::RootDataConnection::getCont
const std::string & getCont(int which) const
Access container name from saved index.
Definition: RootDataConnection.h:324
IRegistry::dataSvc
virtual IDataProviderSvc * dataSvc() const =0
Retrieve pointer to Transient Store.
ConversionSvc::addressCreator
virtual SmartIF< IAddressCreator > & addressCreator() const
Retrieve address creator facility.
Definition: ConversionSvc.cpp:197
IOpaqueAddress
Opaque address interface definition.
Definition: IOpaqueAddress.h:23
S_FAIL
#define S_FAIL
Definition: RootCnvSvc.cpp:39
ana.i
list i
Definition: ana.py:128
Gaudi::RootDataConnection
Concrete implementation of the IDataConnection interface to access ROOT files.
Definition: RootDataConnection.h:92
Gaudi::RootObjectRefs::refs
std::vector< RootRef > refs
The references corresponding to the next layer of items in the data store.
Definition: RootRefs.h:62
virtual StatusCode Gaudi::RootCnvSvc::i__fillRepRefs ( IOpaqueAddress *  pAddr,
DataObject *  pObj 
)
virtual

Resolve the references of the converted object.

Parameters
pAddr[IN] Pointer to object address.
pObj[IN] Pointer to data object
Returns
Status code indicating success or failure.
StatusCode RootCnvSvc::i__fillRepRefs ( IOpaqueAddress *  pAddr,
DataObject *  pObj 
)
virtual

Resolve the references of the converted object.

Parameters
pAddr[IN] Pointer to object address.
pObj[IN] Pointer to data object
Returns
Status code indicating success or failure.

Definition at line 441 of file RootCnvSvc.cpp.

441  {
442  if ( pObj ) {
443  typedef vector<IRegistry*> Leaves;
444  Leaves leaves;
445  RootObjectRefs refs;
446  IRegistry* pR = pObj->registry();
447  auto dataMgr = SmartIF<IDataManagerSvc>{ pR->dataSvc() };
448  if ( dataMgr ) {
449  StatusCode status = dataMgr->objectLeaves(pObj, leaves);
450  if ( status.isSuccess() ) {
451  RootRef ref;
452  const string& id = pR->identifier();
453  size_t len = id.find('/',1);
454  string sect = id.substr(1,len==string::npos ? string::npos : len-1);
455  LinkManager* pLinks = pObj->linkMgr();
456  for(auto &i : leaves ) {
457  if ( i->address() ) {
458  m_current->makeRef(i,ref);
459  ref.entry = i->address()->ipar()[1];
460  refs.refs.push_back(ref);
461  }
462  }
463  for(int i = 0, n=pLinks->size(); i < n; ++i) {
464  LinkManager::Link* lnk = pLinks->link(i);
465  int link_id = m_current->makeLink(lnk->path());
466  refs.links.push_back(link_id);
467  }
468  pair<int,unsigned long> ret =
469  m_current->save(sect,id+"#R",m_classRefs,&refs,m_bufferSize,m_splitLevel,true);
470  if ( ret.first > 1 ) {
471  if( log().level() <= MSG::DEBUG )
472  log() << MSG::DEBUG << "Writing object:" << id << " "
473  << ret.first << " " << hex << ret.second << dec << endmsg;
474  return S_OK;
475  }
476  }
477  }
478  }
479  return S_FAIL;
480 }
Gaudi::RootCnvSvc::log
MsgStream & log() const
Helper: Use message streamer.
Definition: RootCnvSvc.h:99
endmsg
MsgStream & endmsg(MsgStream &s)
MsgStream Modifier: endmsg. Calls the output method of the MsgStream.
Definition: MsgStream.h:244
Gaudi::RootDataConnection::save
std::pair< int, unsigned long > save(const std::string &section, const std::string &cnt, TClass *cl, void *pObj, int buff_siz, int split_lvl, bool fill_missing=false)
Save object of a given class to section and container.
Gaudi::RootCnvSvc::m_current
Gaudi::RootDataConnection * m_current
On writing: reference to active output stream.
Definition: RootCnvSvc.h:60
StatusCode::isSuccess
bool isSuccess() const
Test for a status code of SUCCESS.
Definition: StatusCode.h:76
Gaudi::RootObjectRefs::links
std::vector< int > links
The links of the link manager.
Definition: RootRefs.h:60
DataObject::registry
IRegistry * registry() const
Get pointer to Registry.
Definition: DataObject.h:74
Gaudi::RootObjectRefs
Persistent reference object containing all leafs and links corresponding to a Gaudi DataObject...
Definition: RootRefs.h:58
DataObject::linkMgr
LinkManager * linkMgr() const
Retrieve Link manager.
Definition: DataObject.h:78
Gaudi::RootRef
Persistent reference object.
Definition: RootRefs.h:30
Gaudi::RootCnvSvc::m_splitLevel
int m_splitLevel
Property: Split level optimization parameter for ROOT TTree.
Definition: RootCnvSvc.h:88
StatusCode
This class is used for returning status codes from appropriate routines.
Definition: StatusCode.h:26
S_OK
#define S_OK
Definition: RootCnvSvc.cpp:38
Gaudi::RootDataConnection::makeRef
void makeRef(IRegistry *pA, RootRef &ref)
Create reference object from registry entry.
Definition: RootDataConnection.cpp:603
IRegistry
The IRegistry represents the entry door to the environment any data object residing in a transient da...
Definition: IRegistry.h:22
Gaudi::RootCnvSvc::m_classRefs
TClass * m_classRefs
TClass pointer to reference class.
Definition: RootCnvSvc.h:62
IRegistry::dataSvc
virtual IDataProviderSvc * dataSvc() const =0
Retrieve pointer to Transient Store.
IRegistry::identifier
virtual const id_type & identifier() const =0
Full identifier (or key)
Gaudi::RootDataConnection::makeLink
int makeLink(const std::string &p)
Convert path string to path index.
S_FAIL
#define S_FAIL
Definition: RootCnvSvc.cpp:39
ana.i
list i
Definition: ana.py:128
Gaudi::RootObjectRefs::refs
std::vector< RootRef > refs
The references corresponding to the next layer of items in the data store.
Definition: RootRefs.h:62
Gaudi::RootCnvSvc::m_bufferSize
int m_bufferSize
Property: Buffer size optimization parameter for ROOT TTree.
Definition: RootCnvSvc.h:86
StatusCode RootCnvSvc::initialize ( )
virtual

ConversionSvc overload: initialize Db service.

Reimplemented from ConversionSvc.

Definition at line 91 of file RootCnvSvc.cpp.

91  {
92  string cname;
93  StatusCode status = ConversionSvc::initialize();
94  if ( !status.isSuccess() ) {
95  return error("Failed to initialize ConversionSvc base class.");
96  }
97  m_log.reset( new MsgStream(msgSvc(),name()) );
98  if ( !m_compression.empty() ) {
99  log() << MSG::INFO << "Setting global ROOT compression to:" << m_compression << endmsg;
100  if ( !(status=RootConnectionSetup::setCompression(m_compression)).isSuccess() ) {
101  return error("Unable to interprete ROOT compression encoding:"+m_compression);
102  }
103  }
104  m_ioMgr = service("IODataManager");
105  if( !m_ioMgr)
106  return error("Unable to localize interface from service:IODataManager");
107  m_incidentSvc = service("IncidentSvc");
108  if( !m_incidentSvc )
109  return error("Unable to localize interface from service:IncidentSvc");
110  m_setup->setMessageSvc(new MsgStream(msgSvc(),name()));
111  m_setup->setIncidentSvc(m_incidentSvc.get());
112  GaudiRoot::patchStreamers(log());
113  cname = System::typeinfoName(typeid(DataObject));
114  m_classDO = TClass::GetClass(cname.c_str());
115  if ( !m_classDO )
116  return error("Unable to load class description for DataObject");
117  cname = System::typeinfoName(typeid(RootObjectRefs));
118  m_classRefs = TClass::GetClass(cname.c_str());
119  if ( !m_classRefs )
120  return error("Unable to load class description for ObjectRefs");
121  return S_OK;
122 }
MsgStream
Definition of the MsgStream class used to transmit messages.
Definition: MsgStream.h:24
Gaudi::RootCnvSvc::log
MsgStream & log() const
Helper: Use message streamer.
Definition: RootCnvSvc.h:99
endmsg
MsgStream & endmsg(MsgStream &s)
MsgStream Modifier: endmsg. Calls the output method of the MsgStream.
Definition: MsgStream.h:244
Gaudi::RootCnvSvc::m_log
std::unique_ptr< MsgStream > m_log
Message streamer.
Definition: RootCnvSvc.h:94
StatusCode::isSuccess
bool isSuccess() const
Test for a status code of SUCCESS.
Definition: StatusCode.h:76
System::typeinfoName
GAUDI_API const std::string typeinfoName(const std::type_info &)
Get platform independent information about the class type.
Definition: System.cpp:297
GaudiRoot::patchStreamers
bool patchStreamers(MsgStream &log)
Definition: RootIOHandler.cpp:199
Gaudi::RootCnvSvc::m_ioMgr
SmartIF< Gaudi::IIODataManager > m_ioMgr
Reference to the I/O data manager.
Definition: RootCnvSvc.h:56
Gaudi::RootObjectRefs
Persistent reference object containing all leafs and links corresponding to a Gaudi DataObject...
Definition: RootRefs.h:58
SmartIF::get
TYPE * get() const
Get interface pointer.
Definition: SmartIF.h:76
Gaudi::RootCnvSvc::error
StatusCode error(const std::string &msg)
Standard way to print errors.
Gaudi::RootCnvSvc::m_classDO
TClass * m_classDO
TClass pointer to DataObject class.
Definition: RootCnvSvc.h:64
StatusCode
This class is used for returning status codes from appropriate routines.
Definition: StatusCode.h:26
S_OK
#define S_OK
Definition: RootCnvSvc.cpp:38
Gaudi::RootCnvSvc::m_setup
std::shared_ptr< RootConnectionSetup > m_setup
Setup structure (ref-counted) and passed to data connections.
Definition: RootCnvSvc.h:66
Gaudi::RootCnvSvc::m_classRefs
TClass * m_classRefs
TClass pointer to reference class.
Definition: RootCnvSvc.h:62
Gaudi::RootCnvSvc::m_compression
std::string m_compression
Property: Compression-algorithm:compression-level.
Definition: RootCnvSvc.h:79
Gaudi::RootConnectionSetup::setCompression
static long setCompression(const std::string &compression)
Set the global compression level.
Definition: RootDataConnection.cpp:92
ConversionSvc::initialize
virtual StatusCode initialize()
Initialize the service.
Definition: ConversionSvc.cpp:265
Gaudi::RootCnvSvc::m_incidentSvc
SmartIF< IIncidentSvc > m_incidentSvc
Reference to incident service.
Definition: RootCnvSvc.h:58
DataObject
A DataObject is the base class of any identifiable object on any data store.
Definition: DataObject.h:30
virtual StatusCode Gaudi::RootCnvSvc::initialize ( )
virtual

ConversionSvc overload: initialize Db service.

Reimplemented from ConversionSvc.

void RootCnvSvc::loadConverter ( DataObject *  pObj)
virtual

ConversionSvc overload: Load the class (dictionary) for the converter.

Reimplemented from ConversionSvc.

Definition at line 170 of file RootCnvSvc.cpp.

170  {
171  if (pObject) {
172  string cname = System::typeinfoName(typeid(*pObject));
173  if( log().level() <= MSG::DEBUG )
174  log() << MSG::DEBUG << "Trying to 'Autoload' dictionary for class " << cname << endmsg;
175  TClass* cl = s_classesNames[cname];
176  if ( nullptr == cl ) {
177  cl = TClass::GetClass(cname.c_str());
178  if ( cl ) {
179  s_classesNames[cname] = cl;
180  s_classesClids[pObject->clID()] = cl;
181  }
182  }
183  }
184 }
Gaudi::RootCnvSvc::log
MsgStream & log() const
Helper: Use message streamer.
Definition: RootCnvSvc.h:99
endmsg
MsgStream & endmsg(MsgStream &s)
MsgStream Modifier: endmsg. Calls the output method of the MsgStream.
Definition: MsgStream.h:244
System::typeinfoName
GAUDI_API const std::string typeinfoName(const std::type_info &)
Get platform independent information about the class type.
Definition: System.cpp:297
virtual void Gaudi::RootCnvSvc::loadConverter ( DataObject *  pObj)
virtual

ConversionSvc overload: Load the class (dictionary) for the converter.

Reimplemented from ConversionSvc.

MsgStream& Gaudi::RootCnvSvc::log ( ) const
inlineprotected

Helper: Use message streamer.

Definition at line 99 of file RootCnvSvc.h.

99 { return *m_log; }
Gaudi::RootCnvSvc::m_log
std::unique_ptr< MsgStream > m_log
Message streamer.
Definition: RootCnvSvc.h:94
MsgStream& Gaudi::RootCnvSvc::log ( ) const
inlineprotected

Helper: Use message streamer.

Definition at line 99 of file RootCnvSvc.h.

99 { return *m_log; }
Gaudi::RootCnvSvc::m_log
std::unique_ptr< MsgStream > m_log
Message streamer.
Definition: RootCnvSvc.h:94
virtual StatusCode Gaudi::RootCnvSvc::updateServiceState ( IOpaqueAddress *  )
inlinevirtual

Update state of the service.

Reimplemented from ConversionSvc.

Definition at line 110 of file RootCnvSvc.h.

111  { return StatusCode::SUCCESS; }
virtual StatusCode Gaudi::RootCnvSvc::updateServiceState ( IOpaqueAddress *  )
inlinevirtual

Update state of the service.

Reimplemented from ConversionSvc.

Definition at line 110 of file RootCnvSvc.h.

111  { return StatusCode::SUCCESS; }

Member Data Documentation

int Gaudi::RootCnvSvc::m_autoFlush
protected

Property: AutoFlush parameter for ROOT TTree (Number of events between auto flushes)

Definition at line 82 of file RootCnvSvc.h.

std::set< std::string > Gaudi::RootCnvSvc::m_badFiles
protected

Set with bad files/tables.

Definition at line 91 of file RootCnvSvc.h.

int Gaudi::RootCnvSvc::m_basketSize
protected

Property: Basket optimization parameter for ROOT TTree (total basket size)

Definition at line 84 of file RootCnvSvc.h.

int Gaudi::RootCnvSvc::m_bufferSize
protected

Property: Buffer size optimization parameter for ROOT TTree.

Definition at line 86 of file RootCnvSvc.h.

TClass * Gaudi::RootCnvSvc::m_classDO
protected

TClass pointer to DataObject class.

Definition at line 64 of file RootCnvSvc.h.

TClass * Gaudi::RootCnvSvc::m_classRefs
protected

TClass pointer to reference class.

Definition at line 62 of file RootCnvSvc.h.

std::string Gaudi::RootCnvSvc::m_compression
protected

Property: Compression-algorithm:compression-level.

Definition at line 79 of file RootCnvSvc.h.

Gaudi::RootDataConnection * Gaudi::RootCnvSvc::m_current = nullptr
protected

On writing: reference to active output stream.

Definition at line 60 of file RootCnvSvc.h.

std::string Gaudi::RootCnvSvc::m_currSection
protected

Property: ROOT section name.

Definition at line 68 of file RootCnvSvc.h.

bool Gaudi::RootCnvSvc::m_incidentEnabled
protected

Property: Flag to enable incidents on FILE_OPEN.

Definition at line 71 of file RootCnvSvc.h.

SmartIF< IIncidentSvc > Gaudi::RootCnvSvc::m_incidentSvc
protected

Reference to incident service.

Definition at line 58 of file RootCnvSvc.h.

SmartIF< Gaudi::IIODataManager > Gaudi::RootCnvSvc::m_ioMgr
protected

Reference to the I/O data manager.

Definition at line 56 of file RootCnvSvc.h.

std::string Gaudi::RootCnvSvc::m_ioPerfStats
protected

Property: Enable TTree IOperfStats if not empty; otherwise perf stat file name.

Definition at line 77 of file RootCnvSvc.h.

std::unique_ptr< MsgStream > Gaudi::RootCnvSvc::m_log
protected

Message streamer.

Definition at line 94 of file RootCnvSvc.h.

std::string Gaudi::RootCnvSvc::m_recordName
protected

Property: Records name to fire incident for file records.

Definition at line 75 of file RootCnvSvc.h.

std::shared_ptr< RootConnectionSetup > Gaudi::RootCnvSvc::m_setup
protected

Setup structure (ref-counted) and passed to data connections.

Definition at line 66 of file RootCnvSvc.h.

std::string Gaudi::RootCnvSvc::m_shareFiles
protected

Property: Share files ? If set to YES, files will not be closed on finalize.

Definition at line 73 of file RootCnvSvc.h.

int Gaudi::RootCnvSvc::m_splitLevel
protected

Property: Split level optimization parameter for ROOT TTree.

Definition at line 88 of file RootCnvSvc.h.

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