diff options
| author | Kenneth Anthony Giusti <kgiusti@apache.org> | 2010-04-20 01:32:25 +0000 |
|---|---|---|
| committer | Kenneth Anthony Giusti <kgiusti@apache.org> | 2010-04-20 01:32:25 +0000 |
| commit | 48bf49d3cb0fa77f19b440c6159b573e85fbebd3 (patch) | |
| tree | 54c85d3c262e42e3281957e803e208becc4945fe /cpp/src | |
| parent | c9a75bd767ae8ca218d306bceaa1d7acc1826fc2 (diff) | |
| download | qpid-python-48bf49d3cb0fa77f19b440c6159b573e85fbebd3.tar.gz | |
QPID-2487: remove call to reversed() - not in pre2.4 python, increased bind timeouts
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@935787 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src')
| -rwxr-xr-x | cpp/src/tests/federation.py | 18 |
1 files changed, 9 insertions, 9 deletions
diff --git a/cpp/src/tests/federation.py b/cpp/src/tests/federation.py index dce7965a63..d7f93420e9 100755 --- a/cpp/src/tests/federation.py +++ b/cpp/src/tests/federation.py @@ -949,11 +949,11 @@ class FederationTests(TestBase010): queue_3 = self._brokers[3].client_session.incoming("f1") # wait until the binding key has propagated to each broker (twice at - # broker B1) + # broker B1). Work backwards from binding brokers. binding_counts = [1, 2, 1, 1] self.assertEqual(len(binding_counts), len(exchanges), "Update Test!") - for i in reversed(range(len(exchanges))): + for i in range(3,-1,-1): retries = 0 exchanges[i].update() while exchanges[i].bindingCount < binding_counts[i]: @@ -961,7 +961,7 @@ class FederationTests(TestBase010): self.failIfEqual(retries, 10, "binding failed to propagate to broker %d" % i) - sleep(1) + sleep(3) exchanges[i].update() # send 10 msgs from B0 @@ -1189,11 +1189,11 @@ class FederationTests(TestBase010): queue_3 = self._brokers[3].client_session.incoming("f1") # wait until the binding key has propagated to each broker (twice at - # broker B1) + # broker B1). Work backwards from binding brokers. binding_counts = [1, 2, 1, 1] self.assertEqual(len(binding_counts), len(exchanges), "Update Test!") - for i in reversed(range(len(exchanges))): + for i in range(3,-1,-1): retries = 0 exchanges[i].update() while exchanges[i].bindingCount < binding_counts[i]: @@ -1201,7 +1201,7 @@ class FederationTests(TestBase010): self.failIfEqual(retries, 10, "binding failed to propagate to broker %d" % i) - sleep(1) + sleep(3) exchanges[i].update() # send 10 msgs from B0 @@ -1429,11 +1429,11 @@ class FederationTests(TestBase010): queue_3 = self._brokers[3].client_session.incoming("f1") # wait until the binding key has propagated to each broker (twice at - # broker B1) + # broker B1). Work backwards from binding brokers. binding_counts = [1, 2, 1, 1] self.assertEqual(len(binding_counts), len(exchanges), "Update Test!") - for i in reversed(range(len(exchanges))): + for i in range(3,-1,-1): retries = 0 exchanges[i].update() while exchanges[i].bindingCount < binding_counts[i]: @@ -1441,7 +1441,7 @@ class FederationTests(TestBase010): self.failIfEqual(retries, 10, "binding failed to propagate to broker %d" % i) - sleep(1) + sleep(3) exchanges[i].update() # send 10 msgs from B0 |