diff --git a/perf/local_thr.lua b/perf/local_thr.lua index 329a16d..749e26c 100644 --- a/perf/local_thr.lua +++ b/perf/local_thr.lua @@ -19,6 +19,8 @@ -- THE SOFTWARE. require("zmq") +local socket = require"socket" +local time = socket.gettime if not arg[3] then print("usage: lua local_thr.lua ") @@ -36,22 +38,22 @@ s:bind(bind_to) local msg = s:recv() -local start_time = os.time() +local start_time = time() for i = 1, message_count - 1 do msg = s:recv() end -local end_time = os.time() +local end_time = time() s:close() ctx:term() -local elapsed = os.difftime(end_time, start_time) +local elapsed = end_time - start_time if elapsed == 0 then elapsed = 1 end local throughput = message_count / elapsed -local megabits = throughput * message_size * 8 +local megabits = throughput * message_size * 8 / 1000000 print(string.format("message size: %i [B]", message_size)) print(string.format("message count: %i", message_count)) diff --git a/perf/remote_lat.lua b/perf/remote_lat.lua index 8f36f9d..1a15228 100644 --- a/perf/remote_lat.lua +++ b/perf/remote_lat.lua @@ -19,6 +19,8 @@ -- THE SOFTWARE. require("zmq") +local socket = require"socket" +local time = socket.gettime if not arg[3] then print("usage: lua remote_lat.lua ") @@ -36,19 +38,19 @@ s:connect(connect_to) local msg = "" for i = 1, message_size do msg = msg .. "0" end -local start_time = os.time() +local start_time = time() for i = 1, roundtrip_count do s:send(msg) msg = s:recv() end -local end_time = os.time() +local end_time = time() s:close() ctx:term() -local elapsed = os.difftime(end_time, start_time) +local elapsed = end_time - start_time local latency = elapsed * 1000000 / roundtrip_count / 2 print(string.format("message size: %i [B]", message_size)) diff --git a/perf/remote_thr.lua b/perf/remote_thr.lua index 2824cd8..c617290 100644 --- a/perf/remote_thr.lua +++ b/perf/remote_thr.lua @@ -40,7 +40,7 @@ for i = 1, message_count do s:send(msg) end -os.execute("sleep " .. 10) +--os.execute("sleep " .. 10) s:close() ctx:term()