36 for (
int count = 0; count < 100000; count++) {
37 int rc =
zmq_send (client, &data, 1, 0);
41 int rc =
zmq_send (client, &data, 1, 0);
52 int rc =
zmq_bind (server,
"tcp://127.0.0.1:5560");
59 assert (thread_safe == 1);
67 int threads_completed = 0;
68 while (threads_completed < 2) {
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)
void client_thread(void *client)
ZMQ_EXPORT void * zmq_socket(void *, int type)
ZMQ_EXPORT void zmq_threadclose(void *thread)
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_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 void * zmq_threadstart(zmq_thread_fn *func, void *arg)