47 const size_t services = 5;
48 void *senders [services];
49 for (
size_t peer = 0; peer < services; ++peer) {
51 assert (senders [peer]);
56 char *str = strdup(
"A");
81 for (
size_t peer = 0; peer < services; ++peer) {
86 assert (sum == services *
'A' + services * (services - 1) / 2);
89 for (
size_t peer = 0; peer < services; ++peer) {
105 for (
size_t peer = 0; peer < services; ++peer)
160 assert (errno == EAGAIN);
168 assert (errno == EAGAIN);
172 assert (errno == EAGAIN);
191 const char *binds [] = {
"inproc://a",
"tcp://127.0.0.1:5555" };
192 const char *connects [] = {
"inproc://a",
"tcp://localhost:5555" };
194 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)
void test_destroy_queue_on_disconnect(void *ctx)
void test_fair_queue_in(void *ctx)
ZMQ_EXPORT void * zmq_ctx_new(void)
void setup_test_environment(void)
ZMQ_EXPORT void * zmq_msg_data(zmq_msg_t *msg)
ZMQ_EXPORT void * zmq_socket(void *, int type)
#define ZMQ_ROUTER_MANDATORY
const char * bind_address
ZMQ_EXPORT int zmq_connect(void *s, const char *addr)
static void receiver(void *socket)
ZMQ_EXPORT int zmq_msg_recv(zmq_msg_t *msg, void *s, int flags)
const char * connect_address
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,...)
ZMQ_EXPORT int zmq_disconnect(void *s, const char *addr)
ZMQ_EXPORT int zmq_msg_init(zmq_msg_t *msg)