32 #define THREAD_COUNT 100 61 fprintf (stderr,
"test_shutdown_stress_tipc running...\n");
63 for (j = 0; j != 10; j++) {
72 rc =
zmq_bind (s1,
"tipc://{5560,0,0}");
78 rc = pthread_create (&threads [i], NULL,
worker, s2);
83 rc = pthread_join (threads [i], NULL);
ZMQ_EXPORT void * zmq_init(int io_threads)
ZMQ_EXPORT void * zmq_socket(void *, int type)
static void * worker(void *s)
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)