File zmq_borealis_helpers.hpp

Defines

ERR_CHK_ZMQ(x)

RECV_REPLY(x, y)

RECV_REQUEST(x, y)

RECV_PULSE(x, y)

SEND_REPLY(x, y, z)

SEND_REQUEST(x, y, z)

SEND_PULSE(x, y, z)

Functions

std::vector<zmq::socket_t> create_sockets(zmq::context_t &context, std::vector<std::string> identities, std::string router_address)

void send_data(zmq::socket_t &socket, std::string recv_iden, std::string &data_msg)

std::string recv_data(zmq::socket_t &socket, std::string sender_iden)

void router(zmq::context_t &context, std::string router_address)