summaryrefslogtreecommitdiff
path: root/benchmarks/localhost_socket.py
diff options
context:
space:
mode:
authorVictor Sergeyev <vsergeyev@mirantis.com>2013-11-25 18:21:40 +0200
committerSergey Shepelev <temotor@gmail.com>2014-03-28 10:58:14 +0400
commit2b2f0a96b44779c5b98c851c55d70ec5e46e41f9 (patch)
tree3f8c8cfca3d6899e4355a80668b605adb4abc5e4 /benchmarks/localhost_socket.py
parentcfdd9a922cffc2478a52e4b5b9a4dead5fe580c4 (diff)
downloadeventlet-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.py9
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)