Contains the functions to communicate GDF datatypes across zmq in accordance with the GDFP-SW (GDF Server-Worker protocol) More...

#include "comms/transport.hpp"
#include <iomanip>
#include <boost/lexical_cast.hpp>
#include <random>

Include dependency graph for transport.cpp:

Functions
std::string	stateline::comms::receiveString (zmq::socket_t &socket)
	Read a string form a ZMQ socket. This is a blocking call. More...

bool	stateline::comms::sendString (zmq::socket_t &socket, const std::string &string)
	Send a string over a ZMQ socket. More...

bool	stateline::comms::sendStringPart (zmq::socket_t &socket, const std::string &string)
	Send a string over a ZMQ socket as a chunk of a multipart message. More...

Message	stateline::comms::receive (zmq::socket_t &socket)
	Receive a (possibly multi-part) message conforming to GDFP-SW comms protocal and provide it as a stateline::comms::Message class. More...

void	stateline::comms::send (zmq::socket_t &socket, const Message &message)
	Send a (possibly multi-part) message conforming to GDFP-SW comms protocol. More...

std::string	stateline::comms::randomSocketID ()
	Computes a random socket ID conforming to zeromq requirements for the string (not starting with a zero etc, see zeromq doco). More...

void	stateline::comms::setSocketID (const std::string &id, zmq::socket_t &socket)
	Sets the ID of a socket. The socket must be a DEALER or A REQ. More...

Detailed Description

Contains the functions to communicate GDF datatypes across zmq in accordance with the GDFP-SW (GDF Server-Worker protocol)

Namespaces