43 const size_t services = 5;
45 for (
size_t peer = 0; peer < services; peer++) {
62 for (
size_t peer = 0; peer < services; peer++) {
70 for (
size_t peer = 0; peer < services; peer++)
88 const size_t services = 3;
89 void *router [services];
91 for (
size_t i = 0; i < services; ++i) {
110 for (
size_t i = 0; i < services; ++i) {
123 for (
size_t j = 0; j < services; ++j) {
124 const char *replies [] = {
"WRONG",
"GOOD" };
125 const char *reply = replies [i == j ? 1 : 0];
134 for (
size_t i = 0; i < services; ++i)
170 size_t more_size =
sizeof (more);
210 assert (errno == EAGAIN);
214 assert (errno == EAGAIN);
226 const char *binds [] = {
"inproc://a",
"tcp://127.0.0.1:5555" };
227 const char *connects [] = {
"inproc://a",
"tcp://localhost:5555" };
229 for (
int transport = 0; transport < 2; transport++) {
void msleep(int milliseconds)
void test_req_message_format(void *ctx)
ZMQ_EXPORT int zmq_setsockopt(void *s, int option, const void *optval, size_t optvallen)
ZMQ_EXPORT void * zmq_ctx_new(void)
const char * bind_address
void setup_test_environment(void)
ZMQ_EXPORT int zmq_msg_copy(zmq_msg_t *dest, zmq_msg_t *src)
ZMQ_EXPORT void * zmq_socket(void *, int type)
void test_req_only_listens_to_current_peer(void *ctx)
void test_block_on_send_no_peers(void *ctx)
#define ZMQ_ROUTER_MANDATORY
ZMQ_EXPORT int zmq_getsockopt(void *s, int option, void *optval, size_t *optvallen)
void test_round_robin_out(void *ctx)
ZMQ_EXPORT int zmq_msg_send(zmq_msg_t *msg, void *s, int flags)
ZMQ_EXPORT int zmq_connect(void *s, const char *addr)
ZMQ_EXPORT int zmq_close(void *s)
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)
const char * connect_address
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 size_t zmq_msg_size(zmq_msg_t *msg)
ZMQ_EXPORT int zmq_msg_init(zmq_msg_t *msg)