From 85f4412ea04805e24cdfc1cdecb0d922eff3f6ad Mon Sep 17 00:00:00 2001 From: "Robert G. Jakabosky" Date: Sat, 26 Feb 2011 20:59:54 -0800 Subject: [PATCH] Add multipart benchmark/test code. --- perf/local_multipart.lua | 78 +++++++++++++++++++++++++++++++++++++++ perf/remote_multipart.lua | 55 +++++++++++++++++++++++++++ 2 files changed, 133 insertions(+) create mode 100644 perf/local_multipart.lua create mode 100644 perf/remote_multipart.lua diff --git a/perf/local_multipart.lua b/perf/local_multipart.lua new file mode 100644 index 0000000..8a98e82 --- /dev/null +++ b/perf/local_multipart.lua @@ -0,0 +1,78 @@ +-- Copyright (c) 2010 Aleksey Yeschenko +-- +-- Permission is hereby granted, free of charge, to any person obtaining a copy +-- of this software and associated documentation files (the "Software"), to deal +-- in the Software without restriction, including without limitation the rights +-- to use, copy, modify, merge, publish, distribute, sublicense, and/or sell +-- copies of the Software, and to permit persons to whom the Software is +-- furnished to do so, subject to the following conditions: +-- +-- The above copyright notice and this permission notice shall be included in +-- all copies or substantial portions of the Software. +-- +-- THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR +-- IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, +-- FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE +-- AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER +-- LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, +-- OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN +-- THE SOFTWARE. + +if not arg[3] then + print("usage: lua local_thr.lua []") + os.exit() +end + +local bind_to = arg[1] +local message_size = tonumber(arg[2]) +local message_count = tonumber(arg[3]) +local mod = arg[4] or "zmq" +if mod == 'disable_ffi' then + disable_ffi = true + mod = 'zmq' +end + +local zmq = require(mod) + +local socket = require"socket" +local time = socket.gettime + +local ctx = zmq.init(1) +local s = ctx:socket(zmq.PULL) +--s:setopt(zmq.SUBSCRIBE, ""); +s:bind(bind_to) + +local function recv_msg(s,msg) + assert(s:recv_msg(msg)) + assert(msg:size() == message_size/2, "Invalid message size") + assert(s:getopt(zmq.RCVMORE) == 1, "Message not multipart") + assert(s:recv_msg(msg)) + assert(msg:size() == message_size/2, "Invalid message size") + assert(s:getopt(zmq.RCVMORE) == 0, "Message has too many parts") +end + +local msg +msg = zmq.zmq_msg_t() +recv_msg(s, msg) + +local start_time = time() + +for i = 1, message_count - 1 do + recv_msg(s, msg) +end + +local end_time = time() + +s:close() +ctx:term() + +local elapsed = end_time - start_time +if elapsed == 0 then elapsed = 1 end + +local throughput = message_count / elapsed +local megabits = throughput * message_size * 8 / 1000000 + +print(string.format("message size: %i [B]", message_size)) +print(string.format("message count: %i", message_count)) +print(string.format("mean throughput: %i [msg/s]", throughput)) +print(string.format("mean throughput: %.3f [Mb/s]", megabits)) diff --git a/perf/remote_multipart.lua b/perf/remote_multipart.lua new file mode 100644 index 0000000..f7f7168 --- /dev/null +++ b/perf/remote_multipart.lua @@ -0,0 +1,55 @@ +-- Copyright (c) 2010 Aleksey Yeschenko +-- +-- Permission is hereby granted, free of charge, to any person obtaining a copy +-- of this software and associated documentation files (the "Software"), to deal +-- in the Software without restriction, including without limitation the rights +-- to use, copy, modify, merge, publish, distribute, sublicense, and/or sell +-- copies of the Software, and to permit persons to whom the Software is +-- furnished to do so, subject to the following conditions: +-- +-- The above copyright notice and this permission notice shall be included in +-- all copies or substantial portions of the Software. +-- +-- THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR +-- IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, +-- FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE +-- AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER +-- LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, +-- OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN +-- THE SOFTWARE. + +if not arg[3] then + print("usage: lua remote_thr.lua []") + os.exit() +end + +local connect_to = arg[1] +local message_size = tonumber(arg[2]) +local message_count = tonumber(arg[3]) +local mod = arg[4] or "zmq" +if mod == 'disable_ffi' then + disable_ffi = true + mod = 'zmq' +end + +local zmq = require(mod) +local z_SNDMORE = zmq.SNDMORE + +local ctx = zmq.init(1) +local s = ctx:socket(zmq.PUSH) +s:connect(connect_to) + +local data = ("0"):rep(message_size/2) +local msg = zmq.zmq_msg_t.init_size(message_size/2) + +for i = 1, message_count do + msg:set_data(data) + assert(s:send_msg(msg, z_SNDMORE)) + msg:set_data(data) + assert(s:send_msg(msg)) +end + +os.execute("sleep " .. 1) + +s:close() +ctx:term()