38 const char *bindip =
"tcp://127.0.0.1:5556";
78 ret =
zmq_recv (rbind, buff, 256, 0);
80 assert (0 == buff[0]);
81 ret =
zmq_recv (rbind, buff+128, 128, 0);
83 assert (
'h' == buff[128]);
101 const char *bindip =
"tcp://127.0.0.1:5556";
144 ret =
zmq_recv (rbind, buff, 256, 0);
146 assert (ret &&
'Y' == buff[0]);
148 assert (ret && 0 == buff[0]);
151 ret =
zmq_recv (rbind, buff+128, 128, 0);
152 assert(5 == ret &&
'h' == buff[128]);
167 ret =
zmq_recv (rconn1, buff, 256, 0);
168 assert (
'c' == buff[0] && 6 == ret);
169 ret =
zmq_recv (rconn1, buff+128, 128, 0);
170 assert (3 == ret &&
'o' == buff[128]);
void test_router_2_router(bool named)
ZMQ_EXPORT int zmq_setsockopt(void *s, int option, const void *optval, size_t optvallen)
ZMQ_EXPORT int zmq_unbind(void *s, const char *addr)
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_send_const(void *s, const void *buf, size_t len, int flags)
#define ZMQ_STREAM_NOTIFY
ZMQ_EXPORT void * zmq_socket(void *, int type)
void test_stream_2_stream()
ZMQ_EXPORT int zmq_connect(void *s, const char *addr)
ZMQ_EXPORT int zmq_close(void *s)
ZMQ_EXPORT int zmq_ctx_destroy(void *context)
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)