CopyEventStreamInfo Class Reference

This class provides an algorithm to make the EventStreamInfo object and update it. More...

#include <CopyEventStreamInfo.h>

Inheritance diagram for CopyEventStreamInfo:

Collaboration diagram for CopyEventStreamInfo:

Public Member Functions
	CopyEventStreamInfo (const std::string &type, const std::string &name, const IInterface *parent)
	Standard AlgTool Constructor. More...
virtual	~CopyEventStreamInfo ()=default
	Destructor. More...
virtual StatusCode	initialize () override final
	AthAlgTool Interface method implementations: More...
virtual StatusCode	beginInputFile (const SG::SourceID &="Serial") override final
	Function called when a new input file is opened. More...
virtual StatusCode	endInputFile (const SG::SourceID &="Serial") override final
	Function called when the currently open input file got completely processed. More...
virtual StatusCode	metaDataStop () override final
	Function called when the tool should write out its metadata. More...

Private Attributes
Gaudi::Property< std::vector< std::string > >	m_keys
	(optional) list of keys to copy, all if empty, default: empty More...
ServiceHandle< IAthMetaDataSvc >	m_metaDataSvc {this, "MetaDataSvc", "MetaDataSvc"}
	Access to output MetaDataStore through MetaDataSvc (using MetaContainers) More...
ServiceHandle< StoreGateSvc >	m_inputMetaDataStore {this, "InputMetaDataStore", "StoreGateSvc/InputMetaDataStore"}
	MetaDataStore for input. More...

Detailed Description

This class provides an algorithm to make the EventStreamInfo object and update it.

Definition at line 27 of file CopyEventStreamInfo.h.

Constructor & Destructor Documentation

CopyEventStreamInfo()

CopyEventStreamInfo::CopyEventStreamInfo	(	const std::string &	type,
		const std::string &	name,
		const IInterface *	parent
	)

Standard AlgTool Constructor.

Definition at line 17 of file CopyEventStreamInfo.cxx.

                                                                   :
  base_class(type, name, parent) {
}

~CopyEventStreamInfo()

virtual CopyEventStreamInfo::~CopyEventStreamInfo ( )

virtualdefault

Destructor.

Member Function Documentation

beginInputFile()

StatusCode CopyEventStreamInfo::beginInputFile ( const SG::SourceID &  = "Serial" )

finaloverridevirtual

Function called when a new input file is opened.

Definition at line 33 of file CopyEventStreamInfo.cxx.

{
   std::vector<std::string> keys = m_keys;
   if (keys.empty()) {
      m_inputMetaDataStore->keys<EventStreamInfo>(keys);
   } else {
     // remove keys not in the InputMetaDataStore
     std::erase_if(keys, [this](const std::string& key) {
               return !m_inputMetaDataStore->contains<EventStreamInfo>(key);
             });
   }
 
   // If the input file doesn't have any event stream info metadata,
   // then finish right away:
   if (keys.empty()) return StatusCode::SUCCESS;
 
   for (const auto &key : keys) {
      // Ignore versioned container
      if (key.substr(0, 1) == ";" && key.substr(3, 1) == ";") {
         ATH_MSG_VERBOSE( "Ignore versioned container: " << key );
         continue;
      }
      std::list<SG::ObjectWithVersion<EventStreamInfo> > allVersions;
      ATH_CHECK( m_inputMetaDataStore->retrieveAllVersions(allVersions, key) );
 
      EventStreamInfo* evtStrInfo_out = 0;
      for (SG::ObjectWithVersion<EventStreamInfo>& obj : allVersions) {
         const EventStreamInfo* evtStrInfo_in = obj.dataObject.cptr();
         evtStrInfo_out = m_metaDataSvc->tryRetrieve<EventStreamInfo>(key);
         if( !evtStrInfo_out ) {
            auto esinfo_up = std::make_unique<EventStreamInfo>(*evtStrInfo_in);
            ATH_CHECK( m_metaDataSvc->record( std::move(esinfo_up), key ) );
         } else {
            evtStrInfo_out->addEvent(evtStrInfo_in->getNumberOfEvents());
            for (const auto& elem : evtStrInfo_in->getRunNumbers()) {
               evtStrInfo_out->insertRunNumber(elem);
            }
            for (const auto& elem : evtStrInfo_in->getLumiBlockNumbers()) {
               evtStrInfo_out->insertLumiBlockNumber(elem);
            }
            for (const auto& elem : evtStrInfo_in->getProcessingTags()) {
               evtStrInfo_out->insertProcessingTag(elem);
            }
            for (const auto& [classId, key] : evtStrInfo_in->getItemList()) {
               evtStrInfo_out->insertItemList(classId, key);
            }
            for (const auto& elem : evtStrInfo_in->getEventTypes()) {
               evtStrInfo_out->insertEventType(elem);
            }
         }
      }
   }
   return StatusCode::SUCCESS;
}

endInputFile()

StatusCode CopyEventStreamInfo::endInputFile ( const SG::SourceID &  = "Serial" )

finaloverridevirtual

Function called when the currently open input file got completely processed.

Definition at line 87 of file CopyEventStreamInfo.cxx.

{
   return StatusCode::SUCCESS;
}

initialize()

StatusCode CopyEventStreamInfo::initialize ( )

finaloverridevirtual

AthAlgTool Interface method implementations:

Definition at line 23 of file CopyEventStreamInfo.cxx.

                                           {
   ATH_MSG_DEBUG("Initializing " << name());
   // Locate the MetaDataSvc and InputMetaDataStore
   ATH_CHECK( m_metaDataSvc.retrieve() );
   ATH_CHECK( m_inputMetaDataStore.retrieve() );
 
   return StatusCode::SUCCESS;
}

metaDataStop()

StatusCode CopyEventStreamInfo::metaDataStop ( )

finaloverridevirtual

Function called when the tool should write out its metadata.

Definition at line 91 of file CopyEventStreamInfo.cxx.

{
   return StatusCode::SUCCESS;
}

Member Data Documentation

m_inputMetaDataStore

ServiceHandle<StoreGateSvc> CopyEventStreamInfo::m_inputMetaDataStore {this, "InputMetaDataStore", "StoreGateSvc/InputMetaDataStore"}

private

MetaDataStore for input.

Definition at line 55 of file CopyEventStreamInfo.h.

m_keys

Gaudi::Property<std::vector<std::string> > CopyEventStreamInfo::m_keys

private

Initial value:

{this, "Keys", {},
      "(optional) list of keys to copy, all if empty. default: empty"}

(optional) list of keys to copy, all if empty, default: empty

Definition at line 49 of file CopyEventStreamInfo.h.

m_metaDataSvc

ServiceHandle<IAthMetaDataSvc> CopyEventStreamInfo::m_metaDataSvc {this, "MetaDataSvc", "MetaDataSvc"}

private

Access to output MetaDataStore through MetaDataSvc (using MetaContainers)

Definition at line 53 of file CopyEventStreamInfo.h.

---

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

• CopyEventStreamInfo.h
• CopyEventStreamInfo.cxx