DQTDataFlowMonAlg.cxx

Go to the documentation of this file.

/*
  Copyright (C) 2002-2026 CERN for the benefit of the ATLAS collaboration
*/
 
// ********************************************************************
//
// NAME:     DQTDataFlowMonAlg.cxx
// PACKAGE:  DataQualityTools  
//
// AUTHORS:  Peter Onyisi (ponyisi@cern.ch)
//
//
// ********************************************************************
 
#include "DataQualityTools/DQTDataFlowMonAlg.h"
#include "AthenaMonitoringKernel/Monitored.h"
 
DQTDataFlowMonAlg::DQTDataFlowMonAlg( const std::string& name,
                                      ISvcLocator* pSvcLocator )
  : AthMonitorAlgorithm(name, pSvcLocator)
{
}
 
StatusCode
DQTDataFlowMonAlg::initialize()
{
  ATH_CHECK(AthMonitorAlgorithm::initialize());
  ATH_CHECK(m_TileStatusKey.initialize());
  ATH_CHECK(m_atlasReadyFilter.retrieve(/*not isMC*/));
  return StatusCode::SUCCESS;
}
 
StatusCode 
DQTDataFlowMonAlg::fillHistograms( const EventContext& ctx ) const
{
  ATH_MSG_DEBUG("in fillHistograms()");
 
  using namespace Monitored;
 
  auto environment = Scalar("environment", (int) m_environment);
  const auto & group = getGroup("default");
  fill(group, environment);
  
  if( m_environment != Environment_t::tier0Raw ) {
    SG::ReadHandle<xAOD::EventInfo> evtinfo { GetEventInfo(ctx) };
    if (! evtinfo.isValid()) {
      ATH_MSG_ERROR("Could not retrieve EventInfo");
      return StatusCode::FAILURE;
    } else {
      if (evtinfo->eventType(xAOD::EventInfo::IS_SIMULATION)) {
        auto weight = Scalar<double>("mcweight", evtinfo->eventType(xAOD::EventInfo::IS_SIMULATION) ? evtinfo->mcEventWeight() : 1);
        auto lb = Scalar("LB", evtinfo->lumiBlock());
        fill(group, weight, lb);
      } else {
        //Monitor AtlasReady flag .. for real-data only
        bool atlasReady=m_atlasReadyFilter->accept(ctx);
        auto isReady=Scalar<short>("atlasready",atlasReady);
        fill(group,isReady);
      }
      std::vector<int> detstatevec(xAOD::EventInfo::nDets+1);
      std::vector<int> detstatevec_idx(xAOD::EventInfo::nDets+1);
      std::iota(detstatevec_idx.begin(), detstatevec_idx.end(), 0);
 
      auto detstates = Collection("detstates", detstatevec);
      auto detstates_idx = Collection("detstates_idx", detstatevec_idx);
      xAOD::EventInfo::EventFlagErrorState worststate = xAOD::EventInfo::NotSet;
      for (int i = 0; i < xAOD::EventInfo::nDets; i++) {
        xAOD::EventInfo::EventFlagErrorState detstate = evtinfo->errorState((xAOD::EventInfo::EventFlagSubDet) i);
        detstatevec[i] = detstate;
        if (detstate > worststate) worststate = detstate;
      }
      detstatevec[xAOD::EventInfo::nDets] = worststate;
      fill(group, detstates, detstates_idx);
 
      
      
    }
  }
 
  return StatusCode::SUCCESS;
}