diff options
Diffstat (limited to 'perf')
-rw-r--r-- | perf/Makefile.am | 8 | ||||
-rw-r--r-- | perf/ruby/Makefile.am | 1 | ||||
-rw-r--r-- | perf/ruby/local_lat.rb | 41 | ||||
-rw-r--r-- | perf/ruby/local_thr.rb | 61 | ||||
-rw-r--r-- | perf/ruby/remote_lat.rb | 53 | ||||
-rw-r--r-- | perf/ruby/remote_thr.rb | 45 |
6 files changed, 2 insertions, 207 deletions
diff --git a/perf/Makefile.am b/perf/Makefile.am index 96dc19e..72d24be 100644 --- a/perf/Makefile.am +++ b/perf/Makefile.am @@ -10,9 +10,5 @@ if BUILD_JAVA PERF_DIR_J = java endif -if BUILD_RUBY -PERF_DIR_R = ruby -endif - -SUBDIRS = $(PERF_DIR_C) $(PERF_DIR_CPP) $(PERF_DIR_J) $(PERF_DIR_R) -DIST_SUBDIRS = c cpp java ruby +SUBDIRS = $(PERF_DIR_C) $(PERF_DIR_CPP) $(PERF_DIR_J) +DIST_SUBDIRS = c cpp java diff --git a/perf/ruby/Makefile.am b/perf/ruby/Makefile.am deleted file mode 100644 index 6bcd5da..0000000 --- a/perf/ruby/Makefile.am +++ /dev/null @@ -1 +0,0 @@ -EXTRA_DIST = *.rb diff --git a/perf/ruby/local_lat.rb b/perf/ruby/local_lat.rb deleted file mode 100644 index b27e8bc..0000000 --- a/perf/ruby/local_lat.rb +++ /dev/null @@ -1,41 +0,0 @@ -# -# Copyright (c) 2007-2010 iMatix Corporation -# -# This file is part of 0MQ. -# -# 0MQ is free software; you can redistribute it and/or modify it under -# the terms of the Lesser GNU General Public License as published by -# the Free Software Foundation; either version 3 of the License, or -# (at your option) any later version. -# -# 0MQ is distributed in the hope that it will be useful, -# but WITHOUT ANY WARRANTY; without even the implied warranty of -# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the -# Lesser GNU General Public License for more details. -# -# You should have received a copy of the Lesser GNU General Public License -# along with this program. If not, see <http://www.gnu.org/licenses/>. - -require 'librbzmq' - -if ARGV.length != 3 - puts "usage: local_lat <bind-to> <message-size> <roundtrip-count>" - Process.exit -end - -bind_to = ARGV[0] -message_size = ARGV[1].to_i -roundtrip_count = ARGV[2].to_i - -ctx = ZMQ::Context.new(1, 1, 0) -s = ZMQ::Socket.new(ctx, ZMQ::REP); -s.bind(bind_to); - -for i in 0...roundtrip_count do - msg = s.recv(0) - s.send(msg, 0) -end - -sleep 1 - - diff --git a/perf/ruby/local_thr.rb b/perf/ruby/local_thr.rb deleted file mode 100644 index b20ca60..0000000 --- a/perf/ruby/local_thr.rb +++ /dev/null @@ -1,61 +0,0 @@ -# -# Copyright (c) 2007-2010 iMatix Corporation -# -# This file is part of 0MQ. -# -# 0MQ is free software; you can redistribute it and/or modify it under -# the terms of the Lesser GNU General Public License as published by -# the Free Software Foundation; either version 3 of the License, or -# (at your option) any later version. -# -# 0MQ is distributed in the hope that it will be useful, -# but WITHOUT ANY WARRANTY; without even the implied warranty of -# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the -# Lesser GNU General Public License for more details. -# -# You should have received a copy of the Lesser GNU General Public License -# along with this program. If not, see <http://www.gnu.org/licenses/>. - -require 'librbzmq' - -if ARGV.length != 3 - puts "usage: local_thr <bind-to> <message-size> <message-count>" - Process.exit -end - -bind_to = ARGV[0] -message_size = ARGV[1].to_i -message_count = ARGV[2].to_i - -ctx = ZMQ::Context.new(1, 1, 0) -s = ZMQ::Socket.new(ctx, ZMQ::SUB); -s.setsockopt(ZMQ::SUBSCRIBE, ""); - -# Add your socket options here. -# For example ZMQ_RATE, ZMQ_RECOVERY_IVL and ZMQ_MCAST_LOOP for PGM. - -s.bind(bind_to); - -msg = s.recv(0) - -start_time = Time.now - -for i in 1...message_count.to_i do - msg = s.recv(0) -end - -end_time = Time.now - -elapsed = (end_time.to_f - start_time.to_f) * 1000000 -if elapsed == 0 - elapsed = 1 -end - -throughput = message_count * 1000000 / elapsed -megabits = throughput * message_size * 8 / 1000000 - -puts "message size: %i [B]" % message_size -puts "message count: %i" % message_count -puts "mean throughput: %i [msg/s]" % throughput -puts "mean throughput: %.3f [Mb/s]" % megabits - diff --git a/perf/ruby/remote_lat.rb b/perf/ruby/remote_lat.rb deleted file mode 100644 index ea8cf8e..0000000 --- a/perf/ruby/remote_lat.rb +++ /dev/null @@ -1,53 +0,0 @@ -# -# Copyright (c) 2007-2010 iMatix Corporation -# -# This file is part of 0MQ. -# -# 0MQ is free software; you can redistribute it and/or modify it under -# the terms of the Lesser GNU General Public License as published by -# the Free Software Foundation; either version 3 of the License, or -# (at your option) any later version. -# -# 0MQ is distributed in the hope that it will be useful, -# but WITHOUT ANY WARRANTY; without even the implied warranty of -# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the -# Lesser GNU General Public License for more details. -# -# You should have received a copy of the Lesser GNU General Public License -# along with this program. If not, see <http://www.gnu.org/licenses/>. - -require 'librbzmq' - -if ARGV.length != 3 - puts "usage: remote_lat <connect-to> <message-size> <roundtrip-count>" - Process.exit -end - -connect_to = ARGV[0] -message_size = ARGV[1].to_i -roundtrip_count = ARGV[2].to_i - -ctx = ZMQ::Context.new(1, 1, 0) -s = ZMQ::Socket.new(ctx, ZMQ::REQ); -s.connect(connect_to); - -msg = "#{'0'*message_size}" - -start_time = Time.now - -for i in 0...roundtrip_count do - s.send(msg, 0) - msg = s.recv(0) -end - -end_time = Time.now - -elapsed = (end_time.to_f - start_time.to_f) * 1000000 -latency = elapsed / roundtrip_count / 2 - -puts "message size: %i [B]" % message_size -puts "roundtrip count: %i" % roundtrip_count -puts "mean latency: %.3f [us]" % latency - - - diff --git a/perf/ruby/remote_thr.rb b/perf/ruby/remote_thr.rb deleted file mode 100644 index b2dada6..0000000 --- a/perf/ruby/remote_thr.rb +++ /dev/null @@ -1,45 +0,0 @@ -# -# Copyright (c) 2007-2010 iMatix Corporation -# -# This file is part of 0MQ. -# -# 0MQ is free software; you can redistribute it and/or modify it under -# the terms of the Lesser GNU General Public License as published by -# the Free Software Foundation; either version 3 of the License, or -# (at your option) any later version. -# -# 0MQ is distributed in the hope that it will be useful, -# but WITHOUT ANY WARRANTY; without even the implied warranty of -# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the -# Lesser GNU General Public License for more details. -# -# You should have received a copy of the Lesser GNU General Public License -# along with this program. If not, see <http://www.gnu.org/licenses/>. - -require 'librbzmq' - -if ARGV.length != 3 - puts "usage: remote_thr <connect-to> <message-size> <message-count>" - Process.exit -end - -connect_to = ARGV[0] -message_size = ARGV[1].to_i -message_count = ARGV[2].to_i - -ctx = ZMQ::Context.new(1, 1, 0) -s = ZMQ::Socket.new(ctx, ZMQ::PUB); - -# Add your socket options here. -# For example ZMQ_RATE, ZMQ_RECOVERY_IVL and ZMQ_MCAST_LOOP for PGM. - -s.connect(connect_to); - -msg = "#{'0'*message_size}" - -for i in 0...message_count do - s.send(msg, 0) -end - -sleep 10 - |