HiveAlgA.cxx

Go to the documentation of this file.

/*
  Copyright (C) 2002-2026 CERN for the benefit of the ATLAS collaboration
*/
 
#include "HiveAlgA.h"
 
HiveAlgA::HiveAlgA( const std::string& name, 
            ISvcLocator* pSvcLocator ) : 
  ::HiveAlgBase( name, pSvcLocator )
{
}
 
HiveAlgA::~HiveAlgA() = default;
 
/* * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * */
 
StatusCode HiveAlgA::initialize() {
  ATH_MSG_DEBUG("initialize " << name());
  
  ATH_CHECK( m_evt.initialize() );
  ATH_CHECK( m_wrh1.initialize() );
  ATH_CHECK( m_wrh2.initialize() );
 
  // make sure we initialize the base class
  return HiveAlgBase::initialize();
}
 
/* * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * */
 
StatusCode HiveAlgA::execute(const EventContext& ctx) const {
 
  ATH_MSG_DEBUG("execute " << name());
 
  SG::ReadHandle<xAOD::EventInfo> evt{m_evt, ctx};
  if (!evt.isValid()) {
    ATH_MSG_ERROR ("Could not retrieve EventInfo");
    return StatusCode::FAILURE;
  } else {
    ATH_MSG_INFO("   EventInfo:  r: " << evt->runNumber()
         << " e: " << evt->eventNumber() );
  }
 
  sleep(ctx);
 
  unsigned int i = ctx.evt();
 
  SG::WriteHandle<HiveDataObj> wrh1{m_wrh1, ctx};
  ATH_CHECK(wrh1.record(std::make_unique< HiveDataObj >(10000 + evt->eventNumber()*100 + i)));
 
  SG::WriteHandle<HiveDataObj> wrh2{m_wrh2, ctx};
  ATH_CHECK(wrh2.record(std::make_unique< HiveDataObj >(10050+i)));
  
  ATH_MSG_INFO("  write: " << wrh1.key() << " = " << wrh1->val() );
  ATH_MSG_INFO("  write: " << wrh2.key() << " = " << wrh2->val() );
  
  return StatusCode::SUCCESS;
}