ROBDataMonitor.cxx

Go to the documentation of this file.

/*
  Copyright (C) 2002-2022 CERN for the benefit of the ATLAS collaboration
*/
 
#include <functional>
#include <algorithm>
#include "TrigDataAccessMonitoring/ROBDataMonitor.h"
 
using namespace robmonitor;
 
//
//--- ROBDataStruct 
//    -------------
ROBDataStruct::ROBDataStruct()
  : rob_id(0),
    rob_size(0),
    rob_history(robmonitor::UNCLASSIFIED),
    rob_status_word(0)
{}
 
ROBDataStruct::ROBDataStruct(const uint32_t srcId)
  : rob_id(srcId),
    rob_size(0),
    rob_history(robmonitor::UNCLASSIFIED),
    rob_status_word(0)
{}
 
bool ROBDataStruct::isUnclassified() const {
  return ((rob_history == robmonitor::UNCLASSIFIED) ? true : false);
}
 
bool ROBDataStruct::isHLTCached() const {
  return ((rob_history == robmonitor::HLT_CACHED) ? true : false);
}
 
bool ROBDataStruct::isDCMCached() const {
  return ((rob_history == robmonitor::DCM_CACHED) ? true : false);
}
 
bool ROBDataStruct::isRetrieved() const {
  return ((rob_history == robmonitor::RETRIEVED) ? true : false);
}
 
bool ROBDataStruct::isIgnored() const {
  return ((rob_history == robmonitor::IGNORED) ? true : false);
}
 
bool ROBDataStruct::isUndefined() const {
  return ((rob_history == robmonitor::UNDEFINED) ? true : false);
}
 
bool ROBDataStruct::isStatusOk() const {
  return (rob_status_word == 0) ? true : false;
}
 
 
//
//--- ROBDataMonitorStruct
//    --------------------
ROBDataMonitorStruct::ROBDataMonitorStruct()
  :lvl1ID(0),
   requestor_name("UNKNOWN"),
   requested_ROBs(),
   start_time_of_ROB_request(),
   end_time_of_ROB_request()
{}
 
ROBDataMonitorStruct::ROBDataMonitorStruct(const uint32_t l1_id, const std::string& req_nam="UNKNOWN")
  :lvl1ID(l1_id),
   requestor_name(req_nam),
   requested_ROBs(),
   start_time_of_ROB_request(),
   end_time_of_ROB_request()
{}
 
ROBDataMonitorStruct::ROBDataMonitorStruct(const uint32_t l1_id, 
                       const std::vector<uint32_t>& req_robs,
                       const std::string& req_nam="UNKNOWN")
  :lvl1ID(l1_id),
   requestor_name(req_nam),
   start_time_of_ROB_request(),
   end_time_of_ROB_request()
{
  for (uint32_t rob : req_robs) {
    requested_ROBs[ rob ] = robmonitor::ROBDataStruct( rob ) ;
  }
}
 
unsigned ROBDataMonitorStruct::allROBs() const {
  return requested_ROBs.size(); 
}
 
unsigned ROBDataMonitorStruct::unclassifiedROBs() const {
  ptrdiff_t ret=0;
  for (const auto& p : requested_ROBs) {
    if (p.second.isUnclassified()) ++ret;
  }     
  return ret;
} 
 
unsigned ROBDataMonitorStruct::HLTcachedROBs() const {
  ptrdiff_t ret=0;
  for (const auto& p : requested_ROBs) {
    if (p.second.isHLTCached()) ++ret;
  }     
  return ret;
}
 
unsigned ROBDataMonitorStruct::DCMcachedROBs() const {
  ptrdiff_t ret=0;
  for (const auto& p : requested_ROBs) {
    if (p.second.isDCMCached()) ++ret;
  }     
  return ret;
}
 
unsigned ROBDataMonitorStruct::retrievedROBs() const {
  ptrdiff_t ret=0;
  for (const auto& p : requested_ROBs) {
    if (p.second.isRetrieved()) ++ret;
  }     
  return ret;
}
 
unsigned ROBDataMonitorStruct::ignoredROBs() const {
  ptrdiff_t ret=0;
  for (const auto& p : requested_ROBs) {
    if (p.second.isIgnored()) ++ret;
  }     
  return ret;
}
 
unsigned ROBDataMonitorStruct::undefinedROBs() const {
  ptrdiff_t ret=0;
  for (const auto& p : requested_ROBs) {
    if (p.second.isUndefined()) ++ret;
  }     
  return ret;
}
 
unsigned ROBDataMonitorStruct::statusOkROBs() const {
  ptrdiff_t ret=0;
  for (const auto& p : requested_ROBs) {
    if (p.second.isStatusOk()) ++ret;
  }     
  return ret;
}
 
float ROBDataMonitorStruct::elapsedTime() const {
  int secs = 0 ;
  if (end_time_of_ROB_request.tv_sec >= start_time_of_ROB_request.tv_sec)
    secs = end_time_of_ROB_request.tv_sec - start_time_of_ROB_request.tv_sec;
 
  int usecs = end_time_of_ROB_request.tv_usec - start_time_of_ROB_request.tv_usec;
  return static_cast<float>(secs)*1000 + static_cast<float>(usecs)/1000;
}