diff options
| author | Ken Giusti <kgiusti@apache.org> | 2011-04-28 12:25:59 +0000 |
|---|---|---|
| committer | Ken Giusti <kgiusti@apache.org> | 2011-04-28 12:25:59 +0000 |
| commit | 60f12089bd824585d3434ed4ee8fbdd4f01c638c (patch) | |
| tree | 6269e80bae30d0bf18f2ad72b8943f14f3bcaf6a /cpp/src/tests/queue_flow_limit_tests.py | |
| parent | 5e9ecc01efc48aa736216660015effac6d80f6d7 (diff) | |
| download | qpid-python-60f12089bd824585d3434ed4ee8fbdd4f01c638c.tar.gz | |
QPID-3076: enable flow control for clustered broker configurations.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1097432 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/tests/queue_flow_limit_tests.py')
| -rw-r--r-- | cpp/src/tests/queue_flow_limit_tests.py | 16 |
1 files changed, 7 insertions, 9 deletions
diff --git a/cpp/src/tests/queue_flow_limit_tests.py b/cpp/src/tests/queue_flow_limit_tests.py index bdd2a21b78..6639cdc393 100644 --- a/cpp/src/tests/queue_flow_limit_tests.py +++ b/cpp/src/tests/queue_flow_limit_tests.py @@ -24,7 +24,7 @@ from qpid import datatypes, messaging from qpid.messaging import Message, Empty from threading import Thread, Lock from logging import getLogger -from time import sleep +from time import sleep, time from os import environ, popen class QueueFlowLimitTests(TestBase010): @@ -145,11 +145,10 @@ class QueueFlowLimitTests(TestBase010): totalMsgs = 1213 + 797 + 331 # wait until flow control is active - count = 0 + deadline = time() + 10 while self.qmf.getObjects(_objectId=oid)[0].flowStopped == False and \ - count < 10: - sleep(1); - count += 1; + time() < deadline: + pass self.failUnless(self.qmf.getObjects(_objectId=oid)[0].flowStopped) depth = self.qmf.getObjects(_objectId=oid)[0].msgDepth self.assertGreater(depth, 373) @@ -200,11 +199,10 @@ class QueueFlowLimitTests(TestBase010): totalBytes = 439 + 631 + 823 # wait until flow control is active - count = 0 + deadline = time() + 10 while self.qmf.getObjects(_objectId=oid)[0].flowStopped == False and \ - count < 10: - sleep(1); - count += 1; + time() < deadline: + pass self.failUnless(self.qmf.getObjects(_objectId=oid)[0].flowStopped) self.assertGreater(self.qmf.getObjects(_objectId=oid)[0].byteDepth, 351133) |