dunedaq::iomanager::ReceiverConcept< Datatype > Class Template Reference

#include <Receiver.hpp>

Inheritance diagram for dunedaq::iomanager::ReceiverConcept< Datatype >:

Collaboration diagram for dunedaq::iomanager::ReceiverConcept< Datatype >:

Public Member Functions
	ReceiverConcept (ConnectionId const &conn_id)
virtual Datatype	receive (Receiver::timeout_t timeout)=0
virtual std::optional< Datatype >	try_receive (Receiver::timeout_t timeout)=0
virtual bool	data_pending ()=0
virtual void	add_callback (std::function< void(Datatype &)> callback)=0
virtual void	remove_callback ()=0
virtual void	subscribe (std::string topic)=0
virtual void	unsubscribe (std::string topic)=0
Public Member Functions inherited from dunedaq::iomanager::Receiver
	Receiver (ConnectionId const &this_conn)
virtual	~Receiver ()=default
ConnectionId	id () const
Public Member Functions inherited from dunedaq::utilities::NamedObject
	NamedObject (const std::string &name)
	NamedObject Constructor.
	NamedObject (NamedObject const &)=delete
	NamedObject is not copy-constructible.
	NamedObject (NamedObject &&)=default
	NamedObject is move-constructible.
NamedObject &	operator= (NamedObject const &)=delete
	NamedObject is not copy-assignable.
NamedObject &	operator= (NamedObject &&)=default
	NamedObject is move-assignable.
virtual	~NamedObject ()=default
	Default virtual destructor.
const std::string &	get_name () const final
	Get the name of this NamedObejct.
Public Member Functions inherited from dunedaq::utilities::Named
	Named ()=default
	Named Constructor.
	Named (Named const &)=delete
	Named is not copy-constructible.
	Named (Named &&)=default
	Named is move-constructible.
Named &	operator= (Named const &)=delete
	Named is not copy-assignable.
Named &	operator= (Named &&)=default
	Named is move-assignable.
virtual	~Named ()=default
	Default virtual destructor.

Additional Inherited Members
Public Types inherited from dunedaq::iomanager::Receiver
using	timeout_t = std::chrono::milliseconds
Static Public Attributes inherited from dunedaq::iomanager::Receiver
static constexpr timeout_t	s_block = timeout_t::max()
static constexpr timeout_t	s_no_block = timeout_t::zero()
Protected Attributes inherited from dunedaq::iomanager::Receiver
ConnectionId	m_conn

Detailed Description

template<typename Datatype>
class dunedaq::iomanager::ReceiverConcept< Datatype >

Definition at line 47 of file Receiver.hpp.

Constructor & Destructor Documentation

ReceiverConcept()

template<typename Datatype>

dunedaq::iomanager::ReceiverConcept< Datatype >::ReceiverConcept ( ConnectionId const & conn_id )

inlineexplicit

Definition at line 50 of file Receiver.hpp.

    : Receiver(conn_id)
  {
  }

Member Function Documentation

add_callback()

template<typename Datatype>

virtual void dunedaq::iomanager::ReceiverConcept< Datatype >::add_callback ( std::function< void(Datatype &)> callback )

pure virtual

Implemented in dunedaq::iomanager::NetworkReceiverModel< Datatype >, and dunedaq::iomanager::QueueReceiverModel< Datatype >.

data_pending()

template<typename Datatype>

virtual bool dunedaq::iomanager::ReceiverConcept< Datatype >::data_pending ( )

pure virtual

Implemented in dunedaq::iomanager::NetworkReceiverModel< Datatype >, and dunedaq::iomanager::QueueReceiverModel< Datatype >.

receive()

template<typename Datatype>

virtual Datatype dunedaq::iomanager::ReceiverConcept< Datatype >::receive ( Receiver::timeout_t timeout )

pure virtual

Implemented in dunedaq::iomanager::NetworkReceiverModel< Datatype >, and dunedaq::iomanager::QueueReceiverModel< Datatype >.

remove_callback()

template<typename Datatype>

virtual void dunedaq::iomanager::ReceiverConcept< Datatype >::remove_callback ( )

pure virtual

Implemented in dunedaq::iomanager::NetworkReceiverModel< Datatype >, and dunedaq::iomanager::QueueReceiverModel< Datatype >.

subscribe()

template<typename Datatype>

virtual void dunedaq::iomanager::ReceiverConcept< Datatype >::subscribe ( std::string topic )

pure virtual

Implemented in dunedaq::iomanager::NetworkReceiverModel< Datatype >, and dunedaq::iomanager::QueueReceiverModel< Datatype >.

try_receive()

template<typename Datatype>

virtual std::optional< Datatype > dunedaq::iomanager::ReceiverConcept< Datatype >::try_receive ( Receiver::timeout_t timeout )

pure virtual

Implemented in dunedaq::iomanager::NetworkReceiverModel< Datatype >, and dunedaq::iomanager::QueueReceiverModel< Datatype >.

unsubscribe()

template<typename Datatype>

virtual void dunedaq::iomanager::ReceiverConcept< Datatype >::unsubscribe ( std::string topic )

pure virtual

Implemented in dunedaq::iomanager::NetworkReceiverModel< Datatype >, and dunedaq::iomanager::QueueReceiverModel< Datatype >.

---

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

• /github/workspace/dunedaq/sourcecode/iomanager/include/iomanager/Receiver.hpp