42 int rc =
zmq_bind (rep,
"tcp://127.0.0.1:5563");
82 rc =
zmq_bind (control,
"inproc://control");
92 assert (memcmp (buf,
"msg1", 4) == 0);
98 assert (memcmp (buf,
"msg22", 5) == 0);
100 rc =
zmq_send (control,
"TERMINATE", 9, 0);
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 void zmq_threadclose(void *thread)
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)
void server_task(void *ctx)
ZMQ_EXPORT void * zmq_threadstart(zmq_thread_fn *func, void *arg)
ZMQ_EXPORT int zmq_proxy_steerable(void *frontend, void *backend, void *capture, void *control)