34 fprintf (stderr,
"test_reqrep_device_tipc running...\n");
42 int rc =
zmq_bind (dealer,
"tipc://{5560,0,0}");
46 rc =
zmq_bind (router,
"tipc://{5561,0,0}");
68 for (
int i = 0; i != 4; i++) {
75 size_t sz =
sizeof (rcvmore);
86 assert (memcmp (buff,
"ABC", 3) == 0);
88 size_t sz =
sizeof (rcvmore);
94 assert (memcmp (buff,
"DEF", 3) == 0);
106 for (
int i = 0; i != 4; i++) {
122 assert (memcmp (buff,
"GHI", 3) == 0);
128 assert (memcmp (buff,
"JKL", 3) == 0);
ZMQ_EXPORT void * zmq_init(int io_threads)
ZMQ_EXPORT int zmq_recvmsg(void *s, zmq_msg_t *msg, int flags)
ZMQ_EXPORT int zmq_recv(void *s, 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)
ZMQ_EXPORT int zmq_sendmsg(void *s, zmq_msg_t *msg, int flags)
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_msg_init(zmq_msg_t *msg)