40 assert (router_socket);
50 rc =
zmq_bind (router_socket,
"inproc://hi");
56 rc =
zmq_send (req_socket,
"r", 1, 0);
64 addr_size =
zmq_recv (router_socket, addr,
sizeof (addr), 0);
65 assert (addr_size >= 0);
66 rc =
zmq_recv (router_socket, bottom,
sizeof (bottom), 0);
68 rc =
zmq_recv (router_socket, body,
sizeof (body), 0);
72 rc =
zmq_send (router_socket, addr, addr_size, 0);
73 assert (rc == addr_size);
77 assert (rc == addr_size);
80 rc =
zmq_send (router_socket,
"b", 1, 0);
84 rc =
zmq_recv (req_socket, body,
sizeof (body), 0);
86 assert (body [0] ==
'b');
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_recv(void *s, void *buf, size_t len, int flags)
ZMQ_EXPORT void * zmq_socket(void *, int type)
ZMQ_EXPORT int zmq_connect(void *s, const char *addr)
ZMQ_EXPORT int zmq_close(void *s)
ZMQ_EXPORT int zmq_send(void *s, const void *buf, size_t len, int flags)
ZMQ_EXPORT int zmq_bind(void *s, const char *addr)
ZMQ_EXPORT int zmq_ctx_term(void *context)