32 const char *
address =
"tcp://127.0.0.1:6571";
34 #define NUM_MESSAGES 5 38 #if !defined (ZMQ_HAVE_WINDOWS) 76 int num_bytes =
zmq_recv (pull, buffer, 5, 0);
77 assert (num_bytes == 5);
81 rc = waitpid (pid, &child_status, 0);
82 if (rc == -1 && errno == EINTR)
86 assert (WEXITSTATUS (child_status) == 0);
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_ctx_destroy(void *context)
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)