45 rc =
zmq_bind (bind_socket,
"inproc://a");
50 assert (connect_socket);
64 assert (send_count == recv_count);
94 rc =
zmq_bind (bind_socket,
"inproc://a");
99 assert (connect_socket);
109 assert (connect_socket);
117 assert (bind_socket);
120 rc =
zmq_bind (bind_socket,
"inproc://a");
134 assert (send_count == recv_count);
137 rc =
zmq_send (connect_socket, NULL, 0, 0);
141 rc =
zmq_recv (bind_socket, NULL, 0, 0);
175 assert (connect_socket);
192 assert (bind_socket);
195 rc =
zmq_bind (bind_socket,
"inproc://a");
203 assert (send_count == recv_count);
223 assert (bind_socket);
226 rc =
zmq_bind (bind_socket,
"inproc://a");
273 assert (count == 2000);
277 assert (count == MAX_SENDS);
279 assert (count == MAX_SENDS);
283 assert (count == MAX_SENDS);
285 assert (count == MAX_SENDS);
289 assert (count == MAX_SENDS);
291 assert (count == MAX_SENDS);
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_inproc_connect_and_close_first(int send_hwm, int recv_hwm)
ZMQ_EXPORT void * zmq_socket(void *, int type)
int test_inproc_connect_first(int send_hwm, int recv_hwm)
ZMQ_EXPORT int zmq_connect(void *s, const char *addr)
ZMQ_EXPORT int zmq_close(void *s)
int test_inproc_bind_first(int send_hwm, int recv_hwm)
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)
int count_msg(int send_hwm, int recv_hwm, TestType testType)
int test_inproc_bind_and_close_first(int send_hwm, int)