46 rc =
zmq_bind (pub,
"inproc://soname");
65 int hwmlimit = hwm - 1;
69 for (
int i = 0; i < hwmlimit; i++) {
80 assert (errno == EAGAIN);
88 assert (send_count == recv_count);
101 while (
zmq_send (pub,
"", 0, 0) == 0)
103 assert (errno == EAGAIN);
107 assert (send_count == recv_count);
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)