This class is the EventSelector and AddressProvider for event data. More...

#include <AthenaPoolAddressProviderSvc.h>

Inheritance diagram for AthenaPoolAddressProviderSvc:

Collaboration diagram for AthenaPoolAddressProviderSvc:

Public Types
typedef std::list< SG::TransientAddress * >	tadList

typedef tadList::iterator	tadListIterator

Public Member Functions
	AthenaPoolAddressProviderSvc (const std::string &name, ISvcLocator *pSvcLocator)
	Standard Service Constructor. More...

virtual	~AthenaPoolAddressProviderSvc ()
	Destructor. More...

virtual StatusCode	initialize ()
	Required of all Gaudi Services. More...

virtual StatusCode	finalize ()
	Required of all Gaudi Services. More...

virtual StatusCode	queryInterface (const InterfaceID &riid, void **ppvInterface)
	Does this object satisfy a given interface? See Gaudi documentation for details. More...

virtual StatusCode	preLoadAddresses (StoreID::type storeID, IAddressProvider::tadList &tads)
	Get all addresses from provider. More...

virtual StatusCode	loadAddresses (StoreID::type storeID, IAddressProvider::tadList &tads)
	Get all addresses for this event from provider. More...

virtual StatusCode	updateAddress (StoreID::type storeID, SG::TransientAddress *tad, const EventContext &ctx)
	Update a transient address. More...

MsgStream &	msg () const

MsgStream &	msg (const MSG::Level lvl) const

bool	msgLvl (const MSG::Level lvl) const

	DeclareInterfaceID (IAddressProvider, 1, 0)

Private Member Functions
StoreGateSvc *	eventStore () const
	Return pointer to active event SG. More...

Private Attributes
ServiceHandle< StoreGateSvc >	m_metaDataStore

ServiceHandle< IClassIDSvc >	m_clidSvc

Guid	m_guid

StringProperty	m_dataHeaderKey
	DataHeaderKey, StoreGate key of event entry object (type DataHeader). More...

Gaudi::Property< std::string >	m_attrListKey
	Attribute list key of a secondary input file. More...

Detailed Description

This class is the EventSelector and AddressProvider for event data.

Definition at line 29 of file AthenaPoolAddressProviderSvc.h.

Member Typedef Documentation

◆ tadList

typedef std::list<SG::TransientAddress*> IAddressProvider::tadList

inherited

Definition at line 32 of file IAddressProvider.h.

◆ tadListIterator

typedef tadList::iterator IAddressProvider::tadListIterator

inherited

Definition at line 33 of file IAddressProvider.h.

Constructor & Destructor Documentation

◆ AthenaPoolAddressProviderSvc()

AthenaPoolAddressProviderSvc::AthenaPoolAddressProviderSvc	(	const std::string &	name,
		ISvcLocator *	pSvcLocator
	)

Standard Service Constructor.

Definition at line 30 of file AthenaPoolAddressProviderSvc.cxx.

                                                                                                           :
     ::AthService(name, pSvcLocator),
     m_metaDataStore("MetaDataStore", name),
     m_clidSvc("ClassIDSvc", name),
     m_guid() {
    declareProperty("DataHeaderKey",       m_dataHeaderKey = "EventSelector");
    declareProperty("AttributeListKey",    m_attrListKey = "");
 }

◆ ~AthenaPoolAddressProviderSvc()

AthenaPoolAddressProviderSvc::~AthenaPoolAddressProviderSvc ( )

virtual

Destructor.

Definition at line 39 of file AthenaPoolAddressProviderSvc.cxx.

39 {

40 }

Member Function Documentation

◆ DeclareInterfaceID()

IAddressProvider::DeclareInterfaceID	(	IAddressProvider	,
		1	,
		0
	)

inherited

◆ eventStore()

StoreGateSvc * AthenaPoolAddressProviderSvc::eventStore ( ) const

private

Return pointer to active event SG.

Definition at line 42 of file AthenaPoolAddressProviderSvc.cxx.

                                                              {
    return StoreGateSvc::currentStoreGate();
 }

◆ finalize()

StatusCode AthenaPoolAddressProviderSvc::finalize ( )

virtual

Required of all Gaudi Services.

Definition at line 64 of file AthenaPoolAddressProviderSvc.cxx.

                                                   {
    // Release ClassIDSvc
    if (!m_clidSvc.release().isSuccess()) {
       ATH_MSG_WARNING("Cannot release ClassIDSvc.");
    }
    // Release MetaDataStore
    if (!m_metaDataStore.release().isSuccess()) {
       ATH_MSG_WARNING("Cannot release MetaDataStore.");
    }
    return(::AthService::finalize());
 }

◆ initialize()

StatusCode AthenaPoolAddressProviderSvc::initialize ( )

virtual

Required of all Gaudi Services.

Definition at line 46 of file AthenaPoolAddressProviderSvc.cxx.

                                                     {
    if (!::AthService::initialize().isSuccess()) {
       ATH_MSG_FATAL("Cannot initialize AthService base class.");
       return(StatusCode::FAILURE);
    }
    // Retrieve MetaDataStore
    if (!m_metaDataStore.retrieve().isSuccess()) {
       ATH_MSG_FATAL("Cannot get MetaDataStore.");
       return(StatusCode::FAILURE);
    }
    // Retrieve ClassIDSvc
    if (!m_clidSvc.retrieve().isSuccess()) {
       ATH_MSG_FATAL("Cannot get ClassIDSvc.");
       return(StatusCode::FAILURE);
    }
    return(StatusCode::SUCCESS);
 }

◆ loadAddresses()

StatusCode AthenaPoolAddressProviderSvc::loadAddresses	(	StoreID::type	storeID,
		IAddressProvider::tadList &	tads
	)

virtual

Get all addresses for this event from provider.

Parameters

storeID	[IN] store ID, this function only preloads event store addresses.
tads	[OUT] list of the transient addresses which were preloaded.

Reimplemented from IAddressProvider.

Definition at line 112 of file AthenaPoolAddressProviderSvc.cxx.

                                        {
    if (storeID != StoreID::EVENT_STORE && storeID != StoreID::PILEUP_STORE) {
       return(StatusCode::SUCCESS);
    }
  
    Guid thisFile = Guid::null();
    const DataHeader* dataHeader = nullptr;
    if (dataHeader == nullptr) { // New file (or reading DataHeader)
       SG::ReadHandle<DataHeader> eventDataHeader(m_dataHeaderKey.value(), eventStore()->name());
       if (!eventDataHeader.isValid()) {
          ATH_MSG_ERROR("Cannot retrieve DataHeader from StoreGate: " << m_dataHeaderKey);
          return(StatusCode::FAILURE);
       }
       dataHeader = eventDataHeader.cptr();
    }
    // second data header
    if (m_attrListKey.value() != "") {
       const AthenaAttributeList* attrList = nullptr;
       std::string tokenStr;
       if (eventStore()->retrieve(attrList, m_attrListKey.value()).isSuccess()) {
          try {
             tokenStr = (*attrList)["eventRef_secondary"].data<std::string>();
             ATH_MSG_DEBUG("found AthenaAttribute, name = eventRef_secondary = " << tokenStr);
          } catch (std::exception &e) {
             ATH_MSG_ERROR(e.what());
             return (StatusCode::FAILURE);
          }
       } else {
          ATH_MSG_ERROR("Cannot find AthenaAttribute, key = " << m_attrListKey.value());
          return (StatusCode::FAILURE);
       }
       IOpaqueAddress* iop = new GenericAddress(POOL_StorageType, ClassID_traits<DataHeader>::ID(), tokenStr, "SecondaryEventSelector");
       if (!eventStore()->recordAddress(iop).isSuccess()) {
          ATH_MSG_ERROR("Cannot record address to StoreGate with token string: " << tokenStr);
          return(StatusCode::FAILURE);
       }
       ATH_MSG_DEBUG("Created dataHeader SecondaryEventSelector");
    }
    ATH_MSG_DEBUG("The current Event contains: " << dataHeader->size() << " objects");
    for (const auto& element : *dataHeader) {
       SG::TransientAddress* tadd = element.getAddress();
       if (tadd->clID() == ClassID_traits<DataHeader>::ID()) { // self reference
          delete tadd; tadd = nullptr;
       } else {
          ATH_MSG_DEBUG("loadAddresses: DataObject address, clid = " << tadd->clID() << ", name = " << tadd->name());
          tadd->setProvider(this, storeID);
          tads.push_back(tadd);
       }
       EventSelectorAthenaPoolUtil::registerKeys(element, eventStore());
    }
    m_guid = thisFile;
    return(StatusCode::SUCCESS);
 }

◆ msg() [1/2]

MsgStream& AthCommonMsg< Service >::msg ( ) const

inlineinherited

Definition at line 24 of file AthCommonMsg.h.

                                 {
     return this->msgStream();
   }

◆ msg() [2/2]

MsgStream& AthCommonMsg< Service >::msg ( const MSG::Level lvl ) const

inlineinherited

Definition at line 27 of file AthCommonMsg.h.

                                                   {
     return this->msgStream(lvl);
   }

◆ msgLvl()

bool AthCommonMsg< Service >::msgLvl ( const MSG::Level lvl ) const

inlineinherited

Definition at line 30 of file AthCommonMsg.h.

                                                {
     return this->msgLevel(lvl);
   }

◆ preLoadAddresses()

StatusCode AthenaPoolAddressProviderSvc::preLoadAddresses	(	StoreID::type	storeID,
		IAddressProvider::tadList &	tads
	)

virtual

Get all addresses from provider.

Called before begin event.

Parameters

storeID	[IN] store ID, this function only preloads detector store addresses.
tads	[OUT] list of the transient addresses which were preloaded.

Reimplemented from IAddressProvider.

Definition at line 80 of file AthenaPoolAddressProviderSvc.cxx.

                                        {
    if (storeID != StoreID::DETECTOR_STORE) {
       return(StatusCode::SUCCESS);
    }
    ServiceHandle<StoreGateSvc> detectorStoreSvc("DetectorStore", name());
    if (!detectorStoreSvc.retrieve().isSuccess()) {
       ATH_MSG_ERROR("Cannot get DetectorStore.");
       return(StatusCode::FAILURE);
    }
    SG::ReadHandle<DataHeader> dataHeader("CondProxyProvider", detectorStoreSvc->name());
    if (!dataHeader.isValid()) {
       ATH_MSG_DEBUG("Cannot retrieve DataHeader from DetectorStore.");
       return(StatusCode::SUCCESS);
    }
    ATH_MSG_DEBUG("The current File contains: " << dataHeader->size() << " objects");
    for (const auto& element : *dataHeader) {
       SG::TransientAddress* tadd = element.getAddress();
       if (tadd->clID() == ClassID_traits<DataHeader>::ID()) {
          delete tadd; tadd = nullptr;
       } else {
          ATH_MSG_DEBUG("preLoadAddresses: DataObject address, clid = " << tadd->clID() << ", name = " << tadd->name());
          tads.push_back(tadd);
       }
       EventSelectorAthenaPoolUtil::registerKeys(element, &*detectorStoreSvc);
    }
    if (!detectorStoreSvc.release().isSuccess()) {
       ATH_MSG_WARNING("Cannot release DetectorStoreSvc.");
    }
    return(StatusCode::SUCCESS);
 }

◆ queryInterface()

StatusCode AthenaPoolAddressProviderSvc::queryInterface	(	const InterfaceID &	riid,
		void **	ppvInterface
	)

virtual

Does this object satisfy a given interface? See Gaudi documentation for details.

Definition at line 76 of file AthenaPoolAddressProviderSvc.cxx.

                                                                                                     {
    return(::AthService::queryInterface(riid, ppvInterface));
 }

◆ updateAddress()

StatusCode AthenaPoolAddressProviderSvc::updateAddress	(	StoreID::type	storeID,
		SG::TransientAddress *	tad,
		const EventContext &	ctx
	)

virtual

Update a transient address.

Parameters

storeID	[IN] store ID, this function only preloads event store addresses.
tad	[IN] transient address to be updated.

Implements IAddressProvider.

Definition at line 167 of file AthenaPoolAddressProviderSvc.cxx.

                                                                               {
    return(StatusCode::FAILURE);
 }

Member Data Documentation

◆ m_attrListKey

Gaudi::Property<std::string> AthenaPoolAddressProviderSvc::m_attrListKey

private

Attribute list key of a secondary input file.

If non-zero, creates a new IOpaqueAddress for that file and records it.

Definition at line 70 of file AthenaPoolAddressProviderSvc.h.

◆ m_clidSvc

ServiceHandle<IClassIDSvc> AthenaPoolAddressProviderSvc::m_clidSvc

private

Definition at line 61 of file AthenaPoolAddressProviderSvc.h.

◆ m_dataHeaderKey

StringProperty AthenaPoolAddressProviderSvc::m_dataHeaderKey

private

DataHeaderKey, StoreGate key of event entry object (type DataHeader).

Definition at line 66 of file AthenaPoolAddressProviderSvc.h.

◆ m_guid

Guid AthenaPoolAddressProviderSvc::m_guid

private

Definition at line 62 of file AthenaPoolAddressProviderSvc.h.

◆ m_metaDataStore

ServiceHandle<StoreGateSvc> AthenaPoolAddressProviderSvc::m_metaDataStore

private

Definition at line 60 of file AthenaPoolAddressProviderSvc.h.

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

Public Types

Public Member Functions

Private Member Functions

Private Attributes

Detailed Description

Member Typedef Documentation

◆ tadList

◆ tadListIterator

Constructor & Destructor Documentation

◆ AthenaPoolAddressProviderSvc()

◆ ~AthenaPoolAddressProviderSvc()

Member Function Documentation

◆ DeclareInterfaceID()

◆ eventStore()

◆ finalize()

◆ initialize()

◆ loadAddresses()

◆ msg() [1/2]

◆ msg() [2/2]

◆ msgLvl()

◆ preLoadAddresses()

◆ queryInterface()

◆ updateAddress()

Member Data Documentation

◆ m_attrListKey

◆ m_clidSvc

◆ m_dataHeaderKey

◆ m_guid

◆ m_metaDataStore