#include <zmq.hpp>
#include "RooFit_ZMQ/Utility.h"
#include "RooFit_ZMQ/functions.h"
#include <type_traits>
#include <string>
#include <vector>
#include <sstream>
#include <ios>
#include <iostream>
#include <functional>
#include <memory>
#include <unistd.h>

Classes
struct	ZMQ::MoreException
struct	ZMQ::TimeOutException
class	ZeroMQSvc
	Wrapper class for basic ZeroMQ context and socket management. More...
struct	ZmqLingeringSocketPtrDeleter< PERIOD >

Namespaces
namespace	ZMQ

Typedefs
template<int PERIOD = 0>
using	ZmqLingeringSocketPtr = std::unique_ptr<zmq::socket_t, ZmqLingeringSocketPtrDeleter<PERIOD>>

Functions
template<typename... args_t>
auto	retry_recv (zmq::socket_t &socket, int max_tries, args_t... args) -> decltype(socket.recv(args...))
template<typename... args_t>
auto	retry_send (zmq::socket_t &socket, int max_tries, args_t... args) -> decltype(socket.send(args...))
ZeroMQSvc &	zmqSvc ()
	Get singleton object of this class.

Typedef Documentation

◆ ZmqLingeringSocketPtr

template<int PERIOD = 0>

using ZmqLingeringSocketPtr = std::unique_ptr<zmq::socket_t, ZmqLingeringSocketPtrDeleter<PERIOD>>

Definition at line 74 of file ZeroMQSvc.h.

Function Documentation

◆ retry_recv()

template<typename... args_t>

auto retry_recv	(	zmq::socket_t &	socket,
		int	max_tries,
		args_t...	args ) -> decltype(socket.recv(args...))

Definition at line 98 of file ZeroMQSvc.h.

◆ retry_send()

template<typename... args_t>

auto retry_send	(	zmq::socket_t &	socket,
		int	max_tries,
		args_t...	args ) -> decltype(socket.send(args...))

Definition at line 79 of file ZeroMQSvc.h.

◆ zmqSvc()

ZeroMQSvc & zmqSvc ( )

Get singleton object of this class.

Definition at line 34 of file ZeroMQSvc.cpp.

Classes

Namespaces