34 const char *bind_to =
"tcp://127.0.0.1:5555";
59 rc =
zmq_send(s_out, (
void*)&j,
sizeof(
int), 0);
61 printf (
"error in zmq_sendmsg: %s\n",
zmq_strerror (errno));
67 int payload_recved = 0;
68 rc =
zmq_recv (s_in, (
void*)&payload_recved,
sizeof(
int), 0);
70 assert (payload_recved == message_count - 1);
void msleep(int milliseconds)
ZMQ_EXPORT int zmq_setsockopt(void *s, int option, const void *optval, size_t optvallen)
ZMQ_EXPORT void * zmq_init(int io_threads)
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_connect(void *s, const char *addr)
ZMQ_EXPORT int zmq_close(void *s)
ZMQ_EXPORT const char * zmq_strerror(int errnum)
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)