summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorJenkins <jenkins@review.openstack.org>2014-01-18 17:05:46 +0000
committerGerrit Code Review <review@openstack.org>2014-01-18 17:05:46 +0000
commite2c7f7b80ffec43f212035e5a5885b7ae27649fe (patch)
tree0dbbb00ba334b98033d2caf30a7289f7b18e4ff8
parent63c9917085ac4d5c99afc61e5865cb88417dcd27 (diff)
parenta1cf366a0b57050da05b3abde8a18bf5eee6ee32 (diff)
downloadpython-swiftclient-e2c7f7b80ffec43f212035e5a5885b7ae27649fe.tar.gz
Merge "Replace xrange in for loop with range"
-rw-r--r--swiftclient/multithreading.py2
-rw-r--r--tests/test_multithreading.py22
2 files changed, 13 insertions, 11 deletions
diff --git a/swiftclient/multithreading.py b/swiftclient/multithreading.py
index 512c6e1..cd3c57c 100644
--- a/swiftclient/multithreading.py
+++ b/swiftclient/multithreading.py
@@ -135,7 +135,7 @@ class QueueFunctionManager(object):
self.thread_kwargs = thread_kwargs if thread_kwargs else {}
def __enter__(self):
- for _junk in xrange(self.thread_count):
+ for _junk in range(self.thread_count):
if self.connection_maker:
thread_args = (self.connection_maker(),) + self.thread_args
else:
diff --git a/tests/test_multithreading.py b/tests/test_multithreading.py
index 5a28582..1754f5d 100644
--- a/tests/test_multithreading.py
+++ b/tests/test_multithreading.py
@@ -153,14 +153,14 @@ class TestQueueFunctionManager(ThreadTestCase):
with self.qfq as input_queue:
self.assertEqual(self.starting_thread_count + self.thread_count,
threading.active_count())
- for i in xrange(20):
+ for i in range(20):
input_queue.put('slap%d' % i)
self.assertEqual(self.starting_thread_count, threading.active_count())
self.assertEqual([], self.thread_manager.error.call_args_list)
self.assertEqual(0, self.error_counter[0])
self.assertQueueContains(self.got_items,
- set(['slap%d' % i for i in xrange(20)]))
+ set(['slap%d' % i for i in range(20)]))
self.assertQueueContains(
self.got_args_kwargs,
[(('1arg', '2arg'), {'a': 'b'})] * 20)
@@ -170,7 +170,7 @@ class TestQueueFunctionManager(ThreadTestCase):
with self.qfq as input_queue:
self.assertEqual(self.starting_thread_count + self.thread_count,
threading.active_count())
- for i in xrange(20):
+ for i in range(20):
input_queue.put('item%d' % i if i % 2 == 0 else 'go boom')
self.assertEqual(self.starting_thread_count, threading.active_count())
@@ -179,8 +179,9 @@ class TestQueueFunctionManager(ThreadTestCase):
self.assertTrue(all(['Exception: I went boom!' in s for s in
error_strs]))
self.assertEqual(10, self.error_counter[0])
- expected_items = set(['go boom'] + ['item%d' % i for i in xrange(20)
- if i % 2 == 0])
+ expected_items = set(['go boom'] +
+ ['item%d' % i for i in range(20)
+ if i % 2 == 0])
self.assertQueueContains(self.got_items, expected_items)
self.assertQueueContains(
self.got_args_kwargs,
@@ -191,7 +192,7 @@ class TestQueueFunctionManager(ThreadTestCase):
with self.qfq as input_queue:
self.assertEqual(self.starting_thread_count + self.thread_count,
threading.active_count())
- for i in xrange(20):
+ for i in range(20):
input_queue.put('item%d' % i if i % 2 == 0 else 'c boom')
self.assertEqual(self.starting_thread_count, threading.active_count())
@@ -201,8 +202,9 @@ class TestQueueFunctionManager(ThreadTestCase):
'http://192.168.22.1:80/booze 404 to much no sir!'
self.assertTrue(all([stringification in s for s in error_strs]))
self.assertEqual(10, self.error_counter[0])
- expected_items = set(['c boom'] + ['item%d' % i for i in xrange(20)
- if i % 2 == 0])
+ expected_items = set(['c boom'] +
+ ['item%d' % i for i in range(20)
+ if i % 2 == 0])
self.assertQueueContains(self.got_items, expected_items)
self.assertQueueContains(
self.got_args_kwargs,
@@ -213,14 +215,14 @@ class TestQueueFunctionManager(ThreadTestCase):
with self.qfq as input_queue:
self.assertEqual(self.starting_thread_count + self.thread_count,
threading.active_count())
- for i in xrange(20):
+ for i in range(20):
input_queue.put('item%d' % i)
self.assertEqual(self.starting_thread_count, threading.active_count())
self.assertEqual([], self.thread_manager.error.call_args_list)
self.assertEqual(0, self.error_counter[0])
self.assertQueueContains(self.got_items,
- set(['item%d' % i for i in xrange(20)]))
+ set(['item%d' % i for i in range(20)]))
self.assertQueueContains(
self.got_args_kwargs,
[(('yup, I made a connection', '1arg', '2arg'), {'a': 'b'})] * 20)