TrigOpMonitor.h

Go to the documentation of this file.

/*
  Copyright (C) 2002-2026 CERN for the benefit of the ATLAS collaboration
*/
 
#ifndef TRIGSTEERMONITOR_TRIGOPMONITOR_H
#define TRIGSTEERMONITOR_TRIGOPMONITOR_H

 
#include "AthenaBaseComps/AthAlgorithm.h"
#include "AthenaKernel/IIOVDbSvc.h"
#include "AthenaKernel/IOVRange.h"
#include "GaudiKernel/EventIDBase.h"
#include "GaudiKernel/ITHistSvc.h"
#include "GaudiKernel/ServiceHandle.h"
#include "GaudiKernel/ToolHandle.h"
#include "LumiBlockData/LuminosityCondData.h"
#include "MagFieldConditions/AtlasFieldMapCondObj.h"
#include "StoreGate/ReadCondHandleKey.h"
 
#include "TH1I.h"
#include "TH2I.h"
#include "TProfile.h"
 
#include <unordered_map>
#include <string>
#include <vector>
 
// Forward declarations
class IIncidentSvc;
 
class TrigOpMonitor : public extends<AthAlgorithm, IIncidentListener> {
public:
  TrigOpMonitor(const std::string& name, ISvcLocator* pSvcLocator);
 
  virtual StatusCode initialize() override;
  virtual StatusCode start() override;
  virtual StatusCode execute(const EventContext& ctx) override;
  virtual void handle( const Incident& incident ) override;
 
  /* Ensure this algorithm is a singleton.
     This should not cause any bottle-necks as the algorithm does very
     minimal work. */
  virtual unsigned int cardinality() const override { return 1; }
 
private:
  void fillMagFieldHist();
  void fillReleaseDataHist();
  void fillProcThreadHist(int workerID);
  void fillSubDetHist();
  void fillIOVDbHist();
  void fillIOVDbChangeHist(const EventContext& ctx);
  void fillLumiHist(const EventContext& ctx);
 
  StatusCode bookHists();

  struct FolderHist {
    TH1F* h_time{nullptr};
    TH1F* h_bytes{nullptr};
    float total_time{0};
    float total_bytes{0};
  };
 
  ServiceHandle<IIncidentSvc> m_incidentSvc{ this, "IncidentSvc", "IncidentSvc", "Incident service"};
  ServiceHandle<ITHistSvc> m_histSvc{this, "THistSvc", "THistSvc"};
 
  SmartIF<IIOVDbSvc> m_IOVDbSvc;
 
  TH2I* m_magFieldHist{nullptr};
  TH2I* m_iovChangeHist{nullptr};
  TH1I* m_releaseHist{nullptr};
  TH2I* m_mtConfigHist{nullptr};
  TH1I* m_workersHist{nullptr};
  TH2I* m_subdetHist{nullptr};
  TProfile* m_lumiHist{nullptr};
  TProfile* m_muHist{nullptr};
 
  EventIDBase::number_type m_previousLB{0};                 
  std::unordered_map<std::string, IOVRange> m_currentIOVs;  
  std::unordered_map<std::string, FolderHist> m_folderHist; 
  std::string m_histPath;                                   
 
  /* Properties */
  SG::ReadCondHandleKey<LuminosityCondData> m_lumiDataKey{this, "LuminosityCondDataKey", ""};
  SG::ReadCondHandleKey<AtlasFieldMapCondObj> m_fieldMapKey {this, "AtlasFieldMapCondDataKey", ""};
 
  Gaudi::Property<std::string> m_releaseData{
      this, "ReleaseDataFile", "../ReleaseData",
      "Path to ReleaseData file (relative to LD_LIBRARY_PATH entries"};
 
  Gaudi::Property<bool> m_detailedHists{this, "DetailedFolderHists", true,
                                        "Detailed histograms for COOL folder updates during run"};
 
  Gaudi::Property<unsigned short int> m_maxLB{this, "MaxLumiblocks", 3000,
                                              "Number of lumiblocks for histograms"};
};
 
#endif // TRIGSTEERMONITOR_TRIGOPMONI_H