32 #if !defined (ZMQ_HAVE_WINDOWS) 38 struct addrinfo *addr, hint;
40 hint.ai_family=AF_INET;
41 hint.ai_socktype=SOCK_STREAM;
42 hint.ai_protocol=IPPROTO_TCP;
44 hint.ai_canonname=NULL;
48 int rc = getaddrinfo (address, port, &hint, &addr);
51 int s_pre = socket (AF_INET, SOCK_STREAM, IPPROTO_TCP);
55 rc = setsockopt (s_pre, SOL_SOCKET, SO_REUSEADDR, &flag,
sizeof (
int));
58 rc =
bind (s_pre, addr->ai_addr, addr->ai_addrlen);
61 rc = listen (s_pre, SOMAXCONN);
81 int rc =
zmq_bind (sb,
"tcp://127.0.0.1:5560");
111 int rc =
zmq_bind (sb,
"tcp://127.0.0.1:5560");
133 #if defined(ZMQ_SERVER) && defined(ZMQ_CLIENT) 142 int rc =
zmq_bind (sb,
"tcp://127.0.0.1:5560");
170 assert (routing_id != 0);
194 assert (routing_id == 0);
ZMQ_EXPORT int zmq_setsockopt(void *s, int option, const void *optval, size_t optvallen)
uint32_t zmq_msg_routing_id(zmq_msg_t *msg)
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)
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)
void test_client_server()
void bounce(void *server, void *client)
ZMQ_EXPORT int zmq_bind(void *s, const char *addr)
ZMQ_EXPORT int zmq_ctx_term(void *context)
ZMQ_EXPORT int zmq_msg_close(zmq_msg_t *msg)
ZMQ_EXPORT int zmq_msg_init_size(zmq_msg_t *msg, size_t size)
int zmq_msg_set_routing_id(zmq_msg_t *msg, uint32_t routing_id)
void pre_allocate_sock(void *zmq_socket, const char *address, const char *port)
ZMQ_EXPORT int zmq_msg_init(zmq_msg_t *msg)