TsDataSvc Class Reference

Data service base class. More...

#include <GaudiKernel/TsDataSvc.h>

Inheritance diagram for TsDataSvc:

Collaboration diagram for TsDataSvc:

Public Types
typedef std::vector< DataStoreItem >	LoadItems
	Define set of load items. More...
typedef std::vector< DataStoreItem >	LoadItems
	Define set of load items. More...
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...

Public Member Functions
CLID	rootCLID () const override
	IDataManagerSvc: Accessor for root event CLID. More...
const std::string &	rootName () const override
	IDataManagerSvc: Accessor for root event name. More...
StatusCode	registerAddress (const std::string &fullPath, IOpaqueAddress *pAddress) override
	IDataManagerSvc: Register object address with the data store. More...
StatusCode	registerAddress (DataObject *parentObj, const std::string &objectPath, IOpaqueAddress *pAddress) override
	IDataManagerSvc: Register object address with the data store. More...
StatusCode	registerAddress (IRegistry *parentObj, const std::string &objectPath, IOpaqueAddress *pAddress) override
	IDataManagerSvc: Register object address with the data store. More...
StatusCode	unregisterAddress (const std::string &fullPath) override
	IDataManagerSvc: Unregister object address from the data store. More...
StatusCode	unregisterAddress (DataObject *pParent, const std::string &objPath) override
	IDataManagerSvc: Unregister object address from the data store. More...
StatusCode	unregisterAddress (IRegistry *pParent, const std::string &objPath) override
	IDataManagerSvc: Unregister object address from the data store. More...
StatusCode	objectLeaves (const DataObject *pObject, std::vector< IRegistry * > &refLeaves) override
	IDataManagerSvc: Explore the object store: retrieve all leaves attached to the object. More...
StatusCode	objectLeaves (const IRegistry *pRegistry, std::vector< IRegistry * > &refLeaves) override
	IDataManagerSvc: Explore the object store: retrieve all leaves attached to the object. More...
StatusCode	objectParent (const DataObject *pObject, IRegistry *&refpParent) override
	IDataManagerSvc: Explore the object store: retrieve the object's parent. More...
StatusCode	objectParent (const IRegistry *pRegistry, IRegistry *&refpParent) override
	IDataManagerSvc: Explore the object store: retrieve the object's parent. More...
StatusCode	clearSubTree (const std::string &sub_tree_path) override
	IDataManagerSvc: Remove all data objects below the sub tree identified by its full path name. More...
StatusCode	clearSubTree (DataObject *pObject) override
	IDataManagerSvc: Remove all data objects below the sub tree identified by the object. More...
StatusCode	clearStore () override
	IDataManagerSvc: Remove all data objects in the data store. More...
StatusCode	traverseSubTree (const std::string &sub_tree_path, IDataStoreAgent *pAgent) override
	IDataManagerSvc: Analyze by traversing all data objects below the sub tree identified by its full path name. More...
StatusCode	traverseSubTree (DataObject *pObject, IDataStoreAgent *pAgent) override
	IDataManagerSvc: Analyze by traversing all data objects below the sub tree. More...
StatusCode	traverseTree (IDataStoreAgent *pAgent) override
	IDataManagerSvc: Analyze by traversing all data objects in the data store. More...
StatusCode	setRoot (std::string root_name, DataObject *pRootObj) override
	Initialize data store for new event by giving new event path and root object. More...
virtual StatusCode	i_setRoot (std::string root_name, DataObject *pRootObj)
	Initialize data store for new event by giving new event path and root object. More...
StatusCode	setRoot (std::string root_path, IOpaqueAddress *pRootAddr) override
	Initialize data store for new event by giving new event path and address of root object. More...
virtual StatusCode	i_setRoot (std::string root_path, IOpaqueAddress *pRootAddr)
	Initialize data store for new event by giving new event path and address of root object. More...
StatusCode	setDataLoader (IConversionSvc *svc, IDataProviderSvc *dpsvc=0) override
	IDataManagerSvc: IDataManagerSvc: Pass a default data loader to the service and optionally a data provider. More...
StatusCode	addPreLoadItem (const DataStoreItem &item) override
	Add an item to the preload list. More...
StatusCode	addPreLoadItem (const std::string &itemPath) override
	Add an item to the preload list. More...
StatusCode	removePreLoadItem (const DataStoreItem &item) override
	Remove an item from the preload list. More...
StatusCode	removePreLoadItem (const std::string &itemPath) override
	Add an item to the preload list. More...
StatusCode	resetPreLoad () override
	Clear the preload list. More...
virtual StatusCode	preLoad (int depth, int load_depth, DataObject *pObject)
	Execute one level of preloading and recursively load until the final level is reached. More...
StatusCode	preLoad () override
	load all preload items of the list More...
StatusCode	registerObject (const std::string &fullPath, DataObject *pObject) override
	Register object with the data store. More...
StatusCode	registerObject (const std::string &parentPath, const std::string &objPath, DataObject *pObject) override
	Register object with the data store. More...
StatusCode	registerObject (const std::string &parentPath, int item, DataObject *pObject) override
	Register object with the data store. More...
StatusCode	registerObject (DataObject *parentObj, const std::string &objPath, DataObject *pObject) override
	Register object with the data store. More...
StatusCode	registerObject (DataObject *parentObj, int item, DataObject *pObject) override
	Register object with the data store. More...
StatusCode	unregisterObject (const std::string &fullPath) override
	Unregister object from the data store. More...
StatusCode	unregisterObject (const std::string &parentPath, const std::string &objectPath) override
	Unregister object from the data store. More...
StatusCode	unregisterObject (const std::string &parentPath, int item) override
	Unregister object from the data store. More...
StatusCode	unregisterObject (DataObject *pObject) override
	Unregister object from the data store. More...
StatusCode	unregisterObject (DataObject *pObject, const std::string &objectPath) override
	Unregister object from the data store. More...
StatusCode	unregisterObject (DataObject *pObject, int item) override
	Unregister object from the data store. More...
StatusCode	retrieveObject (IRegistry *pDirectory, const std::string &path, DataObject *&pObject) override
	Retrieve object from data store. More...
StatusCode	retrieveObject (const std::string &fullPath, DataObject *&pObject) override
	Retrieve object identified by its full path from the data store. More...
StatusCode	retrieveObject (const std::string &parentPath, const std::string &objPath, DataObject *&pObject) override
	Retrieve object from data store. More...
StatusCode	retrieveObject (const std::string &parentPath, int item, DataObject *&pObject) override
	Retrieve object from data store. More...
StatusCode	retrieveObject (DataObject *parentObj, const std::string &objPath, DataObject *&pObject) override
	Retrieve object from data store. More...
StatusCode	retrieveObject (DataObject *parentObj, int item, DataObject *&pObject) override
	Retrieve object from data store. More...
StatusCode	findObject (const std::string &fullPath, DataObject *&pObject) override
	Find object identified by its full path in the data store. More...
StatusCode	findObject (IRegistry *pDirectory, const std::string &path, DataObject *&pObject) override
	Find object identified by its full path in the data store. More...
StatusCode	findObject (const std::string &parentPath, const std::string &objPath, DataObject *&pObject) override
	Find object in the data store. More...
StatusCode	findObject (const std::string &parentPath, int item, DataObject *&pObject) override
	Find object in the data store. More...
StatusCode	findObject (DataObject *parentObj, const std::string &objPath, DataObject *&pObject) override
	Find object in the data store. More...
StatusCode	findObject (DataObject *parentObj, int item, DataObject *&pObject) override
	Find object in the data store. More...
StatusCode	linkObject (IRegistry *from, const std::string &objPath, DataObject *to) override
	Add a link to another object. More...
StatusCode	linkObject (const std::string &fromPath, const std::string &objPath, DataObject *to) override
	Add a link to another object. More...
StatusCode	linkObject (DataObject *from, const std::string &objPath, DataObject *to) override
	Add a link to another object. More...
StatusCode	linkObject (const std::string &fullPath, DataObject *to) override
	Add a link to another object. More...
StatusCode	unlinkObject (IRegistry *from, const std::string &objPath) override
	Remove a link to another object. More...
StatusCode	unlinkObject (const std::string &fromPath, const std::string &objPath) override
	Remove a link to another object. More...
StatusCode	unlinkObject (DataObject *fromObj, const std::string &objPath) override
	Remove a link to another object. More...
StatusCode	unlinkObject (const std::string &fullPath) override
	Remove a link to another object. More...
StatusCode	updateObject (IRegistry *pDirectory) override
	Update object identified by its directory entry. More...
StatusCode	updateObject (const std::string &updatePath) override
	Update object. More...
StatusCode	updateObject (DataObject *toUpdate) override
	Update object. More...
StatusCode	updateObject (const std::string &parentPath, const std::string &updatePath) override
	Update object. More...
StatusCode	updateObject (DataObject *pParent, const std::string &updatePath) override
	Update object. More...
StatusCode	initialize () override
	Service initialization. More...
StatusCode	reinitialize () override
	Service initialization. More...
StatusCode	finalize () override
	Service initialization. More...
	TsDataSvc (const std::string &name, ISvcLocator *svc)
	Standard Constructor. More...
virtual	~TsDataSvc ()
	Standard Destructor. More...
CLID	rootCLID () const override
	IDataManagerSvc: Accessor for root event CLID. More...
const std::string &	rootName () const override
	IDataManagerSvc: Accessor for root event name. More...
StatusCode	registerAddress (const std::string &fullPath, IOpaqueAddress *pAddress) override
	IDataManagerSvc: Register object address with the data store. More...
StatusCode	registerAddress (DataObject *parentObj, const std::string &objectPath, IOpaqueAddress *pAddress) override
	IDataManagerSvc: Register object address with the data store. More...
StatusCode	registerAddress (IRegistry *parentObj, const std::string &objectPath, IOpaqueAddress *pAddress) override
	IDataManagerSvc: Register object address with the data store. More...
StatusCode	unregisterAddress (const std::string &fullPath) override
	IDataManagerSvc: Unregister object address from the data store. More...
StatusCode	unregisterAddress (DataObject *pParent, const std::string &objPath) override
	IDataManagerSvc: Unregister object address from the data store. More...
StatusCode	unregisterAddress (IRegistry *pParent, const std::string &objPath) override
	IDataManagerSvc: Unregister object address from the data store. More...
StatusCode	objectLeaves (const DataObject *pObject, std::vector< IRegistry * > &refLeaves) override
	IDataManagerSvc: Explore the object store: retrieve all leaves attached to the object. More...
StatusCode	objectLeaves (const IRegistry *pRegistry, std::vector< IRegistry * > &refLeaves) override
	IDataManagerSvc: Explore the object store: retrieve all leaves attached to the object. More...
StatusCode	objectParent (const DataObject *pObject, IRegistry *&refpParent) override
	IDataManagerSvc: Explore the object store: retrieve the object's parent. More...
StatusCode	objectParent (const IRegistry *pRegistry, IRegistry *&refpParent) override
	IDataManagerSvc: Explore the object store: retrieve the object's parent. More...
StatusCode	clearSubTree (const std::string &sub_tree_path) override
	IDataManagerSvc: Remove all data objects below the sub tree identified by its full path name. More...
StatusCode	clearSubTree (DataObject *pObject) override
	IDataManagerSvc: Remove all data objects below the sub tree identified by the object. More...
StatusCode	clearStore () override
	IDataManagerSvc: Remove all data objects in the data store. More...
StatusCode	traverseSubTree (const std::string &sub_tree_path, IDataStoreAgent *pAgent) override
	IDataManagerSvc: Analyze by traversing all data objects below the sub tree identified by its full path name. More...
StatusCode	traverseSubTree (DataObject *pObject, IDataStoreAgent *pAgent) override
	IDataManagerSvc: Analyze by traversing all data objects below the sub tree. More...
StatusCode	traverseTree (IDataStoreAgent *pAgent) override
	IDataManagerSvc: Analyze by traversing all data objects in the data store. More...
StatusCode	setRoot (std::string root_name, DataObject *pRootObj) override
	Initialize data store for new event by giving new event path and root object. More...
virtual StatusCode	i_setRoot (std::string root_name, DataObject *pRootObj)
	Initialize data store for new event by giving new event path and root object. More...
StatusCode	setRoot (std::string root_path, IOpaqueAddress *pRootAddr) override
	Initialize data store for new event by giving new event path and address of root object. More...
virtual StatusCode	i_setRoot (std::string root_path, IOpaqueAddress *pRootAddr)
	Initialize data store for new event by giving new event path and address of root object. More...
StatusCode	setDataLoader (IConversionSvc *svc, IDataProviderSvc *dpsvc=0) override
	IDataManagerSvc: IDataManagerSvc: Pass a default data loader to the service and optionally a data provider. More...
StatusCode	addPreLoadItem (const DataStoreItem &item) override
	Add an item to the preload list. More...
StatusCode	addPreLoadItem (const std::string &itemPath) override
	Add an item to the preload list. More...
StatusCode	removePreLoadItem (const DataStoreItem &item) override
	Remove an item from the preload list. More...
StatusCode	removePreLoadItem (const std::string &itemPath) override
	Add an item to the preload list. More...
StatusCode	resetPreLoad () override
	Clear the preload list. More...
virtual StatusCode	preLoad (int depth, int load_depth, DataObject *pObject)
	Execute one level of preloading and recursively load until the final level is reached. More...
StatusCode	preLoad () override
	load all preload items of the list More...
StatusCode	registerObject (const std::string &fullPath, DataObject *pObject) override
	Register object with the data store. More...
StatusCode	registerObject (const std::string &parentPath, const std::string &objPath, DataObject *pObject) override
	Register object with the data store. More...
StatusCode	registerObject (const std::string &parentPath, int item, DataObject *pObject) override
	Register object with the data store. More...
StatusCode	registerObject (DataObject *parentObj, const std::string &objPath, DataObject *pObject) override
	Register object with the data store. More...
StatusCode	registerObject (DataObject *parentObj, int item, DataObject *pObject) override
	Register object with the data store. More...
StatusCode	unregisterObject (const std::string &fullPath) override
	Unregister object from the data store. More...
StatusCode	unregisterObject (const std::string &parentPath, const std::string &objectPath) override
	Unregister object from the data store. More...
StatusCode	unregisterObject (const std::string &parentPath, int item) override
	Unregister object from the data store. More...
StatusCode	unregisterObject (DataObject *pObject) override
	Unregister object from the data store. More...
StatusCode	unregisterObject (DataObject *pObject, const std::string &objectPath) override
	Unregister object from the data store. More...
StatusCode	unregisterObject (DataObject *pObject, int item) override
	Unregister object from the data store. More...
StatusCode	retrieveObject (IRegistry *pDirectory, const std::string &path, DataObject *&pObject) override
	Retrieve object from data store. More...
StatusCode	retrieveObject (const std::string &fullPath, DataObject *&pObject) override
	Retrieve object identified by its full path from the data store. More...
StatusCode	retrieveObject (const std::string &parentPath, const std::string &objPath, DataObject *&pObject) override
	Retrieve object from data store. More...
StatusCode	retrieveObject (const std::string &parentPath, int item, DataObject *&pObject) override
	Retrieve object from data store. More...
StatusCode	retrieveObject (DataObject *parentObj, const std::string &objPath, DataObject *&pObject) override
	Retrieve object from data store. More...
StatusCode	retrieveObject (DataObject *parentObj, int item, DataObject *&pObject) override
	Retrieve object from data store. More...
StatusCode	findObject (const std::string &fullPath, DataObject *&pObject) override
	Find object identified by its full path in the data store. More...
StatusCode	findObject (IRegistry *pDirectory, const std::string &path, DataObject *&pObject) override
	Find object identified by its full path in the data store. More...
StatusCode	findObject (const std::string &parentPath, const std::string &objPath, DataObject *&pObject) override
	Find object in the data store. More...
StatusCode	findObject (const std::string &parentPath, int item, DataObject *&pObject) override
	Find object in the data store. More...
StatusCode	findObject (DataObject *parentObj, const std::string &objPath, DataObject *&pObject) override
	Find object in the data store. More...
StatusCode	findObject (DataObject *parentObj, int item, DataObject *&pObject) override
	Find object in the data store. More...
StatusCode	linkObject (IRegistry *from, const std::string &objPath, DataObject *to) override
	Add a link to another object. More...
StatusCode	linkObject (const std::string &fromPath, const std::string &objPath, DataObject *to) override
	Add a link to another object. More...
StatusCode	linkObject (DataObject *from, const std::string &objPath, DataObject *to) override
	Add a link to another object. More...
StatusCode	linkObject (const std::string &fullPath, DataObject *to) override
	Add a link to another object. More...
StatusCode	unlinkObject (IRegistry *from, const std::string &objPath) override
	Remove a link to another object. More...
StatusCode	unlinkObject (const std::string &fromPath, const std::string &objPath) override
	Remove a link to another object. More...
StatusCode	unlinkObject (DataObject *fromObj, const std::string &objPath) override
	Remove a link to another object. More...
StatusCode	unlinkObject (const std::string &fullPath) override
	Remove a link to another object. More...
StatusCode	updateObject (IRegistry *pDirectory) override
	Update object identified by its directory entry. More...
StatusCode	updateObject (const std::string &updatePath) override
	Update object. More...
StatusCode	updateObject (DataObject *toUpdate) override
	Update object. More...
StatusCode	updateObject (const std::string &parentPath, const std::string &updatePath) override
	Update object. More...
StatusCode	updateObject (DataObject *pParent, const std::string &updatePath) override
	Update object. More...
StatusCode	initialize () override
	Service initialization. More...
StatusCode	reinitialize () override
	Service initialization. More...
StatusCode	finalize () override
	Service initialization. More...
	TsDataSvc (const std::string &name, ISvcLocator *svc)
	Standard Constructor. More...
virtual	~TsDataSvc ()
	Standard Destructor. 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
bool	checkRoot ()
	Check if root path is valid. More...
virtual IConversionSvc *	getDataLoader (IRegistry *pReg)
	Retrieve customizable data loader according to registry entry to be retrieved. More...
virtual DataObject *	createDefaultObject () const
	Create default objects in case forced creation of leaves is requested. More...
virtual StatusCode	loadObject (IRegistry *pNode)
	Invoke Persistency service to create transient object from its persistent representation. More...
virtual StatusCode	loadObject (IConversionSvc *pLoader, IRegistry *pNode)
	Invoke Persistency service to create transient object from its persistent representation. More...
StatusCode	retrieveEntry (DataSvcHelpers::RegistryEntry *pNode, const std::string &path, DataSvcHelpers::RegistryEntry *&pEntry)
	Retrieve registry entry from store. More...
DataObject *	handleDataFault (IRegistry *pReg, const std::string &path="")
	Invoke data fault handling if enabled. More...
bool	checkRoot ()
	Check if root path is valid. More...
virtual IConversionSvc *	getDataLoader (IRegistry *pReg)
	Retrieve customizable data loader according to registry entry to be retrieved. More...
virtual DataObject *	createDefaultObject () const
	Create default objects in case forced creation of leaves is requested. More...
virtual StatusCode	loadObject (IRegistry *pNode)
	Invoke Persistency service to create transient object from its persistent representation. More...
virtual StatusCode	loadObject (IConversionSvc *pLoader, IRegistry *pNode)
	Invoke Persistency service to create transient object from its persistent representation. More...
StatusCode	retrieveEntry (DataSvcHelpers::RegistryEntry *pNode, const std::string &path, DataSvcHelpers::RegistryEntry *&pEntry)
	Retrieve registry entry from store. More...
DataObject *	handleDataFault (IRegistry *pReg, const std::string &path="")
	Invoke data fault handling if enabled. More...

Protected Attributes
CLID	m_rootCLID
	Integer Property corresponding to CLID of root entry. More...
std::string	m_rootName
	Name of root event. More...
IConversionSvc *	m_dataLoader
	Pointer to data loader service. More...
IIncidentSvc *	m_incidentSvc
	Pointer to incident service. More...
LoadItems	m_preLoads
	Items to be pre-loaded. More...
bool	m_forceLeaves
	Allow forced creation of default leaves on registerObject. More...
bool	m_enableAccessHdlr
	Flag to enable interrupts on data access requests. More...
bool	m_enableFaultHdlr
	Flag to enable interrupts on data creation requests. More...
DataSvcHelpers::RegistryEntry *	m_root
	Pointer to root entry. More...
DataSvcHelpers::InhibitMap *	m_inhibitMap
	Map with object paths to be inhibited from loading. More...
std::vector< std::string >	m_inhibitPathes
	Property for the inhibited leaves. More...
std::string	m_accessName
	Name of the data access incident. More...
std::string	m_faultName
	Name of the data fault incident. More...
tsDataSvcMutex	m_accessMutex
	Mutex to protect access to the store. More...

Private Member Functions
	TsDataSvc (const TsDataSvc &)
	Fake copy constructor (never implemented). More...
TsDataSvc &	operator= (const TsDataSvc &)
	Fake assignment operator (never implemented). More...
	TsDataSvc (const TsDataSvc &)
	Fake copy constructor (never implemented). More...
TsDataSvc &	operator= (const TsDataSvc &)
	Fake assignment operator (never implemented). More...

Friends
class	SvcFactory< TsDataSvc >
	The class creator is of course a friend! More...

Detailed Description

Data service base class.

A data service manages the transient data stores and implements the IDataProviderSvc and IDataManagerSvc interfaces.

The accessor methods are protected with a lock. This is done having in mind the DetDataSvc and the retrieval of subdetectors in a multithreaded FW. This solution cannot solve the problem of having different conditions set available simultaneously but it is the simplest solution to allow multiple algorithms running concurrently to access detector components. In first approximation, since for the data we have the whiteboard, we protect only the retrieval of objects.

Author

Markus Frank

Sebastien Ponce

Danilo Piparo

Version

1.1

Definition at line 62 of file TsDataSvc.h.

Member Typedef Documentation

typedef std::vector<DataStoreItem> TsDataSvc::LoadItems

Define set of load items.

Definition at line 69 of file TsDataSvc.h.

typedef std::vector<DataStoreItem> TsDataSvc::LoadItems

Define set of load items.

Definition at line 69 of file TsDataSvc.h.

Constructor & Destructor Documentation

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

Standard Constructor.

Definition at line 1397 of file TsDataSvc.cpp.

: base_class(name,svc), m_rootCLID( /*CLID_Event*/ 110),
  m_rootName( "/Event"), m_root(0)
{
  m_dataLoader = 0;
  m_inhibitMap = 0;
  m_incidentSvc = 0;
  m_forceLeaves = false;
  m_enableFaultHdlr = false;
  m_enableAccessHdlr = false;
  m_faultName  = "DataFault";
  m_accessName = "DataAccess";
  declareProperty("RootCLID",            m_rootCLID);
  declareProperty("RootName",            m_rootName);
  declareProperty("ForceLeaves",         m_forceLeaves);
  declareProperty("InhibitPathes",       m_inhibitPathes);
  declareProperty("DataFaultName",       m_faultName);
  declareProperty("DataAccessName",      m_accessName);
  declareProperty("EnableFaultHandler",  m_enableFaultHdlr);
  declareProperty("EnableAccessHandler", m_enableAccessHdlr);
}

TsDataSvc::~TsDataSvc ( )

virtual

Standard Destructor.

Definition at line 1420 of file TsDataSvc.cpp.

                       {
  setDataLoader(0).ignore();
  resetPreLoad().ignore();
  clearStore().ignore();
}

TsDataSvc::TsDataSvc ( const TsDataSvc &  )

private

Fake copy constructor (never implemented).

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

Standard Constructor.

virtual TsDataSvc::~TsDataSvc ( )

virtual

Standard Destructor.

TsDataSvc::TsDataSvc ( const TsDataSvc &  )

private

Fake copy constructor (never implemented).

Member Function Documentation

StatusCode TsDataSvc::addPreLoadItem ( const DataStoreItem &  item )

override

Add an item to the preload list.

Definition at line 1255 of file TsDataSvc.cpp.

                                                                 {
  LoadItems::iterator i = std::find(m_preLoads.begin(), m_preLoads.end(), item);
  if ( i == m_preLoads.end() )    {
    m_preLoads.push_back(item);
  }
  return StatusCode::SUCCESS;
}

StatusCode TsDataSvc::addPreLoadItem ( const DataStoreItem &  item )

override

Add an item to the preload list.

StatusCode TsDataSvc::addPreLoadItem ( const std::string &  itemPath )

override

Add an item to the preload list.

Definition at line 1264 of file TsDataSvc.cpp.

                                                                 {
  return addPreLoadItem( DataStoreItem(itemPath,1) );
}

StatusCode TsDataSvc::addPreLoadItem ( const std::string &  itemPath )

override

Add an item to the preload list.

bool TsDataSvc::checkRoot ( )

inlineprotected

Check if root path is valid.

Definition at line 411 of file TsDataSvc.h.

                      {
    return 0 != m_root;
  }

bool TsDataSvc::checkRoot ( )

inlineprotected

Check if root path is valid.

Definition at line 411 of file TsDataSvc.h.

                      {
    return 0 != m_root;
  }

StatusCode TsDataSvc::clearStore ( )

override

IDataManagerSvc: Remove all data objects in the data store.

StatusCode TsDataSvc::clearStore ( )

override

IDataManagerSvc: Remove all data objects in the data store.

Definition at line 115 of file TsDataSvc.cpp.

                                   {
  if ( checkRoot() )    {
    m_root->release();
    m_root = 0;
    return SUCCESS;
  }
  return INVALID_ROOT;
}

StatusCode TsDataSvc::clearSubTree ( const std::string &  sub_tree_path )

override

IDataManagerSvc: Remove all data objects below the sub tree identified by its full path name.

StatusCode TsDataSvc::clearSubTree ( const std::string &  sub_tree_path )

override

IDataManagerSvc: Remove all data objects below the sub tree identified by its full path name.

Definition at line 77 of file TsDataSvc.cpp.

                                                                    {
  DataObject* pObject = 0;
  StatusCode status = findObject(sub_tree_path, pObject);
  if ( status.isSuccess() )   {
    RegEntry* node_entry = CAST_REGENTRY(RegEntry*,pObject->registry());
    if ( 0 != node_entry )   {
      RegEntry* parent = node_entry->parentEntry();
      if ( 0 != parent )  {
        parent->remove(node_entry);
        return StatusCode::SUCCESS;
      }
      return INVALID_PARENT;
    }
    return INVALID_OBJECT;
  }
  return status;
}

StatusCode TsDataSvc::clearSubTree ( DataObject *  pObject )

override

IDataManagerSvc: Remove all data objects below the sub tree identified by the object.

StatusCode TsDataSvc::clearSubTree ( DataObject *  pObject )

override

IDataManagerSvc: Remove all data objects below the sub tree identified by the object.

Definition at line 98 of file TsDataSvc.cpp.

                                                         {
  if ( checkRoot() )  {
    RegEntry* entry = CAST_REGENTRY(RegEntry*,pObject->registry());
    if ( 0 != entry )   {
      RegEntry* parent = entry->parentEntry();
      if ( 0 != parent )  {
        parent->remove(entry);
        return SUCCESS;
      }
      return INVALID_PARENT;
    }
    return INVALID_OBJECT;
  }
  return INVALID_ROOT;
}

DataObject * TsDataSvc::createDefaultObject ( ) const

protectedvirtual

Create default objects in case forced creation of leaves is requested.

Definition at line 1385 of file TsDataSvc.cpp.

                                                      {
  return new DataObject();
}

virtual DataObject* TsDataSvc::createDefaultObject ( ) const

protectedvirtual

Create default objects in case forced creation of leaves is requested.

StatusCode TsDataSvc::finalize ( )

override

Service initialization.

Service initialisation.

Definition at line 1362 of file TsDataSvc.cpp.

                                  {
  // Nothing to do: just call base class initialisation
  setDataLoader(0).ignore();
  resetPreLoad().ignore();
  clearStore().ignore();
  if ( m_incidentSvc )  {
    m_incidentSvc->release();
    m_incidentSvc = 0;
  }
  return Service::finalize();
}

StatusCode TsDataSvc::finalize ( )

override

Service initialization.

StatusCode TsDataSvc::findObject ( const std::string &  fullPath, DataObject *&  pObject  )

override

Find object identified by its full path in the data store.

Definition at line 956 of file TsDataSvc.cpp.

                                                       {
  STD_LOCK_GUARD_MACRO
  pObject = 0;
  if ( checkRoot() )  {
    if ( path.length() == 0 || path == m_rootName )   {
      pObject = m_root->object();
      return (0 == pObject) ? OBJ_NOT_LOADED : IDataProviderSvc_NO_ERROR;
    }
    else if ( path[0] != SEPARATOR )    {
      return findObject(m_rootName, path, pObject);
    }
    return findObject((IRegistry*)0, path, pObject);
  }
  return INVALID_ROOT;
}

StatusCode TsDataSvc::findObject ( const std::string &  fullPath, DataObject *&  pObject  )

override

Find object identified by its full path in the data store.

StatusCode TsDataSvc::findObject ( IRegistry *  pDirectory, const std::string &  path, DataObject *&  pObject  )

override

Find object identified by its full path in the data store.

Retrieve object identified by its directory from the data store.

Definition at line 936 of file TsDataSvc.cpp.

                                                       {
  STD_LOCK_GUARD_MACRO
  pObject = 0;
  IRegistry* pReg = (0==pRegistry) ? m_root : pRegistry;
  RegEntry* root_entry = CAST_REGENTRY(RegEntry*, pReg);
  if ( 0 != root_entry )    {
    if ( path.length() > 0 )  {
      pReg = root_entry->find(path);
    }
    if ( 0 == pReg )    {
      return INVALID_OBJ_PATH;
    }
    pObject = pReg->object();
  }
  return (0 == pObject) ? OBJ_NOT_LOADED : IDataProviderSvc_NO_ERROR;
}

StatusCode TsDataSvc::findObject ( IRegistry *  pDirectory, const std::string &  path, DataObject *&  pObject  )

override

Find object identified by its full path in the data store.

StatusCode TsDataSvc::findObject ( const std::string &  parentPath, const std::string &  objPath, DataObject *&  pObject  )

override

Find object in the data store.

Retrieve object identified by its full path from the data store.

Definition at line 974 of file TsDataSvc.cpp.

                                                       {
  DataObject* parent = 0;
  StatusCode status = findObject(parentPath, parent);
  if ( status.isSuccess() )   {
    status = findObject (parent, objectPath, pObject);
  }
  return status;
}

StatusCode TsDataSvc::findObject ( const std::string &  parentPath, const std::string &  objPath, DataObject *&  pObject  )

override

Find object in the data store.

StatusCode TsDataSvc::findObject ( const std::string &  parentPath, int  item, DataObject *&  pObject  )

override

Find object in the data store.

StatusCode TsDataSvc::findObject ( const std::string &  parentPath, int  item, DataObject *&  pObject  )

override

Find object in the data store.

Retrieve object identified by its full path from the data store.

Definition at line 986 of file TsDataSvc.cpp.

                                                                 {
  return findObject(parentPath, itemToPath(item), pObject);
}

StatusCode TsDataSvc::findObject ( DataObject *  parentObj, const std::string &  objPath, DataObject *&  pObject  )

override

Find object in the data store.

StatusCode TsDataSvc::findObject ( DataObject *  parentObj, const std::string &  objPath, DataObject *&  pObject  )

override

Find object in the data store.

Find object identified by its full path in the data store.

Definition at line 999 of file TsDataSvc.cpp.

                                                        {
  IRegistry* pDir = (0==parentObj) ? 0 : parentObj->registry();
  return findObject(pDir, path, pObject);
}

StatusCode TsDataSvc::findObject ( DataObject *  parentObj, int  item, DataObject *&  pObject  )

override

Find object in the data store.

StatusCode TsDataSvc::findObject ( DataObject *  parentObj, int  item, DataObject *&  pObject  )

override

Find object in the data store.

Find object identified by its full path in the data store.

Definition at line 992 of file TsDataSvc.cpp.

                                                        {
  return findObject(parentObj, itemToPath(item), pObject);
}

IConversionSvc * TsDataSvc::getDataLoader ( IRegistry *  pReg )

protectedvirtual

Retrieve customizable data loader according to registry entry to be retrieved.

Definition at line 1392 of file TsDataSvc.cpp.

                                                       {
  return m_dataLoader;
}

virtual IConversionSvc* TsDataSvc::getDataLoader ( IRegistry *  pReg )

protectedvirtual

Retrieve customizable data loader according to registry entry to be retrieved.

DataObject * TsDataSvc::handleDataFault ( IRegistry *  pReg, const std::string &  path = ""  )

protected

Invoke data fault handling if enabled.

Parameters

pReg	[IN] Pointer to missing registry entry
path	[IN] Sub-path of requested object from pReg

Returns

Object corresponding to the specified leaf

Definition at line 656 of file TsDataSvc.cpp.

{
  if ( m_enableFaultHdlr )  {
    IRegistry* pLeaf = 0;
    if ( pReg && path.length() == 0 )   {
      DataIncident incident(name(), m_faultName, pReg->identifier());
      m_incidentSvc->fireIncident(incident);
      return pReg->object();
    }
    else if ( pReg )  {
      std::string p = pReg->identifier();
      if (path[0] != SEPARATOR ) p += SEPARATOR;
      p += path;
      DataIncident incident(name(), m_faultName, p);
      m_incidentSvc->fireIncident(incident);
      pLeaf = m_root->findLeaf(p);
    }
    else  {
      std::string p = m_root->identifier();
      if (path[0] != SEPARATOR ) p += SEPARATOR;
      p += path;
      DataIncident incident(name(), m_faultName, p);
      m_incidentSvc->fireIncident(incident);
      pLeaf = m_root->findLeaf(p);
    }
    if ( pLeaf )  {
      return pLeaf->object();
    }
  }
  return 0;
}

DataObject* TsDataSvc::handleDataFault ( IRegistry *  pReg, const std::string &  path = ""  )

protected

Invoke data fault handling if enabled.

Parameters

pReg	[IN] Pointer to missing registry entry
path	[IN] Sub-path of requested object from pReg

Returns

Object corresponding to the specified leaf

StatusCode TsDataSvc::i_setRoot ( std::string  root_path, DataObject *  pRootObj  )

virtual

Initialize data store for new event by giving new event path and root object.

Does not clear the store before reinitializing it. This could lead to errors and should be handle with care. Use setRoot if unsure

Definition at line 176 of file TsDataSvc.cpp.

                                                       {
  if ( 0 != pRootObj )  {
    m_root = new RegEntry(root_path);
    m_root->makeHard(pRootObj);
    m_root->setDataSvc(this);
    // No done with GaudiHive. preLoad().ignore();
  }
  return SUCCESS;
}

virtual StatusCode TsDataSvc::i_setRoot ( std::string  root_name, DataObject *  pRootObj  )

virtual

Initialize data store for new event by giving new event path and root object.

Does not clear the store before reinitializing it. This could lead to errors and should be handle with care. Use setRoot if unsure

StatusCode TsDataSvc::i_setRoot ( std::string  root_path, IOpaqueAddress *  pRootAddr  )

virtual

Initialize data store for new event by giving new event path and address of root object.

Does not clear the store before reinitializing it. This could lead to errors and should be handle with care. Use setRoot if unsure

Definition at line 202 of file TsDataSvc.cpp.

                                                            {
  if ( 0 != pRootAddr )  {
    m_root = new RegEntry(std::move(root_path));
    m_root->makeHard(pRootAddr);
    m_root->setDataSvc(this);
    // Not done with GaudiHive. preLoad().ignore();
  }
  return SUCCESS;
}

virtual StatusCode TsDataSvc::i_setRoot ( std::string  root_path, IOpaqueAddress *  pRootAddr  )

virtual

Initialize data store for new event by giving new event path and address of root object.

Does not clear the store before reinitializing it. This could lead to errors and should be handle with care. Use setRoot if unsure

StatusCode TsDataSvc::initialize ( )

override

Service initialization.

Definition at line 1321 of file TsDataSvc.cpp.

                                    {
  // Nothing to do: just call base class initialisation
  StatusCode sc = Service::initialize();
  if ( !sc.isSuccess() )  {
    return sc;
  }
  sc = service("IncidentSvc", m_incidentSvc, true);
  if ( UNLIKELY(!sc.isSuccess()) )  {
    error() << "Failed to access incident service." << endmsg;
  }
  return sc;
}

StatusCode TsDataSvc::initialize ( )

override

Service initialization.

StatusCode TsDataSvc::linkObject ( IRegistry *  from, const std::string &  objPath, DataObject *  to  )

override

Add a link to another object.

StatusCode TsDataSvc::linkObject ( IRegistry *  from, const std::string &  objPath, DataObject *  to  )

override

Add a link to another object.

Definition at line 1105 of file TsDataSvc.cpp.

                                                                         {
  STD_LOCK_GUARD_MACRO
  if ( checkRoot() )  {
    try   {
      RegEntry* from_entry = CAST_REGENTRY(RegEntry*,from);
      if ( 0 != from_entry )    {
        // First check if both objects are already registered to the store
        RegEntry* to_entry   = m_root->findLeaf(to);
        if ( 0 == to_entry )   {
          return INVALID_OBJECT;
        }
        else  {
          std::string::size_type sep = objPath.rfind(SEPARATOR);
          if ( sep > 0 && sep != std::string::npos )    {   // in case the objPath is a sub-directory itself
            DataObject* pO = 0;
            std::string fromPath(objPath, 0, sep);
            StatusCode sc = retrieveObject(from, fromPath, pO);
            if ( sc.isSuccess() )    {
              std::string toPath(objPath, sep, objPath.length());
              sc = linkObject(pO->registry(), toPath, to);
            }
            return sc;
          }
          // Now register the soft link
          StatusCode status = from_entry->add( objPath, to, true);
          return status.isSuccess() ?
            IDataProviderSvc_NO_ERROR : DOUBL_OBJ_PATH;
        }
      }
    }
    catch (...) {
    }
    return INVALID_PARENT;
  }
  return INVALID_ROOT;
}

StatusCode TsDataSvc::linkObject ( const std::string &  fromPath, const std::string &  objPath, DataObject *  to  )

override

Add a link to another object.

StatusCode TsDataSvc::linkObject ( const std::string &  fromPath, const std::string &  objPath, DataObject *  to  )

override

Add a link to another object.

Definition at line 1160 of file TsDataSvc.cpp.

                                                  {
  STD_LOCK_GUARD_MACRO
  DataObject* pO = 0;
  StatusCode status = retrieveObject(from, pO);
  if ( status.isSuccess() )   {
    return linkObject(pO->registry(), objPath, to);
  }
  return status;
}

StatusCode TsDataSvc::linkObject ( DataObject *  from, const std::string &  objPath, DataObject *  to  )

override

Add a link to another object.

StatusCode TsDataSvc::linkObject ( DataObject *  from, const std::string &  objPath, DataObject *  to  )

override

Add a link to another object.

Definition at line 1173 of file TsDataSvc.cpp.

                                                  {
  STD_LOCK_GUARD_MACRO
  if ( 0 != from )    {
    IRegistry* from_entry = from->registry();
    if ( 0 != from_entry )   {
      return linkObject( from_entry, objPath, to);
    }
  }
  return INVALID_PARENT;
}

StatusCode TsDataSvc::linkObject ( const std::string &  fullPath, DataObject *  to  )

override

Add a link to another object.

StatusCode TsDataSvc::linkObject ( const std::string &  fullPath, DataObject *  to  )

override

Add a link to another object.

Definition at line 1144 of file TsDataSvc.cpp.

                                                  {
  STD_LOCK_GUARD_MACRO
  if ( fullPath.length() > 0 )    {
    if ( fullPath[0] != SEPARATOR )   {
      return linkObject(m_rootName, fullPath, to);
    }
    std::string::size_type sep = fullPath.rfind(SEPARATOR);
    std::string objPath(fullPath, sep, fullPath.length());
    std::string fromPath(fullPath, 0, sep);
    return linkObject( fromPath, objPath, to);
  }
  return INVALID_OBJ_PATH;
}

virtual StatusCode TsDataSvc::loadObject ( IRegistry *  pNode )

protectedvirtual

Invoke Persistency service to create transient object from its persistent representation.

StatusCode TsDataSvc::loadObject ( IRegistry *  pNode )

protectedvirtual

Invoke Persistency service to create transient object from its persistent representation.

Definition at line 691 of file TsDataSvc.cpp.

                                                       {
  IConversionSvc* pLoader = getDataLoader(pRegistry);
  return loadObject(pLoader, pRegistry);
}

virtual StatusCode TsDataSvc::loadObject ( IConversionSvc *  pLoader, IRegistry *  pNode  )

protectedvirtual

Invoke Persistency service to create transient object from its persistent representation.

StatusCode TsDataSvc::loadObject ( IConversionSvc *  pLoader, IRegistry *  pNode  )

protectedvirtual

Invoke Persistency service to create transient object from its persistent representation.

Definition at line 699 of file TsDataSvc.cpp.

                                                                              {
  STD_LOCK_GUARD_MACRO
  StatusCode status = INVALID_OBJ_ADDR;
  DataObject* pObject = 0;
  if ( 0 == pLoader )   {         // Precondition: Data loader must be present
    if (handleDataFault(pRegistry) != 0) return  SUCCESS;
    else                                 return  NO_DATA_LOADER;
  }
  if ( 0 == pRegistry )    {      // Precondition: Directory must be valid
    if (handleDataFault(pRegistry) != 0) return  SUCCESS;
    else                                 return  INVALID_OBJ_ADDR;
  }

  VERMSG << "Requested object " << pRegistry->identifier() << endmsg;

  if ( m_enableAccessHdlr )  {
    // Fire data access incident
    DataIncident incident(name(), m_accessName, pRegistry->identifier());
    m_incidentSvc->fireIncident(incident);
  }
  if ( m_inhibitPathes.size() > 0 )   {
    const std::string& ident = pRegistry->identifier();
    std::vector<std::string>::iterator inhibit =
      std::find(m_inhibitPathes.begin(), m_inhibitPathes.end(), ident);
    if ( inhibit != m_inhibitPathes.end() )   {
      return NO_ACCESS;
    }
  }
  IOpaqueAddress* pAddress = pRegistry->address();
  if ( 0 == pAddress )  {         // Precondition:
    return INVALID_OBJ_ADDR;      // Address must be valid
  }
  try   {
    status = pLoader->createObj(pAddress, pObject);  // Call data loader
    if ( status.isSuccess() )    {

      VERMSG << "Object " << pRegistry->identifier() << " created" << endmsg;

      RegEntry *pEntry = CAST_REGENTRY(RegEntry*,pRegistry);
      pEntry->setObject(pObject);

      VERMSG << "Filling object " << pRegistry->identifier() << endmsg;
      status = pLoader->fillObjRefs(pAddress, pObject);
    }
  }
  catch( const GaudiException& exc ) {
    if ( handleDataFault(pRegistry) != 0 )  {
      return SUCCESS;
    }
    throw GaudiException("GaudiException in loadObject() " + pRegistry->identifier(),
        name(), StatusCode::FAILURE, exc);
  }
  catch( const std::exception& x) {
    if ( handleDataFault(pRegistry) != 0 )  {
      return SUCCESS;
    }
    throw GaudiException("std::exception in loadObject() " + pRegistry->identifier() +
        ": " + System::typeinfoName(typeid(x)) + ", " + x.what(),
      name(), StatusCode::FAILURE);
  }
  catch(...) {
    if ( handleDataFault(pRegistry) != 0 )  {
      return SUCCESS;
    }
    throw GaudiException("UNKN exception in loadObject() " + pRegistry->identifier(),
      name(), StatusCode::FAILURE);
  }
  if ( !status.isSuccess() )  {
    if ( handleDataFault(pRegistry) != 0 )  {
      return StatusCode::SUCCESS;
    }
  }
  ON_VERBOSE if ( status.isSuccess() ) {
    verbose() << "Object " << pRegistry->identifier() << " successfully loaded" << endmsg;
  }
  return status;
}

StatusCode TsDataSvc::objectLeaves ( const DataObject *  pObject, std::vector< IRegistry * > &  refLeaves  )

override

IDataManagerSvc: Explore the object store: retrieve all leaves attached to the object.

StatusCode TsDataSvc::objectLeaves ( const DataObject *  pObject, std::vector< IRegistry * > &  refLeaves  )

override

IDataManagerSvc: Explore the object store: retrieve all leaves attached to the object.

IDataManagerSvc: Explore an object identified by its pointer.

Definition at line 249 of file TsDataSvc.cpp.

                                                   {
  STD_LOCK_GUARD_MACRO
  if ( pObject )    {
    return objectLeaves(pObject->registry(), leaves);
  }
  return INVALID_OBJECT;
}

StatusCode TsDataSvc::objectLeaves ( const IRegistry *  pRegistry, std::vector< IRegistry * > &  refLeaves  )

override

IDataManagerSvc: Explore the object store: retrieve all leaves attached to the object.

StatusCode TsDataSvc::objectLeaves ( const IRegistry *  pRegistry, std::vector< IRegistry * > &  refLeaves  )

override

IDataManagerSvc: Explore the object store: retrieve all leaves attached to the object.

IDataManagerSvc: Explore an object identified by the pointer to the registry entry.

Definition at line 261 of file TsDataSvc.cpp.

                                                   {
  STD_LOCK_GUARD_MACRO
  if ( checkRoot() )    {
    const RegEntry* node_entry = CAST_REGENTRY(const RegEntry*,pRegistry);
    if ( node_entry )   {
      std::copy(node_entry->leaves().begin(),node_entry->leaves().end(),back_inserter(leaves));
      //leaves = node_entry->leaves();
      return StatusCode::SUCCESS;
    }
    return INVALID_OBJECT;
  }
  return INVALID_ROOT;
}

StatusCode TsDataSvc::objectParent ( const DataObject *  pObject, IRegistry *&  refpParent  )

override

IDataManagerSvc: Explore the object store: retrieve the object's parent.

Definition at line 225 of file TsDataSvc.cpp.

                                                           {
  STD_LOCK_GUARD_MACRO
  if ( pObject )    {
    return objectParent(pObject->registry(), refpParent);
  }
  return INVALID_OBJECT;
}

StatusCode TsDataSvc::objectParent ( const DataObject *  pObject, IRegistry *&  refpParent  )

override

IDataManagerSvc: Explore the object store: retrieve the object's parent.

StatusCode TsDataSvc::objectParent ( const IRegistry *  pRegistry, IRegistry *&  refpParent  )

override

IDataManagerSvc: Explore the object store: retrieve the object's parent.

StatusCode TsDataSvc::objectParent ( const IRegistry *  pRegistry, IRegistry *&  refpParent  )

override

IDataManagerSvc: Explore the object store: retrieve the object's parent.

Definition at line 234 of file TsDataSvc.cpp.

                                                          {
  STD_LOCK_GUARD_MACRO
  if ( checkRoot() )    {
    const RegEntry* node_entry = CAST_REGENTRY(const RegEntry*,pRegistry);
    if ( node_entry )   {
      refpParent = node_entry->parent();
      return StatusCode::SUCCESS;
    }
    return INVALID_OBJECT;
  }
  return INVALID_ROOT;
}

TsDataSvc& TsDataSvc::operator= ( const TsDataSvc &  )

private

Fake assignment operator (never implemented).

TsDataSvc& TsDataSvc::operator= ( const TsDataSvc &  )

private

Fake assignment operator (never implemented).

virtual StatusCode TsDataSvc::preLoad ( int  depth, int  load_depth, DataObject *  pObject  )

virtual

Execute one level of preloading and recursively load until the final level is reached.

Parameters

depth	current level of loading from requested parent
load_depth	maximum level of object loading
pObject	pointer to next level root object

Returns

Status code indicating success or failure.

StatusCode TsDataSvc::preLoad ( int  depth, int  load_depth, DataObject *  pObject  )

virtual

Execute one level of preloading and recursively load until the final level is reached.

Preload one level deep, then recursively call the next level.

Parameters

depth	current level of loading from requested parent
load_depth	maximum level of object loading
pObject	pointer to next level root object

Returns

Status code indicating success or failure.

Definition at line 1290 of file TsDataSvc.cpp.

                                                                               {
  //unused:  StatusCode sc = StatusCode::FAILURE;
  if ( 0 != pObject && depth++ < load_depth )    {
    RegEntry* dir = CAST_REGENTRY(RegEntry*,pObject->registry());
    if ( 0 != dir )   {
      for (RegEntry::Iterator i = dir->begin(); i != dir->end(); i++ )    {
        DataObject *pObj = 0;
        StatusCode status = retrieveObject(pObject, (*i)->name(), pObj);
        if ( status.isSuccess() && depth < load_depth )   {
          preLoad(depth, load_depth, pObj).ignore();
        }
      }
    }
  }
  return StatusCode::SUCCESS;
}

StatusCode TsDataSvc::preLoad ( )

override

load all preload items of the list

StatusCode TsDataSvc::preLoad ( )

override

load all preload items of the list

Definition at line 1308 of file TsDataSvc.cpp.

                                {
  DataObject* pObj = 0;
  for (LoadItems::iterator i = m_preLoads.begin(); i != m_preLoads.end(); i++) {
    StatusCode sc = retrieveObject( (*i).path(), pObj);
    int load_depth = (*i).depth();
    if ( sc.isSuccess() && load_depth > 1 )   {
      preLoad(1, load_depth, pObj).ignore();
    }
  }
  return StatusCode::SUCCESS;
}

StatusCode TsDataSvc::registerAddress ( const std::string &  fullPath, IOpaqueAddress *  pAddress  )

override

IDataManagerSvc: Register object address with the data store.

StatusCode TsDataSvc::registerAddress ( const std::string &  fullPath, IOpaqueAddress *  pAddress  )

override

IDataManagerSvc: Register object address with the data store.

Definition at line 277 of file TsDataSvc.cpp.

                                                                {
  if ( fullPath.length() > 0 )    {
    if ( fullPath[0] != SEPARATOR )   {
      return registerAddress(m_root, fullPath, pAddress);
    }
    IRegistry* pRegistry = 0;
    return registerAddress(pRegistry, fullPath, pAddress);
  }
  return INVALID_OBJ_PATH;
}

StatusCode TsDataSvc::registerAddress ( DataObject *  parentObj, const std::string &  objectPath, IOpaqueAddress *  pAddress  )

override

IDataManagerSvc: Register object address with the data store.

Definition at line 290 of file TsDataSvc.cpp.

                                                                {
  IRegistry* pRegistry = (0 == parentObj) ? 0 : parentObj->registry();
  return registerAddress(pRegistry, objectPath, pAddress);
}

StatusCode TsDataSvc::registerAddress ( DataObject *  parentObj, const std::string &  objectPath, IOpaqueAddress *  pAddress  )

override

IDataManagerSvc: Register object address with the data store.

StatusCode TsDataSvc::registerAddress ( IRegistry *  parentObj, const std::string &  objectPath, IOpaqueAddress *  pAddress  )

override

IDataManagerSvc: Register object address with the data store.

Definition at line 298 of file TsDataSvc.cpp.

                                                                {
  if ( checkRoot() )  {
    if ( objPath.length() > 0 )   {
      if ( 0 == parentObj )   {
        if ( objPath[0] != SEPARATOR )    {
          return registerAddress(m_root, objPath, pAddress);
        }
        std::string::size_type sep = objPath.find(SEPARATOR,1);
        if ( sep != std::string::npos )    {
          std::string p_path (objPath, 0, sep);
          if ( p_path == m_rootName )   {
            std::string o_path (objPath, sep, objPath.length());
            return registerAddress(m_root, o_path, pAddress);
          }
        }
        return INVALID_PARENT;
      }
      if ( objPath[0] != SEPARATOR )    {
        std::string path;
        path  = SEPARATOR;
        path += objPath;
        return registerAddress(parentObj, path, pAddress);
      }
      RegEntry* par_entry = CAST_REGENTRY(RegEntry*,parentObj);
      if ( 0 != par_entry )   {
        std::string::size_type sep = objPath.rfind(SEPARATOR);
        if ( sep > 0 && sep != std::string::npos )    {
          std::string p_path (objPath, 0, sep);
          std::string o_path (objPath, sep, objPath.length());
          RegEntry* p_entry = par_entry->findLeaf(p_path);
          // Create default object leafs if the
          // intermediate nodes are not present
          if ( 0 == p_entry && m_forceLeaves )    {
            DataObject *pLeaf = createDefaultObject();
            StatusCode sc = registerObject(par_entry->identifier(),
                                           p_path,
                                           pLeaf);
            if ( ! sc.isSuccess() )   {
              delete pLeaf;
            }
            p_entry = par_entry->findLeaf(p_path);
          }
          if ( 0 != p_entry )  {
            return registerAddress(p_entry, o_path, pAddress);
          }
          return INVALID_PARENT;
        }
        StatusCode status = par_entry->add(objPath, pAddress);
        if ( status.isSuccess() )   {
          return status;
        }
        return DOUBL_OBJ_PATH;
      }
      return INVALID_PARENT;
    }
    return INVALID_OBJ_PATH;
  }
  return INVALID_ROOT;
}

StatusCode TsDataSvc::registerAddress ( IRegistry *  parentObj, const std::string &  objectPath, IOpaqueAddress *  pAddress  )

override

IDataManagerSvc: Register object address with the data store.

StatusCode TsDataSvc::registerObject ( const std::string &  fullPath, DataObject *  pObject  )

override

Register object with the data store.

StatusCode TsDataSvc::registerObject ( const std::string &  fullPath, DataObject *  pObject  )

override

Register object with the data store.

Definition at line 427 of file TsDataSvc.cpp.

                                                           {
  return registerObject(0, fullPath, pObject);
}

StatusCode TsDataSvc::registerObject ( const std::string &  parentPath, const std::string &  objPath, DataObject *  pObject  )

override

Register object with the data store.

Definition at line 434 of file TsDataSvc.cpp.

                                                           {
  DataObject* pO = 0;
  StatusCode status = retrieveObject(parentPath, pO);
  if ( !status.isSuccess() && m_forceLeaves )   {
    pO = createDefaultObject();
    status = registerObject(parentPath, pO);
    if ( !status.isSuccess() )   {
      pO->release();
    }
  }
  if ( status.isSuccess() )   {
    status = registerObject(pO, objPath, pObject);
  }
  return status;
}

StatusCode TsDataSvc::registerObject ( const std::string &  parentPath, const std::string &  objPath, DataObject *  pObject  )

override

Register object with the data store.

StatusCode TsDataSvc::registerObject ( const std::string &  parentPath, int  item, DataObject *  pObject  )

override

Register object with the data store.

Definition at line 453 of file TsDataSvc.cpp.

                                                          {
  return registerObject(parentPath, itemToPath(item), pObject);
}

StatusCode TsDataSvc::registerObject ( const std::string &  parentPath, int  item, DataObject *  pObject  )

override

Register object with the data store.

StatusCode TsDataSvc::registerObject ( DataObject *  parentObj, const std::string &  objPath, DataObject *  pObject  )

override

Register object with the data store.

Definition at line 467 of file TsDataSvc.cpp.

                                                          {
  if ( checkRoot() )  {
    if ( 0 == parentObj )   {
      if ( objPath.length() > 0 )   {
        if ( objPath[0] == SEPARATOR )    {
          std::string::size_type sep = objPath.find(SEPARATOR,1);
          if ( sep != std::string::npos )    {
            std::string p_path (objPath, 0, sep);
            std::string o_path (objPath, sep, objPath.length());
            return registerObject(p_path, o_path, pObject);
          }
        }
        else  {
          return registerObject(m_rootName, objPath, pObject);
        }
      }
      return INVALID_OBJ_PATH;
    }
    RegEntry* node_entry = CAST_REGENTRY(RegEntry*,parentObj->registry());
    if ( 0 != node_entry )   {
      StatusCode status = INVALID_PARENT;
      std::string::size_type sep = objPath.find(SEPARATOR,1);
      if ( sep != std::string::npos )    {
        std::string p_path (objPath, 0, sep);
        std::string o_path (objPath, sep, objPath.length());
        RegEntry* par_entry = node_entry->findLeaf(p_path);
        // Create default object leafs if the
        // intermediate nodes are not present
        if ( 0 == par_entry && m_forceLeaves )    {
          DataObject *pLeaf = createDefaultObject();
          StatusCode sc = registerObject(parentObj, p_path, pLeaf);
          if ( ! sc.isSuccess() )   {
            delete pLeaf;
          }
          par_entry = node_entry->findLeaf(p_path);
        }
        else if ( 0 != par_entry && par_entry->object() == 0 )  {
          status = retrieveEntry( node_entry, p_path, par_entry);
          if ( !status.isSuccess() && !par_entry->address() && m_forceLeaves )  {
            DataObject *pLeaf = createDefaultObject();
            StatusCode sc = registerObject(parentObj, p_path, pLeaf);
            if ( ! sc.isSuccess() )   {
              delete pLeaf;
            }
            par_entry = node_entry->findLeaf(p_path);
          }
        }
        node_entry = par_entry;
        if ( 0 != node_entry )    {
          DataObject* obj = node_entry->object();
          if ( 0 != obj )   {
            status = registerObject( obj, o_path, pObject );
          }
        }
      }
      else   {
        RegEntry* leaf = node_entry->findLeaf(objPath);
        if ( 0 == leaf )    {
          status = node_entry->add( objPath, pObject );
        }
        else    {
          DataObject* obj = leaf->object();
          if ( 0 == obj )    {
            if (0 == pObject) {
              error() << "registerObject: trying to register null DataObject" << endmsg;
              return StatusCode::FAILURE;
            }
            else  {
              pObject->setRegistry(leaf);
            }
            leaf->setAddress(0);
            leaf->setObject(pObject);
            status = StatusCode::SUCCESS;
          }
          else  {
            status = DOUBL_OBJ_PATH;
          }
        }
      }
      return status;
    }
    return INVALID_PARENT;
  }
  return INVALID_ROOT;
}

StatusCode TsDataSvc::registerObject ( DataObject *  parentObj, const std::string &  objPath, DataObject *  pObject  )

override

Register object with the data store.

StatusCode TsDataSvc::registerObject ( DataObject *  parentObj, int  item, DataObject *  pObject  )

override

Register object with the data store.

Definition at line 460 of file TsDataSvc.cpp.

                                                          {
  return registerObject(parentObj, itemToPath(item), pObject);
}

StatusCode TsDataSvc::registerObject ( DataObject *  parentObj, int  item, DataObject *  pObject  )

override

Register object with the data store.

StatusCode TsDataSvc::reinitialize ( )

override

Service initialization.

Service reinitialization.

Definition at line 1335 of file TsDataSvc.cpp.

                                      {
  StatusCode sc;
  // the finalize part is copied here
  setDataLoader(0).ignore();
  resetPreLoad().ignore();
  clearStore().ignore();
  if ( m_incidentSvc )  {
    m_incidentSvc->release();
    m_incidentSvc = 0;
  }
  // re-initialize the base class
  sc = Service::reinitialize();
  if ( UNLIKELY(!sc.isSuccess()) ) {
    error() << "Unable to reinitialize base class" << endmsg;
    return sc;
  }
  // the initialize part is copied here
  sc = service("IncidentSvc", m_incidentSvc, true);
  if ( UNLIKELY(!sc.isSuccess()) )  {
    error() << "Failed to access incident service." << endmsg;
    return sc;
  }
  // return
  return StatusCode::SUCCESS;
}

StatusCode TsDataSvc::reinitialize ( )

override

Service initialization.

StatusCode TsDataSvc::removePreLoadItem ( const DataStoreItem &  item )

override

Remove an item from the preload list.

StatusCode TsDataSvc::removePreLoadItem ( const DataStoreItem &  item )

override

Remove an item from the preload list.

Definition at line 1269 of file TsDataSvc.cpp.

                                                                   {
  LoadItems::iterator i =
    std::remove(m_preLoads.begin(), m_preLoads.end(), item);
  if ( i != m_preLoads.end() )  {
    m_preLoads.erase(i, m_preLoads.end());
  }
  return StatusCode::SUCCESS;
}

StatusCode TsDataSvc::removePreLoadItem ( const std::string &  itemPath )

override

Add an item to the preload list.

Definition at line 1279 of file TsDataSvc.cpp.

                                                                    {
  return removePreLoadItem( DataStoreItem(itemPath,1) );
}

StatusCode TsDataSvc::removePreLoadItem ( const std::string &  itemPath )

override

Add an item to the preload list.

StatusCode TsDataSvc::resetPreLoad ( )

override

Clear the preload list.

StatusCode TsDataSvc::resetPreLoad ( )

override

Clear the preload list.

Definition at line 1284 of file TsDataSvc.cpp.

                                      {
  m_preLoads.erase(m_preLoads.begin(), m_preLoads.end());
  return StatusCode::SUCCESS;
}

StatusCode TsDataSvc::retrieveEntry ( DataSvcHelpers::RegistryEntry *  pNode, const std::string &  path, DataSvcHelpers::RegistryEntry *&  pEntry  )

protected

Retrieve registry entry from store.

Definition at line 778 of file TsDataSvc.cpp.

                                                      {
  STD_LOCK_GUARD_MACRO
  std::string::size_type        sep    = path.find(SEPARATOR,1);
  StatusCode status = StatusCode(INVALID_ROOT,true);
  pEntry = 0;
  // A.Valassi 16.08.2001 avoid core dump if store is empty
  if ( checkRoot() )  {
    if ( 0 == parentObj )    {
      if ( path.length() == 0 || path == m_rootName )   {
        return retrieveEntry(m_root, "", pEntry);
      }
      else if ( path[0] != SEPARATOR )  {
        return retrieveEntry(m_root, path, pEntry);
      }
      else if ( sep != std::string::npos )    {
        if ( m_root->object() == 0 )  {
          RegEntry* r = 0;
          status = retrieveEntry(m_root, "", r);
          if ( !status.isSuccess() )  {
            return status;
          }
        }
        std::string o_path (path, sep, path.length());
        return retrieveEntry(m_root, o_path, pEntry);
      }
      return INVALID_OBJ_PATH;
    }
    if ( sep != std::string::npos )  { // the string contains a separator (after pos 0)
      std::string p_path (path,0,sep);
      std::string o_path (path,sep,path.length());
      if (!parentObj->object()) { // if the parent object has not been loaded yet, load it now
        status = loadObject(parentObj);
        if ( !status.isSuccess() )  {
          return status;
        }
      }
      RegEntry* root_entry = parentObj->findLeaf(p_path);
      if ( !root_entry && m_enableFaultHdlr )    {
        // If not even the parent is there, an incident
        // to load the parent must be fired...
        handleDataFault(parentObj, p_path);
        root_entry = parentObj->findLeaf(p_path);
      }
      if ( root_entry )    {
        DataObject* pO = root_entry->object();
        if ( 0 == pO )  {
          // Object is not loaded: load the object if at all possible
          status = loadObject(root_entry);
          if ( !status.isSuccess() )  {
            return status;
          }
        }
        if ( root_entry->isSoft() )    {
          root_entry = CAST_REGENTRY(RegEntry*,pO->registry());
        }
        return retrieveEntry (root_entry, o_path, pEntry);
      }
      return status;
    }
    else if ( path.length() == 0 )    {
      pEntry = parentObj;
    }
    else {
      if (!parentObj->object()) { // if the parent object has not been loaded yet, load it now
        status = loadObject(parentObj);
        if ( !status.isSuccess() )  {
          return status;
        }
      }
      // last leave in search: find leaf and load
      pEntry = parentObj->findLeaf(path);
      // If no registry entry was found, trigger incident for action-on-demand
      if ( !pEntry && m_enableFaultHdlr )  {
        handleDataFault(parentObj, path);
        pEntry = (0==path.length()) ? parentObj : parentObj->findLeaf(path);
      }
    }
    // Check results and return
    if ( 0 == pEntry )  {
      status = INVALID_OBJ_PATH;
    }
    else if ( 0 == pEntry->object() )  {
      status = loadObject(pEntry);
    }
    else if ( m_enableAccessHdlr )  {
      // Fire data access incident
      // I do not know if this is a good idea....
      // This fires too often!
      //
      //DataIncident incident(name(), m_accessName, pEntry->identifier());
      //m_incidentSvc->fireIncident(incident);
      status = SUCCESS;
    }
    else  {
      status = SUCCESS;
    }
  }
  return status;
}

StatusCode TsDataSvc::retrieveEntry ( DataSvcHelpers::RegistryEntry *  pNode, const std::string &  path, DataSvcHelpers::RegistryEntry *&  pEntry  )

protected

Retrieve registry entry from store.

StatusCode TsDataSvc::retrieveObject ( IRegistry *  pDirectory, const std::string &  path, DataObject *&  pObject  )

override

Retrieve object from data store.

Retrieve object identified by its directory from the data store.

Definition at line 881 of file TsDataSvc.cpp.

                                                           {
  STD_LOCK_GUARD_MACRO
  pObject = 0;
  RegEntry *result = 0, *parent = CAST_REGENTRY(RegEntry*,pRegistry);
  StatusCode status = retrieveEntry(parent, path, result);
  if ( status.isSuccess() )   {
    pObject = result->object();
  }
  return status;
}

StatusCode TsDataSvc::retrieveObject ( IRegistry *  pDirectory, const std::string &  path, DataObject *&  pObject  )

override

Retrieve object from data store.

StatusCode TsDataSvc::retrieveObject ( const std::string &  fullPath, DataObject *&  pObject  )

override

Retrieve object identified by its full path from the data store.

Definition at line 895 of file TsDataSvc.cpp.

                                                           {
  IRegistry* nullDir = 0;
  return retrieveObject(nullDir, fullPath, pObject);
}

StatusCode TsDataSvc::retrieveObject ( const std::string &  fullPath, DataObject *&  pObject  )

override

Retrieve object identified by its full path from the data store.

StatusCode TsDataSvc::retrieveObject ( const std::string &  parentPath, const std::string &  objPath, DataObject *&  pObject  )

override

Retrieve object from data store.

StatusCode TsDataSvc::retrieveObject ( const std::string &  parentPath, const std::string &  objPath, DataObject *&  pObject  )

override

Retrieve object from data store.

Retrieve object identified by its full path from the data store.

Definition at line 902 of file TsDataSvc.cpp.

                                                           {
  DataObject* parent = 0;
  StatusCode status = retrieveObject(parentPath, parent);
  if ( status.isSuccess() )   {
    status = retrieveObject (parent, objectPath, pObject);
  }
  return status;
}

StatusCode TsDataSvc::retrieveObject ( const std::string &  parentPath, int  item, DataObject *&  pObject  )

override

Retrieve object from data store.

Retrieve object identified by its full path from the data store.

Definition at line 914 of file TsDataSvc.cpp.

                                                           {
  return retrieveObject(parentPath, itemToPath(item), pObject);
}

StatusCode TsDataSvc::retrieveObject ( const std::string &  parentPath, int  item, DataObject *&  pObject  )

override

Retrieve object from data store.

StatusCode TsDataSvc::retrieveObject ( DataObject *  parentObj, const std::string &  objPath, DataObject *&  pObject  )

override

Retrieve object from data store.

StatusCode TsDataSvc::retrieveObject ( DataObject *  parentObj, const std::string &  objPath, DataObject *&  pObject  )

override

Retrieve object from data store.

Definition at line 921 of file TsDataSvc.cpp.

                                                          {
  IRegistry* pRegistry = (0==parentObj) ? 0 : parentObj->registry();
  return retrieveObject(pRegistry, path, pObject);
}

StatusCode TsDataSvc::retrieveObject ( DataObject *  parentObj, int  item, DataObject *&  pObject  )

override

Retrieve object from data store.

Retrieve registry entry from store.

Definition at line 929 of file TsDataSvc.cpp.

                                                          {
  return retrieveObject(parentObj, itemToPath(item), pObject);
}

StatusCode TsDataSvc::retrieveObject ( DataObject *  parentObj, int  item, DataObject *&  pObject  )

override

Retrieve object from data store.

CLID TsDataSvc::rootCLID ( ) const

override

IDataManagerSvc: Accessor for root event CLID.

CLID TsDataSvc::rootCLID ( ) const

override

IDataManagerSvc: Accessor for root event CLID.

CLID for root Event.

Definition at line 1375 of file TsDataSvc.cpp.

                               {
  return( (CLID)m_rootCLID );
}

const std::string& TsDataSvc::rootName ( ) const

override

IDataManagerSvc: Accessor for root event name.

const std::string & TsDataSvc::rootName ( ) const

override

IDataManagerSvc: Accessor for root event name.

Name for root Event.

Definition at line 1380 of file TsDataSvc.cpp.

                                           {
  return( m_rootName );
}

StatusCode TsDataSvc::setDataLoader ( IConversionSvc *  svc, IDataProviderSvc *  dpsvc = 0  )

override

IDataManagerSvc: IDataManagerSvc: Pass a default data loader to the service and optionally a data provider.

StatusCode TsDataSvc::setDataLoader ( IConversionSvc *  svc, IDataProviderSvc *  dpsvc = 0  )

override

IDataManagerSvc: IDataManagerSvc: Pass a default data loader to the service and optionally a data provider.

IDataManagerSvc: Pass a default data loader to the service.

Definition at line 214 of file TsDataSvc.cpp.

                                                                                           {
  if ( 0 != pDataLoader  ) pDataLoader->addRef();
  if ( 0 != m_dataLoader ) m_dataLoader->release();
  if ( 0 != pDataLoader  )    {
    pDataLoader->setDataProvider(dpsvc == nullptr ? this : dpsvc).ignore();
  }
  m_dataLoader = pDataLoader;
  return SUCCESS;
}

StatusCode TsDataSvc::setRoot ( std::string  root_name, DataObject *  pRootObj  )

override

Initialize data store for new event by giving new event path and root object.

Takes care to clear the store before reinitializing it

StatusCode TsDataSvc::setRoot ( std::string  root_path, DataObject *  pRootObj  )

override

Initialize data store for new event by giving new event path and root object.

Takes care to clear the store before reinitializing it

Definition at line 165 of file TsDataSvc.cpp.

                                                     {
  clearStore().ignore();
  return i_setRoot (std::move(root_path), pRootObj);
}

StatusCode TsDataSvc::setRoot ( std::string  root_path, IOpaqueAddress *  pRootAddr  )

override

Initialize data store for new event by giving new event path and address of root object.

Takes care to clear the store before reinitializing it

Definition at line 191 of file TsDataSvc.cpp.

                                                          {
  clearStore().ignore();
  return i_setRoot (std::move(root_path), pRootAddr);
}

StatusCode TsDataSvc::setRoot ( std::string  root_path, IOpaqueAddress *  pRootAddr  )

override

Initialize data store for new event by giving new event path and address of root object.

Takes care to clear the store before reinitializing it

StatusCode TsDataSvc::traverseSubTree ( const std::string &  sub_tree_path, IDataStoreAgent *  pAgent  )

override

IDataManagerSvc: Analyze by traversing all data objects below the sub tree identified by its full path name.

IDataManagerSvc: Analyse by traversing all data objects below the sub tree identified by its full path name.

Definition at line 127 of file TsDataSvc.cpp.

                                                               {
  STD_LOCK_GUARD_MACRO
  DataObject* pO = 0;
  StatusCode status = findObject(sub_tree_path, pO);
  if ( status.isSuccess() )   {
    status = traverseSubTree(pO, pAgent);
  }
  return status;
}

StatusCode TsDataSvc::traverseSubTree ( const std::string &  sub_tree_path, IDataStoreAgent *  pAgent  )

override

IDataManagerSvc: Analyze by traversing all data objects below the sub tree identified by its full path name.

StatusCode TsDataSvc::traverseSubTree ( DataObject *  pObject, IDataStoreAgent *  pAgent  )

override

IDataManagerSvc: Analyze by traversing all data objects below the sub tree.

IDataManagerSvc: Analyse by traversing all data objects below the sub tree.

Definition at line 139 of file TsDataSvc.cpp.

                                                                 {
  STD_LOCK_GUARD_MACRO
  if ( checkRoot() )    {
    RegEntry* entry = CAST_REGENTRY(RegEntry*,pObject->registry());
    if ( 0 != entry )   {
      return entry->traverseTree(pAgent);
    }
    return INVALID_OBJECT;
  }
  return INVALID_ROOT;
}

StatusCode TsDataSvc::traverseSubTree ( DataObject *  pObject, IDataStoreAgent *  pAgent  )

override

IDataManagerSvc: Analyze by traversing all data objects below the sub tree.

StatusCode TsDataSvc::traverseTree ( IDataStoreAgent *  pAgent )

override

IDataManagerSvc: Analyze by traversing all data objects in the data store.

IDataManagerSvc: Analyse by traversing all data objects in the data store.

Definition at line 153 of file TsDataSvc.cpp.

                                                            {
  STD_LOCK_GUARD_MACRO
  if ( checkRoot() )    {
    return m_root->traverseTree(pAgent);
  }
  return INVALID_ROOT;
}

StatusCode TsDataSvc::traverseTree ( IDataStoreAgent *  pAgent )

override

IDataManagerSvc: Analyze by traversing all data objects in the data store.

StatusCode TsDataSvc::unlinkObject ( IRegistry *  from, const std::string &  objPath  )

override

Remove a link to another object.

StatusCode TsDataSvc::unlinkObject ( IRegistry *  from, const std::string &  objPath  )

override

Remove a link to another object.

Definition at line 1187 of file TsDataSvc.cpp.

                                                              {
  STD_LOCK_GUARD_MACRO
  if ( checkRoot() )  {
    try   {
      RegEntry* from_entry = CAST_REGENTRY(RegEntry*,from);
      if ( 0 != from_entry )    {
        std::string::size_type sep = objPath.rfind(SEPARATOR);
        if ( sep > 0 && sep != std::string::npos )    {  // in case the objPath is a sub-directory itself
          DataObject* pO = 0;
          std::string fromPath(objPath, 0, sep);
          StatusCode sc = findObject(from, fromPath, pO);
          if ( sc.isSuccess() )    {
            std::string toPath(objPath, sep, objPath.length());
            sc = unlinkObject(pO->registry(), toPath);
          }
          return sc;
        }
        StatusCode status = from_entry->remove( objPath );
        if ( status.isSuccess() )     {
          return status;
        }
        return INVALID_OBJ_PATH;
      }
    }
    catch (...)   {
    }
    return INVALID_PARENT;
  }
  return INVALID_ROOT;
}

StatusCode TsDataSvc::unlinkObject ( const std::string &  fromPath, const std::string &  objPath  )

override

Remove a link to another object.

Definition at line 1234 of file TsDataSvc.cpp.

                                                              {
  DataObject* pObject = 0;
  StatusCode status = findObject(from, pObject);
  if ( status.isSuccess() )   {
    status = unlinkObject(pObject->registry(), objPath);
  }
  return status;
}

StatusCode TsDataSvc::unlinkObject ( const std::string &  fromPath, const std::string &  objPath  )

override

Remove a link to another object.

StatusCode TsDataSvc::unlinkObject ( DataObject *  fromObj, const std::string &  objPath  )

override

Remove a link to another object.

Definition at line 1245 of file TsDataSvc.cpp.

                                                              {
  if ( checkRoot() )  {
    IRegistry* from_entry = m_root->findLeaf(from);
    return unlinkObject(from_entry, objPath);
  }
  return INVALID_ROOT;
}

StatusCode TsDataSvc::unlinkObject ( DataObject *  fromObj, const std::string &  objPath  )

override

Remove a link to another object.

StatusCode TsDataSvc::unlinkObject ( const std::string &  fullPath )

override

Remove a link to another object.

Definition at line 1220 of file TsDataSvc.cpp.

                                                               {
  if ( fullPath.length() > 0 )    {
    if ( fullPath[0] != SEPARATOR )   {
      return unlinkObject(m_rootName, fullPath);
    }
    std::string::size_type sep = fullPath.rfind(SEPARATOR);
    std::string objPath(fullPath, sep, fullPath.length());
    std::string fromPath(fullPath, 0, sep);
    return unlinkObject(fromPath, objPath);
  }
  return INVALID_OBJ_PATH;
}

StatusCode TsDataSvc::unlinkObject ( const std::string &  fullPath )

override

Remove a link to another object.

StatusCode TsDataSvc::unregisterAddress ( const std::string &  fullPath )

override

IDataManagerSvc: Unregister object address from the data store.

StatusCode TsDataSvc::unregisterAddress ( const std::string &  fullPath )

override

IDataManagerSvc: Unregister object address from the data store.

Definition at line 361 of file TsDataSvc.cpp.

                                                                    {
  if ( fullPath.length() > 0 )    {
    IRegistry* pRegistry = 0;
    if ( fullPath[0] != SEPARATOR )   {
      return unregisterAddress(m_root, fullPath);
    }
    return unregisterAddress(pRegistry, fullPath);
  }
  return INVALID_OBJ_PATH;
}

StatusCode TsDataSvc::unregisterAddress ( DataObject *  pParent, const std::string &  objPath  )

override

IDataManagerSvc: Unregister object address from the data store.

StatusCode TsDataSvc::unregisterAddress ( DataObject *  pParent, const std::string &  objPath  )

override

IDataManagerSvc: Unregister object address from the data store.

Definition at line 373 of file TsDataSvc.cpp.

                                                                  {
  IRegistry* pRegistry = (0 == pParent) ? 0 : pParent->registry();
  return unregisterAddress(pRegistry, objPath);
}

StatusCode TsDataSvc::unregisterAddress ( IRegistry *  pParent, const std::string &  objPath  )

override

IDataManagerSvc: Unregister object address from the data store.

Definition at line 380 of file TsDataSvc.cpp.

                                                                  {
  if ( checkRoot() )  {
    if ( objPath.length() > 0 )   {
      if ( 0 == pParent )   {
        if ( objPath[0] != SEPARATOR )    {
          return unregisterAddress(m_root, objPath);
        }
        std::string::size_type sep = objPath.find(SEPARATOR,1);
        if ( sep != std::string::npos )    {
          std::string p_path (objPath, 0, sep);
          if ( p_path == m_rootName )   {
            std::string o_path (objPath, sep, objPath.length());
            return unregisterAddress(m_root, o_path);
          }
        }
        return INVALID_PARENT;
      }
      if ( objPath[0] != SEPARATOR )    {
        std::string path;
        path  = SEPARATOR;
        path += objPath;
        return unregisterAddress(pParent, path);
      }
      RegEntry* node_entry = CAST_REGENTRY(RegEntry*,pParent);
      if ( 0 != node_entry )   {
        RegEntry* leaf_entry = node_entry->findLeaf(objPath);
        if ( 0 != leaf_entry )    {
          std::string::size_type sep = objPath.rfind(SEPARATOR);
          if ( sep > 0 && sep != std::string::npos )    {
            std::string path = objPath.substr(sep);
            return unregisterAddress(leaf_entry->parent(), path);
          }
          StatusCode status = node_entry->remove(objPath);
          if ( status.isSuccess() )   {
            return status;
          }
        }
      }
      return INVALID_PARENT;
    }
    return INVALID_OBJ_PATH;
  }
  return INVALID_ROOT;
}

StatusCode TsDataSvc::unregisterAddress ( IRegistry *  pParent, const std::string &  objPath  )

override

IDataManagerSvc: Unregister object address from the data store.

StatusCode TsDataSvc::unregisterObject ( const std::string &  fullPath )

override

Unregister object from the data store.

StatusCode TsDataSvc::unregisterObject ( const std::string &  fullPath )

override

Unregister object from the data store.

Definition at line 556 of file TsDataSvc.cpp.

                                                                  {
  DataObject* pObject = 0;
  StatusCode status = findObject(fullPath, pObject);
  if ( status.isSuccess() )   {
    RegEntry* pEntry = CAST_REGENTRY(RegEntry*,pObject->registry());
    if ( 0 != pEntry )    {
      if ( pEntry->isEmpty() )    {
        RegEntry* pParent = pEntry->parentEntry();
        if ( 0 != pParent )   {
          if ( 0 != pObject )    {
            pObject->addRef();
          }
          pParent->remove(pEntry);
          return StatusCode::SUCCESS;
        }
        return INVALID_PARENT;
      }
      return DIR_NOT_EMPTY;
    }
    return INVALID_ROOT;
  }
  return status;
}

StatusCode TsDataSvc::unregisterObject ( const std::string &  parentPath, const std::string &  objectPath  )

override

Unregister object from the data store.

Definition at line 581 of file TsDataSvc.cpp.

                                                                 {
  DataObject* pO = 0;
  StatusCode status = findObject(parentPath, pO);
  if ( status.isSuccess() )   {
    status = unregisterObject(pO, objPath);
  }
  return status;
}

StatusCode TsDataSvc::unregisterObject ( const std::string &  parentPath, const std::string &  objectPath  )

override

Unregister object from the data store.

StatusCode TsDataSvc::unregisterObject ( const std::string &  parentPath, int  item  )

override

Unregister object from the data store.

Definition at line 592 of file TsDataSvc.cpp.

                                                                            {
  return unregisterObject(parentPath, itemToPath(item));
}

StatusCode TsDataSvc::unregisterObject ( const std::string &  parentPath, int  item  )

override

Unregister object from the data store.

StatusCode TsDataSvc::unregisterObject ( DataObject *  pObject )

override

Unregister object from the data store.

Definition at line 597 of file TsDataSvc.cpp.

                                                             {
  if ( checkRoot() )  {
    RegEntry* entry = m_root->findLeaf(pObject);
    if ( 0 != entry )   {
      RegEntry* parent = entry->parentEntry();
      if ( 0 != parent )    {
        if ( entry->isEmpty() )    {
          if ( 0 != entry->object() )    {
            entry->object()->addRef();
          }
          if ( 0 != parent )  {
            parent->remove(entry);
          }
          return SUCCESS;
        }
        return INVALID_PARENT;
      }
      return DIR_NOT_EMPTY;
    }
    return INVALID_OBJECT;
  }
  return INVALID_ROOT;
}

StatusCode TsDataSvc::unregisterObject ( DataObject *  pObject )

override

Unregister object from the data store.

StatusCode TsDataSvc::unregisterObject ( DataObject *  pObject, const std::string &  objectPath  )

override

Unregister object from the data store.

Definition at line 622 of file TsDataSvc.cpp.

                                                                   {
  if ( checkRoot() )  {
    try   {
      RegEntry* parent = CAST_REGENTRY(RegEntry*,pParentObj->registry());
      if ( 0 != parent )   {
        RegEntry* entry = parent->findLeaf(objectPath);
        if ( 0 != entry )   {
          if ( entry->isEmpty() )    {
            if ( 0 != entry->object() )    {
              entry->object()->addRef();
            }
            parent->remove(entry);
            return SUCCESS;
          }
          return DIR_NOT_EMPTY;
        }
        return INVALID_OBJECT;
      }
    }
    catch(...) {
    }
    return INVALID_PARENT;
  }
  return INVALID_ROOT;
}

StatusCode TsDataSvc::unregisterObject ( DataObject *  pObject, const std::string &  objectPath  )

override

Unregister object from the data store.

StatusCode TsDataSvc::unregisterObject ( DataObject *  pObject, int  item  )

override

Unregister object from the data store.

StatusCode TsDataSvc::unregisterObject ( DataObject *  pObject, int  item  )

override

Unregister object from the data store.

Definition at line 650 of file TsDataSvc.cpp.

                                                                          {
  return unregisterObject(pParentObj, itemToPath(item));
}

StatusCode TsDataSvc::updateObject ( IRegistry *  pDirectory )

override

Update object identified by its directory entry.

StatusCode TsDataSvc::updateObject ( IRegistry *  pDirectory )

override

Update object identified by its directory entry.

Update object.

Definition at line 1017 of file TsDataSvc.cpp.

                                                          {
  if ( 0 == pRegistry )  {                     // Precondition:
    return INVALID_OBJ_ADDR;                   // Addres must be valid
  }
  DataObject* toUpdate = pRegistry->object();
  if ( 0 == toUpdate )  {                      // Try first to load
    return loadObject(pRegistry);
  }
  return updateObject(toUpdate);
}

StatusCode TsDataSvc::updateObject ( const std::string &  updatePath )

override

Update object.

Definition at line 1007 of file TsDataSvc.cpp.

                                                                {
  DataObject* pO = 0;
  StatusCode status = findObject(updatePath, pO);
  if ( status.isSuccess() )   {
    return updateObject(pO);
  }
  return retrieveObject(updatePath, pO);
}

StatusCode TsDataSvc::updateObject ( const std::string &  updatePath )

override

Update object.

StatusCode TsDataSvc::updateObject ( DataObject *  toUpdate )

override

Update object.

StatusCode TsDataSvc::updateObject ( DataObject *  toUpdate )

override

Update object.

Definition at line 1029 of file TsDataSvc.cpp.

                                                          {
  STD_LOCK_GUARD_MACRO
  StatusCode status = INVALID_OBJ_ADDR;
  if ( 0 == toUpdate )  {                          // Precondition:
    return INVALID_OBJECT;                         // Address must be valid
  }
  IRegistry* pRegistry = toUpdate->registry();     // Precondition:
  if ( 0 == pRegistry )    {                       // Need valid registry
    return INVALID_OBJECT;
  }
  IOpaqueAddress* pAddress = pRegistry->address(); // Precondition:
  if ( 0 == pAddress )    {                        // Need valid address
    return INVALID_OBJ_ADDR;
  }
  IConversionSvc* pLoader = getDataLoader(pRegistry);
  if ( 0 == pLoader )   {                      // Precondition:
    return NO_DATA_LOADER;                     // Data loader must be present
  }
  if ( m_inhibitPathes.size() > 0 )   {
    const std::string& ident = pRegistry->identifier();
    std::vector<std::string>::iterator inhibit =
      std::find(m_inhibitPathes.begin(), m_inhibitPathes.end(), ident);
    if ( inhibit != m_inhibitPathes.end() )   {
      return NO_ACCESS;
    }
  }
  try   {
    status = pLoader->updateObj(pAddress, toUpdate);  // Call data loader
    if ( status.isSuccess() )   {
      status = pLoader->updateObjRefs(pAddress, toUpdate);
    }
  }
  catch( const GaudiException& exc ) {
    throw GaudiException("GaudiException in updateObject() " +
                         pRegistry->name(),
                         name(),
                         StatusCode::FAILURE, exc);
  }
  catch( const std::exception& x) {
    throw GaudiException("std::exception in updateObject() " +
                         pRegistry->name() + ": " +
                         System::typeinfoName(typeid(x)) + ", " +
                         x.what(),
                         name(), StatusCode::FAILURE);
  }
  catch(...) {
    throw GaudiException("UNKN exception in updateObject() " +
                         pRegistry->name(),
      name(), StatusCode::FAILURE);
  }
  return status;
}

StatusCode TsDataSvc::updateObject ( const std::string &  parentPath, const std::string &  updatePath  )

override

Update object.

Definition at line 1083 of file TsDataSvc.cpp.

                                                                 {
  DataObject* pParent = 0;
  StatusCode status = findObject(parentPath, pParent);
  if ( status.isSuccess() )   {
    status = updateObject( pParent, updatePath);
  }
  return status;
}

StatusCode TsDataSvc::updateObject ( const std::string &  parentPath, const std::string &  updatePath  )

override

Update object.

StatusCode TsDataSvc::updateObject ( DataObject *  pParent, const std::string &  updatePath  )

override

Update object.

Definition at line 1094 of file TsDataSvc.cpp.

                                                                {
  DataObject* pObject = 0;
  StatusCode status = findObject(parent, updatePath, pObject);
  if ( status.isSuccess() )   {
    status = updateObject(pObject);
  }
  return status;
}

StatusCode TsDataSvc::updateObject ( DataObject *  pParent, const std::string &  updatePath  )

override

Update object.

Friends And Related Function Documentation

friend class SvcFactory< TsDataSvc >

friend

The class creator is of course a friend!

Definition at line 65 of file TsDataSvc.h.

Member Data Documentation

tsDataSvcMutex TsDataSvc::m_accessMutex

protected

Mutex to protect access to the store.

Definition at line 447 of file TsDataSvc.h.

std::string TsDataSvc::m_accessName

protected

Name of the data access incident.

Definition at line 95 of file TsDataSvc.h.

IConversionSvc * TsDataSvc::m_dataLoader

protected

Pointer to data loader service.

Definition at line 77 of file TsDataSvc.h.

bool TsDataSvc::m_enableAccessHdlr

protected

Flag to enable interrupts on data access requests.

Definition at line 85 of file TsDataSvc.h.

bool TsDataSvc::m_enableFaultHdlr

protected

Flag to enable interrupts on data creation requests.

Definition at line 87 of file TsDataSvc.h.

std::string TsDataSvc::m_faultName

protected

Name of the data fault incident.

Definition at line 97 of file TsDataSvc.h.

bool TsDataSvc::m_forceLeaves

protected

Allow forced creation of default leaves on registerObject.

Definition at line 83 of file TsDataSvc.h.

IIncidentSvc * TsDataSvc::m_incidentSvc

protected

Pointer to incident service.

Definition at line 79 of file TsDataSvc.h.

DataSvcHelpers::InhibitMap * TsDataSvc::m_inhibitMap

protected

Map with object paths to be inhibited from loading.

Definition at line 91 of file TsDataSvc.h.

std::vector< std::string > TsDataSvc::m_inhibitPathes

protected

Property for the inhibited leaves.

Definition at line 93 of file TsDataSvc.h.

LoadItems TsDataSvc::m_preLoads

protected

Items to be pre-loaded.

Definition at line 81 of file TsDataSvc.h.

DataSvcHelpers::RegistryEntry * TsDataSvc::m_root

protected

Pointer to root entry.

Definition at line 89 of file TsDataSvc.h.

CLID TsDataSvc::m_rootCLID

protected

Integer Property corresponding to CLID of root entry.

Definition at line 73 of file TsDataSvc.h.

std::string TsDataSvc::m_rootName

protected

Name of root event.

Definition at line 75 of file TsDataSvc.h.

---

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

• InstallArea/x86_64-slc6-gcc49-opt/include/GaudiKernel/TsDataSvc.h
• GaudiKernel/src/Lib/TsDataSvc.cpp