From 45414b5444db0a1f7e325c7dce92fbe84667d093 Mon Sep 17 00:00:00 2001 From: Martin Sustrik Date: Sat, 27 Feb 2010 12:23:22 +0100 Subject: python binding removed --- perf/python/Makefile.am | 1 - perf/python/local_lat.py | 49 --------------------------------- perf/python/local_thr.py | 70 ----------------------------------------------- perf/python/remote_lat.py | 61 ----------------------------------------- perf/python/remote_thr.py | 53 ----------------------------------- 5 files changed, 234 deletions(-) delete mode 100644 perf/python/Makefile.am delete mode 100644 perf/python/local_lat.py delete mode 100644 perf/python/local_thr.py delete mode 100644 perf/python/remote_lat.py delete mode 100644 perf/python/remote_thr.py (limited to 'perf/python') diff --git a/perf/python/Makefile.am b/perf/python/Makefile.am deleted file mode 100644 index c504159..0000000 --- a/perf/python/Makefile.am +++ /dev/null @@ -1 +0,0 @@ -EXTRA_DIST = *.py diff --git a/perf/python/local_lat.py b/perf/python/local_lat.py deleted file mode 100644 index bc1d804..0000000 --- a/perf/python/local_lat.py +++ /dev/null @@ -1,49 +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 . -# - -import sys -import time -import libpyzmq - -def main (): - if len (sys.argv) != 4: - print 'usage: local_lat ' - sys.exit (1) - - try: - bind_to = sys.argv [1] - message_size = int (sys.argv [2]) - roundtrip_count = int (sys.argv [3]) - except (ValueError, OverflowError), e: - print 'message-size and roundtrip-count must be integers' - sys.exit (1) - - ctx = libpyzmq.Context (1, 1); - s = libpyzmq.Socket (ctx, libpyzmq.REP) - s.bind (bind_to) - - for i in range (0, roundtrip_count): - msg = s.recv () - assert len (msg) == message_size - s.send (msg) - - time.sleep (1) - -if __name__ == "__main__": - main () diff --git a/perf/python/local_thr.py b/perf/python/local_thr.py deleted file mode 100644 index 9a45294..0000000 --- a/perf/python/local_thr.py +++ /dev/null @@ -1,70 +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 . -# - -import sys -import time -import libpyzmq - -def main (): - if len (sys.argv) != 4: - print 'usage: local_thr ' - sys.exit (1) - - try: - bind_to = sys.argv [1] - message_size = int (sys.argv [2]) - message_count = int (sys.argv [3]) - except (ValueError, OverflowError), e: - print 'message-size and message-count must be integers' - sys.exit (1) - - ctx = libpyzmq.Context (1, 1); - s = libpyzmq.Socket (ctx, libpyzmq.SUB) - - s.setsockopt (libpyzmq.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 () - assert len (msg) == message_size - - start = time.clock () - - for i in range (1, message_count): - msg = s.recv () - assert len (msg) == message_size - - end = time.clock () - - elapsed = (end - start) * 1000000 - if elapsed == 0: - elapsed = 1 - throughput = (1000000.0 * float (message_count)) / float (elapsed) - megabits = float (throughput * message_size * 8) / 1000000 - - print "message size: %.0f [B]" % (message_size, ) - print "message count: %.0f" % (message_count, ) - print "mean throughput: %.0f [msg/s]" % (throughput, ) - print "mean throughput: %.3f [Mb/s]" % (megabits, ) - -if __name__ == "__main__": - main () diff --git a/perf/python/remote_lat.py b/perf/python/remote_lat.py deleted file mode 100644 index 52ab061..0000000 --- a/perf/python/remote_lat.py +++ /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 . -# - -import sys -import time -import libpyzmq - -def main (): - if len(sys.argv) != 4: - print 'usage: remote_lat ' - sys.exit (1) - - try: - connect_to = sys.argv [1] - message_size = int (sys.argv [2]) - roundtrip_count = int (sys.argv [3]) - except (ValueError, OverflowError), e: - print 'message-size and message-count must be integers' - sys.exit (1) - - ctx = libpyzmq.Context (1, 1); - s = libpyzmq.Socket (ctx, libpyzmq.REQ) - s.connect (connect_to) - - msg = ''.join ([' ' for n in range (0, message_size)]) - - start = time.clock () - - for i in range (0, roundtrip_count): - s.send (msg) - msg = s.recv () - assert len (msg) == message_size - - end = time.clock () - - elapsed = (end - start) * 1000000 - latency = elapsed / roundtrip_count / 2 - - print "message size: %.0f [B]" % (message_size, ) - print "roundtrip count: %.0f" % (roundtrip_count, ) - print "mean latency: %.3f [us]" % (latency, ) - -if __name__ == "__main__": - main () - diff --git a/perf/python/remote_thr.py b/perf/python/remote_thr.py deleted file mode 100644 index 5fb8a2b..0000000 --- a/perf/python/remote_thr.py +++ /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 . -# - -import sys -import libpyzmq -import time - -def main (): - if len (sys.argv) != 4: - print 'usage: remote_thr ' - sys.exit (1) - - try: - connect_to = sys.argv [1] - message_size = int (sys.argv [2]) - message_count = int (sys.argv [3]) - except (ValueError, OverflowError), e: - print 'message-size and message-count must be integers' - sys.exit (1) - - ctx = libpyzmq.Context (1, 1); - s = libpyzmq.Socket (ctx, libpyzmq.PUB) - - # Add your socket options here. - # For example ZMQ_RATE, ZMQ_RECOVERY_IVL and ZMQ_MCAST_LOOP for PGM. - - s.connect (connect_to) - - msg = ''.join ([' ' for n in range (0, message_size)]) - - for i in range (0, message_count): - s.send (msg) - - time.sleep (10) - -if __name__ == "__main__": - main () -- cgit v1.2.3