dunedaq::crtmodules::SourceModel< TargetPayloadType > Class Template Reference

#include <SourceModel.hpp>

Inheritance diagram for dunedaq::crtmodules::SourceModel< TargetPayloadType >:

Collaboration diagram for dunedaq::crtmodules::SourceModel< TargetPayloadType >:

Public Types
using	sink_t = iomanager::SenderConcept<TargetPayloadType>
using	inherited = SourceConcept
using	data_t = nlohmann::json
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
	SourceModel ()
	SourceModel Constructor.
	~SourceModel ()
void	set_sink (const std::string &sink_name, bool callback_mode) override
void	acquire_callback () override
std::shared_ptr< sink_t > &	get_sink ()
bool	handle_payload (char *message, std::size_t size)
std::size_t	get_frame_size () const override
void	generate_opmon_data () override
Public Member Functions inherited from dunedaq::crtmodules::SourceConcept
	SourceConcept ()
virtual	~SourceConcept ()
	SourceConcept (const SourceConcept &)=delete
	SourceConcept is not copy-constructible.
SourceConcept &	operator= (const SourceConcept &)=delete
	SourceConcept is not copy-assignable.
	SourceConcept (SourceConcept &&)=delete
	SourceConcept is not move-constructible.
SourceConcept &	operator= (SourceConcept &&)=delete
	SourceConcept is not move-assignable.
void	set_sink_name (const std::string &sink_name)
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

Static Public Attributes
static constexpr auto	buffer_size = sizeof(TargetPayloadType)
	Buffer size based on TargetPayloadType.

Private Types
using	sink_cb_t = std::shared_ptr<std::function<void(TargetPayloadType&&)>>

Private Attributes
std::string	m_sink_id
bool	m_sink_is_set { false }
std::shared_ptr< sink_t >	m_sink_queue
bool	m_callback_mode
bool	m_callback_is_acquired { false }
sink_cb_t	m_sink_callback
std::atomic< uint64_t >	m_dropped_packets {0}

Additional Inherited Members
Static Public Member Functions inherited from dunedaq::opmonlib::MonitorableObject
static bool	publishable_metric (OpMonLevel entry, OpMonLevel system) noexcept
Public Attributes inherited from dunedaq::crtmodules::SourceConcept
std::string	m_sink_name
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

Detailed Description

template<class TargetPayloadType>
class dunedaq::crtmodules::SourceModel< TargetPayloadType >

Definition at line 36 of file SourceModel.hpp.

Member Typedef Documentation

data_t

template<class TargetPayloadType >

using dunedaq::crtmodules::SourceModel< TargetPayloadType >::data_t = nlohmann::json

Definition at line 41 of file SourceModel.hpp.

inherited

template<class TargetPayloadType >

using dunedaq::crtmodules::SourceModel< TargetPayloadType >::inherited = SourceConcept

Definition at line 40 of file SourceModel.hpp.

sink_cb_t

template<class TargetPayloadType >

using dunedaq::crtmodules::SourceModel< TargetPayloadType >::sink_cb_t = std::shared_ptr<std::function<void(TargetPayloadType&&)>>

private

Definition at line 139 of file SourceModel.hpp.

sink_t

template<class TargetPayloadType >

using dunedaq::crtmodules::SourceModel< TargetPayloadType >::sink_t = iomanager::SenderConcept<TargetPayloadType>

Definition at line 39 of file SourceModel.hpp.

Constructor & Destructor Documentation

SourceModel()

template<class TargetPayloadType >

dunedaq::crtmodules::SourceModel< TargetPayloadType >::SourceModel ( )

inline

SourceModel Constructor.

Parameters

name	Instance name for this SourceModel instance

Definition at line 52 of file SourceModel.hpp.

    : SourceConcept()
  {}

~SourceModel()

template<class TargetPayloadType >

dunedaq::crtmodules::SourceModel< TargetPayloadType >::~SourceModel ( )

inline

Definition at line 55 of file SourceModel.hpp.

{}

Member Function Documentation

acquire_callback()

template<class TargetPayloadType >

void dunedaq::crtmodules::SourceModel< TargetPayloadType >::acquire_callback ( )

inlineoverridevirtual

Implements dunedaq::crtmodules::SourceConcept.

Definition at line 72 of file SourceModel.hpp.

  {
    if (m_callback_mode) {
      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_name);
        m_callback_is_acquired = true;
      }
    } else {
      TLOG_DEBUG(5) << "Won't acquire callback, as IOM sink is set!";
    }
  }

generate_opmon_data()

template<class TargetPayloadType >

void dunedaq::crtmodules::SourceModel< TargetPayloadType >::generate_opmon_data ( )

inlineoverridevirtual

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

Reimplemented from dunedaq::opmonlib::MonitorableObject.

Definition at line 122 of file SourceModel.hpp.

                                      {
 
    opmon::SourceInfo info;
    info.set_dropped_frames( m_dropped_packets.load() ); 
 
    publish( std::move(info) );
  }

get_frame_size()

template<class TargetPayloadType >

std::size_t dunedaq::crtmodules::SourceModel< TargetPayloadType >::get_frame_size ( ) const

inlineoverridevirtual

Implements dunedaq::crtmodules::SourceConcept.

Definition at line 117 of file SourceModel.hpp.

                                            {
    TargetPayloadType target_payload; 
    return target_payload.get_frame_size(); // TODO (DTE): Could be a static function?
  }

get_sink()

template<class TargetPayloadType >

std::shared_ptr< sink_t > & dunedaq::crtmodules::SourceModel< TargetPayloadType >::get_sink ( )

inline

Definition at line 88 of file SourceModel.hpp.

{ return m_sink_queue; }

handle_payload()

template<class TargetPayloadType >

bool dunedaq::crtmodules::SourceModel< TargetPayloadType >::handle_payload ( char * message, std::size_t size )

inlinevirtual

Implements dunedaq::crtmodules::SourceConcept.

Definition at line 90 of file SourceModel.hpp.

  {
    bool push_out = true;
    if (push_out) {
 
      TargetPayloadType& target_payload = *reinterpret_cast<TargetPayloadType*>(message);
  
      if (m_callback_mode) {
        (*m_sink_callback)(std::move(target_payload));
      } else {
        if (!m_sink_queue->try_send(std::move(target_payload), iomanager::Sender::s_no_block)) {
          //if(m_dropped_packets == 0 || m_dropped_packets%10000) {
          //  TLOG() << "Dropped data " << m_dropped_packets;
          //}
          ++m_dropped_packets;
        }
      }
 
    } else {
      TargetPayloadType target_payload;
      uint32_t bytes_copied = 0;
      datahandlinglibs::buffer_copy(message, size, static_cast<void*>(&target_payload), bytes_copied, sizeof(target_payload));
    }
 
    return true;
  }

set_sink()

template<class TargetPayloadType >

void dunedaq::crtmodules::SourceModel< TargetPayloadType >::set_sink ( const std::string & sink_name, bool callback_mode )

inlineoverridevirtual

Implements dunedaq::crtmodules::SourceConcept.

Definition at line 57 of file SourceModel.hpp.

  {
    m_callback_mode = callback_mode;
    if (callback_mode) {
      TLOG_DEBUG(5) << "Callback mode requested. Won't acquire iom sender!";
    } else {
      if (m_sink_is_set) {
        TLOG_DEBUG(5) << "SourceModel sink is already set in initialized!";
      } else {
        m_sink_queue = get_iom_sender<TargetPayloadType>(sink_name);
        m_sink_is_set = true;
      }
    }
  }

Member Data Documentation

buffer_size

template<class TargetPayloadType >

auto dunedaq::crtmodules::SourceModel< TargetPayloadType >::buffer_size = sizeof(TargetPayloadType)

staticconstexpr

Buffer size based on TargetPayloadType.

Definition at line 46 of file SourceModel.hpp.

m_callback_is_acquired

template<class TargetPayloadType >

bool dunedaq::crtmodules::SourceModel< TargetPayloadType >::m_callback_is_acquired { false }

private

Definition at line 138 of file SourceModel.hpp.

{ false };

m_callback_mode

template<class TargetPayloadType >

bool dunedaq::crtmodules::SourceModel< TargetPayloadType >::m_callback_mode

private

Definition at line 137 of file SourceModel.hpp.

m_dropped_packets

template<class TargetPayloadType >

std::atomic<uint64_t> dunedaq::crtmodules::SourceModel< TargetPayloadType >::m_dropped_packets {0}

private

Definition at line 142 of file SourceModel.hpp.

{0};

m_sink_callback

template<class TargetPayloadType >

sink_cb_t dunedaq::crtmodules::SourceModel< TargetPayloadType >::m_sink_callback

private

Definition at line 140 of file SourceModel.hpp.

m_sink_id

template<class TargetPayloadType >

std::string dunedaq::crtmodules::SourceModel< TargetPayloadType >::m_sink_id

private

Definition at line 132 of file SourceModel.hpp.

m_sink_is_set

template<class TargetPayloadType >

bool dunedaq::crtmodules::SourceModel< TargetPayloadType >::m_sink_is_set { false }

private

Definition at line 133 of file SourceModel.hpp.

{ false };

m_sink_queue

template<class TargetPayloadType >

std::shared_ptr<sink_t> dunedaq::crtmodules::SourceModel< TargetPayloadType >::m_sink_queue

private

Definition at line 134 of file SourceModel.hpp.

---

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

• /github/workspace/dunedaq/sourcecode/crtmodules/src/SourceModel.hpp