AthPoolEx::ReadMeta Class Reference

This class provides an example for reading in file meta data objects from Pool. More...

#include <ReadMeta.h>

Inheritance diagram for AthPoolEx::ReadMeta:

Collaboration diagram for AthPoolEx::ReadMeta:

Public Member Functions
	ReadMeta (const std::string &type, const std::string &name, const IInterface *parent)
virtual	~ReadMeta ()=default
virtual StatusCode	initialize () override final
	Gaudi AlgTool Interface method implementations: More...
virtual StatusCode	beginInputFile (const SG::SourceID &) override final
	Function called when a new input file is opened. More...
virtual StatusCode	endInputFile (const SG::SourceID &) override final
	Function called when the currently open input file got completely processed. More...
virtual StatusCode	metaDataStop () override final
	Function writing the collected metadata to the output. More...
virtual void	handle (const Incident &incident) override final
	Incident service handle listening for BeginInputFile and EndInputFile. More...

Private Attributes
ServiceHandle< StoreGateSvc >	m_pMetaDataStore
ServiceHandle< StoreGateSvc >	m_pInputStore

Detailed Description

This class provides an example for reading in file meta data objects from Pool.

Definition at line 25 of file ReadMeta.h.

Constructor & Destructor Documentation

ReadMeta()

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

Definition at line 23 of file ReadMeta.cxx.

                                                                                         :
   base_class(type, name, parent),
   m_pMetaDataStore ("StoreGateSvc/MetaDataStore",      name),
   m_pInputStore    ("StoreGateSvc/InputMetaDataStore", name) {
}

~ReadMeta()

virtual AthPoolEx::ReadMeta::~ReadMeta ( )

virtualdefault

Member Function Documentation

beginInputFile()

StatusCode ReadMeta::beginInputFile ( const SG::SourceID &  )

finaloverridevirtual

Function called when a new input file is opened.

Definition at line 54 of file ReadMeta.cxx.

{
   ATH_MSG_DEBUG("saw BeginInputFile incident.");
   if (m_pInputStore->contains<ExampleHitContainer>("PedestalWriteData")) {
      std::list<SG::ObjectWithVersion<ExampleHitContainer> > allVersions;
      ATH_CHECK( m_pInputStore->retrieveAllVersions(allVersions, "PedestalWriteData") );
      //const ExampleHitContainer* ep;
      ExampleHitContainer* ep_out = nullptr;
      for (SG::ObjectWithVersion<ExampleHitContainer>& obj : allVersions) {
         const ExampleHitContainer* ep = obj.dataObject.cptr();
         if (!m_pMetaDataStore->contains<ExampleHitContainer>("PedestalWriteData")) {
            auto ep_out_unique = std::make_unique<ExampleHitContainer>();
            const ExampleHit* entry = *ep->begin();
            auto entry_out = std::make_unique<ExampleHit>();
            entry_out->setX(entry->getX());
            entry_out->setY(entry->getY());
            entry_out->setZ(entry->getZ());
            entry_out->setDetector(entry->getDetector());
            ep_out_unique->push_back(std::move(entry_out));
            ep_out = ep_out_unique.get();
            ATH_CHECK( m_pMetaDataStore->record(std::move(ep_out_unique), "PedestalWriteData") );
         } else {
            ATH_CHECK( m_pMetaDataStore->retrieve(ep_out, "PedestalWriteData") );
            const ExampleHit* entry = *ep->begin();
            ExampleHit* entry_out = *ep_out->begin();
            int weight = entry->getDetector().size() - 2;
            int weight_out = entry_out->getDetector().size() - 2;
            entry_out->setX((entry->getX() * weight + entry_out->getX() * weight_out) / (weight + weight_out));
            entry_out->setY((entry->getY() * weight + entry_out->getY() * weight_out) / (weight + weight_out));
            entry_out->setZ((entry->getZ() * weight + entry_out->getZ() * weight_out) / (weight + weight_out));
            entry_out->setDetector(entry->getDetector().substr(0, entry->getDetector().size() - 1) + entry_out->getDetector().substr(1));
         }
      }
      if (ep_out != nullptr) {
         for (const ExampleHit* obj : *ep_out) {
            ATH_MSG_INFO("Pedestal x = " << obj->getX() << " y = " << obj->getY() << " z = " << obj->getZ() << " string = " << obj->getDetector());
         }
      }
   }
 
   return StatusCode::SUCCESS;
}

endInputFile()

virtual StatusCode AthPoolEx::ReadMeta::endInputFile ( const SG::SourceID &  )

inlinefinaloverridevirtual

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

Definition at line 39 of file ReadMeta.h.

{return StatusCode::SUCCESS;}

handle()

void ReadMeta::handle ( const Incident &  incident )

finaloverridevirtual

Incident service handle listening for BeginInputFile and EndInputFile.

Definition at line 44 of file ReadMeta.cxx.

                                         {
   ATH_MSG_DEBUG("handle() " << inc.type());
   const FileIncident* fileInc  = dynamic_cast<const FileIncident*>(&inc);
   if (fileInc == nullptr) {
      ATH_MSG_ERROR(" Unable to get FileName from BeginInputFile/EndInputFile incident");
      return;
   }
   ATH_MSG_DEBUG("handle() " << inc.type() << " for " << fileInc->fileName());
}

initialize()

StatusCode ReadMeta::initialize ( )

finaloverridevirtual

Gaudi AlgTool Interface method implementations:

Definition at line 29 of file ReadMeta.cxx.

                                {
   ATH_MSG_INFO("in initialize()");
 
   // locate the DetectorStore and initialize our local ptr
   ATH_CHECK( m_pMetaDataStore.retrieve() );
   ATH_CHECK( m_pInputStore.retrieve() );
 
   // Set to be listener for end of event
   ServiceHandle<IIncidentSvc> incSvc("IncidentSvc", this->name());
   ATH_CHECK( incSvc.retrieve() );
   incSvc->addListener(this, "BeginInputFile", 60); // pri has to be < 100 to be after MetaDataSvc.
   incSvc->addListener(this, "EndInputFile", 50); // pri has to be > 10 to be before MetaDataSvc.
   return StatusCode::SUCCESS;
}

metaDataStop()

virtual StatusCode AthPoolEx::ReadMeta::metaDataStop ( )

inlinefinaloverridevirtual

Function writing the collected metadata to the output.

Definition at line 42 of file ReadMeta.h.

{return StatusCode::SUCCESS;}

Member Data Documentation

m_pInputStore

ServiceHandle<StoreGateSvc> AthPoolEx::ReadMeta::m_pInputStore

private

Definition at line 49 of file ReadMeta.h.

m_pMetaDataStore

ServiceHandle<StoreGateSvc> AthPoolEx::ReadMeta::m_pMetaDataStore

private

Definition at line 48 of file ReadMeta.h.

---

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

• ReadMeta.h
• ReadMeta.cxx