32 #define THREAD_COUNT 100 59 for (j = 0; j != 10; j++) {
69 rc =
zmq_bind (s1,
"tcp://127.0.0.1:5560");
ZMQ_EXPORT void * zmq_ctx_new(void)
void setup_test_environment(void)
static void worker(void *s)
ZMQ_EXPORT void * zmq_socket(void *, int type)
ZMQ_EXPORT void zmq_threadclose(void *thread)
ZMQ_EXPORT int zmq_ctx_set(void *context, int option, int optval)
ZMQ_EXPORT int zmq_connect(void *s, const char *addr)
ZMQ_EXPORT int zmq_close(void *s)
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)