43 const size_t services = 5;
44 void *pulls [services];
45 for (
size_t peer = 0; peer < services; ++peer) {
47 assert (pulls [peer]);
61 for (
size_t peer = 0; peer < services; ++peer)
63 for (
size_t peer = 0; peer < services; ++peer)
67 for (
size_t peer = 0; peer < services; ++peer) {
74 for (
size_t peer = 0; peer < services; ++peer)
89 const size_t services = 5;
90 void *pushs [services];
91 for (
size_t peer = 0; peer < services; ++peer)
94 assert (pushs [peer]);
107 for (
size_t peer = 0; peer < services; ++peer) {
108 char *str = strdup(
"A");
112 first_half += str [0];
116 second_half += str [0];
129 for (
size_t peer = 0; peer < services; ++peer) {
133 first_half -= str [0];
135 assert (first_half == 0);
138 for (
size_t peer = 0; peer < services; ++peer) {
142 second_half -= str [0];
144 assert (second_half == 0);
151 for (
size_t peer = 0; peer < services; ++peer)
169 assert (errno == EAGAIN);
173 assert (errno == EAGAIN);
208 assert (errno == EAGAIN);
227 assert (errno == EAGAIN);
232 assert (errno == EAGAIN);
241 assert (errno == EAGAIN);
249 assert (errno == EAGAIN);
267 const char *binds [] = {
"inproc://a",
"tcp://127.0.0.1:5555" };
268 const char *connects [] = {
"inproc://a",
"tcp://localhost:5555" };
270 for (
int transport = 0; transport < 2; ++transport) {
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)
void test_pull_fair_queue_in(void *ctx)
ZMQ_EXPORT void * zmq_msg_data(zmq_msg_t *msg)
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)
const char * bind_address
ZMQ_EXPORT int zmq_msg_recv(zmq_msg_t *msg, void *s, int flags)
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)
ZMQ_EXPORT int zmq_msg_close(zmq_msg_t *msg)
void s_send_seq(void *socket,...)
void test_push_round_robin_out(void *ctx)
ZMQ_EXPORT int zmq_disconnect(void *s, const char *addr)
void test_destroy_queue_on_disconnect(void *ctx)
void test_push_block_on_send_no_peers(void *ctx)
ZMQ_EXPORT int zmq_msg_init(zmq_msg_t *msg)
const char * connect_address