35 int rc =
zmq_recv (socket, &buffer,
sizeof (buffer), 0);
void msleep(int milliseconds)
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_close(void *s)
static void receiver(void *socket)
ZMQ_EXPORT int zmq_ctx_shutdown(void *context)
ZMQ_EXPORT int zmq_ctx_destroy(void *context)
ZMQ_EXPORT void * zmq_threadstart(zmq_thread_fn *func, void *arg)