51 size_t placeholder =
sizeof(val);
61 assert(send_count == 4);
89 size_t placeholder =
sizeof(val);
99 assert(send_count == 6);
122 zmq_bind(bind_socket,
"inproc://a");
127 while (send_count < MAX_SENDS &&
zmq_send(bind_socket, &send_count,
sizeof(send_count),
ZMQ_DONTWAIT) ==
sizeof(send_count))
129 assert(send_count == 101);
136 size_t placeholder =
sizeof(val);
145 while (read_count < MAX_SENDS &&
zmq_recv(connect_socket, &read_data,
sizeof(read_data),
ZMQ_DONTWAIT) ==
sizeof(read_data)) {
146 assert(read_count == read_data);
150 assert(read_count == 101);
157 while (send_count < MAX_SENDS &&
zmq_send(bind_socket, &send_count,
sizeof(send_count),
ZMQ_DONTWAIT) ==
sizeof(send_count))
161 assert(send_count > 0);
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)
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_getsockopt(void *s, int option, void *optval, size_t *optvallen)
void test_change_after_connected()
ZMQ_EXPORT int zmq_connect(void *s, const char *addr)
ZMQ_EXPORT int zmq_close(void *s)
void test_change_before_connected()
void test_decrease_when_full()
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)