MultiStoreSvc Class Reference

Data service base class. More...

Inheritance diagram for MultiStoreSvc:

Collaboration diagram for MultiStoreSvc:

Classes
struct	tagROOT

Public Member Functions
CLID	rootCLID () const override
	IDataManagerSvc: Accessor for root event CLID. More...
const std::string &	rootName () const override
	Name for root Event. More...
STATUS	registerAddress (CSTR &path, ADDRESS *pAddr) override
	IDataManagerSvc: Register object address with the data store. More...
STATUS	registerAddress (OBJECT *parent, CSTR &path, ADDRESS *pAddr) override
	IDataManagerSvc: Register object address with the data store. More...
STATUS	registerAddress (IRegistry *parent, CSTR &path, ADDRESS *pAdd) override
	IDataManagerSvc: Register object address with the data store. More...
STATUS	unregisterAddress (CSTR &path) override
	IDataManagerSvc: Unregister object address from the data store. More...
STATUS	unregisterAddress (OBJECT *pParent, CSTR &path) override
	IDataManagerSvc: Unregister object address from the data store. More...
STATUS	unregisterAddress (IRegistry *pParent, CSTR &path) override
	IDataManagerSvc: Unregister object address from the data store. More...
STATUS	objectLeaves (const OBJECT *pObject, std::vector< IRegistry * > &leaves) override
	Explore the object store: retrieve all leaves attached to the object. More...
STATUS	objectLeaves (const IRegistry *pObject, std::vector< IRegistry * > &leaves) override
	Explore the object store: retrieve all leaves attached to the object. More...
STATUS	objectParent (const OBJECT *pObject, IRegistry *&refpParent) override
	IDataManagerSvc: Explore the object store: retrieve the object's parent. More...
STATUS	objectParent (const IRegistry *pObject, IRegistry *&refpParent) override
	IDataManagerSvc: Explore the object store: retrieve the object's parent. More...
STATUS	clearSubTree (CSTR &path) override
	Remove all data objects below the sub tree identified. More...
STATUS	clearSubTree (OBJECT *pObject) override
	Remove all data objects below the sub tree identified. More...
STATUS	clearStore () override
	IDataManagerSvc: Remove all data objects in the data store. More...
STATUS	traverseSubTree (CSTR &path, AGENT *pAgent) override
	Analyze by traversing all data objects below the sub tree. More...
STATUS	traverseSubTree (OBJECT *pObject, AGENT *pAgent) override
	IDataManagerSvc: Analyze by traversing all data objects below the sub tree. More...
STATUS	traverseTree (AGENT *pAgent) override
	IDataManagerSvc: Analyze by traversing all data objects in the data store. More...
STATUS	setRoot (std::string path, OBJECT *pObj) override
	Initialize data store for new event by giving new event path and root object. More...
STATUS	setRoot (std::string path, ADDRESS *pAddr) override
	Initialize data store for new event by giving new event path and address of root object. More...
STATUS	setDataLoader (IConversionSvc *pDataLoader, IDataProviderSvc *dpsvc=nullptr) override
	IDataManagerSvc: Pass a default data loader to the service. More...
STATUS	addPreLoadItem (const DataStoreItem &item) override
	Add an item to the preload list. More...
STATUS	addPreLoadItem (CSTR &item) override
	Add an item to the preload list. More...
STATUS	removePreLoadItem (const DataStoreItem &item) override
	Remove an item from the preload list. More...
STATUS	removePreLoadItem (CSTR &item) override
	Add an item to the preload list. More...
STATUS	resetPreLoad () override
	Clear the preload list. More...
STATUS	preLoad () override
	load all preload items of the list More...
STATUS	registerObject (CSTR &path, OBJECT *pObj) override
	Register object with the data store. More...
STATUS	registerObject (CSTR &parent, CSTR &obj, OBJECT *pObj) override
	Register object with the data store. More...
STATUS	registerObject (CSTR &parent, int item, OBJECT *pObj) override
	Register object with the data store. More...
STATUS	registerObject (OBJECT *parent, CSTR &obj, OBJECT *pObj) override
	Register object with the data store. More...
STATUS	registerObject (OBJECT *parent, int obj, OBJECT *pObj) override
	Register object with the data store. More...
STATUS	unregisterObject (CSTR &path) override
	Unregister object from the data store. More...
STATUS	unregisterObject (CSTR &parent, CSTR &obj) override
	Unregister object from the data store. More...
STATUS	unregisterObject (CSTR &parent, int obj) override
	Unregister object from the data store. More...
STATUS	unregisterObject (OBJECT *pObj) override
	Unregister object from the data store. More...
STATUS	unregisterObject (OBJECT *pObj, CSTR &path) override
	Unregister object from the data store. More...
STATUS	unregisterObject (OBJECT *pObj, int item) override
	Unregister object from the data store. More...
STATUS	retrieveObject (IRegistry *parent, CSTR &path, OBJECT *&pObj) override
	Retrieve object from data store. More...
STATUS	retrieveObject (CSTR &path, OBJECT *&pObj) override
	Retrieve object identified by its full path from the data store. More...
STATUS	retrieveObject (CSTR &parent, CSTR &path, OBJECT *&pObj) override
	Retrieve object from data store. More...
STATUS	retrieveObject (CSTR &parent, int item, OBJECT *&pObj) override
	Retrieve object from data store. More...
STATUS	retrieveObject (OBJECT *parent, CSTR &path, OBJECT *&pObj) override
	Retrieve object from data store. More...
STATUS	retrieveObject (OBJECT *parent, int item, OBJECT *&pObj) override
	Retrieve object from data store. More...
STATUS	findObject (CSTR &path, OBJECT *&pObj) override
	Find object identified by its full path in the data store. More...
STATUS	findObject (IRegistry *parent, CSTR &path, OBJECT *&pObj) override
	Find object identified by its full path in the data store. More...
STATUS	findObject (CSTR &parent, CSTR &path, OBJECT *&pObj) override
	Find object in the data store. More...
STATUS	findObject (CSTR &parent, int item, OBJECT *&pObject) override
	Find object in the data store. More...
STATUS	findObject (OBJECT *parent, CSTR &path, OBJECT *&pObject) override
	Find object in the data store. More...
STATUS	findObject (OBJECT *parent, int item, OBJECT *&pObject) override
	Find object in the data store. More...
STATUS	linkObject (IRegistry *from, CSTR &objPath, OBJECT *to) override
	Add a link to another object. More...
STATUS	linkObject (CSTR &from, CSTR &objPath, OBJECT *to) override
	Add a link to another object. More...
STATUS	linkObject (OBJECT *from, CSTR &objPath, OBJECT *to) override
	Add a link to another object. More...
STATUS	linkObject (CSTR &fullPath, OBJECT *to) override
	Add a link to another object. More...
STATUS	unlinkObject (IRegistry *from, CSTR &objPath) override
	Remove a link to another object. More...
STATUS	unlinkObject (CSTR &from, CSTR &objPath) override
	Remove a link to another object. More...
STATUS	unlinkObject (OBJECT *from, CSTR &objPath) override
	Remove a link to another object. More...
STATUS	unlinkObject (CSTR &path) override
	Remove a link to another object. More...
STATUS	updateObject (IRegistry *pDirectory) override
	Update object identified by its directory entry. More...
STATUS	updateObject (CSTR &path) override
	Update object. More...
STATUS	updateObject (OBJECT *pObj) override
	Update object. More...
STATUS	updateObject (CSTR &parent, CSTR &updatePath) override
	Update object. More...
STATUS	updateObject (OBJECT *parent, CSTR &updatePath) override
	Update object. More...
STATUS	create (CSTR &nam, CSTR &typ) override
	Create a partition object. The name identifies the partition uniquely. More...
STATUS	create (CSTR &nam, CSTR &typ, IInterface *&pPartition) override
	Create a partition object. The name identifies the partition uniquely. More...
STATUS	drop (CSTR &nam) override
	Drop a partition object. The name identifies the partition uniquely. More...
STATUS	drop (IInterface *pPartition) override
	Drop a partition object. The name identifies the partition uniquely. More...
STATUS	activate (CSTR &nam) override
	Activate a partition object. The name identifies the partition uniquely. More...
STATUS	activate (IInterface *pPartition) override
	Activate a partition object. More...
STATUS	get (CSTR &nam, IInterface *&pPartition) const override
	Access a partition object. The name identifies the partition uniquely. More...
StatusCode	activePartition (std::string &nam, IInterface *&pPartition) const override
	Access the active partition object. More...
STATUS	attachServices ()
STATUS	detachServices ()
STATUS	initialize () override
	Service initialisation. More...
STATUS	reinitialize () override
	Service initialisation. More...
STATUS	finalize () override
	Service initialisation. More...
	MultiStoreSvc (CSTR &name, ISvcLocator *svc)
	Standard Constructor. More...
	~MultiStoreSvc () override
	Standard Destructor. More...
STATUS	preparePartitions ()
	Prepare partition for usage. More...
STATUS	clearPartitions ()
	Clear all partitions. More...
STATUS	makePartitions ()
	Create all partitions according to job options. 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 Types
enum	{ no_type = 0, address_type = 1, object_type = 2 }
	Root type (address or object) More...
typedef std::vector< std::string >	PartitionDefs
typedef std::map< std::string, Partition >	Partitions

Protected Member Functions
template<typename... Args, typename... UArgs>
STATUS	call_ (STATUS(IDataProviderSvc::*pmf)(Args...), UArgs &&...args)
template<typename... Args, typename... UArgs>
STATUS	call_ (STATUS(IDataManagerSvc::*pmf)(Args...), UArgs &&...args)

Protected Attributes
CLID	m_rootCLID
	Integer Property corresponding to CLID of root entry. More...
std::string	m_rootName
	Name of root event. More...
std::string	m_loader
	Data loader name. More...
SmartIF< IConversionSvc >	m_dataLoader
	Pointer to data loader service. More...
SmartIF< IAddressCreator >	m_addrCreator
	Reference to address creator. More...
struct MultiStoreSvc::tagROOT	m_root
Partition	m_current
	Current partition. More...
Partitions	m_partitions
	Datastore partitions. More...
PartitionDefs	m_partitionDefs
	Datastore partition definitions. More...
std::string	m_defaultPartition
	Default partition. More...

Additional Inherited Members
Public Types inherited from extends< BASE, Interfaces >
using	base_class = extends
	Typedef to this class. More...
using	extend_interfaces_base = extend_interfaces< Interfaces...>
	Typedef to the base of this class. More...
using	base_class = extends
	Typedef to this class. More...
using	extend_interfaces_base = extend_interfaces< Interfaces...>
	Typedef to the base of this class. More...
Public Types inherited from extend_interfaces< Interfaces...>
using	ext_iids = typename Gaudi::interface_list_cat< typename Interfaces::ext_iids...>::type
	take union of the ext_iids of all Interfaces... More...
using	ext_iids = typename Gaudi::interface_list_cat< typename Interfaces::ext_iids...>::type
	take union of the ext_iids of all Interfaces... More...

Detailed Description

Data service base class.

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

Author

Markus Frank

Sebastien Ponce

Version

1.0

Definition at line 67 of file MultiStoreSvc.cpp.

Member Typedef Documentation

typedef std::vector<std::string> MultiStoreSvc::PartitionDefs

protected

Definition at line 73 of file MultiStoreSvc.cpp.

typedef std::map<std::string, Partition> MultiStoreSvc::Partitions

protected

Definition at line 74 of file MultiStoreSvc.cpp.

Member Enumeration Documentation

anonymous enum

protected

Root type (address or object)

Enumerator
no_type
address_type
object_type

Definition at line 86 of file MultiStoreSvc.cpp.

{ no_type = 0, address_type = 1, object_type = 2};

Constructor & Destructor Documentation

MultiStoreSvc::MultiStoreSvc ( CSTR &  name, ISvcLocator *  svc  )

inline

Standard Constructor.

Definition at line 605 of file MultiStoreSvc.cpp.

  : base_class(name,svc)
  {
    declareProperty("RootCLID",         m_rootCLID = 110);
    declareProperty("RootName",         m_rootName = "/Event");
    declareProperty("Partitions",       m_partitionDefs);
    declareProperty("DataLoader",       m_loader="EventPersistencySvc");
    declareProperty("DefaultPartition", m_defaultPartition="Default");
  }

MultiStoreSvc::~MultiStoreSvc ( )

inlineoverride

Standard Destructor.

Definition at line 616 of file MultiStoreSvc.cpp.

                            {
    setDataLoader(nullptr).ignore();
    resetPreLoad().ignore();
    clearStore().ignore();
    clearPartitions().ignore();
  }

Member Function Documentation

STATUS MultiStoreSvc::activate ( CSTR &  nam )

inlineoverride

Activate a partition object. The name identifies the partition uniquely.

Definition at line 475 of file MultiStoreSvc.cpp.

                                      {
    auto i = m_partitions.find(nam);
    if ( i != m_partitions.end() )  {
      m_current = i->second;
      return STATUS::SUCCESS;
    }
    m_current = Partition();
    return PARTITION_NOT_PRESENT;
  }

STATUS MultiStoreSvc::activate ( IInterface *  pPartition )

inlineoverride

Activate a partition object.

Definition at line 486 of file MultiStoreSvc.cpp.

                                                   {
    auto provider = SmartIF<IDataProviderSvc>(pPartition);
    m_current = Partition();
    if ( !provider )  return NO_INTERFACE;
    auto i = std::find_if(std::begin(m_partitions), std::end(m_partitions),
                          [&](Partitions::const_reference p) {
            return p.second.dataProvider == provider;
    } );
    if (i == std::end(m_partitions)) return PARTITION_NOT_PRESENT;
    m_current = i->second;
    return STATUS::SUCCESS;
  }

StatusCode MultiStoreSvc::activePartition ( std::string &  nam, IInterface *&  pPartition  ) const

inlineoverride

Access the active partition object.

Definition at line 511 of file MultiStoreSvc.cpp.

                                                                                     {
    if ( m_current.dataProvider )  {
      nam = m_current.name;
      pPartition = m_current.dataProvider;
      return STATUS::SUCCESS;
    }
    nam.clear();
    pPartition = nullptr;
    return NO_ACTIVE_PARTITION;
  }

STATUS MultiStoreSvc::addPreLoadItem ( const DataStoreItem &  item )

inlineoverride

Add an item to the preload list.

Definition at line 262 of file MultiStoreSvc.cpp.

                                                            {
    return call_<const DataStoreItem&>( &IDataProviderSvc::addPreLoadItem, item);
  }

STATUS MultiStoreSvc::addPreLoadItem ( CSTR &  item )

inlineoverride

Add an item to the preload list.

Definition at line 266 of file MultiStoreSvc.cpp.

                                             {
    return call_<CSTR&>( &IDataProviderSvc::addPreLoadItem, item);
  }

STATUS MultiStoreSvc::attachServices ( )

inline

Definition at line 522 of file MultiStoreSvc.cpp.

                           {
    MsgStream log(msgSvc(), name());
    // Attach address creator facility
    m_addrCreator = service(m_loader, true);
    if (!m_addrCreator) {
      log << MSG::ERROR
          << "Failed to retrieve data loader "
          << "\"" << m_loader << "\"" << endmsg;
      return StatusCode::FAILURE;
    }
    // Attach data loader facility
    auto dataLoader = service<IConversionSvc>(m_loader, true);
    if (!dataLoader) {
      log << MSG::ERROR << "Failed to retrieve data loader "
          << "\"" << m_loader << "\"" << endmsg;
      return StatusCode::FAILURE;
    }
    auto sc = setDataLoader(dataLoader.get());
    if (!sc.isSuccess()) {
      log << MSG::ERROR << "Failed to set data loader "
          << "\"" << m_loader << "\"" << endmsg;
    }
    return sc;
  }

template<typename... Args, typename... UArgs>

STATUS MultiStoreSvc::call_ ( STATUS(IDataProviderSvc::*)(Args...)  pmf, UArgs &&...  args  )

inlineprotected

Definition at line 107 of file MultiStoreSvc.cpp.

  {
    return m_current.dataProvider ? (m_current.dataProvider->*pmf)(std::forward<UArgs>(args)...)
                                  : IDataProviderSvc::INVALID_ROOT;
  }

template<typename... Args, typename... UArgs>

STATUS MultiStoreSvc::call_ ( STATUS(IDataManagerSvc::*)(Args...)  pmf, UArgs &&...  args  )

inlineprotected

Definition at line 113 of file MultiStoreSvc.cpp.

  {
    return m_current.dataManager ? (m_current.dataManager->*pmf)(std::forward<UArgs>(args)...)
                                  : IDataProviderSvc::INVALID_ROOT;
  }

STATUS MultiStoreSvc::clearPartitions ( )

inline

Clear all partitions.

Definition at line 660 of file MultiStoreSvc.cpp.

                            {
    for(auto &i : m_partitions) i.second.dataManager->clearStore().ignore();
    m_partitions.clear();
    return STATUS::SUCCESS;
  }

STATUS MultiStoreSvc::clearStore ( )

inlineoverride

IDataManagerSvc: Remove all data objects in the data store.

Definition at line 178 of file MultiStoreSvc.cpp.

                               {
    for(auto &i : m_partitions) {
      i.second.dataManager->clearStore().ignore();
    }
    if ( m_root.root.object )  {
      switch ( m_root.type )  {
        case address_type:
          m_root.root.address->release();
          break;
        case object_type:
          m_root.root.object->release();
          break;
      }
      m_root.root.object = nullptr;
    }
    m_root.path.clear();
    m_root.type = no_type;
    return STATUS::SUCCESS;
  }

STATUS MultiStoreSvc::clearSubTree ( CSTR &  path )

inlineoverride

Remove all data objects below the sub tree identified.

Definition at line 170 of file MultiStoreSvc.cpp.

                                           {
    return call_<CSTR&>( &IDataManagerSvc::clearSubTree, path);
  }

STATUS MultiStoreSvc::clearSubTree ( OBJECT *  pObject )

inlineoverride

Remove all data objects below the sub tree identified.

Definition at line 174 of file MultiStoreSvc.cpp.

                                                {
    return call_<OBJECT*>( &IDataManagerSvc::clearSubTree, pObject);
  }

STATUS MultiStoreSvc::create ( CSTR &  nam, CSTR &  typ  )

inlineoverride

Create a partition object. The name identifies the partition uniquely.

Definition at line 431 of file MultiStoreSvc.cpp.

                                               {
    IInterface* pPartition = nullptr;
    return create(nam, typ, pPartition);
  }

STATUS MultiStoreSvc::create ( CSTR &  nam, CSTR &  typ, IInterface *&  pPartition  )

inlineoverride

Create a partition object. The name identifies the partition uniquely.

Fix-Me:

: In the old implementation the services were "unmanaged" (non-active)

Definition at line 436 of file MultiStoreSvc.cpp.

                                                                        {
    if ( get(nam, pPartition).isSuccess() )  return PARTITION_EXISTS;
    auto isvc = serviceLocator()->service<IService>(typ);
    if (!isvc) return NO_INTERFACE;
    auto dataMgr = isvc.as<IDataManagerSvc>();
    auto dataProv = isvc.as<IDataProviderSvc>();
    if ( !dataMgr || !dataProv ) return NO_INTERFACE;
    m_partitions.emplace( nam, Partition{ dataProv, dataMgr, nam }  );
    return STATUS::SUCCESS;
  }

STATUS MultiStoreSvc::detachServices ( )

inline

Definition at line 547 of file MultiStoreSvc.cpp.

                           {
    m_addrCreator.reset();
    m_dataLoader.reset();
    return STATUS::SUCCESS;
  }

STATUS MultiStoreSvc::drop ( CSTR &  nam )

inlineoverride

Drop a partition object. The name identifies the partition uniquely.

Definition at line 449 of file MultiStoreSvc.cpp.

                                  {
    auto i = m_partitions.find(nam);
    if ( i == m_partitions.end() )  return PARTITION_NOT_PRESENT;
    if ( i->second.dataManager == m_current.dataManager )  {
      m_current = Partition();
    }
    i->second.dataManager->clearStore().ignore();
    m_partitions.erase(i);
    return STATUS::SUCCESS;
  }

STATUS MultiStoreSvc::drop ( IInterface *  pPartition )

inlineoverride

Drop a partition object. The name identifies the partition uniquely.

Definition at line 461 of file MultiStoreSvc.cpp.

                                               {
    auto provider = SmartIF<IDataProviderSvc>(pPartition);
    if ( !provider )  return NO_INTERFACE;
    auto i = std::find_if( std::begin(m_partitions), std::end(m_partitions),
                           [&](Partitions::const_reference p) {
        return p.second.dataProvider == provider;
    } );
    if (i==std::end(m_partitions)) return PARTITION_NOT_PRESENT;
    i->second.dataManager->clearStore().ignore();
    m_partitions.erase(i);
    return STATUS::SUCCESS;
  }

STATUS MultiStoreSvc::finalize ( )

inlineoverride

Service initialisation.

Definition at line 592 of file MultiStoreSvc.cpp.

                             {
    setDataLoader(nullptr).ignore();
    clearStore().ignore();
    clearPartitions().ignore();
    m_current = Partition();
    detachServices();
    return Service::finalize();
  }

STATUS MultiStoreSvc::findObject ( CSTR &  path, OBJECT *&  pObj  )

inlineoverride

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

Definition at line 354 of file MultiStoreSvc.cpp.

                                                        {
    return call_<CSTR&,OBJECT*&>( &IDataProviderSvc::retrieveObject, path, pObj);
  }

STATUS MultiStoreSvc::findObject ( IRegistry *  parent, CSTR &  path, OBJECT *&  pObj  )

inlineoverride

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

Definition at line 358 of file MultiStoreSvc.cpp.

                                                                           {
    return call_<IRegistry*,CSTR&,OBJECT*&>( &IDataProviderSvc::findObject, parent, path, pObj);
  }

STATUS MultiStoreSvc::findObject ( CSTR &  parent, CSTR &  path, OBJECT *&  pObj  )

inlineoverride

Find object in the data store.

Definition at line 362 of file MultiStoreSvc.cpp.

                                                                      {
    return call_<CSTR&,CSTR&,OBJECT*&>( &IDataProviderSvc::retrieveObject, parent, path, pObj);
  }

STATUS MultiStoreSvc::findObject ( CSTR &  parent, int  item, OBJECT *&  pObject  )

inlineoverride

Find object in the data store.

Definition at line 366 of file MultiStoreSvc.cpp.

                                                                        {
    return call_<CSTR&,int,OBJECT*&>( &IDataProviderSvc::findObject, parent, item, pObject);
  }

STATUS MultiStoreSvc::findObject ( OBJECT *  parent, CSTR &  path, OBJECT *&  pObject  )

inlineoverride

Find object in the data store.

Definition at line 370 of file MultiStoreSvc.cpp.

                                                                           {
    return call_<OBJECT*,CSTR&,OBJECT*&>( &IDataProviderSvc::findObject, parent, path, pObject);
  }

STATUS MultiStoreSvc::findObject ( OBJECT *  parent, int  item, OBJECT *&  pObject  )

inlineoverride

Find object in the data store.

Definition at line 374 of file MultiStoreSvc.cpp.

                                                                         {
    return call_<OBJECT*,int,OBJECT*&>( &IDataProviderSvc::findObject, parent, item, pObject);
  }

STATUS MultiStoreSvc::get ( CSTR &  nam, IInterface *&  pPartition  ) const

inlineoverride

Access a partition object. The name identifies the partition uniquely.

Definition at line 500 of file MultiStoreSvc.cpp.

                                                                {
    auto i = m_partitions.find(nam);
    if ( i != m_partitions.end() )  {
      pPartition = i->second.dataProvider;
      return STATUS::SUCCESS;
    }
    pPartition = nullptr;
    return PARTITION_NOT_PRESENT;
  }

STATUS MultiStoreSvc::initialize ( )

inlineoverride

Service initialisation.

Definition at line 554 of file MultiStoreSvc.cpp.

                               {
    // Nothing to do: just call base class initialisation
    STATUS sc = Service::initialize();
    if ( !sc.isSuccess() )  return sc;
    sc = makePartitions();
    if (!sc.isSuccess()) {
      MsgStream log(msgSvc(), name());
      log << MSG::ERROR << "Failed to connect to all store partitions." << endmsg;
      return sc;
    }
    return attachServices();
  }

STATUS MultiStoreSvc::linkObject ( IRegistry *  from, CSTR &  objPath, OBJECT *  to  )

inlineoverride

Add a link to another object.

Definition at line 378 of file MultiStoreSvc.cpp.

                                                                         {
    return call_<IRegistry*,CSTR&,OBJECT*>( &IDataProviderSvc::linkObject, from, objPath, to);
  }

STATUS MultiStoreSvc::linkObject ( CSTR &  from, CSTR &  objPath, OBJECT *  to  )

inlineoverride

Add a link to another object.

Definition at line 382 of file MultiStoreSvc.cpp.

                                                                    {
    return call_<CSTR&,CSTR&,OBJECT*>( &IDataProviderSvc::linkObject, from, objPath, to);
  }

STATUS MultiStoreSvc::linkObject ( OBJECT *  from, CSTR &  objPath, OBJECT *  to  )

inlineoverride

Add a link to another object.

Definition at line 386 of file MultiStoreSvc.cpp.

                                                                      {
    return call_<OBJECT*,CSTR&,OBJECT*>( &IDataProviderSvc::linkObject, from, objPath, to);
  }

STATUS MultiStoreSvc::linkObject ( CSTR &  fullPath, OBJECT *  to  )

inlineoverride

Add a link to another object.

Definition at line 390 of file MultiStoreSvc.cpp.

                                                         {
    return call_<CSTR&,OBJECT*>( &IDataProviderSvc::linkObject, fullPath, to);
  }

STATUS MultiStoreSvc::makePartitions ( )

inline

Create all partitions according to job options.

Definition at line 667 of file MultiStoreSvc.cpp.

                           {
    using Parser = Gaudi::Utils::AttribStringParser;
    std::string typ, nam;
    clearPartitions().ignore();
    for(auto part: m_partitionDefs)  {
      for(auto attrib: Parser(std::move(part)))   {
        switch( ::toupper(attrib.tag[0]) )    {
        case 'N':
          nam = std::move(attrib.value);
          break;
        case 'T':
          typ = std::move(attrib.value);
          break;
        }
      }
      STATUS sc = create(nam, typ);
      if ( !sc.isSuccess() )  return sc;
      if ( m_defaultPartition.empty() )  m_defaultPartition = nam;
    }
    return STATUS::SUCCESS;
  }

STATUS MultiStoreSvc::objectLeaves ( const OBJECT *  pObject, std::vector< IRegistry * > &  leaves  )

inlineoverride

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

Definition at line 154 of file MultiStoreSvc.cpp.

                                                                                      {
    return call_<const OBJECT*,std::vector<IRegistry*>&>(&IDataManagerSvc::objectLeaves, pObject, leaves);
  }

STATUS MultiStoreSvc::objectLeaves ( const IRegistry *  pObject, std::vector< IRegistry * > &  leaves  )

inlineoverride

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

Definition at line 158 of file MultiStoreSvc.cpp.

                                                                                        {
    return call_<const IRegistry*,std::vector<IRegistry*>&>( &IDataManagerSvc::objectLeaves, pObject, leaves);
  }

STATUS MultiStoreSvc::objectParent ( const OBJECT *  pObject, IRegistry *&  refpParent  )

inlineoverride

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

Definition at line 162 of file MultiStoreSvc.cpp.

                                                                              {
    return call_<const OBJECT*, IRegistry*&>( &IDataManagerSvc::objectParent, pObject, refpParent);
  }

STATUS MultiStoreSvc::objectParent ( const IRegistry *  pObject, IRegistry *&  refpParent  )

inlineoverride

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

Definition at line 166 of file MultiStoreSvc.cpp.

                                                                                 {
    return call_<const IRegistry*, IRegistry*&>( &IDataManagerSvc::objectParent, pObject, refpParent);
  }

STATUS MultiStoreSvc::preLoad ( )

inlineoverride

load all preload items of the list

Definition at line 282 of file MultiStoreSvc.cpp.

                            {
    return call_<>( &IDataProviderSvc::preLoad );
  }

STATUS MultiStoreSvc::preparePartitions ( )

inline

Prepare partition for usage.

Definition at line 624 of file MultiStoreSvc.cpp.

                              {
    STATUS iret = STATUS::SUCCESS;
    for(auto& i : m_partitions) {
      STATUS sc = STATUS::FAILURE;
      switch ( m_root.type )  {
        case address_type:
          if ( m_root.root.address )  {
            ADDRESS* pAdd = nullptr;
            ADDRESS* p = m_root.root.address;
            sc = m_addrCreator->createAddress(p->svcType(),
                                              p->clID(),
                                              p->par(),
                                              p->ipar(),
                                              pAdd);
            if ( sc.isSuccess() )  {
            sc = i.second.dataManager->setRoot(m_root.path, pAdd);
            }
          }
          break;
        case object_type:
          if ( m_root.root.object )  {
            if ( m_root.root.object->clID() == CLID_DataObject )  {
              sc = i.second.dataManager->setRoot(m_root.path, new DataObject());
            }
          }
          break;
        default:
          sc = STATUS::FAILURE;
          break;
      }
      if ( !sc.isSuccess() )  iret = sc;
    }
    return iret;
  }

STATUS MultiStoreSvc::registerAddress ( CSTR &  path, ADDRESS *  pAddr  )

inlineoverride

IDataManagerSvc: Register object address with the data store.

Definition at line 130 of file MultiStoreSvc.cpp.

                                                              {
    return call_<CSTR&,ADDRESS*>( &IDataManagerSvc::registerAddress, path, pAddr);
  }

STATUS MultiStoreSvc::registerAddress ( OBJECT *  parent, CSTR &  path, ADDRESS *  pAddr  )

inlineoverride

IDataManagerSvc: Register object address with the data store.

Definition at line 134 of file MultiStoreSvc.cpp.

                                                                              {
    return call_<OBJECT*,CSTR&,ADDRESS*>( &IDataManagerSvc::registerAddress, parent, path, pAddr);
  }

STATUS MultiStoreSvc::registerAddress ( IRegistry *  parent, CSTR &  path, ADDRESS *  pAdd  )

inlineoverride

IDataManagerSvc: Register object address with the data store.

Definition at line 138 of file MultiStoreSvc.cpp.

                                                                                {
    return call_<IRegistry*,CSTR&,ADDRESS*>( &IDataManagerSvc::registerAddress, parent, path, pAdd);
  }

STATUS MultiStoreSvc::registerObject ( CSTR &  path, OBJECT *  pObj  )

inlineoverride

Register object with the data store.

Definition at line 286 of file MultiStoreSvc.cpp.

                                                           {
    return registerObject(nullptr, path, pObj);
  }

STATUS MultiStoreSvc::registerObject ( CSTR &  parent, CSTR &  obj, OBJECT *  pObj  )

inlineoverride

Register object with the data store.

Definition at line 290 of file MultiStoreSvc.cpp.

                                                                        {
    return call_<CSTR&,CSTR&,OBJECT*>(&IDataProviderSvc::registerObject, parent,obj,pObj);
  }

STATUS MultiStoreSvc::registerObject ( CSTR &  parent, int  item, OBJECT *  pObj  )

inlineoverride

Register object with the data store.

Definition at line 294 of file MultiStoreSvc.cpp.

                                                                       {
    return call_<CSTR&,int,OBJECT*>( &IDataProviderSvc::registerObject, parent, item, pObj);
  }

STATUS MultiStoreSvc::registerObject ( OBJECT *  parent, CSTR &  obj, OBJECT *  pObj  )

inlineoverride

Register object with the data store.

Definition at line 298 of file MultiStoreSvc.cpp.

                                                                          {
    return call_<OBJECT*,CSTR&,OBJECT*>( &IDataProviderSvc::registerObject, parent, obj, pObj);
  }

STATUS MultiStoreSvc::registerObject ( OBJECT *  parent, int  obj, OBJECT *  pObj  )

inlineoverride

Register object with the data store.

Definition at line 302 of file MultiStoreSvc.cpp.

                                                                        {
    return call_<OBJECT*,int,OBJECT*>( &IDataProviderSvc::registerObject, parent, obj, pObj);
  }

STATUS MultiStoreSvc::reinitialize ( )

inlineoverride

Service initialisation.

Definition at line 568 of file MultiStoreSvc.cpp.

                                 {
    STATUS sc = Service::reinitialize();
    MsgStream log(msgSvc(), name());
    if (!sc.isSuccess()) {
      log << MSG::ERROR << "Enable to reinitialize base class"
          << endmsg;
      return sc;
    }
    detachServices();
    sc = attachServices();
    if ( !sc.isSuccess() )  {
      log << MSG::ERROR << "Failed to attach necessary services." << endmsg;
      return sc;
    }
    sc = makePartitions();
    if (!sc.isSuccess()) {
      log << MSG::ERROR << "Failed to connect to store partitions." << endmsg;
      return sc;
    }
    // return
    return STATUS::SUCCESS;
  }

STATUS MultiStoreSvc::removePreLoadItem ( const DataStoreItem &  item )

inlineoverride

Remove an item from the preload list.

Definition at line 270 of file MultiStoreSvc.cpp.

                                                               {
    return call_<const DataStoreItem&>( &IDataProviderSvc::removePreLoadItem, item);
  }

STATUS MultiStoreSvc::removePreLoadItem ( CSTR &  item )

inlineoverride

Add an item to the preload list.

Definition at line 274 of file MultiStoreSvc.cpp.

                                                {
    return call_<CSTR&>( &IDataProviderSvc::removePreLoadItem, item);
  }

STATUS MultiStoreSvc::resetPreLoad ( )

inlineoverride

Clear the preload list.

Definition at line 278 of file MultiStoreSvc.cpp.

                                 {
    return call_<>( &IDataProviderSvc::resetPreLoad);
  }

STATUS MultiStoreSvc::retrieveObject ( IRegistry *  parent, CSTR &  path, OBJECT *&  pObj  )

inlineoverride

Retrieve object from data store.

Definition at line 330 of file MultiStoreSvc.cpp.

                                                                                {
    return call_<IRegistry*,CSTR&,OBJECT*&>( &IDataProviderSvc::retrieveObject, parent, path, pObj);
  }

STATUS MultiStoreSvc::retrieveObject ( CSTR &  path, OBJECT *&  pObj  )

inlineoverride

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

Definition at line 334 of file MultiStoreSvc.cpp.

                                                            {
    return call_<CSTR&,OBJECT*&>( &IDataProviderSvc::retrieveObject, path, pObj);
  }

STATUS MultiStoreSvc::retrieveObject ( CSTR &  parent, CSTR &  path, OBJECT *&  pObj  )

inlineoverride

Retrieve object from data store.

Definition at line 338 of file MultiStoreSvc.cpp.

                                                                           {
    return call_<CSTR&,CSTR&,OBJECT*&>( &IDataProviderSvc::retrieveObject, parent, path, pObj);
  }

STATUS MultiStoreSvc::retrieveObject ( CSTR &  parent, int  item, OBJECT *&  pObj  )

inlineoverride

Retrieve object from data store.

Definition at line 342 of file MultiStoreSvc.cpp.

                                                                        {
    return call_<CSTR&,int,OBJECT*&>( &IDataProviderSvc::retrieveObject, parent, item, pObj);
  }

STATUS MultiStoreSvc::retrieveObject ( OBJECT *  parent, CSTR &  path, OBJECT *&  pObj  )

inlineoverride

Retrieve object from data store.

Definition at line 346 of file MultiStoreSvc.cpp.

                                                                             {
    return call_<OBJECT*,CSTR&,OBJECT*&>( &IDataProviderSvc::retrieveObject, parent, path, pObj);
  }

STATUS MultiStoreSvc::retrieveObject ( OBJECT *  parent, int  item, OBJECT *&  pObj  )

inlineoverride

Retrieve object from data store.

Definition at line 350 of file MultiStoreSvc.cpp.

                                                                           {
    return call_<OBJECT*,int,OBJECT*&>( &IDataProviderSvc::retrieveObject, parent, item, pObj);
  }

CLID MultiStoreSvc::rootCLID ( ) const

inlineoverride

IDataManagerSvc: Accessor for root event CLID.

Definition at line 121 of file MultiStoreSvc.cpp.

                                 {
    return m_rootCLID;
  }

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

inlineoverride

Name for root Event.

Definition at line 125 of file MultiStoreSvc.cpp.

                                             {
    return m_rootName;
  }

STATUS MultiStoreSvc::setDataLoader ( IConversionSvc *  pDataLoader, IDataProviderSvc *  dpsvc = nullptr  )

inlineoverride

IDataManagerSvc: Pass a default data loader to the service.

Definition at line 253 of file MultiStoreSvc.cpp.

                                                                                                {
    m_dataLoader = pDataLoader;
    if ( m_dataLoader ) m_dataLoader->setDataProvider(dpsvc ? dpsvc : this);
    for(auto& i : m_partitions) {
      i.second.dataManager->setDataLoader(m_dataLoader.get()).ignore();
    }
    return SUCCESS;
  }

STATUS MultiStoreSvc::setRoot ( std::string  path, OBJECT *  pObj  )

inlineoverride

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 211 of file MultiStoreSvc.cpp.

                                                         {
    if ( m_root.root.object )  {
      switch ( m_root.type )  {
        case address_type:
          m_root.root.address->release();
          break;
        case object_type:
          m_root.root.object->release();
          break;
      }
    }
    m_root.path    = std::move(path);
    m_root.type    = object_type;
    m_root.root.object  = pObj;
    preparePartitions();
    return activate(m_defaultPartition);
  }

STATUS MultiStoreSvc::setRoot ( std::string  path, ADDRESS *  pAddr  )

inlineoverride

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 231 of file MultiStoreSvc.cpp.

                                                           {
    if ( m_root.root.object )  {
      switch ( m_root.type )  {
        case address_type:
          m_root.root.address->release();
          break;
        case object_type:
          m_root.root.object->release();
          break;
      }
    }
    m_root.path    = std::move(path);
    m_root.type    = address_type;
    m_root.root.address = pAddr;
    if ( m_root.root.address )  {
      m_root.root.address->addRef();
      preparePartitions();
      return activate(m_defaultPartition);
    }
    return STATUS::FAILURE;
  }

STATUS MultiStoreSvc::traverseSubTree ( CSTR &  path, AGENT *  pAgent  )

inlineoverride

Analyze by traversing all data objects below the sub tree.

Definition at line 198 of file MultiStoreSvc.cpp.

                                                             {
    return call_<CSTR&,AGENT*>( &IDataManagerSvc::traverseSubTree, path, pAgent);
  }

STATUS MultiStoreSvc::traverseSubTree ( OBJECT *  pObject, AGENT *  pAgent  )

inlineoverride

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

Definition at line 202 of file MultiStoreSvc.cpp.

                                                                  {
    return call_<OBJECT*,AGENT*>( &IDataManagerSvc::traverseSubTree, pObject, pAgent);
  }

STATUS MultiStoreSvc::traverseTree ( AGENT *  pAgent )

inlineoverride

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

Definition at line 206 of file MultiStoreSvc.cpp.

                                                {
    return call_<AGENT*>( &IDataManagerSvc::traverseTree, pAgent);
  }

STATUS MultiStoreSvc::unlinkObject ( IRegistry *  from, CSTR &  objPath  )

inlineoverride

Remove a link to another object.

Definition at line 394 of file MultiStoreSvc.cpp.

                                                               {
    return call_<IRegistry*,CSTR&>( &IDataProviderSvc::unlinkObject, from, objPath);
  }

STATUS MultiStoreSvc::unlinkObject ( CSTR &  from, CSTR &  objPath  )

inlineoverride

Remove a link to another object.

Definition at line 398 of file MultiStoreSvc.cpp.

                                                          {
    return call_<CSTR&,CSTR&>( &IDataProviderSvc::unlinkObject, from, objPath);
  }

STATUS MultiStoreSvc::unlinkObject ( OBJECT *  from, CSTR &  objPath  )

inlineoverride

Remove a link to another object.

Definition at line 402 of file MultiStoreSvc.cpp.

                                                            {
    return call_<OBJECT*,CSTR&>( &IDataProviderSvc::unlinkObject, from, objPath);
  }

STATUS MultiStoreSvc::unlinkObject ( CSTR &  path )

inlineoverride

Remove a link to another object.

Definition at line 406 of file MultiStoreSvc.cpp.

                                           {
    return call_<CSTR&>( &IDataProviderSvc::unlinkObject, path);
  }

STATUS MultiStoreSvc::unregisterAddress ( CSTR &  path )

inlineoverride

IDataManagerSvc: Unregister object address from the data store.

Definition at line 142 of file MultiStoreSvc.cpp.

                                                {
    return call_<CSTR&>( &IDataManagerSvc::unregisterAddress, path);
  }

STATUS MultiStoreSvc::unregisterAddress ( OBJECT *  pParent, CSTR &  path  )

inlineoverride

IDataManagerSvc: Unregister object address from the data store.

Definition at line 146 of file MultiStoreSvc.cpp.

                                                                 {
    return call_<OBJECT*,CSTR&>( &IDataManagerSvc::unregisterAddress, pParent, path);
  }

STATUS MultiStoreSvc::unregisterAddress ( IRegistry *  pParent, CSTR &  path  )

inlineoverride

IDataManagerSvc: Unregister object address from the data store.

Definition at line 150 of file MultiStoreSvc.cpp.

                                                                    {
    return call_<IRegistry*,CSTR&>( &IDataManagerSvc::unregisterAddress, pParent, path);
  }

STATUS MultiStoreSvc::unregisterObject ( CSTR &  path )

inlineoverride

Unregister object from the data store.

Definition at line 306 of file MultiStoreSvc.cpp.

                                               {
    return call_<CSTR&>( &IDataProviderSvc::unregisterObject, path);
  }

STATUS MultiStoreSvc::unregisterObject ( CSTR &  parent, CSTR &  obj  )

inlineoverride

Unregister object from the data store.

Definition at line 310 of file MultiStoreSvc.cpp.

                                                            {
    return call_<CSTR&,CSTR&>( &IDataProviderSvc::unregisterObject, parent, obj);
  }

STATUS MultiStoreSvc::unregisterObject ( CSTR &  parent, int  obj  )

inlineoverride

Unregister object from the data store.

Definition at line 314 of file MultiStoreSvc.cpp.

                                                          {
    return call_<CSTR&,int>( &IDataProviderSvc::unregisterObject, parent, obj);
  }

STATUS MultiStoreSvc::unregisterObject ( OBJECT *  pObj )

inlineoverride

Unregister object from the data store.

Definition at line 318 of file MultiStoreSvc.cpp.

                                                 {
    return call_<OBJECT*>( &IDataProviderSvc::unregisterObject, pObj);
  }

STATUS MultiStoreSvc::unregisterObject ( OBJECT *  pObj, CSTR &  path  )

inlineoverride

Unregister object from the data store.

Definition at line 322 of file MultiStoreSvc.cpp.

                                                             {
    return call_<OBJECT*,CSTR&>( &IDataProviderSvc::unregisterObject, pObj, path);
  }

STATUS MultiStoreSvc::unregisterObject ( OBJECT *  pObj, int  item  )

inlineoverride

Unregister object from the data store.

Definition at line 326 of file MultiStoreSvc.cpp.

                                                            {
    return call_<OBJECT*,int>( &IDataProviderSvc::unregisterObject, pObj, item);
  }

STATUS MultiStoreSvc::updateObject ( IRegistry *  pDirectory )

inlineoverride

Update object identified by its directory entry.

Definition at line 410 of file MultiStoreSvc.cpp.

                                                       {
    return call_<IRegistry*>( &IDataProviderSvc::updateObject, pDirectory);
  }

STATUS MultiStoreSvc::updateObject ( CSTR &  path )

inlineoverride

Update object.

Definition at line 414 of file MultiStoreSvc.cpp.

                                           {
    return call_<CSTR&>( &IDataProviderSvc::updateObject, path);
  }

STATUS MultiStoreSvc::updateObject ( OBJECT *  pObj )

inlineoverride

Update object.

Definition at line 418 of file MultiStoreSvc.cpp.

                                              {
    return call_<OBJECT*>( &IDataProviderSvc::updateObject, pObj);
  }

STATUS MultiStoreSvc::updateObject ( CSTR &  parent, CSTR &  updatePath  )

inlineoverride

Update object.

Definition at line 422 of file MultiStoreSvc.cpp.

                                                                {
    return call_<CSTR&,CSTR&>( &IDataProviderSvc::updateObject, parent, updatePath);
  }

STATUS MultiStoreSvc::updateObject ( OBJECT *  parent, CSTR &  updatePath  )

inlineoverride

Update object.

Definition at line 426 of file MultiStoreSvc.cpp.

                                                                 {
    return call_<OBJECT*,CSTR&>( &IDataProviderSvc::updateObject, parent, updatePath);
  }

Member Data Documentation

SmartIF<IAddressCreator> MultiStoreSvc::m_addrCreator

protected

Reference to address creator.

Definition at line 84 of file MultiStoreSvc.cpp.

Partition MultiStoreSvc::m_current

protected

Current partition.

Definition at line 97 of file MultiStoreSvc.cpp.

SmartIF<IConversionSvc> MultiStoreSvc::m_dataLoader

protected

Pointer to data loader service.

Definition at line 82 of file MultiStoreSvc.cpp.

std::string MultiStoreSvc::m_defaultPartition

protected

Default partition.

Definition at line 103 of file MultiStoreSvc.cpp.

std::string MultiStoreSvc::m_loader

protected

Data loader name.

Definition at line 80 of file MultiStoreSvc.cpp.

PartitionDefs MultiStoreSvc::m_partitionDefs

protected

Datastore partition definitions.

Definition at line 101 of file MultiStoreSvc.cpp.

Partitions MultiStoreSvc::m_partitions

protected

Datastore partitions.

Definition at line 99 of file MultiStoreSvc.cpp.

struct MultiStoreSvc::tagROOT MultiStoreSvc::m_root

protected

CLID MultiStoreSvc::m_rootCLID

protected

Integer Property corresponding to CLID of root entry.

Definition at line 76 of file MultiStoreSvc.cpp.

std::string MultiStoreSvc::m_rootName

protected

Name of root event.

Definition at line 78 of file MultiStoreSvc.cpp.

---

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

• GaudiCommonSvc/src/DataSvc/MultiStoreSvc.cpp