From 9b7442210d74846fac84e5e86236f0f2fc21886c Mon Sep 17 00:00:00 2001 From: Kenneth Anthony Giusti Date: Thu, 28 Apr 2011 12:25:59 +0000 Subject: 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 --- cpp/src/tests/queue_flow_limit_tests.py | 16 +++++++--------- 1 file changed, 7 insertions(+), 9 deletions(-) (limited to 'cpp/src/tests/queue_flow_limit_tests.py') 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) -- cgit v1.2.1