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 ()
	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
	Access to output MetaDataStore through MetaDataSvc (using MetaContainers) More...
ServiceHandle< StoreGateSvc >	m_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 16 of file CopyEventStreamInfo.cxx.

                                                                   :
  base_class(type, name, parent),
  m_metaDataSvc("MetaDataSvc", name),
  m_inputMetaDataStore("StoreGateSvc/InputMetaDataStore", name) {
}

~CopyEventStreamInfo()

CopyEventStreamInfo::~CopyEventStreamInfo ( )

virtual

Destructor.

Definition at line 24 of file CopyEventStreamInfo.cxx.

                                          {
}

Member Function Documentation

beginInputFile()

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

finaloverridevirtual

Function called when a new input file is opened.

Definition at line 37 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
     keys.erase(
         std::remove_if(
             keys.begin(), keys.end(),
             [this](std::string& key) {
               return !m_inputMetaDataStore->contains<EventStreamInfo>(key);
             }),
         keys.end());
   }
 
   // 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 (auto elem = evtStrInfo_in->getRunNumbers().begin(),
                        lastElem = evtStrInfo_in->getRunNumbers().end(); 
                        elem != lastElem; elem++) {
               evtStrInfo_out->insertRunNumber(*elem);
            }
            for (auto elem = evtStrInfo_in->getLumiBlockNumbers().begin(),
                        lastElem = evtStrInfo_in->getLumiBlockNumbers().end(); 
                        elem != lastElem; elem++) {
               evtStrInfo_out->insertLumiBlockNumber(*elem);
            }
            for (auto elem = evtStrInfo_in->getProcessingTags().begin(),
                        lastElem = evtStrInfo_in->getProcessingTags().end(); 
                        elem != lastElem; elem++) {
               evtStrInfo_out->insertProcessingTag(*elem);
            }
            for (auto elem = evtStrInfo_in->getItemList().begin(),
                        lastElem = evtStrInfo_in->getItemList().end(); 
                        elem != lastElem; elem++) {
               evtStrInfo_out->insertItemList((*elem).first, (*elem).second);
            }
            for (auto elem = evtStrInfo_in->getEventTypes().begin(),
                        lastElem = evtStrInfo_in->getEventTypes().end(); 
                        elem != lastElem; elem++) {
               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 105 of file CopyEventStreamInfo.cxx.

{
   return(StatusCode::SUCCESS);
}

initialize()

StatusCode CopyEventStreamInfo::initialize ( )

finaloverridevirtual

AthAlgTool Interface method implementations:

Definition at line 27 of file CopyEventStreamInfo.cxx.

                                           {
   ATH_MSG_INFO("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 109 of file CopyEventStreamInfo.cxx.

{
   return(StatusCode::SUCCESS);
}

Member Data Documentation

m_inputMetaDataStore

ServiceHandle<StoreGateSvc> CopyEventStreamInfo::m_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

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