diff options
Diffstat (limited to 'external_libs/python/pyzmq-14.7.0/examples/bench')
14 files changed, 0 insertions, 178 deletions
diff --git a/external_libs/python/pyzmq-14.7.0/examples/bench/benchmark.py b/external_libs/python/pyzmq-14.7.0/examples/bench/benchmark.py deleted file mode 100644 index c379af9a..00000000 --- a/external_libs/python/pyzmq-14.7.0/examples/bench/benchmark.py +++ /dev/null @@ -1,25 +0,0 @@ -from timeit import default_timer as timer - -def benchmark(f, size, reps): - msg = size*'0' - t1 = timer() - for i in range(reps): - msg2 = f(msg) - assert msg == msg2 - t2 = timer() - diff = (t2-t1) - latency = diff/reps - return latency*1000000 - -kB = [1000*2**n for n in range(10)] -MB = [1000000*2**n for n in range(8)] -sizes = [1] + kB + MB - -def benchmark_set(f, sizes, reps): - latencies = [] - for size, rep in zip(sizes, reps): - print "Running benchmark with %r reps of %r bytes" % (rep, size) - lat = benchmark(f, size, rep) - latencies.append(lat) - return sizes, latencies - diff --git a/external_libs/python/pyzmq-14.7.0/examples/bench/jsonrpc_client.py b/external_libs/python/pyzmq-14.7.0/examples/bench/jsonrpc_client.py deleted file mode 100644 index 7fb6ef48..00000000 --- a/external_libs/python/pyzmq-14.7.0/examples/bench/jsonrpc_client.py +++ /dev/null @@ -1,4 +0,0 @@ -from timeit import default_timer as timer -from jsonrpclib import Server - -client = Server('http://localhost:10000') diff --git a/external_libs/python/pyzmq-14.7.0/examples/bench/jsonrpc_server.py b/external_libs/python/pyzmq-14.7.0/examples/bench/jsonrpc_server.py deleted file mode 100644 index 4500a02f..00000000 --- a/external_libs/python/pyzmq-14.7.0/examples/bench/jsonrpc_server.py +++ /dev/null @@ -1,8 +0,0 @@ -from jsonrpclib.SimpleJSONRPCServer import SimpleJSONRPCServer - -def echo(x): - return x - -server = SimpleJSONRPCServer(('localhost',10000)) -server.register_function(echo) -server.serve_forever()
\ No newline at end of file diff --git a/external_libs/python/pyzmq-14.7.0/examples/bench/latency.png b/external_libs/python/pyzmq-14.7.0/examples/bench/latency.png Binary files differdeleted file mode 100644 index bb414b59..00000000 --- a/external_libs/python/pyzmq-14.7.0/examples/bench/latency.png +++ /dev/null diff --git a/external_libs/python/pyzmq-14.7.0/examples/bench/msgs_sec.png b/external_libs/python/pyzmq-14.7.0/examples/bench/msgs_sec.png Binary files differdeleted file mode 100644 index a7b294ba..00000000 --- a/external_libs/python/pyzmq-14.7.0/examples/bench/msgs_sec.png +++ /dev/null diff --git a/external_libs/python/pyzmq-14.7.0/examples/bench/msgs_sec_log.png b/external_libs/python/pyzmq-14.7.0/examples/bench/msgs_sec_log.png Binary files differdeleted file mode 100644 index c3a361e1..00000000 --- a/external_libs/python/pyzmq-14.7.0/examples/bench/msgs_sec_log.png +++ /dev/null diff --git a/external_libs/python/pyzmq-14.7.0/examples/bench/msgs_sec_ratio.png b/external_libs/python/pyzmq-14.7.0/examples/bench/msgs_sec_ratio.png Binary files differdeleted file mode 100644 index 0a873318..00000000 --- a/external_libs/python/pyzmq-14.7.0/examples/bench/msgs_sec_ratio.png +++ /dev/null diff --git a/external_libs/python/pyzmq-14.7.0/examples/bench/plot_latency.py b/external_libs/python/pyzmq-14.7.0/examples/bench/plot_latency.py deleted file mode 100644 index f50ef295..00000000 --- a/external_libs/python/pyzmq-14.7.0/examples/bench/plot_latency.py +++ /dev/null @@ -1,84 +0,0 @@ -"""Plot latency data from messaging benchmarks. - -To generate the data for each library, I started the server and then did -the following for each client:: - - from xmlrpc_client import client - for i in range(9): - s = '0'*10**i - print s - %timeit client.echo(s) -""" - -from matplotlib.pylab import * - -rawdata = """# Data in milliseconds -Bytes JSONRPC PYRO XMLRPC pyzmq_copy pyzmq_nocopy -1 2.15 0.186 2.07 0.111 0.136 -10 2.49 0.187 1.87 0.115 0.137 -100 2.5 0.189 1.9 0.126 0.138 -1000 2.54 0.196 1.91 0.129 0.141 -10000 2.91 0.271 2.77 0.204 0.197 -100000 6.65 1.44 9.17 0.961 0.546 -1000000 50.2 15.8 81.5 8.39 2.25 -10000000 491 159 816 91.7 25.2 -100000000 5010 1560 8300 893 248 - -""" -with open('latency.csv','w') as f: - f.writelines(rawdata) - -data = csv2rec('latency.csv',delimiter='\t') - -loglog(data.bytes, data.xmlrpc*1000, label='XMLRPC') -loglog(data.bytes, data.jsonrpc*1000, label='JSONRPC') -loglog(data.bytes, data.pyro*1000, label='Pyro') -loglog(data.bytes, data.pyzmq_nocopy*1000, label='PyZMQ') -loglog(data.bytes, len(data.bytes)*[60], label='Ping') -legend(loc=2) -title('Latency') -xlabel('Number of bytes') -ylabel('Round trip latency ($\mu s$)') -grid(True) -show() -savefig('latency.png') - -clf() - -semilogx(data.bytes, 1000/data.xmlrpc, label='XMLRPC') -semilogx(data.bytes, 1000/data.jsonrpc, label='JSONRPC') -semilogx(data.bytes, 1000/data.pyro, label='Pyro') -semilogx(data.bytes, 1000/data.pyzmq_nocopy, label='PyZMQ') -legend(loc=1) -xlabel('Number of bytes') -ylabel('Message/s') -title('Message Throughput') -grid(True) -show() -savefig('msgs_sec.png') - -clf() - -loglog(data.bytes, 1000/data.xmlrpc, label='XMLRPC') -loglog(data.bytes, 1000/data.jsonrpc, label='JSONRPC') -loglog(data.bytes, 1000/data.pyro, label='Pyro') -loglog(data.bytes, 1000/data.pyzmq_nocopy, label='PyZMQ') -legend(loc=3) -xlabel('Number of bytes') -ylabel('Message/s') -title('Message Throughput') -grid(True) -show() -savefig('msgs_sec_log.png') - -clf() - -semilogx(data.bytes, data.pyro/data.pyzmq_nocopy, label="No-copy") -semilogx(data.bytes, data.pyro/data.pyzmq_copy, label="Copy") -xlabel('Number of bytes') -ylabel('Ratio throughputs') -title('PyZMQ Throughput/Pyro Throughput') -grid(True) -legend(loc=2) -show() -savefig('msgs_sec_ratio.png') diff --git a/external_libs/python/pyzmq-14.7.0/examples/bench/pyro_client.py b/external_libs/python/pyzmq-14.7.0/examples/bench/pyro_client.py deleted file mode 100644 index 5e25feb2..00000000 --- a/external_libs/python/pyzmq-14.7.0/examples/bench/pyro_client.py +++ /dev/null @@ -1,3 +0,0 @@ -import Pyro.core - -client = Pyro.core.getProxyForURI("PYROLOC://localhost:7766/echo")
\ No newline at end of file diff --git a/external_libs/python/pyzmq-14.7.0/examples/bench/pyro_server.py b/external_libs/python/pyzmq-14.7.0/examples/bench/pyro_server.py deleted file mode 100644 index a2a2446a..00000000 --- a/external_libs/python/pyzmq-14.7.0/examples/bench/pyro_server.py +++ /dev/null @@ -1,14 +0,0 @@ -import Pyro.core - -class Echo(Pyro.core.ObjBase): - def __init__(self): - Pyro.core.ObjBase.__init__(self) - def echo(self, x): - return x - -Pyro.core.initServer() -daemon=Pyro.core.Daemon() -uri=daemon.connect(Echo(),"echo") - -daemon.requestLoop() -
\ No newline at end of file diff --git a/external_libs/python/pyzmq-14.7.0/examples/bench/pyzmq_client.py b/external_libs/python/pyzmq-14.7.0/examples/bench/pyzmq_client.py deleted file mode 100644 index 9afccec3..00000000 --- a/external_libs/python/pyzmq-14.7.0/examples/bench/pyzmq_client.py +++ /dev/null @@ -1,16 +0,0 @@ -import zmq - -c = zmq.Context() -s = c.socket(zmq.REQ) -s.connect('tcp://127.0.0.1:10001') - -def echo(msg): - s.send(msg, copy=False) - msg2 = s.recv(copy=False) - return msg2 - -class Client(object): - pass - -client = Client() -client.echo = echo diff --git a/external_libs/python/pyzmq-14.7.0/examples/bench/pyzmq_server.py b/external_libs/python/pyzmq-14.7.0/examples/bench/pyzmq_server.py deleted file mode 100644 index cab00822..00000000 --- a/external_libs/python/pyzmq-14.7.0/examples/bench/pyzmq_server.py +++ /dev/null @@ -1,10 +0,0 @@ -import zmq - -c = zmq.Context() -s = c.socket(zmq.REP) -s.bind('tcp://127.0.0.1:10001') - -while True: - msg = s.recv(copy=False) - s.send(msg) - diff --git a/external_libs/python/pyzmq-14.7.0/examples/bench/xmlrpc_client.py b/external_libs/python/pyzmq-14.7.0/examples/bench/xmlrpc_client.py deleted file mode 100644 index a73ddfd7..00000000 --- a/external_libs/python/pyzmq-14.7.0/examples/bench/xmlrpc_client.py +++ /dev/null @@ -1,6 +0,0 @@ -from timeit import default_timer as timer -from xmlrpclib import ServerProxy - -client = ServerProxy('http://localhost:10002') - -
\ No newline at end of file diff --git a/external_libs/python/pyzmq-14.7.0/examples/bench/xmlrpc_server.py b/external_libs/python/pyzmq-14.7.0/examples/bench/xmlrpc_server.py deleted file mode 100644 index 24ab0190..00000000 --- a/external_libs/python/pyzmq-14.7.0/examples/bench/xmlrpc_server.py +++ /dev/null @@ -1,8 +0,0 @@ -from SimpleXMLRPCServer import SimpleXMLRPCServer - -def echo(x): - return x - -server = SimpleXMLRPCServer(('localhost',10002)) -server.register_function(echo) -server.serve_forever()
\ No newline at end of file |
