43 rc =
zmq_bind (pub_socket,
"inproc://a");
68 assert (send_hwm == recv_count);
106 rc =
zmq_bind (pub_socket,
"inproc://a");
124 while (send_count < msgCnt )
133 assert(EAGAIN == errno);
134 recv_count +=
receive(sub_socket);
135 assert(recv_count == send_count);
139 recv_count +=
receive(sub_socket);
157 int first_count = 9999;
158 int second_count = 1100;
170 rc =
zmq_bind (pub_socket,
"tcp://127.0.0.1:1234");
178 rc =
zmq_connect (sub_socket,
"tcp://127.0.0.1:1234");
189 assert (first_count == send_count);
199 assert (first_count == recv_count);
207 assert (second_count == send_count);
217 assert (second_count == recv_count);
238 assert (count == 1000);
242 assert (count == 6000);
void msleep(int milliseconds)
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)
int test_blocking(int send_hwm, int msgCnt)
ZMQ_EXPORT void * zmq_socket(void *, int type)
int test_defaults(int send_hwm, int msgCnt)
ZMQ_EXPORT int zmq_connect(void *s, const char *addr)
ZMQ_EXPORT int zmq_close(void *s)
int receive(void *socket)
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)