diff options
| -rw-r--r-- | perf/python/local_lat.py | 67 | ||||
| -rw-r--r-- | perf/python/local_thr.py | 68 | ||||
| -rw-r--r-- | perf/python/remote_lat.py | 59 | ||||
| -rw-r--r-- | perf/python/remote_thr.py | 50 |
4 files changed, 244 insertions, 0 deletions
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 <http://www.gnu.org/licenses/>. +# + +import sys +from datetime import datetime +import libpyzmq +import time + + +def main (): + if len (sys.argv) != 5: + print 'usage: py_local_lat <in-interface> <out-interface> <message-size> <roundtrip-count>' + 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 <http://www.gnu.org/licenses/>. +# + +import sys +from datetime import datetime +import libpyzmq + +def main (): + if len (sys.argv) != 4: + print ('usage: py_local_thr <in_interface> <message-size> ' + + '<message-count>') + 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 <http://www.gnu.org/licenses/>. +# + +import sys +from datetime import datetime +import libpyzmq +import time + + +def main (): + if len(sys.argv) != 5: + print ('usage: py_remote_lat <in-interface> ' + + '<out-interface> <message-size> <roundtrip-count>') + 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 <http://www.gnu.org/licenses/>. +# + +import sys +from datetime import datetime +import libpyzmq +import time + +def main (): + if len (sys.argv) != 4: + print 'usage: py_remote_thr <out-interface> <message-size> <message-count>' + 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 () |