#include <BackendOpMonFacility.hpp>

Inheritance diagram for dunedaq::opmonlib::BackendOpMonFacility:

Collaboration diagram for dunedaq::opmonlib::BackendOpMonFacility:

Public Member Functions
	BackendOpMonFacility ()
void	publish (entry_t &&e) const override
data_t	get_entries (std::regex measurement_filter=std::regex(".*"))
Public Member Functions inherited from dunedaq::opmonlib::OpMonFacility
	OpMonFacility (std::string uri)
virtual	~OpMonFacility ()=default
	OpMonFacility (const OpMonFacility &)=delete
	OpMonFacility is not copy-constructible.
OpMonFacility &	operator= (const OpMonFacility &)=delete
	OpMonFacility is not copy-assignable.
	OpMonFacility (OpMonFacility &&)=delete
	OpMonFacility is not move-constructible.
OpMonFacility &	operator= (OpMonFacility &&)=delete
	OpMonFacility is not move-assignable.
const auto &	get_URI () const

Private Types
using	entry_t = dunedaq::opmon::OpMonEntry
using	data_t = std::list<entry_t>

Private Attributes
data_t	m_list
std::mutex	m_mutex

Detailed Description

Definition at line 13 of file BackendOpMonFacility.hpp.

Member Typedef Documentation

◆ data_t

using dunedaq::opmonlib::BackendOpMonFacility::data_t = std::list<entry_t>

private

Definition at line 17 of file BackendOpMonFacility.hpp.

◆ entry_t

using dunedaq::opmonlib::BackendOpMonFacility::entry_t = dunedaq::opmon::OpMonEntry

private

Definition at line 16 of file BackendOpMonFacility.hpp.

Constructor & Destructor Documentation

◆ BackendOpMonFacility()

dunedaq::opmonlib::BackendOpMonFacility::BackendOpMonFacility ( )

inline

Definition at line 20 of file BackendOpMonFacility.hpp.

    : OpMonFacility("backend://")
  {
    ;
  }

Member Function Documentation

◆ get_entries()

BackendOpMonFacility::data_t BackendOpMonFacility::get_entries ( std::regex measurement_filter = std::regex(".*") )

Definition at line 15 of file BackendOpMonFacility.cpp.

{
 
  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;
}

◆ publish()

void BackendOpMonFacility::publish ( entry_t && e ) const

overridevirtual

The implmentations of this functions need to be thread safe. It is a requirement to implement this function asyncronously. This function can throw, but it is guaranteed to throw an OpMonPublishFailure

Implements dunedaq::opmonlib::OpMonFacility.

Definition at line 7 of file BackendOpMonFacility.cpp.

{
 
  std::lock_guard<std::mutex> lk(m_mutex);
  m_list.push_back(e);
}

Member Data Documentation

◆ m_list

data_t dunedaq::opmonlib::BackendOpMonFacility::m_list

mutableprivate

Definition at line 31 of file BackendOpMonFacility.hpp.

◆ m_mutex

std::mutex dunedaq::opmonlib::BackendOpMonFacility::m_mutex