#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 16 of file BackendOpMonFacility.hpp.

◆ entry_t

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

private

Definition at line 15 of file BackendOpMonFacility.hpp.

Constructor & Destructor Documentation

◆ BackendOpMonFacility()

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

inline

Definition at line 20 of file BackendOpMonFacility.hpp.

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

dunedaq::opmonlib::OpMonFacility::OpMonFacility

OpMonFacility(std::string uri)

Definition OpMonFacility.hpp:62

Member Function Documentation

◆ get_entries()

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

Definition at line 14 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 && ) 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 6 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 27 of file BackendOpMonFacility.hpp.

◆ m_mutex

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