TriggerSummaryAlg.cxx

Go to the documentation of this file.

/*
  Copyright (C) 2002-2023 CERN for the benefit of the ATLAS collaboration
*/
 
#include "Gaudi/Property.h"
#include "TriggerSummaryAlg.h"
#include "AthenaMonitoringKernel/Monitored.h"
 
TriggerSummaryAlg::TriggerSummaryAlg( const std::string& name, 
              ISvcLocator* pSvcLocator ) : 
  ::AthReentrantAlgorithm( name, pSvcLocator ) {}
 
TriggerSummaryAlg::~TriggerSummaryAlg()
{}
 
StatusCode TriggerSummaryAlg::initialize()
{
 
  ATH_CHECK(  m_inputDecisionKey.initialize() );
 
  renounceArray( m_finalDecisionKeys );
  ATH_CHECK( m_finalDecisionKeys.initialize() );
 
  ATH_MSG_DEBUG("Will consume implicit decisions:" );
  for (auto& input: m_finalDecisionKeys){  
    ATH_MSG_DEBUG( " "<<input.key() );
  }
 
  ATH_CHECK( m_startStampKey.initialize() );
 
  ATH_CHECK( m_outputTools.retrieve() );
 
  if ( !m_monTool.empty() ) ATH_CHECK( m_monTool.retrieve() );
 
  return StatusCode::SUCCESS;
}
 
StatusCode TriggerSummaryAlg::execute(const EventContext& context) const
{
  
  // that is certain input
  auto l1DecisionHandle = SG::makeHandle(  m_inputDecisionKey, context );
  auto inputHandles( m_finalDecisionKeys.makeHandles(context) );
  TrigCompositeUtils::DecisionIDContainer allPassingIDs;
  for ( auto input: inputHandles ) {
    if ( input.isValid() ) {
      for ( auto decisionObject: *input )  {
        TrigCompositeUtils::decisionIDs( decisionObject, allPassingIDs );
      }
      ATH_MSG_DEBUG( "Found "<<input->size()<<" Decisions for " << input.key() );
    } else {
      ATH_MSG_DEBUG( "Missing decisions for " << input.key() << " which may be perfectly correct" );
    }
  }
 
  if ( msgLvl( MSG::DEBUG ) ){
    ATH_MSG_DEBUG( "In summary " << allPassingIDs.size() << " chains passed:" );
    for ( TrigCompositeUtils::DecisionID id : allPassingIDs ) {
      ATH_MSG_DEBUG( " +++ " << HLT::Identifier( id ) );
    }
  }
 
  for ( auto& tool: m_outputTools ) {
    ATH_CHECK( tool->createOutput( context ) );
  }
 
  auto timeStampHandle = SG::makeHandle( m_startStampKey, context );
  ATH_MSG_DEBUG( "Time since the start of L1 decoding " << timeStampHandle.cptr()->millisecondsSince()  << " ms" );
  Monitored::Group ( m_monTool,  Monitored::Scalar("TIME_SinceEventStart", timeStampHandle.cptr()->millisecondsSince() ) );
 
  return StatusCode::SUCCESS;
}