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/remote_thr.py | 50 +++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 50 insertions(+) create mode 100644 perf/python/remote_thr.py (limited to 'perf/python/remote_thr.py') 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