47 const size_t services = 5;
48 void *reqs [services];
49 for (
size_t peer = 0; peer < services; ++peer) {
73 #ifdef SOMEONE_FIXES_THIS 75 for (
size_t peer = 0; peer < services; ++peer) {
76 char * str = strdup(
"A");
83 for (
size_t peer = 0; peer < services; ++peer) {
84 char * str = strdup(
"A");
95 for (
size_t peer = 0; peer < services; ++peer)
141 const char *binds [] = {
"inproc://a",
"tcp://127.0.0.1:5555" };
142 const char *connects [] = {
"inproc://a",
"tcp://localhost:5555" };
144 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_envelope(void *ctx)
ZMQ_EXPORT void * zmq_ctx_new(void)
void setup_test_environment(void)
ZMQ_EXPORT void * zmq_socket(void *, int type)
void test_fair_queue_in(void *ctx)
const char * bind_address
ZMQ_EXPORT int zmq_connect(void *s, const char *addr)
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)
const char * connect_address
void s_send_seq(void *socket,...)