From 72fdf47d16c8d3ecd9da657b4649978e414d775c Mon Sep 17 00:00:00 2001 From: Martin Sustrik Date: Mon, 31 Aug 2009 12:50:53 +0200 Subject: python perf tests added --- perf/python/local_lat.py | 67 ++++++++++++++++++++++++++++++++++++++++++++++ perf/python/local_thr.py | 68 +++++++++++++++++++++++++++++++++++++++++++++++ perf/python/remote_lat.py | 59 ++++++++++++++++++++++++++++++++++++++++ perf/python/remote_thr.py | 50 ++++++++++++++++++++++++++++++++++ 4 files changed, 244 insertions(+) create mode 100644 perf/python/local_lat.py create mode 100644 perf/python/local_thr.py create mode 100644 perf/python/remote_lat.py create mode 100644 perf/python/remote_thr.py (limited to 'perf/python') diff --git a/perf/python/local_lat.py b/perf/python/local_lat.py new file mode 100644 index 0000000..9883dc0 --- /dev/null +++ b/perf/python/local_lat.py @@ -0,0 +1,67 @@ +# +# Copyright (c) 2007-2009 FastMQ Inc. +# +# 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 +from datetime import datetime +import libpyzmq +import time + + +def main (): + if len (sys.argv) != 5: + print 'usage: py_local_lat ' + sys.exit (1) + + try: + in_interface = sys.argv [1] + out_interface = sys.argv [2] + message_size = int (sys.argv [3]) + roundtrip_count = int (sys.argv [4]) + except (ValueError, OverflowError), e: + print 'message-size and roundtrip-count must be integers' + sys.exit (1) + + print "message size:", message_size, "[B]" + print "roundtrip count:", roundtrip_count + + z = libpyzmq.Zmq () + context = z.context (1,1); + + in_socket = z.socket (context, libpyzmq.ZMQ_SUB) + out_socket = z.socket (context, libpyzmq.ZMQ_PUB) + + z.bind (in_socket, addr = in_interface) + z.bind (out_socket, addr = out_interface) + + msg_out = z.init_msg_data (string_msg, type) + + start = datetime.now () + for i in range (0, roundtrip_count): + z.send (out_socket, msg_out, True) + list = z.receive (in_socket, True) + msg_in = list [1] + assert len(msg_in) == message_size + end = datetime.now () + + delta = end - start + delta_us = delta.seconds * 1000000 + delta.microseconds + print 'Your average latency is', delta_us / roundtrip_count, ' [us]' + +if __name__ == "__main__": + main () diff --git a/perf/python/local_thr.py b/perf/python/local_thr.py new file mode 100644 index 0000000..9b199df --- /dev/null +++ b/perf/python/local_thr.py @@ -0,0 +1,68 @@ +# +# Copyright (c) 2007-2009 FastMQ Inc. +# +# 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 +from datetime import datetime +import libpyzmq + +def main (): + if len (sys.argv) != 4: + print ('usage: py_local_thr ' + + '') + sys.exit (1) + + try: + 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) + + print "message size:", message_size, "[B]" + print "message count:", message_count + + z = libpyzmq.Zmq () + + context = z.context (1,1) + in_socket = z.socket (context, libpyzmq.ZMQ_SUB) + z.connect (in_socketaddr = sys.argv [1]) + + + list = z.receive (in_socket, True) + msg = list [1] + assert len(msg) == message_size + start = datetime.now () + for i in range (1, message_count): + list = z.receive (in_socket, True) + msg = list [1] + assert len(msg) == message_size + end = datetime.now() + + delta = end - start + delta_us = delta.seconds * 1000000 + delta.microseconds + if delta_us == 0: + delta_us = 1 + message_thr = (1000000.0 * float (message_count)) / float (delta_us) + megabit_thr = (message_thr * float (message_size) * 8.0) / 1000000.0; + + print "Your average throughput is %.0f [msg/s]" % (message_thr, ) + print "Your average throughput is %.2f [Mb/s]" % (megabit_thr, ) + +if __name__ == "__main__": + main () diff --git a/perf/python/remote_lat.py b/perf/python/remote_lat.py new file mode 100644 index 0000000..ac73595 --- /dev/null +++ b/perf/python/remote_lat.py @@ -0,0 +1,59 @@ +# +# Copyright (c) 2007-2009 FastMQ Inc. +# +# 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 +from datetime import datetime +import libpyzmq +import time + + +def main (): + if len(sys.argv) != 5: + print ('usage: py_remote_lat ' + + ' ') + sys.exit (1) + + try: + message_size = int (sys.argv [3]) + roundtrip_count = int (sys.argv [4]) + except (ValueError, OverflowError), e: + print 'message-size and message-count must be integers' + sys.exit (1) + + z = libpyzmq.Zmq () + + context = z.context (1,1) + + in_socket = z.socket (context, libpyzmq.ZMQ_SUB) + out_socket = z.socket (context, libpyzmq.ZMQ_PUB) + + z.connect (in_socket, addr = in_interface) + z.connect (out_socket, addr = out_interface) + + for i in range (0, roundtrip_count): + list = z.receive (in_socket, True) + message = list [1] + z.send (out_socket, message, True) + + time.sleep (2) + + +if __name__ == "__main__": + main () + diff --git a/perf/python/remote_thr.py b/perf/python/remote_thr.py new file mode 100644 index 0000000..a4f2b66 --- /dev/null +++ b/perf/python/remote_thr.py @@ -0,0 +1,50 @@ +# +# Copyright (c) 2007-2009 FastMQ Inc. +# +# 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 +from datetime import datetime +import libpyzmq +import time + +def main (): + if len (sys.argv) != 4: + print 'usage: py_remote_thr ' + sys.exit (1) + + try: + 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) + + z = libpyzmq.Zmq () + context = z.context (1,1); + out_socket = z.socket (context, libpyzmq.ZMQ_PUB) + z.bind (out_socket, addr = sys.argv [1]) + + msg = z.init_msg_data (string_msg, type) + + for i in range (0, message_count): + z.send (out_socket, msg, True) + + time.sleep (2) + +if __name__ == "__main__": + main () -- cgit v1.2.3