From 88695aaee607e6f4db1f4fd052e2596653fb18b2 Mon Sep 17 00:00:00 2001 From: malosek Date: Fri, 11 Sep 2009 11:13:15 +0200 Subject: link libzmq with glib when congifured --with-pgm --- perf/cpp/remote_thr.cpp | 13 ++++++++++++- 1 file changed, 12 insertions(+), 1 deletion(-) (limited to 'perf/cpp') diff --git a/perf/cpp/remote_thr.cpp b/perf/cpp/remote_thr.cpp index 15a4ed1..71a7b53 100644 --- a/perf/cpp/remote_thr.cpp +++ b/perf/cpp/remote_thr.cpp @@ -22,6 +22,7 @@ #include #include #include +#include int main (int argc, char *argv []) { @@ -34,9 +35,19 @@ 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_P2P); + 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)); + s.connect (connect_to); for (int i = 0; i != message_count; i++) { -- cgit v1.2.3