summaryrefslogtreecommitdiff
path: root/perf/inproc_thr.cpp
diff options
context:
space:
mode:
authorMartin Sustrik <sustrik@250bpm.com>2011-06-19 09:22:11 +0200
committerMartin Sustrik <sustrik@250bpm.com>2011-06-19 09:22:11 +0200
commit5b77a41eafe6501a3f7cc76f2c746858036aef81 (patch)
tree6c4d0fbdde979a1ebf0ed2a3f1ea517b14d6d1e1 /perf/inproc_thr.cpp
parent4b60023b96d25571f58e50899a2717da14866e6b (diff)
Throughput tests fixed.
Introduction of subscription forwarding have broken throughput tests. This patch changes the pattern used in the tests to PUSH/PULL. Signed-off-by: Martin Sustrik <sustrik@250bpm.com>
Diffstat (limited to 'perf/inproc_thr.cpp')
-rw-r--r--perf/inproc_thr.cpp10
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));