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 | 703054a805aaa32c1cf5403cd2870a4f67d5d19e (patch) | |
| tree | cc53d676010629db850370ac62dad2e221da5012 /qpid/cpp/src/tests/federation.py | |
| parent | 83c1219c3de180f4a41996b7dfb6ca4d6ee6ef6a (diff) | |
| download | qpid-python-703054a805aaa32c1cf5403cd2870a4f67d5d19e.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@935787 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp/src/tests/federation.py')
| -rwxr-xr-x | qpid/cpp/src/tests/federation.py | 18 |
1 files changed, 9 insertions, 9 deletions
diff --git a/qpid/cpp/src/tests/federation.py b/qpid/cpp/src/tests/federation.py index dce7965a63..d7f93420e9 100755 --- a/qpid/cpp/src/tests/federation.py +++ b/qpid/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 |