diff options
| author | Victor Sergeyev <vsergeyev@mirantis.com> | 2013-11-25 18:21:40 +0200 |
|---|---|---|
| committer | Sergey Shepelev <temotor@gmail.com> | 2014-03-28 10:58:14 +0400 |
| commit | 2b2f0a96b44779c5b98c851c55d70ec5e46e41f9 (patch) | |
| tree | 3f8c8cfca3d6899e4355a80668b605adb4abc5e4 /benchmarks/localhost_socket.py | |
| parent | cfdd9a922cffc2478a52e4b5b9a4dead5fe580c4 (diff) | |
| download | eventlet-2b2f0a96b44779c5b98c851c55d70ec5e46e41f9.tar.gz | |
python3 compat fixes
https://github.com/eventlet/eventlet/pull/59
Diffstat (limited to 'benchmarks/localhost_socket.py')
| -rw-r--r-- | benchmarks/localhost_socket.py | 9 |
1 files changed, 5 insertions, 4 deletions
diff --git a/benchmarks/localhost_socket.py b/benchmarks/localhost_socket.py index 777f036..aa862b1 100644 --- a/benchmarks/localhost_socket.py +++ b/benchmarks/localhost_socket.py @@ -4,6 +4,7 @@ from __future__ import print_function import time import benchmarks +from eventlet.support import six BYTES=1000 @@ -30,13 +31,13 @@ def writer(addr, socket_impl): def green_accepter(server_sock, pool): - for i in xrange(CONCURRENCY): + for i in six.moves.range(CONCURRENCY): sock, addr = server_sock.accept() pool.spawn_n(reader, sock) def heavy_accepter(server_sock, pool): - for i in xrange(CONCURRENCY): + for i in six.moves.range(CONCURRENCY): sock, addr = server_sock.accept() t = threading.Thread(None, reader, "reader thread", (sock,)) t.start() @@ -57,7 +58,7 @@ def launch_green_threads(): server_sock.listen(50) addr = ('localhost', server_sock.getsockname()[1]) pool.spawn_n(green_accepter, server_sock, pool) - for i in xrange(CONCURRENCY): + for i in six.moves.range(CONCURRENCY): pool.spawn_n(writer, addr, eventlet.green.socket.socket) pool.waitall() @@ -75,7 +76,7 @@ def launch_heavy_threads(): accepter_thread = threading.Thread(None, heavy_accepter, "accepter thread", (server_sock, threads)) accepter_thread.start() threads.append(accepter_thread) - for i in xrange(CONCURRENCY): + for i in six.moves.range(CONCURRENCY): client_thread = threading.Thread(None, writer, "writer thread", (addr, socket.socket)) client_thread.start() threads.append(client_thread) |
