summaryrefslogtreecommitdiff
path: root/tests/tpool_test.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 /tests/tpool_test.py
parentcfdd9a922cffc2478a52e4b5b9a4dead5fe580c4 (diff)
downloadeventlet-2b2f0a96b44779c5b98c851c55d70ec5e46e41f9.tar.gz
python3 compat fixes
https://github.com/eventlet/eventlet/pull/59
Diffstat (limited to 'tests/tpool_test.py')
-rw-r--r--tests/tpool_test.py21
1 files changed, 13 insertions, 8 deletions
diff --git a/tests/tpool_test.py b/tests/tpool_test.py
index 6338e4c..5423b54 100644
--- a/tests/tpool_test.py
+++ b/tests/tpool_test.py
@@ -23,19 +23,24 @@ import gc
from tests import skipped, skip_with_pyevent, LimitedTestCase, main
from eventlet import tpool, debug
+from eventlet.support import six
import eventlet
+
one = 1
two = 2
three = 3
none = None
+
def noop():
pass
+
def raise_exception():
raise RuntimeError("hi")
+
class TestTpool(LimitedTestCase):
def setUp(self):
super(TestTpool, self).setUp()
@@ -144,24 +149,24 @@ class TestTpool(LimitedTestCase):
@skip_with_pyevent
def test_wrap_iterator(self):
self.reset_timeout(2)
- prox = tpool.Proxy(xrange(10))
+ prox = tpool.Proxy(range(10))
result = []
for i in prox:
result.append(i)
- self.assertEquals(range(10), result)
+ self.assertEquals(list(range(10)), result)
@skip_with_pyevent
def test_wrap_iterator2(self):
self.reset_timeout(5) # might take a while due to imprecise sleeping
def foo():
import time
- for x in xrange(2):
+ for x in range(2):
yield x
time.sleep(0.001)
counter = [0]
def tick():
- for i in xrange(20000):
+ for i in six.moves.range(20000):
counter[0]+=1
if counter[0] % 20 == 0:
eventlet.sleep(0.0001)
@@ -296,7 +301,7 @@ class TpoolLongTests(LimitedTestCase):
def sender_loop(loopnum):
obj = tpool.Proxy(Dummy())
count = 100
- for n in xrange(count):
+ for n in six.moves.range(count):
eventlet.sleep(random.random()/200.0)
now = time.time()
token = loopnum * count + n
@@ -306,7 +311,7 @@ class TpoolLongTests(LimitedTestCase):
cnt = 10
pile = eventlet.GreenPile(cnt)
- for i in xrange(cnt):
+ for i in six.moves.range(cnt):
pile.spawn(sender_loop,i)
results = list(pile)
self.assertEquals(len(results), cnt)
@@ -339,14 +344,14 @@ from eventlet.tpool import execute
tpool.execute(noop) # get it started
gc.collect()
initial_objs = len(gc.get_objects())
- for i in xrange(10):
+ for i in range(10):
self.assertRaises(RuntimeError, tpool.execute, raise_exception)
gc.collect()
middle_objs = len(gc.get_objects())
# some objects will inevitably be created by the previous loop
# now we test to ensure that running the loop an order of
# magnitude more doesn't generate additional objects
- for i in xrange(100):
+ for i in six.moves.range(100):
self.assertRaises(RuntimeError, tpool.execute, raise_exception)
first_created = middle_objs - initial_objs
gc.collect()