42 int rc =
zmq_bind (vent,
"tcp://127.0.0.1:55556");
53 #if defined(ZMQ_SERVER) && defined(ZMQ_CLIENT) 56 rc =
zmq_bind (server,
"tcp://127.0.0.1:55557");
84 assert (event.
socket == sink);
104 size_t fd_size =
sizeof (SOCKET);
107 size_t fd_size =
sizeof (
int);
116 assert (event.
socket == NULL);
117 assert (event.
fd == fd);
121 #if defined(ZMQ_SERVER) && defined(ZMQ_CLIENT) 125 rc =
zmq_connect (client,
"tcp://127.0.0.1:55557");
131 assert (event.
socket == server);
141 assert (event.
socket == server);
153 #if defined(ZMQ_SERVER) && defined(ZMQ_CLIENT) int zmq_poller_remove_fd(void *poller, int fd)
int zmq_poller_add_fd(void *poller, int fd, void *user_data, short events)
int zmq_poller_add(void *poller, void *socket, void *user_data, short events)
ZMQ_EXPORT void * zmq_ctx_new(void)
void setup_test_environment(void)
int zmq_poller_wait(void *poller, zmq_poller_event_t *event, long timeout)
ZMQ_EXPORT int zmq_recv(void *s, void *buf, size_t len, int flags)
ZMQ_EXPORT int zmq_send_const(void *s, const void *buf, size_t len, int flags)
ZMQ_EXPORT void * zmq_socket(void *, int type)
ZMQ_EXPORT int zmq_getsockopt(void *s, int option, void *optval, size_t *optvallen)
ZMQ_EXPORT int zmq_connect(void *s, const char *addr)
ZMQ_EXPORT int zmq_close(void *s)
int zmq_poller_modify(void *poller, void *socket, short events)
int zmq_poller_remove(void *poller, void *socket)
ZMQ_EXPORT int zmq_bind(void *s, const char *addr)
ZMQ_EXPORT int zmq_ctx_term(void *context)
int zmq_poller_destroy(void **poller_p)
void * zmq_poller_new(void)