dunedaq::asiolibs::GenericReceiverModel< TargetPayloadType > Class Template Reference

#include <GenericReceiverModel.hpp>

Inheritance diagram for dunedaq::asiolibs::GenericReceiverModel< TargetPayloadType >:

Collaboration diagram for dunedaq::asiolibs::GenericReceiverModel< TargetPayloadType >:

Public Member Functions
	GenericReceiverModel (const std::string &receiver_connection_name)
std::optional< TypeErasedPayload >	try_receive (dunedaq::iomanager::Receiver::timeout_t timeout) override
Public Member Functions inherited from dunedaq::asiolibs::GenericReceiverConcept
virtual	~GenericReceiverConcept ()=default

Private Attributes
std::shared_ptr< iomanager::ReceiverConcept< TargetPayloadType > >	m_receiver
	Generic IOManager Receiver.

Detailed Description

template<class TargetPayloadType>
class dunedaq::asiolibs::GenericReceiverModel< TargetPayloadType >

Definition at line 20 of file GenericReceiverModel.hpp.

Constructor & Destructor Documentation

GenericReceiverModel()

template<class TargetPayloadType>

dunedaq::asiolibs::GenericReceiverModel< TargetPayloadType >::GenericReceiverModel ( const std::string & receiver_connection_name )

inlineexplicit

Definition at line 23 of file GenericReceiverModel.hpp.

    : m_receiver(get_iom_receiver<TargetPayloadType>(receiver_connection_name))
  {}

Member Function Documentation

try_receive()

template<class TargetPayloadType>

std::optional< TypeErasedPayload > dunedaq::asiolibs::GenericReceiverModel< TargetPayloadType >::try_receive ( dunedaq::iomanager::Receiver::timeout_t timeout )

inlineoverridevirtual

Implements dunedaq::asiolibs::GenericReceiverConcept.

Definition at line 27 of file GenericReceiverModel.hpp.

                                                                                                 {
    auto opt_payload = m_receiver->try_receive(timeout);
    if (opt_payload) {
      // Allocate the received payload on the heap with shared ownership,
      // so its lifetime can outlive this function and be tied to async sends.
      auto payload = std::make_shared<TargetPayloadType>(std::move(*opt_payload));
      return TypeErasedPayload{ std::reinterpret_pointer_cast<const void>(payload), payload.get(), sizeof(*payload) };
    }
    return std::nullopt;
  }

Member Data Documentation

m_receiver

template<class TargetPayloadType>

std::shared_ptr<iomanager::ReceiverConcept<TargetPayloadType> > dunedaq::asiolibs::GenericReceiverModel< TargetPayloadType >::m_receiver

private

Generic IOManager Receiver.

Definition at line 42 of file GenericReceiverModel.hpp.

---

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

• /github/workspace/dunedaq/sourcecode/asiolibs/src/GenericReceiverModel.hpp