53 rc =
zmq_bind (to,
"tipc://{6555,0,0}");
71 for (
int i = 0; i < 10; ++i) {
84 rc =
zmq_recv (to, &buffer,
sizeof (buffer), 0);
112 rc =
zmq_bind (to,
"tipc://{5560,0,0}");
140 for (
int i = 0; i < 10; ++i) {
141 rc =
zmq_send (from,
"Hello", 5, 0);
149 rc =
zmq_recv (to, &buffer,
sizeof (buffer), 0);
186 rc =
zmq_bind (backend,
"tipc://{5560,0,0}");
188 rc =
zmq_connect (frontend,
"tipc://{5560,0}@0.0.0");
192 rc =
zmq_send (backend,
"Hello", 5, 0);
194 rc =
zmq_recv (frontend, buffer, 255, 0);
216 rc =
zmq_bind (backend,
"tipc://{5560,0,0}");
220 rc =
zmq_send (backend,
"Hello", 5, 0);
222 rc =
zmq_recv (frontend, buffer, 255, 0);
void msleep(int milliseconds)
ZMQ_EXPORT int zmq_setsockopt(void *s, int option, const void *optval, size_t optvallen)
ZMQ_EXPORT void * zmq_ctx_new(void)
ZMQ_EXPORT int zmq_recv(void *s, void *buf, size_t len, int flags)
#define ZMQ_DELAY_ATTACH_ON_CONNECT
ZMQ_EXPORT void * zmq_socket(void *, int type)
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)