Nanomsg Wrapper

Classes
class	turi::nanosockets::async_reply_socket
class	turi::nanosockets::async_request_socket
class	turi::nanosockets::publish_socket
class	turi::nanosockets::subscribe_socket

Typedefs
typedef std::string	turi::nanosockets::nn_msg_t

Functions
std::string	turi::nanosockets::normalize_address (const std::string &address)

Detailed Description

Typedef Documentation

nn_msg_t

typedef std::string turi::nanosockets::nn_msg_t

Describes a wrapper around an array of nanomsg messages part. Writes are performed through the insert_back() function. The standard pattern is:

// creates a new message part and returning it
nn_msg_t* msg = msgvec.insert_back();
zmq_msg_init_...(msg, ...)

It can also be used for reading. It maintains a read index which is initialized to zero. Each call to read_next() will return the message part at the readindex, and increment the read index. If there are no more parts, the function will return NULL.

The contents of the vector are automatically freed on destruction.

This class says zmq. It was originally built as a thin wrapper around zeromq but is now built using nanomsg but the interface and all names are maintained for maximal backward compatibility

Definition at line 40 of file zmq_msg_vector.hpp.

Function Documentation

normalize_address()

std::string turi::nanosockets::normalize_address

(

const std::string &

address

)

Normalizes an zeromq address. On windows, this converts IPc addresses to localhost address.