BackendOpMonFacility.cpp

Go to the documentation of this file.

 
#include "opmonlib/BackendOpMonFacility.hpp"
 
using namespace dunedaq::opmonlib;
 
void
BackendOpMonFacility::publish(opmon::OpMonEntry&& e) const
{
 
  std::lock_guard<std::mutex> lk(m_mutex);
  m_list.push_back(e);
}
 
BackendOpMonFacility::data_t
BackendOpMonFacility::get_entries(std::regex measurement_filter)
{
 
  std::unique_lock<std::mutex> lk(m_mutex);
  data_t ret;
  m_list.swap(ret);
  lk.unlock();
 
  std::smatch values;
  auto it = ret.begin();
  while (it != ret.end()) {
    if (!std::regex_match(it->measurement(), values, measurement_filter)) {
      it = ret.erase(it);
    } else {
      ++it;
    }
  }
 
  return ret;
}