LivetimeCounter.cpp

Go to the documentation of this file.

#include "trigger/LivetimeCounter.hpp"
 
#include "logging/Logging.hpp"
 
#include <sstream>
 
namespace dunedaq::trigger {
 
LivetimeCounter::LivetimeCounter(LivetimeCounter::State state)
  : m_state(state)
  , m_last_state_change_time(now())
{
  TLOG_DEBUG(1) << "Starting LivetimeCounter in state " << get_state_name(state);
  m_state_times[State::kLive]=0;
  m_state_times[State::kDead]=0;
  m_state_times[State::kPaused]=0;
}
 
LivetimeCounter::~LivetimeCounter()
{
  std::string report=get_report_string();
  TLOG() << "LivetimeCounter stopping. Counts: " << report;
}
 
void
LivetimeCounter::update_map()
{
  // Caller must lock the mutex, so we don't here
  auto current_time=now();
  auto delta=(current_time-m_last_state_change_time);
  m_state_times[m_state]+=delta;
  m_last_state_change_time=current_time;
}
 
 
void
LivetimeCounter::set_state(LivetimeCounter::State state)
{
  std::lock_guard<std::mutex> l(m_mutex);
  update_map(); // Add the time to the old state
  TLOG_DEBUG(1) << "Changing state from " << get_state_name(m_state) << " to " << get_state_name(state);
  m_state=state;
}
 
std::map<LivetimeCounter::State, LivetimeCounter::state_time_t>
LivetimeCounter::get_time_map()
{
  std::lock_guard<std::mutex> l(m_mutex);
  update_map();
  return m_state_times;
}
 
LivetimeCounter::state_time_t
LivetimeCounter::get_time(LivetimeCounter::State state)
{
  std::lock_guard<std::mutex> l(m_mutex);
  update_map();
  return m_state_times[state];
}
 
LivetimeCounter::state_time_t
LivetimeCounter::now() const
{
  using namespace std::chrono;
  return duration_cast<milliseconds>(steady_clock::now().time_since_epoch()).count();
}
 
std::string
LivetimeCounter::get_report_string()
{
  std::lock_guard<std::mutex> l(m_mutex);
  update_map();
  std::ostringstream oss;
  for(auto const& [state, t]: m_state_times){
    oss << get_state_name(state) << ": " << t << "ms ";
  }
  return oss.str();
}
 
 
std::string
LivetimeCounter::get_state_name(LivetimeCounter::State state) const
{
  switch(state){
  case State::kLive: return "live";
  case State::kDead: return "dead";
  case State::kPaused: return "paused";
  default:
    return "UNKNOWN";
  }
}
 
} // namespace dunedaq::trigger