ByteStreamMetadataTool Class Reference

This class provides the MetaDataTool for ByteStreamMetadata objects. More...

#include <ByteStreamMetadataTool.h>

Inheritance diagram for ByteStreamMetadataTool:

Collaboration diagram for ByteStreamMetadataTool:

Public Member Functions
	ByteStreamMetadataTool (const std::string &type, const std::string &name, const IInterface *parent)
	Standard Service Constructor.
virtual	~ByteStreamMetadataTool ()
	Destructor.
virtual StatusCode	initialize () override
	Gaudi Service Interface method implementations:
virtual StatusCode	beginInputFile (const SG::SourceID &) override
	Incident service handle listening for BeginInputFile and EndInputFile.
virtual StatusCode	metaDataStop () override
virtual StatusCode	endInputFile (const SG::SourceID &) override

Private Member Functions
std::set< std::string >	keysFromInput () const

Private Attributes
ServiceHandle< StoreGateSvc >	m_metadataStore
ServiceHandle< StoreGateSvc >	m_inputStore

Detailed Description

This class provides the MetaDataTool for ByteStreamMetadata objects.

Definition at line 28 of file ByteStreamMetadataTool.h.

Constructor & Destructor Documentation

ByteStreamMetadataTool()

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

Standard Service Constructor.

Definition at line 17 of file ByteStreamMetadataTool.cxx.

  : base_class(type, name, parent)
  , m_metadataStore("StoreGateSvc/MetaDataStore", name)
  , m_inputStore   ("StoreGateSvc/InputMetaDataStore", name)
{
}

~ByteStreamMetadataTool()

ByteStreamMetadataTool::~ByteStreamMetadataTool ( )

virtual

Destructor.

Definition at line 29 of file ByteStreamMetadataTool.cxx.

{}

Member Function Documentation

beginInputFile()

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

overridevirtual

Incident service handle listening for BeginInputFile and EndInputFile.

Definition at line 48 of file ByteStreamMetadataTool.cxx.

{
  std::set<std::string> keys = keysFromInput();
 
  std::vector<std::unique_ptr<ByteStreamMetadata> > copy;
  std::set<std::string> transGuids;
 
 
  for(const auto& key : keys) {
    ATH_MSG_DEBUG("Processing Input ByteStreamMetadata, key = " << key);
    copy.clear();
 
    if(m_inputStore->contains<ByteStreamMetadata>(key)) {
 
      std::list<SG::ObjectWithVersion<ByteStreamMetadata> > allVersions;
      ATH_CHECK(m_inputStore->retrieveAllVersions(allVersions, key));
 
      for(SG::ObjectWithVersion<ByteStreamMetadata>& obj : allVersions)
        copy.push_back(std::make_unique<ByteStreamMetadata>(*obj.dataObject));
 
    }
 
 
    if(m_inputStore->contains<ByteStreamMetadataContainer>(key)) {
 
      std::list<SG::ObjectWithVersion<ByteStreamMetadataContainer> > allVersions;
      ATH_CHECK(m_inputStore->retrieveAllVersions(allVersions, key));
 
      for(SG::ObjectWithVersion<ByteStreamMetadataContainer>& obj : allVersions)
        for(const ByteStreamMetadata* md : *obj.dataObject)
          copy.push_back(std::make_unique<ByteStreamMetadata>(*md));
    }
 
 
    if(!copy.empty()) {
 
      transGuids.clear();
      // Check for existing container
      ByteStreamMetadataContainer* bsmdc = nullptr;
 
      if (m_metadataStore->contains<ByteStreamMetadataContainer>(key)) {
 
        ATH_MSG_DEBUG("Pre-existing ByteStreamMetadataContainer found");
        ATH_CHECK(m_metadataStore->retrieve(bsmdc, key));
 
        for (const auto bsmd : *bsmdc)
          transGuids.insert(bsmd->getGuid());
 
      } else {
 
        bsmdc = new ByteStreamMetadataContainer;
        ATH_CHECK(m_metadataStore->record(bsmdc, key));
 
      }
 
      for(auto& pBSMD : copy) {
        // Only insert new metadata records (with GUID not yet in container)
        if(transGuids.insert(pBSMD->getGuid()).second)
          bsmdc->push_back(std::move(pBSMD));
      }
    }
  }
 
  return StatusCode::SUCCESS;
}

endInputFile()

StatusCode ByteStreamMetadataTool::endInputFile ( const SG::SourceID & )

overridevirtual

Definition at line 136 of file ByteStreamMetadataTool.cxx.

{
  return StatusCode::SUCCESS;
}

initialize()

StatusCode ByteStreamMetadataTool::initialize ( )

overridevirtual

Gaudi Service Interface method implementations:

Definition at line 35 of file ByteStreamMetadataTool.cxx.

{
  ATH_MSG_INFO("Initializing");
 
  ATH_CHECK(m_metadataStore.retrieve());
  ATH_CHECK(m_inputStore.retrieve());
 
  return StatusCode::SUCCESS;
}

keysFromInput()

std::set< std::string > ByteStreamMetadataTool::keysFromInput ( ) const

inlineprivate

Definition at line 119 of file ByteStreamMetadataTool.cxx.

{
  std::vector<std::string> vKeys;
  std::set<std::string> keys;
 
  m_inputStore->keys<ByteStreamMetadata>(vKeys);
  keys.insert(vKeys.begin(), vKeys.end());
 
  m_inputStore->keys<ByteStreamMetadataContainer>(vKeys);
  keys.insert(vKeys.begin(), vKeys.end());
 
  return keys;
}

metaDataStop()

StatusCode ByteStreamMetadataTool::metaDataStop ( )

overridevirtual

Definition at line 143 of file ByteStreamMetadataTool.cxx.

{
  return StatusCode::SUCCESS;
}

Member Data Documentation

m_inputStore

ServiceHandle<StoreGateSvc> ByteStreamMetadataTool::m_inputStore

private

Definition at line 49 of file ByteStreamMetadataTool.h.

m_metadataStore

ServiceHandle<StoreGateSvc> ByteStreamMetadataTool::m_metadataStore

private

Definition at line 48 of file ByteStreamMetadataTool.h.

---

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

• ByteStreamMetadataTool.h
• ByteStreamMetadataTool.cxx