diff options
Diffstat (limited to 'perf/inproc_thr.cpp')
-rw-r--r-- | perf/inproc_thr.cpp | 10 |
1 files changed, 2 insertions, 8 deletions
diff --git a/perf/inproc_thr.cpp b/perf/inproc_thr.cpp index 0fa32f5..4673eba 100644 --- a/perf/inproc_thr.cpp +++ b/perf/inproc_thr.cpp @@ -48,7 +48,7 @@ static void *worker (void *ctx_) int i; zmq_msg_t msg; - s = zmq_socket (ctx_, ZMQ_PUB); + s = zmq_socket (ctx_, ZMQ_PUSH); if (!s) { printf ("error in zmq_socket: %s\n", zmq_strerror (errno)); exit (1); @@ -127,18 +127,12 @@ int main (int argc, char *argv []) return -1; } - s = zmq_socket (ctx, ZMQ_SUB); + s = zmq_socket (ctx, ZMQ_PULL); if (!s) { printf ("error in zmq_socket: %s\n", zmq_strerror (errno)); return -1; } - rc = zmq_setsockopt (s, ZMQ_SUBSCRIBE , "", 0); - if (rc != 0) { - printf ("error in zmq_setsockopt: %s\n", zmq_strerror (errno)); - return -1; - } - rc = zmq_bind (s, "inproc://thr_test"); if (rc != 0) { printf ("error in zmq_bind: %s\n", zmq_strerror (errno)); |