43 const size_t services = 5;
45 for (
size_t peer = 0; peer < services; ++peer) {
61 for (
size_t i = 0; i < services; ++i)
68 for (
size_t peer = 0; peer < services; ++peer)
76 for (
size_t peer = 0; peer < services; ++peer)
95 const size_t services = 5;
96 void *senders [services];
97 for (
size_t peer = 0; peer < services; ++peer) {
99 assert (senders [peer]);
119 for (
size_t peer = 0; peer < services; ++peer)
126 for (
size_t peer = 0; peer < services; ++peer)
134 for (
size_t peer = 0; peer < services; ++peer)
175 assert (errno == EAGAIN);
179 assert (errno == EAGAIN);
187 assert (errno == EAGAIN);
191 assert (errno == EAGAIN);
214 assert (errno == EAGAIN);
218 assert (errno == EAGAIN);
230 const char *binds [] = {
"inproc://a",
"tcp://127.0.0.1:5555" };
231 const char *connects [] = {
"inproc://a",
"tcp://localhost:5555" };
233 for (
int transports = 0; transports < 2; ++transports) {
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 void * zmq_socket(void *, int type)
const char * bind_address
void test_block_on_send_no_peers(void *ctx)
ZMQ_EXPORT int zmq_connect(void *s, const char *addr)
ZMQ_EXPORT int zmq_close(void *s)
static void receiver(void *socket)
ZMQ_EXPORT int zmq_msg_recv(zmq_msg_t *msg, void *s, int flags)
void test_round_robin_out(void *ctx)
ZMQ_EXPORT int zmq_poll(zmq_pollitem_t *items, int nitems, long timeout)
ZMQ_EXPORT int zmq_send(void *s, const void *buf, size_t len, int flags)
void close_zero_linger(void *socket)
ZMQ_EXPORT int zmq_bind(void *s, const char *addr)
void s_recv_seq(void *socket,...)
ZMQ_EXPORT int zmq_ctx_term(void *context)
void test_destroy_queue_on_disconnect(void *ctx)
ZMQ_EXPORT int zmq_msg_close(zmq_msg_t *msg)
const char * connect_address
void s_send_seq(void *socket,...)
void test_fair_queue_in(void *ctx)
ZMQ_EXPORT int zmq_disconnect(void *s, const char *addr)
ZMQ_EXPORT int zmq_msg_init(zmq_msg_t *msg)