TsDataSvc.h

Go to the documentation of this file.

#ifndef GAUDIKERNEL_TSDATASVC_H
#define GAUDIKERNEL_TSDATASVC_H

// Include files
#include "GaudiKernel/DataStoreItem.h"
#include "GaudiKernel/IDataManagerSvc.h"
#include "GaudiKernel/IDataProviderSvc.h"
#include "GaudiKernel/Service.h"

// External libraries
#include "tbb/recursive_mutex.h"
#include "tbb/spin_mutex.h"

namespace
{
  typedef tbb::recursive_mutex tsDataSvcMutex;
  // typedef  tbb::spin_mutex tsDataSvcMutex;
}

// Forward declarations
// Incident service
class IIncidentSvc;
// Generic address
class IOpaqueAddress;
// Generic interface to data object class
class DataObject;
// Data store agent
class IDataStoreAgent;

// Do not clutter global namespace for helpers...
namespace DataSvcHelpers
{
  // Map of objects where loading is inhibited
  class InhibitMap;
  // Generic registry entry
  class RegistryEntry;
}

class GAUDI_API TsDataSvc : public extends<Service, IDataProviderSvc, IDataManagerSvc>
{
public:
  typedef std::vector<DataStoreItem> LoadItems;

protected:
  IConversionSvc* m_dataLoader = nullptr;
  IIncidentSvc* m_incidentSvc = nullptr;

  Gaudi::Property<CLID> m_rootCLID{this, "RootCLID", 110 /*CLID_Event*/, "CLID of root entry"};
  Gaudi::Property<std::string> m_rootName{this, "RootName", "/Event", "name of root entry"};
  Gaudi::Property<bool> m_forceLeaves{this, "ForceLeaves", false, "force creation of default leaves on registerObject"};
  Gaudi::Property<std::vector<std::string>> m_inhibitPathes{this, "InhibitPathes", {}, "inhibited leaves"};

  Gaudi::Property<bool> m_enableFaultHdlr{this, "EnableFaultHandler", false,
                                          "enable incidents on data creation requests"};
  Gaudi::Property<std::string> m_faultName{this, "DataFaultName", "DataFault", "Name of the data fault incident"};

  Gaudi::Property<bool> m_enableAccessHdlr{this, "EnableAccessHandler", false,
                                           "enable incidents on data access requests"};
  Gaudi::Property<std::string> m_accessName{this, "DataAccessName", "DataAccess", "Name of the data access incident"};

  LoadItems m_preLoads;
  DataSvcHelpers::RegistryEntry* m_root = nullptr;
  DataSvcHelpers::InhibitMap* m_inhibitMap = nullptr;

public:
  CLID rootCLID() const override;

  const std::string& rootName() const override;

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

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

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

  StatusCode unregisterAddress( const std::string& fullPath ) override;

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

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

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

  StatusCode objectParent( const DataObject* pObject, IRegistry*& refpParent ) override;
  StatusCode objectParent( const IRegistry* pRegistry, IRegistry*& refpParent ) override;

  StatusCode clearSubTree( const std::string& sub_tree_path ) override;

  StatusCode clearSubTree( DataObject* pObject ) override;

  StatusCode clearStore() override;

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

  StatusCode traverseSubTree( DataObject* pObject, IDataStoreAgent* pAgent ) override;

  StatusCode traverseTree( IDataStoreAgent* pAgent ) override;

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

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

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

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

  StatusCode setDataLoader( IConversionSvc* svc, IDataProviderSvc* dpsvc = nullptr ) override;

  StatusCode addPreLoadItem( const DataStoreItem& item ) override;

  StatusCode addPreLoadItem( const std::string& itemPath ) override;

  StatusCode removePreLoadItem( const DataStoreItem& item ) override;

  StatusCode removePreLoadItem( const std::string& itemPath ) override;

  StatusCode resetPreLoad() override;

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

  StatusCode preLoad() override;

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

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

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

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

  StatusCode registerObject( DataObject* parentObj, int item, DataObject* pObject ) override;

  StatusCode unregisterObject( const std::string& fullPath ) override;

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

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

  StatusCode unregisterObject( DataObject* pObject ) override;

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

  StatusCode unregisterObject( DataObject* pObject, int item ) override;

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

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

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

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

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

  StatusCode retrieveObject( DataObject* parentObj, int item, DataObject*& pObject ) override;

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

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

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

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

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

  StatusCode findObject( DataObject* parentObj, int item, DataObject*& pObject ) override;

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

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

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

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

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

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

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

  StatusCode unlinkObject( const std::string& fullPath ) override;

  StatusCode updateObject( IRegistry* pDirectory ) override;

  StatusCode updateObject( const std::string& updatePath ) override;

  StatusCode updateObject( DataObject* toUpdate ) override;

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

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

  StatusCode initialize() override;

  StatusCode reinitialize() override;

  StatusCode finalize() override;

  using extends::extends;

  ~TsDataSvc() override;

private:
  TsDataSvc( const TsDataSvc& ) = delete;
  TsDataSvc& operator=( const TsDataSvc& ) = delete;

protected:
  bool checkRoot() { return 0 != m_root; }

  virtual IConversionSvc* getDataLoader( IRegistry* pReg );

  virtual DataObject* createDefaultObject() const;

  virtual StatusCode loadObject( IRegistry* pNode );

  virtual StatusCode loadObject( IConversionSvc* pLoader, IRegistry* pNode );

  StatusCode retrieveEntry( DataSvcHelpers::RegistryEntry* pNode, const std::string& path,
                            DataSvcHelpers::RegistryEntry*& pEntry );
  DataObject* handleDataFault( IRegistry* pReg, const std::string& path = "" );

  tsDataSvcMutex m_accessMutex;
};
#endif // GAUDIKERNEL_TSDATASVC_H