37 #define TRACE_ENABLED 0 42 if (
TRACE_ENABLED) fprintf(stderr,
"Staring router mandatory HWM test ...\n");
60 rc =
zmq_bind (router,
"tcp://127.0.0.1:5560");
77 rc =
zmq_send (dealer,
"Hello", 5, 0);
79 rc =
zmq_recv (router, buffer, 255, 0);
81 assert (buffer [0] ==
'X');
86 memset(buf, 0, BUF_SIZE);
88 for(i = 0; i < 100000; ++i) {
89 if (
TRACE_ENABLED) fprintf(stderr,
"Sending message %d ...\n", i);
91 if (rc == -1 &&
zmq_errno() == EAGAIN)
break;
94 assert (rc == BUF_SIZE);
101 for(; i < 100000; ++i) {
102 if (
TRACE_ENABLED) fprintf(stderr,
"Sending message %d (part 2) ...\n", i);
104 if (rc == -1 &&
zmq_errno() == EAGAIN)
break;
107 assert (rc == BUF_SIZE);
113 if (
TRACE_ENABLED) fprintf(stderr,
"Done sending messages.\n");
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)
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)
#define ZMQ_ROUTER_MANDATORY
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)