diff options
Diffstat (limited to 'perf')
-rw-r--r-- | perf/cpp/remote_thr.cpp | 13 |
1 files changed, 1 insertions, 12 deletions
diff --git a/perf/cpp/remote_thr.cpp b/perf/cpp/remote_thr.cpp index 71a7b53..15a4ed1 100644 --- a/perf/cpp/remote_thr.cpp +++ b/perf/cpp/remote_thr.cpp @@ -22,7 +22,6 @@ #include <stdlib.h> #include <assert.h> #include <stddef.h> -#include <stdint.h> int main (int argc, char *argv []) { @@ -35,19 +34,9 @@ int main (int argc, char *argv []) size_t message_size = (size_t) atoi (argv [2]); int message_count = atoi (argv [3]); - // appl threads, io threads zmq::context_t ctx (1, 1); - zmq::socket_t s (ctx, ZMQ_PUB); - - // 10Mb/s - uint32_t rate = 10000; - s.setsockopt (ZMQ_RATE, &rate, sizeof (rate)); - - // 10s - uint32_t recovery_ivl = 10; - s.setsockopt (ZMQ_RECOVERY_IVL, &recovery_ivl, sizeof (recovery_ivl)); - + zmq::socket_t s (ctx, ZMQ_P2P); s.connect (connect_to); for (int i = 0; i != message_count; i++) { |