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)
	Standard Service Constructor. More...
virtual	~ReadMeta ()
	Destructor. More...
virtual StatusCode	initialize () override
	Gaudi AlgTool Interface method implementations: More...
virtual StatusCode	beginInputFile (const SG::SourceID &) override
	Function called when a new input file is opened. More...
virtual StatusCode	endInputFile (const SG::SourceID &) override
	Function called when the currently open input file got completely processed. More...
virtual StatusCode	metaDataStop () override
	Function writing the collected metadata to the output. More...
virtual void	handle (const Incident &incident) override
	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
	)

Standard Service Constructor.

Definition at line 23 of file ReadMeta.cxx.

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

~ReadMeta()

ReadMeta::~ReadMeta ( )

virtual

Destructor.

Definition at line 29 of file ReadMeta.cxx.

                    {
}

Member Function Documentation

beginInputFile()

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

overridevirtual

Function called when a new input file is opened.

Definition at line 57 of file ReadMeta.cxx.

{
   ATH_MSG_DEBUG("saw BeginInputFile incident.");
   if (m_pInputStore->contains<ExampleHitContainer>("PedestalWriteData")) {
      std::list<SG::ObjectWithVersion<ExampleHitContainer> > allVersions;
      if (m_pInputStore->retrieveAllVersions(allVersions, "PedestalWriteData").isFailure()) {
         ATH_MSG_ERROR("Could not retrieve all versions for PedestalWriteData");
         return StatusCode::FAILURE;
      }
      //const ExampleHitContainer* ep;
      ExampleHitContainer* ep_out = 0;
      for (SG::ObjectWithVersion<ExampleHitContainer>& obj : allVersions) {
         const ExampleHitContainer* ep = obj.dataObject.cptr();
         if (!m_pMetaDataStore->contains<ExampleHitContainer>("PedestalWriteData")) {
            ep_out = new ExampleHitContainer();
            const ExampleHit* entry = *ep->begin();
            ExampleHit* entry_out = new ExampleHit();
            entry_out->setX(entry->getX());
            entry_out->setY(entry->getY());
            entry_out->setZ(entry->getZ());
            entry_out->setDetector(entry->getDetector());
            ep_out->push_back(entry_out);
            if (m_pMetaDataStore->record(ep_out, "PedestalWriteData").isFailure()) {
               ATH_MSG_ERROR("Could not record DataObject: PedestalWriteData");
               return StatusCode::FAILURE;
            }
         } else {
            if (m_pMetaDataStore->retrieve(ep_out, "PedestalWriteData").isFailure()) {
               ATH_MSG_ERROR("Could not find DataObject in output: PedestalWriteData");
               return StatusCode::FAILURE;
            }
            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 != 0) {
         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 &  )

inlineoverridevirtual

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

Definition at line 41 of file ReadMeta.h.

{return StatusCode::SUCCESS;}

handle()

void ReadMeta::handle ( const Incident &  incident )

overridevirtual

Incident service handle listening for BeginInputFile and EndInputFile.

Definition at line 47 of file ReadMeta.cxx.

                                         {
   ATH_MSG_DEBUG("handle() " << inc.type());
   const FileIncident* fileInc  = dynamic_cast<const FileIncident*>(&inc);
   if (fileInc == 0) {
      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 ( )

overridevirtual

Gaudi AlgTool Interface method implementations:

Definition at line 32 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 ( )

inlineoverridevirtual

Function writing the collected metadata to the output.

Definition at line 44 of file ReadMeta.h.

{return StatusCode::SUCCESS;}

Member Data Documentation

m_pInputStore

ServiceHandle<StoreGateSvc> AthPoolEx::ReadMeta::m_pInputStore

private

Definition at line 51 of file ReadMeta.h.

m_pMetaDataStore

ServiceHandle<StoreGateSvc> AthPoolEx::ReadMeta::m_pMetaDataStore

private

Definition at line 50 of file ReadMeta.h.

---

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

• ReadMeta.h
• ReadMeta.cxx