GenericReceiverModel.hpp

Go to the documentation of this file.

 
#ifndef ASIOLIBS_SRC_GENERICRECEIVERMODEL_HPP_
#define ASIOLIBS_SRC_GENERICRECEIVERMODEL_HPP_
 
#include "GenericReceiverConcept.hpp"
 
namespace dunedaq::asiolibs {
 
template<class TargetPayloadType>
class GenericReceiverModel : public GenericReceiverConcept
{
public:
  explicit GenericReceiverModel(const std::string& raw_data_receiver_connection_name)
    : m_receiver(get_iom_receiver<TargetPayloadType>(raw_data_receiver_connection_name))
  {}
 
  std::optional<std::pair<const void*, std::size_t>> try_receive(dunedaq::iomanager::Receiver::timeout_t timeout) override {
    auto opt_payload = m_receiver->try_receive(timeout);
    if (opt_payload) {
        m_received = std::move(*opt_payload);
        return std::make_pair(&m_received, sizeof(TargetPayloadType));
    }
    return std::nullopt;
  }
  
private:
  std::shared_ptr<iomanager::ReceiverConcept<TargetPayloadType>> m_receiver;
 
  TargetPayloadType m_received;
};
 
} // namespace dunedaq::asiolibs
 
#endif // ASIOLIBS_SRC_GENERICRECEIVERMODEL_HPP_