HiveWhiteBoard Class Reference

Data service base class. More...

Inheritance diagram for HiveWhiteBoard:

Collaboration diagram for HiveWhiteBoard:

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...
StatusCode	registerAddress (const std::string &path, IOpaqueAddress *pAddr) override
	IDataManagerSvc: Register object address with the data store. More...
StatusCode	registerAddress (DataObject *parent, const std::string &path, IOpaqueAddress *pAddr) override
	IDataManagerSvc: Register object address with the data store. More...
StatusCode	registerAddress (IRegistry *parent, const std::string &path, IOpaqueAddress *pAdd) override
	IDataManagerSvc: Register object address with the data store. More...
StatusCode	unregisterAddress (const std::string &path) override
	IDataManagerSvc: Unregister object address from the data store. More...
StatusCode	unregisterAddress (DataObject *pParent, const std::string &path) override
	IDataManagerSvc: Unregister object address from the data store. More...
StatusCode	unregisterAddress (IRegistry *pParent, const std::string &path) override
	IDataManagerSvc: Unregister object address from the data store. More...
StatusCode	objectLeaves (const DataObject *pObject, std::vector< IRegistry * > &leaves) override
	Explore the object store: retrieve all leaves attached to the object. More...
StatusCode	objectLeaves (const IRegistry *pObject, std::vector< IRegistry * > &leaves) override
	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 *pObject, IRegistry *&refpParent) override
	IDataManagerSvc: Explore the object store: retrieve the object's parent. More...
StatusCode	clearSubTree (const std::string &path) override
	Remove all data objects below the sub tree identified. More...
StatusCode	clearSubTree (DataObject *pObject) override
	Remove all data objects below the sub tree identified. More...
StatusCode	clearStore () override
	IDataManagerSvc: Remove all data objects in the data store. More...
StatusCode	traverseSubTree (const std::string &path, IDataStoreAgent *pAgent) override
	Analyze by traversing all data objects below the sub tree. 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 path, DataObject *pObj) override
	Initialize data store for new event by giving new event path and root object. More...
StatusCode	setRoot (std::string path, IOpaqueAddress *pAddr) override
	Initialize data store for new event by giving new event path and address of root object. More...
StatusCode	setDataLoader (IConversionSvc *pDataLoader, IDataProviderSvc *dpsvc __attribute__((unused))=nullptr) override
	IDataManagerSvc: Pass a default data loader to the service. More...
StatusCode	addPreLoadItem (const DataStoreItem &item) override
	Add an item to the preload list. More...
StatusCode	addPreLoadItem (const std::string &item) 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 &item) override
	Add an item to the preload list. More...
StatusCode	resetPreLoad () override
	Clear the preload list. More...
StatusCode	preLoad () override
	load all preload items of the list More...
StatusCode	registerObject (const std::string &path, DataObject *pObj) override
	Register object with the data store. (The most common one is the only monitored one for the time being....) More...
StatusCode	registerObject (const std::string &parent, const std::string &obj, DataObject *pObj) override
	Register object with the data store. More...
StatusCode	registerObject (const std::string &parent, int item, DataObject *pObj) override
	Register object with the data store. More...
StatusCode	registerObject (DataObject *parent, const std::string &obj, DataObject *pObj) override
	Register object with the data store. More...
StatusCode	registerObject (DataObject *parent, int obj, DataObject *pObj) override
	Register object with the data store. More...
StatusCode	unregisterObject (const std::string &path) override
	Unregister object from the data store. More...
StatusCode	unregisterObject (const std::string &parent, const std::string &obj) override
	Unregister object from the data store. More...
StatusCode	unregisterObject (const std::string &parent, int obj) override
	Unregister object from the data store. More...
StatusCode	unregisterObject (DataObject *pObj) override
	Unregister object from the data store. More...
StatusCode	unregisterObject (DataObject *pObj, const std::string &path) override
	Unregister object from the data store. More...
StatusCode	unregisterObject (DataObject *pObj, int item) override
	Unregister object from the data store. More...
StatusCode	retrieveObject (IRegistry *parent, const std::string &path, DataObject *&pObj) override
	Retrieve object from data store. More...
StatusCode	retrieveObject (const std::string &path, DataObject *&pObj) override
	Retrieve object identified by its full path from the data store. More...
StatusCode	retrieveObject (const std::string &parent, const std::string &path, DataObject *&pObj) override
	Retrieve object from data store. More...
StatusCode	retrieveObject (const std::string &parent, int item, DataObject *&pObj) override
	Retrieve object from data store. More...
StatusCode	retrieveObject (DataObject *parent, const std::string &path, DataObject *&pObj) override
	Retrieve object from data store. More...
StatusCode	retrieveObject (DataObject *parent, int item, DataObject *&pObj) override
	Retrieve object from data store. More...
StatusCode	findObject (const std::string &path, DataObject *&pObj) override
	Find object identified by its full path in the data store. More...
StatusCode	findObject (IRegistry *parent, const std::string &path, DataObject *&pObj) override
	Find object identified by its full path in the data store. More...
StatusCode	findObject (const std::string &parent, const std::string &path, DataObject *&pObj) override
	Find object in the data store. More...
StatusCode	findObject (const std::string &parent, int item, DataObject *&pObject) override
	Find object in the data store. More...
StatusCode	findObject (DataObject *parent, const std::string &path, DataObject *&pObject) override
	Find object in the data store. More...
StatusCode	findObject (DataObject *parent, 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 &from, 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 &from, const std::string &objPath) override
	Remove a link to another object. More...
StatusCode	unlinkObject (DataObject *from, const std::string &objPath) override
	Remove a link to another object. More...
StatusCode	unlinkObject (const std::string &path) 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 &path) override
	Update object. More...
StatusCode	updateObject (DataObject *pObj) override
	Update object. More...
StatusCode	updateObject (const std::string &parent, const std::string &updatePath) override
	Update object. More...
StatusCode	updateObject (DataObject *parent, const std::string &updatePath) override
	Update object. More...
StatusCode	clearStore (size_t partition) override
	Remove all data objects in one 'slot' of the data store. More...
StatusCode	selectStore (size_t partition) override
	Activate a partition object. The identifies the partition uniquely. More...
StatusCode	setNumberOfStores (size_t slots) override
	Set the number of event slots (copies of DataSvc objects). More...
size_t	getNumberOfStores () override
	Get the number of event slots (copies of DataSvc objects). More...
StatusCode	getNewDataObjects (std::vector< std::string > &products) override
	Get the list of new DataObjects in the current store. More...
bool	newDataObjectsPresent () override
	Check if new DataObjects are in the current store. More...
size_t	allocateStore (int evtnumber) override
	Allocate a store partition for a given event number. More...
StatusCode	freeStore (size_t partition) override
	Free a store partition. More...
size_t	getPartitionNumber (int eventnumber) const override
	Get the partition number corresponding to a given event. More...
StatusCode	attachServices ()
StatusCode	detachServices ()
StatusCode	initialize () override
	Service initialisation. More...
StatusCode	reinitialize () override
	Service initialisation. More...
StatusCode	finalize () override
	Service initialisation. More...
	HiveWhiteBoard (const std::string &name, ISvcLocator *svc)
	Standard Constructor. More...
virtual	~HiveWhiteBoard ()
	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 Types
typedef std::vector< Partition >	Partitions

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...
IConversionSvc *	m_dataLoader
	Pointer to data loader service. More...
IAddressCreator *	m_addrCreator
	Reference to address creator. More...
Partitions	m_partitions
	Datastore partitions. More...
int	m_slots
	Datastore slots. More...
bool	m_forceLeaves
	Allow forced creation of default leaves on registerObject. More...
bool	m_enableFaultHdlr
	Flag to enable interrupts on data creation requests. 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

Pere Mato

Version

1.0

Definition at line 87 of file HiveWhiteBoard.cpp.

Member Typedef Documentation

typedef std::vector<Partition> HiveWhiteBoard::Partitions

protected

Definition at line 93 of file HiveWhiteBoard.cpp.

Constructor & Destructor Documentation

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

inline

Standard Constructor.

Definition at line 583 of file HiveWhiteBoard.cpp.

  : base_class(name,svc), m_rootCLID(110), m_rootName("/Event"),
    m_dataLoader(0), m_addrCreator(0)
  {
    m_dataLoader = 0;
    declareProperty("RootCLID",           m_rootCLID);
    declareProperty("RootName",           m_rootName);
    declareProperty("DataLoader",         m_loader="EventPersistencySvc");
    declareProperty("EventSlots",         m_slots = 1);
    declareProperty("ForceLeaves",        m_forceLeaves = 1);
    declareProperty("EnableFaultHandler", m_enableFaultHdlr = 0);
  }

virtual HiveWhiteBoard::~HiveWhiteBoard ( )

inlinevirtual

Standard Destructor.

Definition at line 597 of file HiveWhiteBoard.cpp.

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

    for(Partitions::iterator i = m_partitions.begin(); i != m_partitions.end(); ++i) {
      (*i).dataManager->release();
      (*i).dataProvider->release();
    }
    m_partitions.clear();
  }

Member Function Documentation

StatusCode HiveWhiteBoard::addPreLoadItem ( const DataStoreItem &  item )

inlineoverride

Add an item to the preload list.

Definition at line 226 of file HiveWhiteBoard.cpp.

                                                                   {
    for(auto& p: m_partitions) p.dataProvider->addPreLoadItem(item);
    return StatusCode::SUCCESS;
  }

StatusCode HiveWhiteBoard::addPreLoadItem ( const std::string &  item )

inlineoverride

Add an item to the preload list.

Definition at line 231 of file HiveWhiteBoard.cpp.

                                                              {
    for(auto& p: m_partitions) p.dataProvider->addPreLoadItem(item);
    return StatusCode::SUCCESS;
  }

size_t HiveWhiteBoard::allocateStore ( int  evtnumber )

inlineoverride

Allocate a store partition for a given event number.

Definition at line 454 of file HiveWhiteBoard.cpp.

                                                 {
    //size_t free = std::string::npos;
    size_t index = 0;
    for (auto& p : m_partitions ) {
      if( p.eventNumber == evtnumber) {
        error() << "Attempt to allocate a store partition for an event that is still active" << endmsg;
        return std::string::npos;
      } else if (p.eventNumber == -1) {
        p.eventNumber = evtnumber;
        //info() << "Got allocated slot..." << index << endmsg;
        return index;
      }
      index++;
    }
    return std::string::npos;
  }

StatusCode HiveWhiteBoard::attachServices ( )

inline

Definition at line 489 of file HiveWhiteBoard.cpp.

                               {
    StatusCode sc = service(m_loader, m_addrCreator, true);
    if (!sc.isSuccess()) {
      error() << "Failed to retrieve data loader " << "\"" << m_loader << "\"" << endmsg;
      return sc;
    }
    IConversionSvc* dataLoader = 0;
    sc = service(m_loader, dataLoader, true);
    if (!sc.isSuccess()) {
      error() << MSG::ERROR << "Failed to retrieve data loader " << "\"" << m_loader << "\"" << endmsg;
      return sc;
    }
    sc = setDataLoader(dataLoader);
    dataLoader->release();
    if (!sc.isSuccess()) {
      error() << MSG::ERROR << "Failed to set data loader " << "\"" << m_loader << "\"" << endmsg;
      return sc;
    }
    return sc;
  }

StatusCode HiveWhiteBoard::clearStore ( )

inlineoverride

IDataManagerSvc: Remove all data objects in the data store.

Definition at line 179 of file HiveWhiteBoard.cpp.

                                    {
    for(auto& p: m_partitions) p.dataManager->clearStore().ignore();
    return StatusCode::SUCCESS;
  }

StatusCode HiveWhiteBoard::clearStore ( size_t  partition )

inlineoverride

Remove all data objects in one 'slot' of the data store.

Definition at line 413 of file HiveWhiteBoard.cpp.

                                                    {
    return m_partitions[partition].dataManager->clearStore();
  }

StatusCode HiveWhiteBoard::clearSubTree ( const std::string &  path )

inlineoverride

Remove all data objects below the sub tree identified.

Definition at line 171 of file HiveWhiteBoard.cpp.

                                                           {
    _CALL(dataManager, clearSubTree, (path));
  }

StatusCode HiveWhiteBoard::clearSubTree ( DataObject *  pObject )

inlineoverride

Remove all data objects below the sub tree identified.

Definition at line 175 of file HiveWhiteBoard.cpp.

                                                         {
    _CALL(dataManager, clearSubTree, (pObject));
  }

StatusCode HiveWhiteBoard::detachServices ( )

inline

Definition at line 510 of file HiveWhiteBoard.cpp.

                               {
    if ( m_addrCreator )  m_addrCreator->release();
    if ( m_dataLoader )  m_dataLoader->release();
    m_addrCreator = 0;
    m_dataLoader = 0;
    return StatusCode::SUCCESS;
  }

StatusCode HiveWhiteBoard::finalize ( )

inlineoverride

Service initialisation.

Definition at line 573 of file HiveWhiteBoard.cpp.

                                   {
    setDataLoader(0).ignore();
    clearStore().ignore();
    return Service::finalize();
  }

StatusCode HiveWhiteBoard::findObject ( const std::string &  path, DataObject *&  pObj  )

inlineoverride

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

Definition at line 332 of file HiveWhiteBoard.cpp.

                                                                            {
    _CALL(dataProvider, retrieveObject, (path, pObj));
  }

StatusCode HiveWhiteBoard::findObject ( IRegistry *  parent, const std::string &  path, DataObject *&  pObj  )

inlineoverride

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

Definition at line 336 of file HiveWhiteBoard.cpp.

                                                                                               {
    _CALL(dataProvider, retrieveObject, (parent, path, pObj));
  }

StatusCode HiveWhiteBoard::findObject ( const std::string &  parent, const std::string &  path, DataObject *&  pObj  )

inlineoverride

Find object in the data store.

Definition at line 340 of file HiveWhiteBoard.cpp.

                                                                                                     {
    _CALL(dataProvider, retrieveObject, (parent, path, pObj));
  }

StatusCode HiveWhiteBoard::findObject ( const std::string &  parent, int  item, DataObject *&  pObject  )

inlineoverride

Find object in the data store.

Definition at line 344 of file HiveWhiteBoard.cpp.

                                                                                           {
    _CALL(dataProvider, findObject, (parent, item, pObject));
  }

StatusCode HiveWhiteBoard::findObject ( DataObject *  parent, const std::string &  path, DataObject *&  pObject  )

inlineoverride

Find object in the data store.

Definition at line 348 of file HiveWhiteBoard.cpp.

                                                                                                   {
    _CALL(dataProvider, findObject, (parent, path, pObject));
  }

StatusCode HiveWhiteBoard::findObject ( DataObject *  parent, int  item, DataObject *&  pObject  )

inlineoverride

Find object in the data store.

Definition at line 352 of file HiveWhiteBoard.cpp.

                                                                                      {
    _CALL(dataProvider, findObject, (parent, item, pObject));
  }

StatusCode HiveWhiteBoard::freeStore ( size_t  partition )

inlineoverride

Free a store partition.

Definition at line 472 of file HiveWhiteBoard.cpp.

                                                    {
    m_partitions[partition].eventNumber = -1;
    //info() << "Freed slot..." << partition << endmsg;
    return StatusCode::SUCCESS;
  }

StatusCode HiveWhiteBoard::getNewDataObjects ( std::vector< std::string > &  products )

inlineoverride

Get the list of new DataObjects in the current store.

Definition at line 440 of file HiveWhiteBoard.cpp.

                                                                        {
    wbMutex::scoped_lock lock; lock.acquire(s_current->storeMutex);
    products = s_current->newDataObjects;
    s_current->newDataObjects.clear();
    return StatusCode::SUCCESS;
  }

size_t HiveWhiteBoard::getNumberOfStores ( )

inlineoverride

Get the number of event slots (copies of DataSvc objects).

Definition at line 435 of file HiveWhiteBoard.cpp.

                                      {
    return m_slots;
  }

size_t HiveWhiteBoard::getPartitionNumber ( int  eventnumber ) const

inlineoverride

Get the partition number corresponding to a given event.

Definition at line 480 of file HiveWhiteBoard.cpp.

                                                            {
    size_t index{};
    for (auto& p : m_partitions) {
      if (p.eventNumber == eventnumber) return index;
      ++index;
    }
    return std::string::npos;
  }

StatusCode HiveWhiteBoard::initialize ( )

inlineoverride

Service initialisation.

Definition at line 523 of file HiveWhiteBoard.cpp.

                                    {
    StatusCode sc = Service::initialize();
    if ( !sc.isSuccess() )  {
      error() << "Unable to initialize base class" << endmsg;
      return sc;
    }

    if (1 > m_slots ){
      error() << "Invalid number of slots (" << m_slots << ")" << endmsg;
      return StatusCode::FAILURE;
    }

    for( int i = 0; i< m_slots; i++) {
      std::ostringstream oss;
      oss << name() << "_" << i;
      DataSvc* svc = new DataSvc(oss.str(), serviceLocator());
      // Percolate properties
      svc->setProperty("RootCLID", std::to_string(m_rootCLID));
      svc->setProperty("RootName", m_rootName);
      svc->setProperty("ForceLeaves", std::to_string(m_forceLeaves));
      svc->setProperty("EnableFaultHandler", std::to_string(m_enableFaultHdlr));

      sc = svc->initialize();
      if (!sc.isSuccess()) {
        error() << "Failed to instantiate DataSvc as store partition" << endmsg;
        return sc;
      }
      m_partitions.push_back(Partition(svc, svc));
    }
    selectStore(0).ignore();
    return attachServices();
  }

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

inlineoverride

Add a link to another object.

Definition at line 356 of file HiveWhiteBoard.cpp.

                                                                                             {
    _CALL(dataProvider, linkObject, (from, objPath, to));
  }

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

inlineoverride

Add a link to another object.

Definition at line 360 of file HiveWhiteBoard.cpp.

                                                                                                    {
    _CALL(dataProvider, linkObject, (from, objPath, to));
  }

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

inlineoverride

Add a link to another object.

Definition at line 364 of file HiveWhiteBoard.cpp.

                                                                                              {
    _CALL(dataProvider, linkObject, (from, objPath, to));
  }

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

inlineoverride

Add a link to another object.

Definition at line 368 of file HiveWhiteBoard.cpp.

                                                                             {
    _CALL(dataProvider, linkObject, (fullPath, to));
  }

bool HiveWhiteBoard::newDataObjectsPresent ( )

inlineoverride

Check if new DataObjects are in the current store.

Definition at line 448 of file HiveWhiteBoard.cpp.

                                        {
    wbMutex::scoped_lock lock; lock.acquire(s_current->storeMutex);
    return s_current->newDataObjects.size()!=0;
  }

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

inlineoverride

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

Definition at line 155 of file HiveWhiteBoard.cpp.

                                                                                               {
    _CALL(dataManager, objectLeaves, (pObject, leaves));
  }

StatusCode HiveWhiteBoard::objectLeaves ( const IRegistry *  pObject, std::vector< IRegistry * > &  leaves  )

inlineoverride

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

Definition at line 159 of file HiveWhiteBoard.cpp.

                                                                                             {
    _CALL(dataManager, objectLeaves, (pObject, leaves));
  }

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

inlineoverride

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

Definition at line 163 of file HiveWhiteBoard.cpp.

                                                                                       {
    _CALL(dataManager, objectParent, (pObject, refpParent));
  }

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

inlineoverride

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

Definition at line 167 of file HiveWhiteBoard.cpp.

                                                                                      {
    _CALL(dataManager, objectParent, (pObject, refpParent));
  }

StatusCode HiveWhiteBoard::preLoad ( )

inlineoverride

load all preload items of the list

Definition at line 251 of file HiveWhiteBoard.cpp.

                                 {
    wbMutex::scoped_lock lock; lock.acquire(s_current->storeMutex);
    StatusCode sc = s_current->dataProvider->preLoad();
    DataAgent da(s_current->newDataObjects);
    s_current->dataManager->traverseTree(&da);
    return sc;
  }

StatusCode HiveWhiteBoard::registerAddress ( const std::string &  path, IOpaqueAddress *  pAddr  )

inlineoverride

IDataManagerSvc: Register object address with the data store.

Definition at line 131 of file HiveWhiteBoard.cpp.

                                                                                      {
    _CALL(dataManager, registerAddress, (path, pAddr));
  }

StatusCode HiveWhiteBoard::registerAddress ( DataObject *  parent, const std::string &  path, IOpaqueAddress *  pAddr  )

inlineoverride

IDataManagerSvc: Register object address with the data store.

Definition at line 135 of file HiveWhiteBoard.cpp.

                                                                                                         {
    _CALL(dataManager, registerAddress, (parent, path, pAddr));
  }

StatusCode HiveWhiteBoard::registerAddress ( IRegistry *  parent, const std::string &  path, IOpaqueAddress *  pAdd  )

inlineoverride

IDataManagerSvc: Register object address with the data store.

Definition at line 139 of file HiveWhiteBoard.cpp.

                                                                                                       {
    _CALL(dataManager, registerAddress, (parent, path, pAdd));
  }

StatusCode HiveWhiteBoard::registerObject ( const std::string &  path, DataObject *  pObj  )

inlineoverride

Register object with the data store. (The most common one is the only monitored one for the time being....)

Definition at line 259 of file HiveWhiteBoard.cpp.

                                                                               {
    wbMutex::scoped_lock lock; lock.acquire(s_current->storeMutex);
    StatusCode sc = s_current->dataProvider->registerObject(path, pObj);
    if( sc.isSuccess()) {
      s_current->newDataObjects.push_back(path);
    }
    return sc;
  }

StatusCode HiveWhiteBoard::registerObject ( const std::string &  parent, const std::string &  obj, DataObject *  pObj  )

inlineoverride

Register object with the data store.

Definition at line 268 of file HiveWhiteBoard.cpp.

                                                                                                       {
    _CALL(dataProvider, registerObject, (parent, obj, pObj));
  }

StatusCode HiveWhiteBoard::registerObject ( const std::string &  parent, int  item, DataObject *  pObj  )

inlineoverride

Register object with the data store.

Definition at line 272 of file HiveWhiteBoard.cpp.

                                                                                           {
    _CALL(dataProvider, registerObject, (parent, item, pObj));
  }

StatusCode HiveWhiteBoard::registerObject ( DataObject *  parent, const std::string &  obj, DataObject *  pObj  )

inlineoverride

Register object with the data store.

Definition at line 276 of file HiveWhiteBoard.cpp.

                                                                                                  {
    _CALL(dataProvider, registerObject, (parent, obj, pObj));
  }

StatusCode HiveWhiteBoard::registerObject ( DataObject *  parent, int  obj, DataObject *  pObj  )

inlineoverride

Register object with the data store.

Definition at line 280 of file HiveWhiteBoard.cpp.

                                                                                     {
    _CALL(dataProvider, registerObject, (parent, obj, pObj));
  }

StatusCode HiveWhiteBoard::reinitialize ( )

inlineoverride

Service initialisation.

Definition at line 557 of file HiveWhiteBoard.cpp.

                                       {
    StatusCode sc = Service::reinitialize();
    if (!sc.isSuccess()) {
      error() << "Unable to reinitialize base class" << endmsg;
      return sc;
    }
    detachServices();
    sc = attachServices();
    if ( !sc.isSuccess() )  {
      error() << "Failed to attach necessary services." << endmsg;
      return sc;
    }
    return StatusCode::SUCCESS;
  }

StatusCode HiveWhiteBoard::removePreLoadItem ( const DataStoreItem &  item )

inlineoverride

Remove an item from the preload list.

Definition at line 236 of file HiveWhiteBoard.cpp.

                                                                    {
    for(auto& p: m_partitions) p.dataProvider->removePreLoadItem(item);
    return StatusCode::SUCCESS;
  }

StatusCode HiveWhiteBoard::removePreLoadItem ( const std::string &  item )

inlineoverride

Add an item to the preload list.

Definition at line 241 of file HiveWhiteBoard.cpp.

                                                                {
    for(auto& p: m_partitions) p.dataProvider->removePreLoadItem(item);
    return StatusCode::SUCCESS;
  }

StatusCode HiveWhiteBoard::resetPreLoad ( )

inlineoverride

Clear the preload list.

Definition at line 246 of file HiveWhiteBoard.cpp.

                                     {
    for(auto& p: m_partitions) p.dataProvider->resetPreLoad();
    return StatusCode::SUCCESS;
  }

StatusCode HiveWhiteBoard::retrieveObject ( IRegistry *  parent, const std::string &  path, DataObject *&  pObj  )

inlineoverride

Retrieve object from data store.

Definition at line 308 of file HiveWhiteBoard.cpp.

                                                                                                    {
    _CALL(dataProvider, retrieveObject, (parent, path, pObj));
  }

StatusCode HiveWhiteBoard::retrieveObject ( const std::string &  path, DataObject *&  pObj  )

inlineoverride

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

Definition at line 312 of file HiveWhiteBoard.cpp.

                                                                                {
    _CALL(dataProvider, retrieveObject, (path, pObj));
  }

StatusCode HiveWhiteBoard::retrieveObject ( const std::string &  parent, const std::string &  path, DataObject *&  pObj  )

inlineoverride

Retrieve object from data store.

Definition at line 316 of file HiveWhiteBoard.cpp.

                                                                                                          {
    _CALL(dataProvider, retrieveObject, (parent, path, pObj));
  }

StatusCode HiveWhiteBoard::retrieveObject ( const std::string &  parent, int  item, DataObject *&  pObj  )

inlineoverride

Retrieve object from data store.

Definition at line 320 of file HiveWhiteBoard.cpp.

                                                                                            {
    _CALL(dataProvider, retrieveObject, (parent, item, pObj));
  }

StatusCode HiveWhiteBoard::retrieveObject ( DataObject *  parent, const std::string &  path, DataObject *&  pObj  )

inlineoverride

Retrieve object from data store.

Definition at line 324 of file HiveWhiteBoard.cpp.

                                                                                                     {
    _CALL(dataProvider, retrieveObject, (parent, path, pObj));
  }

StatusCode HiveWhiteBoard::retrieveObject ( DataObject *  parent, int  item, DataObject *&  pObj  )

inlineoverride

Retrieve object from data store.

Definition at line 328 of file HiveWhiteBoard.cpp.

                                                                                        {
    _CALL(dataProvider, retrieveObject, (parent, item, pObj));
  }

CLID HiveWhiteBoard::rootCLID ( ) const

inlineoverride

IDataManagerSvc: Accessor for root event CLID.

Definition at line 116 of file HiveWhiteBoard.cpp.

                                 {
    return (CLID)m_rootCLID;
  }

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

inlineoverride

Name for root Event.

Definition at line 120 of file HiveWhiteBoard.cpp.

                                             {
    return m_rootName;
  }

StatusCode HiveWhiteBoard::selectStore ( size_t  partition )

inlineoverride

Activate a partition object. The identifies the partition uniquely.

Definition at line 418 of file HiveWhiteBoard.cpp.

                                                    {
      s_current = &m_partitions[partition];
      return StatusCode::SUCCESS;
  }

StatusCode HiveWhiteBoard::setDataLoader ( IConversionSvc *  pDataLoader, IDataProviderSvc *dpsvc   __attribute__(unused) = nullptr  )

inlineoverride

IDataManagerSvc: Pass a default data loader to the service.

The optional data provider is not considered. On the other hand, the data provider is specified to be the whiteboard.

Definition at line 212 of file HiveWhiteBoard.cpp.

                                                                                               {
    if ( 0 != pDataLoader  ) pDataLoader->addRef();
    if ( 0 != m_dataLoader ) m_dataLoader->release();
    if ( 0 != pDataLoader  )    {
      pDataLoader->setDataProvider(this);
    }
    m_dataLoader = pDataLoader;
    for(auto& p: m_partitions) {
      p.dataManager->setDataLoader(m_dataLoader,this).ignore();
    }
    return SUCCESS;
  }

StatusCode HiveWhiteBoard::setNumberOfStores ( size_t  slots )

inlineoverride

Set the number of event slots (copies of DataSvc objects).

Definition at line 424 of file HiveWhiteBoard.cpp.

                                                      {
    if((int)slots != m_slots and
       FSMState() ==  Gaudi::StateMachine::INITIALIZED) {
      warning() << "Too late to change the number of slots!" << endmsg;
      return StatusCode::FAILURE;
    }
    m_slots = slots;
    return StatusCode::SUCCESS;
  }

StatusCode HiveWhiteBoard::setRoot ( std::string  path, DataObject *  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 198 of file HiveWhiteBoard.cpp.

                                                                {
    _CALL(dataManager, setRoot, (path, pObj));
  }

StatusCode HiveWhiteBoard::setRoot ( std::string  path, IOpaqueAddress *  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 204 of file HiveWhiteBoard.cpp.

                                                                      {
    _CALL(dataManager, setRoot, (path, pAddr));
  }

StatusCode HiveWhiteBoard::traverseSubTree ( const std::string &  path, IDataStoreAgent *  pAgent  )

inlineoverride

Analyze by traversing all data objects below the sub tree.

Definition at line 185 of file HiveWhiteBoard.cpp.

                                                                                       {
    _CALL(dataManager, traverseSubTree, (path, pAgent));
  }

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

inlineoverride

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

Definition at line 189 of file HiveWhiteBoard.cpp.

                                                                                     {
    _CALL(dataManager, traverseSubTree, (pObject, pAgent));
  }

StatusCode HiveWhiteBoard::traverseTree ( IDataStoreAgent *  pAgent )

inlineoverride

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

Definition at line 193 of file HiveWhiteBoard.cpp.

                                                               {
    _CALL(dataManager, traverseTree, (pAgent));
  }

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

inlineoverride

Remove a link to another object.

Definition at line 372 of file HiveWhiteBoard.cpp.

                                                                               {
    _CALL(dataProvider, unlinkObject, (from, objPath));
  }

StatusCode HiveWhiteBoard::unlinkObject ( const std::string &  from, const std::string &  objPath  )

inlineoverride

Remove a link to another object.

Definition at line 376 of file HiveWhiteBoard.cpp.

                                                                                     {
    _CALL(dataProvider, unlinkObject, (from, objPath));
  }

StatusCode HiveWhiteBoard::unlinkObject ( DataObject *  from, const std::string &  objPath  )

inlineoverride

Remove a link to another object.

Definition at line 380 of file HiveWhiteBoard.cpp.

                                                                                {
    _CALL(dataProvider, unlinkObject, (from, objPath));
  }

StatusCode HiveWhiteBoard::unlinkObject ( const std::string &  path )

inlineoverride

Remove a link to another object.

Definition at line 384 of file HiveWhiteBoard.cpp.

                                                          {
    _CALL(dataProvider, unlinkObject, (path));
  }

StatusCode HiveWhiteBoard::unregisterAddress ( const std::string &  path )

inlineoverride

IDataManagerSvc: Unregister object address from the data store.

Definition at line 143 of file HiveWhiteBoard.cpp.

                                                                {
    _CALL(dataManager, unregisterAddress, (path));
  }

StatusCode HiveWhiteBoard::unregisterAddress ( DataObject *  pParent, const std::string &  path  )

inlineoverride

IDataManagerSvc: Unregister object address from the data store.

Definition at line 147 of file HiveWhiteBoard.cpp.

                                                                                     {
    _CALL(dataManager, unregisterAddress, (pParent, path));
  }

StatusCode HiveWhiteBoard::unregisterAddress ( IRegistry *  pParent, const std::string &  path  )

inlineoverride

IDataManagerSvc: Unregister object address from the data store.

Definition at line 151 of file HiveWhiteBoard.cpp.

                                                                                    {
    _CALL(dataManager, unregisterAddress, (pParent, path));
  }

StatusCode HiveWhiteBoard::unregisterObject ( const std::string &  path )

inlineoverride

Unregister object from the data store.

Definition at line 284 of file HiveWhiteBoard.cpp.

                                                                {
    _CALL(dataProvider, unregisterObject, (path));
  }

StatusCode HiveWhiteBoard::unregisterObject ( const std::string &  parent, const std::string &  obj  )

inlineoverride

Unregister object from the data store.

Definition at line 288 of file HiveWhiteBoard.cpp.

                                                                                       {
    _CALL(dataProvider, unregisterObject, (parent, obj));
  }

StatusCode HiveWhiteBoard::unregisterObject ( const std::string &  parent, int  obj  )

inlineoverride

Unregister object from the data store.

Definition at line 292 of file HiveWhiteBoard.cpp.

                                                                          {
    _CALL(dataProvider, unregisterObject, (parent, obj));
  }

StatusCode HiveWhiteBoard::unregisterObject ( DataObject *  pObj )

inlineoverride

Unregister object from the data store.

Definition at line 296 of file HiveWhiteBoard.cpp.

                                                          {
    _CALL(dataProvider, unregisterObject, (pObj));
  }

StatusCode HiveWhiteBoard::unregisterObject ( DataObject *  pObj, const std::string &  path  )

inlineoverride

Unregister object from the data store.

Definition at line 300 of file HiveWhiteBoard.cpp.

                                                                                 {
    _CALL(dataProvider, unregisterObject, (pObj, path));
  }

StatusCode HiveWhiteBoard::unregisterObject ( DataObject *  pObj, int  item  )

inlineoverride

Unregister object from the data store.

Definition at line 304 of file HiveWhiteBoard.cpp.

                                                                     {
    _CALL(dataProvider, unregisterObject, (pObj, item));
  }

StatusCode HiveWhiteBoard::updateObject ( IRegistry *  pDirectory )

inlineoverride

Update object identified by its directory entry.

Definition at line 388 of file HiveWhiteBoard.cpp.

                                                            {
    _CALL(dataProvider, updateObject, (pDirectory));
  }

StatusCode HiveWhiteBoard::updateObject ( const std::string &  path )

inlineoverride

Update object.

Definition at line 392 of file HiveWhiteBoard.cpp.

                                                           {
    _CALL(dataProvider, updateObject, (path));
  }

StatusCode HiveWhiteBoard::updateObject ( DataObject *  pObj )

inlineoverride

Update object.

Definition at line 396 of file HiveWhiteBoard.cpp.

                                                       {
    _CALL(dataProvider, updateObject, (pObj));
  }

StatusCode HiveWhiteBoard::updateObject ( const std::string &  parent, const std::string &  updatePath  )

inlineoverride

Update object.

Definition at line 400 of file HiveWhiteBoard.cpp.

                                                                                           {
    _CALL(dataProvider, updateObject, (parent, updatePath));
  }

StatusCode HiveWhiteBoard::updateObject ( DataObject *  parent, const std::string &  updatePath  )

inlineoverride

Update object.

Definition at line 404 of file HiveWhiteBoard.cpp.

                                                                                     {
    _CALL(dataProvider, updateObject, (parent, updatePath));
  }

Member Data Documentation

IAddressCreator* HiveWhiteBoard::m_addrCreator

protected

Reference to address creator.

Definition at line 104 of file HiveWhiteBoard.cpp.

IConversionSvc* HiveWhiteBoard::m_dataLoader

protected

Pointer to data loader service.

Definition at line 102 of file HiveWhiteBoard.cpp.

bool HiveWhiteBoard::m_enableFaultHdlr

protected

Flag to enable interrupts on data creation requests.

Definition at line 112 of file HiveWhiteBoard.cpp.

bool HiveWhiteBoard::m_forceLeaves

protected

Allow forced creation of default leaves on registerObject.

Definition at line 110 of file HiveWhiteBoard.cpp.

std::string HiveWhiteBoard::m_loader

protected

Data loader name.

Definition at line 100 of file HiveWhiteBoard.cpp.

Partitions HiveWhiteBoard::m_partitions

protected

Datastore partitions.

Definition at line 106 of file HiveWhiteBoard.cpp.

CLID HiveWhiteBoard::m_rootCLID

protected

Integer Property corresponding to CLID of root entry.

Definition at line 96 of file HiveWhiteBoard.cpp.

std::string HiveWhiteBoard::m_rootName

protected

Name of root event.

Definition at line 98 of file HiveWhiteBoard.cpp.

int HiveWhiteBoard::m_slots

protected

Datastore slots.

Definition at line 108 of file HiveWhiteBoard.cpp.

---

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

• GaudiHive/src/HiveWhiteBoard.cpp