dunedaq::ipm Namespace Reference

An ERS Error indicating that an exception was thrown from ZMQ while performing an operation. More...

Namespaces
namespace	opmon

Classes
class	CallbackAdapter
class	Receiver
class	Sender
class	Subscriber
class	ZmqContext

Enumerations
enum class	IpmPluginType { Sender , Receiver , Publisher , Subscriber }

Functions
std::string	get_recommended_plugin_name (IpmPluginType type)
std::shared_ptr< Receiver >	make_ipm_receiver (std::string const &plugin_name)
std::shared_ptr< Sender >	make_ipm_sender (std::string const &plugin_name)
std::shared_ptr< Subscriber >	make_ipm_subscriber (std::string const &plugin_name)

Variables
const std::map< IpmPluginType, std::string >	ZmqPluginNames

Detailed Description

An ERS Error indicating that an exception was thrown from ZMQ while performing an operation.

Parameters

operation	The operation that failed (connect/bind/disconnect/unbind)
direction	The direction of the socket (send/receive)
what	The zmq::error_t exception message
connection_string	The connection string that caused the error

An ERS Error indicating that an exception was thrown from ZMQ while sending

Parameters

what	The zmq::error_t exception message
N	number of bytes in attempted send
topic	Send topic

An ERS Error indicating that an exception was thrown from ZMQ while receiving

Parameters

what	The zmq::error_t exception message
which	Which receive had an issue

An ERS Error indicating that an exception was thrown from ZMQ during a subscribe

Parameters

what	The zmq::error_t exception message
topic	Topic being subscribed to

An ERS Error indicating that an exception was thrown from ZMQ during an unsubscribe

Parameters

what	The zmq::error_t exception message
topic	Topic being unsubscribed from

Enumeration Type Documentation

IpmPluginType

enum class dunedaq::ipm::IpmPluginType

strong

Enumerator
Sender
Receiver
Publisher
Subscriber

Definition at line 24 of file PluginInfo.hpp.

{
  Sender,
  Receiver,
  Publisher,
  Subscriber
};

Function Documentation

get_recommended_plugin_name()

std::string dunedaq::ipm::get_recommended_plugin_name

(

IpmPluginType

type

)

Definition at line 38 of file PluginInfo.hpp.

{
  return ZmqPluginNames.at(type);
}

make_ipm_receiver()

std::shared_ptr< Receiver > dunedaq::ipm::make_ipm_receiver ( std::string const & plugin_name )

inline

Definition at line 124 of file Receiver.hpp.

{
  static cet::BasicPluginFactory bpf("duneIPM", "make");
  return bpf.makePlugin<std::shared_ptr<Receiver>>(plugin_name);
}

make_ipm_sender()

std::shared_ptr< Sender > dunedaq::ipm::make_ipm_sender ( std::string const & plugin_name )

inline

Definition at line 119 of file Sender.hpp.

{
  static cet::BasicPluginFactory bpf("duneIPM", "make");
  return bpf.makePlugin<std::shared_ptr<Sender>>(plugin_name);
}

make_ipm_subscriber()

std::shared_ptr< Subscriber > dunedaq::ipm::make_ipm_subscriber ( std::string const & plugin_name )

inline

Definition at line 59 of file Subscriber.hpp.

{
  static cet::BasicPluginFactory bpf("duneIPM", "make");
  auto receiver_ptr = bpf.makePlugin<std::shared_ptr<Receiver>>(plugin_name);
  return std::dynamic_pointer_cast<Subscriber>(receiver_ptr);
}

Variable Documentation

ZmqPluginNames

const std::map<IpmPluginType, std::string> dunedaq::ipm::ZmqPluginNames

Initial value:

{ { IpmPluginType::Sender, "ZmqSender" },
                                                           { IpmPluginType::Receiver, "ZmqReceiver" },
                                                           { IpmPluginType::Publisher, "ZmqPublisher" },
                                                           { IpmPluginType::Subscriber, "ZmqSubscriber" } }

Definition at line 32 of file PluginInfo.hpp.

                                                     { { IpmPluginType::Sender, "ZmqSender" },
                                                           { IpmPluginType::Receiver, "ZmqReceiver" },
                                                           { IpmPluginType::Publisher, "ZmqPublisher" },
                                                           { IpmPluginType::Subscriber, "ZmqSubscriber" } };