20 #define TSDATASVC_DATASVC_CPP 44 #define STD_LOCK_GUARD_MACRO std::lock_guard<tsDataSvcMutex> lock( m_accessMutex ); 49 s.append( sr.data(), sr.size() );
53 boost::string_ref::size_type find( boost::string_ref
s,
char c,
size_t o ) {
54 if ( !s.empty() ) s.remove_prefix( o );
56 return r == boost::string_ref::npos ? r : ( r + o );
65 #define CAST_REGENTRY( x, y ) dynamic_cast<x>( y ) 69 #define ON_DEBUG if ( msgLevel( MSG::DEBUG ) ) 70 #define ON_VERBOSE if ( msgLevel( MSG::VERBOSE ) ) 72 #define DEBMSG ON_DEBUG debug() 73 #define VERMSG ON_VERBOSE verbose() 83 if ( !node_entry )
return Status::INVALID_OBJECT;
85 if ( !parent )
return Status::INVALID_PARENT;
86 parent->
remove( node_entry );
94 if ( !
checkRoot() )
return Status::INVALID_ROOT;
96 if ( !entry )
return Status::INVALID_OBJECT;
98 if ( !parent )
return Status::INVALID_PARENT;
105 if ( !
checkRoot() )
return Status::INVALID_ROOT;
122 if ( !
checkRoot() )
return Status::INVALID_ROOT;
124 if ( !entry )
return Status::INVALID_OBJECT;
131 if ( !
checkRoot() )
return Status::INVALID_ROOT;
185 if ( pDataLoader ) pDataLoader->
addRef();
194 if ( !pObject )
return Status::INVALID_OBJECT;
200 if ( !
checkRoot() )
return Status::INVALID_ROOT;
202 if ( !node_entry )
return Status::INVALID_OBJECT;
203 refpParent = node_entry->
parent();
209 if ( !pObject )
return Status::INVALID_OBJECT;
217 if ( !pRegistry )
return Status::INVALID_OBJECT;
219 if ( !node_entry )
return Status::INVALID_OBJECT;
228 if ( fullPath.empty() )
return Status::INVALID_OBJ_PATH;
234 if ( !
checkRoot() )
return Status::INVALID_ROOT;
235 if ( objPath.empty() )
return Status::INVALID_OBJ_PATH;
238 auto sep = find( objPath,
SEPARATOR, 1 );
239 if ( sep == boost::string_ref::npos || objPath.substr( 0, sep ) !=
m_rootName.value() ) {
240 return Status::INVALID_PARENT;
246 if ( !par_entry )
return Status::INVALID_PARENT;
248 if ( sep > 0 && sep != boost::string_ref::npos ) {
249 auto p_path = objPath.substr( 0, sep );
250 auto o_path = objPath.substr( sep );
258 p_entry = par_entry->
findLeaf( p_path );
260 if ( !p_entry )
return Status::INVALID_PARENT;
263 StatusCode status = par_entry->
add( objPath.to_string(), pAddress );
264 return status.
isSuccess() ? status : Status::DOUBL_OBJ_PATH;
269 if ( fullPath.empty() )
return Status::INVALID_OBJ_PATH;
275 if ( !
checkRoot() )
return Status::INVALID_ROOT;
277 if ( objPath.empty() )
return Status::INVALID_OBJ_PATH;
280 auto sep = find( objPath,
SEPARATOR, 1 );
281 if ( sep == boost::string_ref::npos || objPath.substr( 0, sep ) !=
m_rootName.value() ) {
282 return Status::INVALID_PARENT;
292 if ( sep > 0 && sep != boost::string_ref::npos ) {
296 if ( status.isSuccess() )
return status;
299 return Status::INVALID_PARENT;
316 if ( !
checkRoot() )
return Status::INVALID_ROOT;
318 if ( !objPath.empty() ) {
320 auto sep = find( objPath,
SEPARATOR, 1 );
321 if ( sep != boost::string_ref::npos ) {
322 return registerObject( objPath.substr( 0, sep ), objPath.substr( sep ), pObject );
325 return Status::INVALID_OBJ_PATH;
330 auto sep = find( objPath,
SEPARATOR, 1 );
331 if ( sep != boost::string_ref::npos ) {
332 auto p_path = objPath.substr( 0, sep );
333 auto o_path = objPath.substr( sep );
341 par_entry = node_entry->
findLeaf( p_path );
342 }
else if ( par_entry && !par_entry->
object() ) {
348 par_entry = node_entry->
findLeaf( p_path );
351 node_entry = par_entry;
359 status = node_entry->
add( objPath.to_string(), pObject );
364 error() <<
"registerObject: trying to register null DataObject" <<
endmsg;
373 status = Status::DOUBL_OBJ_PATH;
379 return Status::INVALID_PARENT;
388 if ( !pEntry )
return Status::INVALID_ROOT;
389 if ( !pEntry->
isEmpty() )
return Status::DIR_NOT_EMPTY;
391 if ( !pParent )
return Status::INVALID_PARENT;
392 if ( pObject ) pObject->
addRef();
393 pParent->
remove( pEntry );
399 if ( !
checkRoot() )
return Status::INVALID_ROOT;
401 if ( !entry )
return Status::INVALID_OBJECT;
403 if ( !parent )
return Status::INVALID_PARENT;
404 if ( !entry->
isEmpty() )
return Status::DIR_NOT_EMPTY;
406 if ( parent ) parent->
remove( entry );
412 if ( !
checkRoot() )
return Status::INVALID_ROOT;
417 if ( !entry )
return Status::INVALID_OBJECT;
418 if ( !entry->
isEmpty() )
return Status::DIR_NOT_EMPTY;
424 return Status::INVALID_PARENT;
432 if ( pReg && path.empty() ) {
439 p.
append( path.data(), path.size() );
446 p.
append( path.data(), path.size() );
451 if ( pLeaf )
return pLeaf->
object();
475 return Status::NO_DATA_LOADER;
481 return Status::INVALID_OBJ_ADDR;
498 return Status::INVALID_OBJ_ADDR;
501 status = pLoader->
createObj( pAddress, pObject );
510 status = pLoader->
fillObjRefs( pAddress, pObject );
545 if ( sep == boost::string_ref::npos )
return Status::INVALID_OBJ_PATH;
549 if ( !status.
isSuccess() )
return status;
553 if ( sep != boost::string_ref::npos ) {
554 auto p_path = path.substr( 0, sep );
555 auto o_path = path.substr( sep );
556 if ( !parentObj->
object() ) {
558 if ( !status.
isSuccess() )
return status;
565 root_entry = parentObj->
findLeaf( p_path );
572 if ( !status.
isSuccess() )
return status;
578 }
else if ( path.empty() ) {
581 if ( !parentObj->
object() ) {
583 if ( !status.
isSuccess() )
return status;
586 pEntry = parentObj->
findLeaf( path );
590 pEntry = ( path.empty() ? parentObj : parentObj->
findLeaf( path ) );
595 status = Status::INVALID_OBJ_PATH;
596 }
else if ( !pEntry->
object() ) {
629 if ( !path.empty() ) pReg = root_entry->
find( path );
630 if ( !pReg )
return Status::INVALID_OBJ_PATH;
633 return pObject ? Status::IDataProviderSvc_NO_ERROR : Status::OBJ_NOT_LOADED;
640 if ( !
checkRoot() )
return Status::INVALID_ROOT;
643 return !pObject ? Status::OBJ_NOT_LOADED : Status::IDataProviderSvc_NO_ERROR;
650 if ( !pRegistry )
return Status::INVALID_OBJ_ADDR;
658 if ( !toUpdate )
return Status::INVALID_OBJECT;
660 if ( !pRegistry )
return Status::INVALID_OBJECT;
662 if ( !pAddress )
return Status::INVALID_OBJ_ADDR;
665 if ( !pLoader )
return Status::NO_DATA_LOADER;
672 status = pLoader->updateObj( pAddress, toUpdate );
673 if ( status.
isSuccess() ) { status = pLoader->updateObjRefs( pAddress, toUpdate ); }
677 throw GaudiException(
"std::exception in updateObject() " + pRegistry->
name() +
": " +
689 if ( !
checkRoot() )
return Status::INVALID_ROOT;
695 if ( !to_entry )
return Status::INVALID_OBJECT;
697 if ( sep > 0 && sep != boost::string_ref::npos ) {
703 StatusCode status = from_entry->
add( objPath.to_string(), to, true );
704 return status.
isSuccess() ? Status::IDataProviderSvc_NO_ERROR : Status::DOUBL_OBJ_PATH;
707 return Status::INVALID_PARENT;
712 if ( fullPath.empty() )
return Status::INVALID_OBJ_PATH;
715 return linkObject( fullPath.substr( 0, sep ), fullPath.substr( sep ), to );
724 if ( !
checkRoot() )
return Status::INVALID_ROOT;
729 if ( sep > 0 && sep != boost::string_ref::npos ) {
735 return status.
isSuccess() ? status : Status::INVALID_OBJ_PATH;
738 return Status::INVALID_PARENT;
743 if ( fullPath.empty() )
return Status::INVALID_OBJ_PATH;
746 return unlinkObject( fullPath.substr( 0, sep ), fullPath.substr( sep ) );
751 if ( !
checkRoot() )
return Status::INVALID_ROOT;
778 if ( pObject && depth++ < load_depth ) {
781 for (
const auto& i : *dir ) {
796 int load_depth = i.depth();
826 error() <<
"Unable to reinitialize base class" <<
endmsg;
832 error() <<
"Failed to access incident service." <<
endmsg;
StatusCode initialize() override
RegistryEntry * findLeaf(boost::string_ref path) const
Find identified leaf in this registry node.
Define general base for Gaudi exception.
DataObject * object() const override
Retrive object behind the link.
const std::string & name() const override
Retrieve name of the service.
virtual StatusCode createObj(IOpaqueAddress *pAddress, DataObject *&refpObject)=0
Create the transient representation of an object.
StatusCode setRoot(std::string root_name, DataObject *pRootObj) override
Initialize data store for new event by giving new event path and root object.
StatusCode finalize() override
StatusCode addPreLoadItem(const DataStoreItem &item) override
Add an item to the preload list.
StatusCode linkObject(IRegistry *from, boost::string_ref objPath, DataObject *to) override
Add a link to another object.
StatusCode unregisterObject(boost::string_ref fullPath) override
Unregister object from the data store.
GAUDI_API const std::string typeinfoName(const std::type_info &)
Get platform independent information about the class type.
StatusCode traverseTree(IDataStoreAgent *pAgent, int level=0)
traverse data tree
StatusCode traverseTree(IDataStoreAgent *pAgent) override
IDataManagerSvc: Analyze by traversing all data objects in the data store.
StatusCode updateObject(IRegistry *pDirectory) override
Update object identified by its directory entry.
StatusCode unregisterAddress(boost::string_ref fullPath) override
IDataManagerSvc: Unregister object address from the data store.
Gaudi::Property< std::string > m_accessName
Gaudi::Property< CLID > m_rootCLID
StatusCode retrieveObject(IRegistry *pDirectory, boost::string_ref path, DataObject *&pObject) override
Retrieve object from data store.
MsgStream & verbose() const
shortcut for the method msgStream(MSG::VERBOSE)
virtual StatusCode setDataProvider(IDataProviderSvc *pService)=0
Set Data provider service.
constexpr static const auto SUCCESS
void setRegistry(IRegistry *pRegistry)
Set pointer to Registry.
virtual const name_type & name() const =0
Name of the directory (or key)
StatusCode initialize() override
Service initialization.
StatusCode removePreLoadItem(const DataStoreItem &item) override
Remove an item from the preload list.
virtual IConversionSvc * getDataLoader(IRegistry *pReg)
Retrieve customizable data loader according to registry entry to be retrieved.
const Store & leaves() const
Access the leaves of the object.
bool isSoft() const
Is the link soft or hard.
IConversionSvc * m_dataLoader
Pointer to data loader service.
StatusCode setDataLoader(IConversionSvc *svc, IDataProviderSvc *dpsvc=nullptr) override
IDataManagerSvc: IDataManagerSvc: Pass a default data loader to the service and optionally a data pro...
Data provider interface definition.
void setAddress(IOpaqueAddress *pAddress) override
Set/Update Opaque address.
Description of the DataStoreItem class.
IRegistry * registry() const
Get pointer to Registry.
StatusCode resetPreLoad() override
Clear the preload list.
MsgStream & error() const
shortcut for the method msgStream(MSG::ERROR)
StatusCode registerAddress(boost::string_ref fullPath, IOpaqueAddress *pAddress) override
IDataManagerSvc: Register object address with the data store.
virtual unsigned long addRef()
Add reference to object.
virtual void fireIncident(const Incident &incident)=0
Fire an Incident.
void setObject(DataObject *obj)
Set/Update object address.
StatusCode preLoad() override
load all preload items of the list
StatusCode findObject(boost::string_ref fullPath, DataObject *&pObject) override
Find object identified by its full path in the data store.
IIncidentSvc * m_incidentSvc
Pointer to incident service.
virtual const id_type & identifier() const =0
Full identifier (or key)
This class is used for returning status codes from appropriate routines.
IRegistry * parent() const
Pointer to parent directory entry.
DataSvcHelpers::RegistryEntry RegEntry
void setDataSvc(IDataProviderSvc *s)
Set the transient data store.
const std::string & rootName() const override
IDataManagerSvc: Accessor for root event name.
Gaudi::Property< bool > m_enableAccessHdlr
StatusCode reinitialize() override
Service initialization.
StatusCode objectLeaves(const DataObject *pObject, std::vector< IRegistry * > &refLeaves) override
IDataManagerSvc: Explore the object store: retrieve all leaves attached to the object.
The IRegistry represents the entry door to the environment any data object residing in a transient da...
StatusCode unlinkObject(IRegistry *from, boost::string_ref objPath) override
Remove a link to another object.
StatusCode reinitialize() override
unsigned int CLID
Class ID definition.
IOpaqueAddress * address() const override
Retrieve opaque storage address.
StatusCode retrieveEntry(DataSvcHelpers::RegistryEntry *pNode, boost::string_ref path, DataSvcHelpers::RegistryEntry *&pEntry)
Retrieve registry entry from store.
virtual DataObject * object() const =0
Retrieve object behind the link.
Definition of an entry in the transient data store.
std::unique_ptr< DataSvcHelpers::RegistryEntry > m_root
Pointer to root entry.
virtual unsigned long release()
release reference to object
StatusCode add(std::string name, DataObject *pObject, bool is_soft=false)
Add entry to data store.
virtual DataObject * createDefaultObject() const
Create default objects in case forced creation of leaves is requested.
virtual StatusCode fillObjRefs(IOpaqueAddress *pAddress, DataObject *pObject)=0
Resolve the references of the created transient object.
virtual unsigned long release()=0
Release Interface instance.
StatusCode finalize() override
Service initialization.
Generic data agent interface.
StatusCode clearSubTree(boost::string_ref sub_tree_path) override
IDataManagerSvc: Remove all data objects below the sub tree identified by its full path name...
std::vector< DataStoreItem > m_preLoads
Items to be pre-loaded.
RegistryEntry * parentEntry()
Pointer to parent registry entry.
virtual StatusCode i_setRoot(std::string root_name, DataObject *pRootObj)
Initialize data store for new event by giving new event path and root object.
const StatusCode & ignore() const
Ignore/check StatusCode.
decltype(auto) operator+(const T &v, const Property< TP, V, H > &p)
implemantation of (value + property)
IRegistry * find(const IRegistry *obj) const
Try to find an object identified by its pointer.
constexpr static const auto FAILURE
const std::string & name() const
Retreive DataObject name. It is the name when registered in the store.
bool checkRoot()
Check if root path is valid.
virtual unsigned long addRef()=0
Increment the reference count of Interface instance.
StatusCode traverseSubTree(boost::string_ref sub_tree_path, IDataStoreAgent *pAgent) override
IDataManagerSvc: Analyze by traversing all data objects below the sub tree identified by its full pat...
Gaudi::Property< bool > m_forceLeaves
StatusCode service(const std::string &name, const T *&psvc, bool createIf=true) const
Access a service by name, creating it if it doesn't already exist.
const std::string & identifier() const override
Full identifier (or key)
StatusCode remove(boost::string_ref name)
Remove an entry from the store.
StatusCode clearStore() override
IDataManagerSvc: Remove all data objects in the data store.
bool isEmpty() const
Simple check if the Container is empty.
StatusCode registerObject(boost::string_ref parentPath, boost::string_ref objPath, DataObject *pObject) override
Register object with the data store.
Data service incident class.
Opaque address interface definition.
CLID rootCLID() const override
IDataManagerSvc: Accessor for root event CLID.
virtual IOpaqueAddress * address() const =0
Retrieve opaque storage address.
Gaudi::Property< std::vector< std::string > > m_inhibitPathes
DataObject * handleDataFault(IRegistry *pReg, boost::string_ref path={})
Invoke data fault handling if enabled.
A DataObject is the base class of any identifiable object on any data store.
#define STD_LOCK_GUARD_MACRO
#define CAST_REGENTRY(x, y)
virtual StatusCode loadObject(IRegistry *pNode)
Invoke Persistency service to create transient object from its persistent representation.
StatusCode objectParent(const DataObject *pObject, IRegistry *&refpParent) override
IDataManagerSvc: Explore the object store: retrieve the object's parent.
MsgStream & endmsg(MsgStream &s)
MsgStream Modifier: endmsg. Calls the output method of the MsgStream.
Gaudi::Property< bool > m_enableFaultHdlr
Gaudi::Property< std::string > m_faultName
Gaudi::Property< std::string > m_rootName
void makeHard(DataObject *pObject)
Initialize link as hard link.