AtlasTest/DatabaseTest/AthenaPoolTest/src/EventInfoWriter.cxx

Go to the documentation of this file.

/*
  Copyright (C) 2002-2024 CERN for the benefit of the ATLAS collaboration
*/
 
//<<<<<< INCLUDES                                                       >>>>>>
 
#include "EventInfoWriter.h"
 
// Event includes
#include "EventInfoMgt/ITagInfoMgr.h"
 
// Constructor with parameters:
EventInfoWriter::EventInfoWriter(const std::string &name, 
                 ISvcLocator *pSvcLocator) :
        AthAlgorithm(name,pSvcLocator)
{
}
 
// Initialize method:
StatusCode EventInfoWriter::initialize()
{
    // Get the messaging service, print where you are
    ATH_MSG_DEBUG("EventInfoWriter::initialize()");
 
    ATH_MSG_DEBUG("CreateDummyTags         " << m_createDummyTags);
    ATH_MSG_DEBUG("RemoveDummyTags         " << m_removeDummyTags);
    ATH_MSG_DEBUG("CreateDummyOverrideTags " << m_createDummyOverrideTags);
 
    // get TagInfoMgr service
    ATH_CHECK(m_tagInfoMgr.retrieve());
 
    // Insert a dummy tag into the TagInfoMgr
    if (m_tagInfoMgr->addTag("EventInfoWriterTag", "EIW-00-00-01").isFailure()) {
    ATH_MSG_FATAL("Unable to add tag to TagInfoMgr !");
    return StatusCode::FAILURE;
    } 
    else {
    ATH_MSG_DEBUG("Added tag to TagInfoMgr");
    }
 
    if (fillTagInfo().isFailure()) {
    ATH_MSG_FATAL("Unable to to call fillTagInfo !");
    return StatusCode::FAILURE;
    } 
    else {
    ATH_MSG_DEBUG("Called fillTagInfo");
    }
 
    ATH_CHECK (m_eventInfoKey.initialize());
 
    return StatusCode::SUCCESS;
}
 
// Execute method:
StatusCode EventInfoWriter::execute() 
{
    // Get the messaging service, print where you are
    ATH_MSG_DEBUG("EventInfoWriter::execute()");
 
    SG::ReadHandle<xAOD::EventInfo> eventInfo (m_eventInfoKey, getContext());
    if(!eventInfo.isValid()) {
    ATH_MSG_ERROR("  Could not get event info");      
    return StatusCode::FAILURE;
    }
    else {
    ATH_MSG_DEBUG("Event ID: ["
              << eventInfo->runNumber()   << ","
              << eventInfo->eventNumber() << ":"
              << eventInfo->timeStamp() << "] "
              );
    }
 
    // Set new dummy tags only at the first event of run 2
    if (!m_setDummyTags && eventInfo->runNumber() == 2 && m_createDummyOverrideTags) {
        m_setDummyTags = true;
        ATH_MSG_DEBUG("Create dummy tags, A2-D2");
    // New/different tags
        if (m_tagInfoMgr->addTag("TagA1", "A2").isFailure()) {
            ATH_MSG_WARNING("TagA1 NOT added");
        } 
        if (m_tagInfoMgr->addTag("TagB1", "B2").isFailure()) {
            ATH_MSG_WARNING("TagB1 NOT added");
    } 
        if (m_tagInfoMgr->addTag("TagC1", "C2").isFailure()) {
            ATH_MSG_WARNING("TagC1 NOT added");
    } 
        if (m_tagInfoMgr->addTag("TagD1", "D2").isFailure()) {
            ATH_MSG_WARNING("TagD1 NOT added");
    } 
    }
 
    // Dump out Tags
    ATH_MSG_DEBUG("Tags from TagInfoMgr:");
    MsgStream log(msgSvc(), name());
    m_tagInfoMgr->printTags(log);
    
    // Print out current Release version 
    std::string releaseVersion = m_tagInfoMgr->findTag("AtlasRelease");
    ATH_MSG_DEBUG("Found Release version from TagInfoMgr: " << releaseVersion);
 
    return StatusCode::SUCCESS;
}
 
 
// Finalize method:
StatusCode EventInfoWriter::finalize() 
{
    // Get the messaging service, print where you are
    ATH_MSG_DEBUG("EventInfoWriter::finalize()");
 
    return StatusCode::SUCCESS;
}
 
StatusCode 
EventInfoWriter::fillTagInfo    ()
{
 
    // Get the messaging service, print where you are
    ATH_MSG_DEBUG("EventInfoWriter::fillTagInfo()");
 
    //
    //  For tests, add in dummy tags
    //
    if(m_createDummyTags) {
    ATH_MSG_DEBUG("Create dummy tags, A1-D1");
    // New/different tags
        if (m_tagInfoMgr->addTag("TagA1", "A1").isFailure()) {
        ATH_MSG_WARNING("TagA1 NOT added");
        } 
        if (m_tagInfoMgr->addTag("TagB1", "B1").isFailure()) {
        ATH_MSG_WARNING("TagB1 NOT added");
    } 
        if (m_tagInfoMgr->addTag("TagC1", "C1").isFailure()) {
        ATH_MSG_WARNING("TagC1 NOT added");
    } 
        if (m_tagInfoMgr->addTag("TagD1", "D1").isFailure()) {
        ATH_MSG_WARNING("TagD1 NOT added");
    } 
    }
 
    // Remove incoming dummy tag
    if (m_removeDummyTags) {
    ATH_MSG_DEBUG("Create dummy tags, A1-D1");
        if (m_tagInfoMgr->removeTagFromInput("TagC1").isFailure()) {
        ATH_MSG_WARNING("TagC1 NOT removed");
    } 
    }
        
    return StatusCode::SUCCESS;
}