35 size_t more_size =
sizeof (more);
73 rc =
zmq_bind (req,
"tcp://127.0.0.1:5555");
76 const size_t services = 5;
78 for (
size_t peer = 0; peer < services; peer++) {
86 rc =
zmq_connect (rep [peer],
"tcp://localhost:5555");
145 for (
size_t peer = 0; peer < services; peer++)
177 rc =
zmq_bind (router,
"tcp://127.0.0.1:5555");
void msleep(int milliseconds)
ZMQ_EXPORT int zmq_setsockopt(void *s, int option, const void *optval, size_t optvallen)
ZMQ_EXPORT void * zmq_ctx_new(void)
void setup_test_environment(void)
ZMQ_EXPORT int zmq_msg_copy(zmq_msg_t *dest, zmq_msg_t *src)
ZMQ_EXPORT void * zmq_socket(void *, int type)
ZMQ_EXPORT int zmq_getsockopt(void *s, int option, void *optval, size_t *optvallen)
ZMQ_EXPORT int zmq_msg_send(zmq_msg_t *msg, void *s, int flags)
ZMQ_EXPORT int zmq_connect(void *s, const char *addr)
static void bounce(void *socket)
ZMQ_EXPORT int zmq_msg_recv(zmq_msg_t *msg, void *s, int flags)
void close_zero_linger(void *socket)
ZMQ_EXPORT int zmq_bind(void *s, const char *addr)
void s_recv_seq(void *socket,...)
ZMQ_EXPORT int zmq_ctx_term(void *context)
ZMQ_EXPORT int zmq_msg_close(zmq_msg_t *msg)
void s_send_seq(void *socket,...)
#define ZMQ_REQ_CORRELATE
ZMQ_EXPORT int zmq_msg_init(zmq_msg_t *msg)