dunedaq::flxlibs::ElinkModel< TargetPayloadType > Class Template Reference

#include <ElinkModel.hpp>

Inheritance diagram for dunedaq::flxlibs::ElinkModel< TargetPayloadType >:

Collaboration diagram for dunedaq::flxlibs::ElinkModel< TargetPayloadType >:

Public Types
using	err_sink_t = iomanager::SenderConcept<felix::packetformat::chunk>
using	inherited = ElinkConcept
using	data_t = nlohmann::json
using	sink_cb_t = std::shared_ptr<std::function<void(TargetPayloadType&&)>>
Public Types inherited from dunedaq::opmonlib::MonitorableObject
using	NodePtr = std::weak_ptr<MonitorableObject>
using	NewNodePtr = std::shared_ptr<MonitorableObject>
using	ElementId = std::string

Public Member Functions
	ElinkModel ()
	ElinkModel Constructor.
	~ElinkModel ()
std::shared_ptr< err_sink_t > &	get_error_sink ()
void	init (const size_t block_queue_capacity)
void	conf (size_t block_size, bool is_32b_trailers)
void	start ()
void	stop ()
void	set_running (bool should_run)
bool	queue_in_block_address (uint64_t block_addr)
void	acquire_callback () override
Public Member Functions inherited from dunedaq::flxlibs::ElinkConcept
	ElinkConcept ()
virtual	~ElinkConcept ()
	ElinkConcept (const ElinkConcept &)=delete
	ElinkConcept is not copy-constructible.
ElinkConcept &	operator= (const ElinkConcept &)=delete
	ElinkConcept is not copy-assginable.
	ElinkConcept (ElinkConcept &&)=delete
	ElinkConcept is not move-constructible.
ElinkConcept &	operator= (ElinkConcept &&)=delete
	ElinkConcept is not move-assignable.
DefaultParserImpl &	get_parser ()
void	set_sink_config (const appmodel::DataMoveCallbackConf *sink_conf)
void	set_ids (int card, int slr, int id, int tag)
Public Member Functions inherited from dunedaq::opmonlib::MonitorableObject
	MonitorableObject (const MonitorableObject &)=delete
MonitorableObject &	operator= (const MonitorableObject &)=delete
	MonitorableObject (MonitorableObject &&)=delete
MonitorableObject &	operator= (MonitorableObject &&)=delete
virtual	~MonitorableObject ()=default
auto	get_opmon_id () const noexcept
auto	get_opmon_level () const noexcept

Public Attributes
bool	m_callback_is_acquired { false }
sink_cb_t	m_sink_callback
Public Attributes inherited from dunedaq::flxlibs::ElinkConcept
const appmodel::DataMoveCallbackConf *	m_sink_conf

Protected Member Functions
void	generate_opmon_data () override
Protected Member Functions inherited from dunedaq::opmonlib::MonitorableObject
	MonitorableObject ()=default
void	register_node (ElementId name, NewNodePtr)
void	publish (google::protobuf::Message &&, CustomOrigin &&co={}, OpMonLevel l=to_level(EntryOpMonLevel::kDefault)) const noexcept

Private Types
using	UniqueBlockAddrQueue = std::unique_ptr<folly::ProducerConsumerQueue<uint64_t>>

Private Member Functions
void	process_elink ()

Private Attributes
std::atomic< bool >	m_run_marker
bool	m_configured { false }
bool	m_sink_is_set { false }
std::shared_ptr< err_sink_t >	m_error_sink_queue
UniqueBlockAddrQueue	m_block_addr_queue
utilities::ReusableThread	m_parser_thread

Static Private Attributes
static const std::string	m_parser_thread_name = "elinkp"

Additional Inherited Members
Static Public Member Functions inherited from dunedaq::opmonlib::MonitorableObject
static bool	publishable_metric (OpMonLevel entry, OpMonLevel system) noexcept
Protected Attributes inherited from dunedaq::flxlibs::ElinkConcept
DefaultParserImpl	m_parser_impl
std::unique_ptr< felix::packetformat::BlockParser< DefaultParserImpl > >	m_parser
int	m_card_id
int	m_logical_unit
int	m_link_id
int	m_link_tag
std::string	m_elink_str
std::string	m_elink_source_tid
std::chrono::time_point< std::chrono::high_resolution_clock >	m_t0

Detailed Description

template<class TargetPayloadType>
class dunedaq::flxlibs::ElinkModel< TargetPayloadType >

Definition at line 36 of file ElinkModel.hpp.

Member Typedef Documentation

data_t

template<class TargetPayloadType >

using dunedaq::flxlibs::ElinkModel< TargetPayloadType >::data_t = nlohmann::json

Definition at line 41 of file ElinkModel.hpp.

err_sink_t

template<class TargetPayloadType >

using dunedaq::flxlibs::ElinkModel< TargetPayloadType >::err_sink_t = iomanager::SenderConcept<felix::packetformat::chunk>

Definition at line 39 of file ElinkModel.hpp.

inherited

template<class TargetPayloadType >

using dunedaq::flxlibs::ElinkModel< TargetPayloadType >::inherited = ElinkConcept

Definition at line 40 of file ElinkModel.hpp.

sink_cb_t

template<class TargetPayloadType >

using dunedaq::flxlibs::ElinkModel< TargetPayloadType >::sink_cb_t = std::shared_ptr<std::function<void(TargetPayloadType&&)>>

Definition at line 129 of file ElinkModel.hpp.

UniqueBlockAddrQueue

template<class TargetPayloadType >

using dunedaq::flxlibs::ElinkModel< TargetPayloadType >::UniqueBlockAddrQueue = std::unique_ptr<folly::ProducerConsumerQueue<uint64_t>>

private

Definition at line 183 of file ElinkModel.hpp.

Constructor & Destructor Documentation

ElinkModel()

template<class TargetPayloadType >

dunedaq::flxlibs::ElinkModel< TargetPayloadType >::ElinkModel ( )

inline

ElinkModel Constructor.

Parameters

name	Instance name for this ElinkModel instance

Definition at line 47 of file ElinkModel.hpp.

    : ElinkConcept()
    , m_run_marker{ false }
    , m_parser_thread(0)
  {}

~ElinkModel()

template<class TargetPayloadType >

dunedaq::flxlibs::ElinkModel< TargetPayloadType >::~ElinkModel ( )

inline

Definition at line 52 of file ElinkModel.hpp.

{}

Member Function Documentation

acquire_callback()

template<class TargetPayloadType >

void dunedaq::flxlibs::ElinkModel< TargetPayloadType >::acquire_callback ( )

inlineoverridevirtual

Implements dunedaq::flxlibs::ElinkConcept.

Definition at line 115 of file ElinkModel.hpp.

  {
    if (m_callback_is_acquired) {
      TLOG_DEBUG(5) << "SourceModel callback is already acquired!";
    } else {
      // Getting DataMoveCBRegistry
      auto dmcbr = datahandlinglibs::DataMoveCallbackRegistry::get();
      m_sink_callback = dmcbr->get_callback<TargetPayloadType>(inherited::m_sink_conf);
      m_callback_is_acquired = true;
    }
  }

conf()

template<class TargetPayloadType >

void dunedaq::flxlibs::ElinkModel< TargetPayloadType >::conf ( size_t block_size, bool is_32b_trailers )

inlinevirtual

Implements dunedaq::flxlibs::ElinkConcept.

Definition at line 61 of file ElinkModel.hpp.

  {
    if (m_configured) {
      TLOG_DEBUG(5) << "ElinkModel is already configured!";
    } else {
      m_parser_thread.set_name(inherited::m_elink_source_tid, inherited::m_link_tag);
      // if (inconsistency)
      // ers::fatal(ElinkConfigurationInconsistency(ERS_HERE, m_num_links));
 
      m_parser->configure(block_size, is_32b_trailers); // unsigned bsize, bool trailer_is_32bit
      m_configured = true;
    }
  }

generate_opmon_data()

template<class TargetPayloadType >

void dunedaq::flxlibs::ElinkModel< TargetPayloadType >::generate_opmon_data ( )

inlineoverrideprotectedvirtual

Hook for customisable pubblication. The function can throw, exception will be caught by the monitoring thread

Reimplemented from dunedaq::opmonlib::MonitorableObject.

Definition at line 133 of file ElinkModel.hpp.

                                      {
 
    opmon::CardReaderInfo info;
    auto now = std::chrono::high_resolution_clock::now();
    auto& stats = m_parser_impl.get_stats();
 
    double seconds = std::chrono::duration_cast<std::chrono::microseconds>(now - m_t0).count() / 1000000.;
 
    info.set_num_short_chunks_processed( stats.short_ctr.exchange(0) );
    info.set_num_chunks_processed( stats.chunk_ctr.exchange(0) );
    info.set_num_subchunks_processed(stats.subchunk_ctr.exchange(0));
    info.set_num_blocks_processed(stats.block_ctr.exchange(0));
 
    info.set_rate_blocks_processed(info.num_blocks_processed() / seconds / 1000. );
    info.set_rate_chunks_processed(info.num_chunks_processed() / seconds / 1000. );
 
    info.set_num_short_chunks_processed_with_error(stats.error_short_ctr.exchange(0));
    info.set_num_chunks_processed_with_error(stats.error_chunk_ctr.exchange(0));
    info.set_num_subchunks_processed_with_error(stats.error_subchunk_ctr.exchange(0));
    info.set_num_blocks_processed_with_error(stats.error_block_ctr.exchange(0));
    info.set_num_subchunk_crc_errors(stats.subchunk_crc_error_ctr.exchange(0));
    info.set_num_subchunk_trunc_errors(stats.subchunk_trunc_error_ctr.exchange(0));
    info.set_num_subchunk_errors(stats.subchunk_error_ctr.exchange(0));
 
 
    TLOG_DEBUG(2) << inherited::m_elink_str // Move to TLVL_TAKE_NOTE from readout
          << " Parser stats ->"
          << " Blocks: " << info.num_blocks_processed() << " Block rate: " << info.rate_blocks_processed()
          << " [kHz]"
          << " Chunks: " << info.num_chunks_processed() << " Chunk rate: " << info.rate_chunks_processed()
          << " [kHz]"
          << " Shorts: " << info.num_short_chunks_processed() << " Subchunks:" << info.num_subchunks_processed()
          << " Error Chunks: " << info.num_chunks_processed_with_error()
          << " Error Shorts: " << info.num_short_chunks_processed_with_error()
          << " Error Subchunks: " << info.num_subchunks_processed_with_error()
          << " Error Block: " << info.num_blocks_processed_with_error();
 
    m_t0 = now;
 
    publish( std::move(info),
         { { "card", std::to_string(m_card_id) },
           { "logical_unit", std::to_string(m_logical_unit) },
           { "link", std::to_string(m_link_id) },
           { "tag", std::to_string(m_link_tag) } } );
         
  }

get_error_sink()

template<class TargetPayloadType >

std::shared_ptr< err_sink_t > & dunedaq::flxlibs::ElinkModel< TargetPayloadType >::get_error_sink ( )

inline

Definition at line 54 of file ElinkModel.hpp.

{ return m_error_sink_queue; }

init()

template<class TargetPayloadType >

void dunedaq::flxlibs::ElinkModel< TargetPayloadType >::init ( const size_t block_queue_capacity )

inlinevirtual

Implements dunedaq::flxlibs::ElinkConcept.

Definition at line 56 of file ElinkModel.hpp.

  {
    m_block_addr_queue = std::make_unique<folly::ProducerConsumerQueue<uint64_t>>(block_queue_capacity); // NOLINT
  }

process_elink()

template<class TargetPayloadType >

void dunedaq::flxlibs::ElinkModel< TargetPayloadType >::process_elink ( )

inlineprivate

Definition at line 199 of file ElinkModel.hpp.

  {
    while (m_run_marker.load()) {
      uint64_t block_addr;                        // NOLINT
      if (m_block_addr_queue->read(block_addr)) { // read success
        const auto* block = const_cast<felix::packetformat::block*>(
          felix::packetformat::block_from_bytes(reinterpret_cast<const char*>(block_addr)) // NOLINT
        );
        m_parser->process(block);
      } else { // couldn't read from queue
        std::this_thread::sleep_for(std::chrono::milliseconds(10));
      }
    }
  }

queue_in_block_address()

template<class TargetPayloadType >

bool dunedaq::flxlibs::ElinkModel< TargetPayloadType >::queue_in_block_address ( uint64_t block_addr )

inlinevirtual

Implements dunedaq::flxlibs::ElinkConcept.

Definition at line 106 of file ElinkModel.hpp.

  {
    if (m_block_addr_queue->write(block_addr)) { // ok write
      return true;
    } else { // failed write
      return false;
    }
  }

set_running()

template<class TargetPayloadType >

void dunedaq::flxlibs::ElinkModel< TargetPayloadType >::set_running ( bool should_run )

inline

Definition at line 100 of file ElinkModel.hpp.

  {
    bool was_running = m_run_marker.exchange(should_run);
    TLOG_DEBUG(5) << "Active state was toggled from " << was_running << " to " << should_run;
  }

start()

template<class TargetPayloadType >

void dunedaq::flxlibs::ElinkModel< TargetPayloadType >::start ( )

inlinevirtual

Implements dunedaq::flxlibs::ElinkConcept.

Definition at line 75 of file ElinkModel.hpp.

  {
    m_t0 = std::chrono::high_resolution_clock::now();
    if (!m_run_marker.load()) {
      set_running(true);
      m_parser_thread.set_work(&ElinkModel::process_elink, this);
      TLOG() << "Started ElinkModel of link " << inherited::m_link_id << "...";
    } else {
      TLOG_DEBUG(5) << "ElinkModel of link " << inherited::m_link_id << " is already running!";
    }
  }

stop()

template<class TargetPayloadType >

void dunedaq::flxlibs::ElinkModel< TargetPayloadType >::stop ( )

inlinevirtual

Implements dunedaq::flxlibs::ElinkConcept.

Definition at line 87 of file ElinkModel.hpp.

  {
    if (m_run_marker.load()) {
      set_running(false);
      while (!m_parser_thread.get_readiness()) {
        std::this_thread::sleep_for(std::chrono::milliseconds(10));
      }
      TLOG_DEBUG(5) << "Stopped ElinkModel of link " << m_link_id << "!";
    } else {
      TLOG_DEBUG(5) << "ElinkModel of link " << m_link_id << " is already stopped!";
    }
  }

Member Data Documentation

m_block_addr_queue

template<class TargetPayloadType >

UniqueBlockAddrQueue dunedaq::flxlibs::ElinkModel< TargetPayloadType >::m_block_addr_queue

private

Definition at line 194 of file ElinkModel.hpp.

m_callback_is_acquired

template<class TargetPayloadType >

bool dunedaq::flxlibs::ElinkModel< TargetPayloadType >::m_callback_is_acquired { false }

Definition at line 128 of file ElinkModel.hpp.

{ false };

m_configured

template<class TargetPayloadType >

bool dunedaq::flxlibs::ElinkModel< TargetPayloadType >::m_configured { false }

private

Definition at line 187 of file ElinkModel.hpp.

{ false };

m_error_sink_queue

template<class TargetPayloadType >

std::shared_ptr<err_sink_t> dunedaq::flxlibs::ElinkModel< TargetPayloadType >::m_error_sink_queue

private

Definition at line 191 of file ElinkModel.hpp.

m_parser_thread

template<class TargetPayloadType >

utilities::ReusableThread dunedaq::flxlibs::ElinkModel< TargetPayloadType >::m_parser_thread

private

Definition at line 198 of file ElinkModel.hpp.

m_parser_thread_name

template<class TargetPayloadType >

const std::string dunedaq::flxlibs::ElinkModel< TargetPayloadType >::m_parser_thread_name = "elinkp"

inlinestaticprivate

Definition at line 197 of file ElinkModel.hpp.

m_run_marker

template<class TargetPayloadType >

std::atomic<bool> dunedaq::flxlibs::ElinkModel< TargetPayloadType >::m_run_marker

private

Definition at line 186 of file ElinkModel.hpp.

m_sink_callback

template<class TargetPayloadType >

sink_cb_t dunedaq::flxlibs::ElinkModel< TargetPayloadType >::m_sink_callback

Definition at line 130 of file ElinkModel.hpp.

m_sink_is_set

template<class TargetPayloadType >

bool dunedaq::flxlibs::ElinkModel< TargetPayloadType >::m_sink_is_set { false }

private

Definition at line 190 of file ElinkModel.hpp.

{ false };

---

The documentation for this class was generated from the following file:

• /github/workspace/dunedaq/sourcecode/flxlibs/src/ElinkModel.hpp