CondWriterExtAlg.cxx

Go to the documentation of this file.

/*
  Copyright (C) 2002-2022 CERN for the benefit of the ATLAS collaboration
*/
 
#include "CondWriterExtAlg.h"
 
#include "StoreGate/ReadHandle.h"
 
#include <stdlib.h>
 
namespace DMTest {
 
CondWriterExtAlg::CondWriterExtAlg(const std::string& name, ISvcLocator* pSvcLocator) :
  AthAlgorithm(name, pSvcLocator),
  m_iovSvc("IOVSvc", name)
{
}
 
StatusCode CondWriterExtAlg::initialize()
{
  ATH_CHECK( m_iovSvc.retrieve() );
 
  return StatusCode::SUCCESS;
}
 
StatusCode CondWriterExtAlg::execute()
{
  const EventContext& context = getContext();
  ATH_MSG_INFO ("Event " << context.eventID().event_number() <<
                " LBN " << context.eventID().lumi_block());
 
  // Check if we need to execute a command
  auto it = m_cmd.find(context.eventID().lumi_block());
  if (it != m_cmd.end()) {
    ATH_MSG_INFO("Executing: " << it->second);
    if ( system(it->second.c_str()) != 0 ) {
      ATH_MSG_ERROR("Error executing command");
      return StatusCode::FAILURE;
    }
    // Remove this command
    m_cmd.erase(it);
 
    ATH_MSG_INFO("Resetting and dropping payload of folder " << m_attrListKey.value());
 
    ATH_CHECK( m_iovSvc->dropObjectFromDB(detStore()->clid(m_attrListKey), m_attrListKey, "StoreGateSvc") );
  }
 
  return StatusCode::SUCCESS;
}
 
} // namespace DMTest