Receiver.hpp

Go to the documentation of this file.

 
#ifndef IOMANAGER_INCLUDE_IOMANAGER_RECEIVER_HPP_
#define IOMANAGER_INCLUDE_IOMANAGER_RECEIVER_HPP_
 
#include "iomanager/CommonIssues.hpp"
#include "iomanager/SchemaUtils.hpp"
 
#include "logging/Logging.hpp"
#include "utilities/NamedObject.hpp"
 
#include <optional>
 
namespace dunedaq {
 
namespace iomanager {
 
// Typeless
class Receiver : public utilities::NamedObject
{
public:
  using timeout_t = std::chrono::milliseconds;
  static constexpr timeout_t s_block = timeout_t::max();
  static constexpr timeout_t s_no_block = timeout_t::zero();
 
  explicit Receiver(ConnectionId const& this_conn)
    : utilities::NamedObject(this_conn.uid)
    , m_conn(this_conn)
  {
  }
 
  virtual ~Receiver() = default;
 
  ConnectionId id() const { return m_conn; }
 
protected:
  ConnectionId m_conn;
};
 
// Interface
template<typename Datatype>
class ReceiverConcept : public Receiver
{
public:
  explicit ReceiverConcept(ConnectionId const& conn_id)
    : Receiver(conn_id)
  {
  }
  virtual Datatype receive(Receiver::timeout_t timeout) = 0;
  virtual std::optional<Datatype> try_receive(Receiver::timeout_t timeout) = 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;
};
 
} // namespace iomanager
} // namespace dunedaq
 
#endif // IOMANAGER_INCLUDE_IOMANAGER_RECEIVER_HPP_