34 #define BUF_SIZE (FILENAME_MAX+1) 42 const char *ep =
"tcp://127.0.0.1:5560";
43 const char *ep_wc_tcp =
"tcp://127.0.0.1:*";
44 #if !defined ZMQ_HAVE_WINDOWS && !defined ZMQ_HAVE_OPENVMS 45 const char *ep_wc_ipc =
"ipc://*";
47 #if defined ZMQ_HAVE_VMCI 48 const char *ep_wc_vmci =
"vmci://*:*";
66 rc =
zmq_recv (pull, buf,
sizeof (buf), 0);
78 assert (rc == -1 &&
zmq_errno () == EAGAIN);
103 rc =
zmq_recv (pull, buf,
sizeof (buf), 0);
115 assert (rc == -1 &&
zmq_errno () == EAGAIN);
134 #if !defined ZMQ_HAVE_WINDOWS && !defined ZMQ_HAVE_OPENVMS 138 #if defined ZMQ_HAVE_VMCI 146 buf_size =
sizeof(buf);
151 #if !defined ZMQ_HAVE_WINDOWS && !defined ZMQ_HAVE_OPENVMS 152 buf_size =
sizeof(buf);
158 #if defined ZMQ_HAVE_VMCI 159 buf_size =
sizeof(buf);
183 #if !defined ZMQ_HAVE_WINDOWS && !defined ZMQ_HAVE_OPENVMS 187 #if defined ZMQ_HAVE_VMCI 196 assert (rc == -1 &&
zmq_errno () == ENOENT);
197 #if !defined ZMQ_HAVE_WINDOWS && !defined ZMQ_HAVE_OPENVMS 199 assert (rc == -1 &&
zmq_errno () == ENOENT);
201 #if defined ZMQ_HAVE_VMCI 203 assert (rc == -1 &&
zmq_errno () == ENOENT);
void msleep(int milliseconds)
ZMQ_EXPORT int zmq_unbind(void *s, const char *addr)
#define ZMQ_LAST_ENDPOINT
ZMQ_EXPORT void * zmq_ctx_new(void)
void setup_test_environment(void)
ZMQ_EXPORT int zmq_recv(void *s, void *buf, size_t len, int flags)
ZMQ_EXPORT int zmq_errno(void)
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)
ZMQ_EXPORT int zmq_send(void *s, const void *buf, size_t len, int flags)
ZMQ_EXPORT int zmq_bind(void *s, const char *addr)
ZMQ_EXPORT int zmq_ctx_term(void *context)
ZMQ_EXPORT int zmq_disconnect(void *s, const char *addr)