From f83cacde528bd3d8adb1f9efad383fa61a5c9f51 Mon Sep 17 00:00:00 2001 From: "Robert G. Jakabosky" Date: Mon, 31 Dec 2012 16:15:24 -0800 Subject: [PATCH] Add more stats. --- perf/local_lat.lua | 15 +++++++++++++++ perf/remote_lat.lua | 1 + perf/thread_lat.lua | 3 +++ 3 files changed, 19 insertions(+) diff --git a/perf/local_lat.lua b/perf/local_lat.lua index d6a4ec1..027c583 100644 --- a/perf/local_lat.lua +++ b/perf/local_lat.lua @@ -35,11 +35,26 @@ s:bind(bind_to) local msg = zmq.zmq_msg_t() +local timer + for i = 1, roundtrip_count do assert(s:recv_msg(msg)) + if not timer then + timer = zmq.stopwatch_start() + end assert(msg:size() == message_size, "Invalid message size") assert(s:send_msg(msg)) end +local elapsed = timer:stop() + s:close() ctx:term() + +local latency = elapsed / roundtrip_count / 2 + +print(string.format("mean latency: %.3f [us]", latency)) +local secs = elapsed / (1000 * 1000) +print(string.format("elapsed = %f", secs)) +print(string.format("msg/sec = %f", roundtrip_count / secs)) + diff --git a/perf/remote_lat.lua b/perf/remote_lat.lua index 4376f60..ebcc680 100644 --- a/perf/remote_lat.lua +++ b/perf/remote_lat.lua @@ -54,3 +54,4 @@ local latency = elapsed / roundtrip_count / 2 print(string.format("message size: %i [B]", message_size)) print(string.format("roundtrip count: %i", roundtrip_count)) print(string.format("mean latency: %.3f [us]", latency)) + diff --git a/perf/thread_lat.lua b/perf/thread_lat.lua index 01e4451..f781e55 100644 --- a/perf/thread_lat.lua +++ b/perf/thread_lat.lua @@ -83,4 +83,7 @@ ctx:term() local latency = elapsed / roundtrip_count / 2 print(string.format("mean latency: %.3f [us]", latency)) +local secs = elapsed / (1000 * 1000) +print(string.format("elapsed = %f", secs)) +print(string.format("msg/sec = %f", roundtrip_count / secs))