AthViews/src_dflow/DFlowAlg1.cxx

Go to the documentation of this file.

 
/*
  Copyright (C) 2002-2026 CERN for the benefit of the ATLAS collaboration
*/
 
// DFlowAlg1.cxx 
// Implementation file for class DFlowAlg1
// Modifed by bwynne to add simple tests for views
// Author: S.Binet<binet@cern.ch>
 
// AthExStoreGateExample includes
#include "DFlowAlg1.h"
 
// STL includes
 
// FrameWork includes
#include "Gaudi/Property.h"
#include "StoreGate/ReadHandle.h"
#include "StoreGate/WriteHandle.h"
 
namespace AthViews {
 
// Athena Algorithm's Hooks
StatusCode DFlowAlg1::initialize()
{
  ATH_MSG_INFO ("Initializing " << name() << "...");
 
  CHECK( m_r_int.initialize() );
  CHECK( m_w_int.initialize() );
  CHECK( m_testUpdate.initialize() );
 
  return StatusCode::SUCCESS;
}
 
StatusCode DFlowAlg1::finalize()
{
  ATH_MSG_INFO ("Finalizing " << name() << "...");
 
  return StatusCode::SUCCESS;
}
 
StatusCode DFlowAlg1::execute(const EventContext& ctx) const
{  
  ATH_MSG_DEBUG ("Executing " << name() << "...");
 
  SG::ReadHandle< int > inputData( m_r_int, ctx );
  if ( !inputData.isValid() )
  {
    ATH_MSG_ERROR( "Failed to retrieve initial view data from store " << inputData.store() );
    return StatusCode::FAILURE;
  }
  int seedData = *inputData;
 
  SG::WriteHandle< int > outputData( m_w_int, ctx );
  ATH_MSG_INFO("myint handle...");
  ATH_MSG_INFO("name: [" << outputData.name() << "]");
  ATH_MSG_INFO("store [" << outputData.store() << "]");
  ATH_MSG_INFO("clid: [" << outputData.clid() << "]");
  
  ATH_CHECK( outputData.record( std::make_unique< int >( seedData ) ) );
 
  //redundant check as op = would throw if outputData was not valid (e.g. because if clid/key combo was duplicated)
  if ( outputData.isValid() )
  {
    ATH_MSG_INFO("ptr: " << outputData.cptr());
    ATH_MSG_INFO("val: " << *outputData);
    
    ATH_MSG_INFO("modify myint by value...");
 
    ATH_MSG_INFO("ptr: " << outputData.cptr());
    ATH_MSG_INFO("val: " << *outputData);
  }
 
  // Test update handles
  SG::WriteHandle< HiveDataObj > testUpdate( m_testUpdate, ctx );
  ATH_CHECK( testUpdate.recordNonConst( std::make_unique< HiveDataObj >( 123 ) ) );
  ATH_MSG_INFO( "Update handle initial: " << testUpdate->val() );
 
  return StatusCode::SUCCESS;
}
 
} //> end namespace AthViews