generic-library/libzmq
1
0
Fork 0
mirror of https://github.com/zeromq/libzmq.git synced 2025-02-21 22:56:22 +01:00
Code Issues Projects Releases Wiki Activity

Throughput tests fixed.

Browse Source 
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>
This commit is contained in:
Martin Sustrik 2011-06-19 09:22:11 +02:00
parent 4b60023b96
commit 5b77a41eaf
3 changed files with 4 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
perf/inproc_thr.cpp
View File

@ -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));

8
perf/local_thr.cpp
View File

@ -52,18 +52,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;
}
// Add your socket options here.
// For example ZMQ_RATE, ZMQ_RECOVERY_IVL and ZMQ_MCAST_LOOP for PGM.

4
perf/remote_thr.cpp
View File

@ -50,7 +50,7 @@ int main (int argc, char *argv [])
return -1;
}
s = zmq_socket (ctx, ZMQ_PUB);
s = zmq_socket (ctx, ZMQ_PUSH);
if (!s) {
printf ("error in zmq_socket: %s\n", zmq_strerror (errno));
return -1;
@ -88,8 +88,6 @@ int main (int argc, char *argv [])
}
}
zmq_sleep (2);
rc = zmq_close (s);
if (rc != 0) {
printf ("error in zmq_close: %s\n", zmq_strerror (errno));