You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by kg...@apache.org on 2013/07/24 18:18:40 UTC
svn commit: r1506613 -
/qpid/trunk/qpid/cpp/src/tests/queue_flow_limit_tests.py
Author: kgiusti
Date: Wed Jul 24 16:18:39 2013
New Revision: 1506613
URL: http://svn.apache.org/r1506613
Log:
QPID-5015: increase timeouts for queue flow tests
Modified:
qpid/trunk/qpid/cpp/src/tests/queue_flow_limit_tests.py
Modified: qpid/trunk/qpid/cpp/src/tests/queue_flow_limit_tests.py
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/tests/queue_flow_limit_tests.py?rev=1506613&r1=1506612&r2=1506613&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/tests/queue_flow_limit_tests.py (original)
+++ qpid/trunk/qpid/cpp/src/tests/queue_flow_limit_tests.py Wed Jul 24 16:18:39 2013
@@ -27,6 +27,8 @@ from os import environ, popen
class QueueFlowLimitTests(TestBase010):
+ _timeout = 100
+
def __getattr__(self, name):
if name == "assertGreater":
return lambda a, b: self.failUnless(a > b)
@@ -156,7 +158,7 @@ class QueueFlowLimitTests(TestBase010):
totalMsgs = 1213 + 797 + 331
# wait until flow control is active
- deadline = time() + 10
+ deadline = time() + self._timeout
while (not self.qmf.getObjects(_objectId=oid)[0].flowStopped) and \
time() < deadline:
pass
@@ -209,7 +211,7 @@ class QueueFlowLimitTests(TestBase010):
totalMsgs = 1699 + 1129 + 881
# wait until flow control is active
- deadline = time() + 10
+ deadline = time() + self._timeout
while (not self.qmf.getObjects(_objectId=oid)[0].flowStopped) and \
time() < deadline:
pass
@@ -255,7 +257,7 @@ class QueueFlowLimitTests(TestBase010):
# fill up the queue, waiting until flow control is active
sndr1 = self._start_qpid_send(testq.mgmt.name, count=testq.sendCount, content=testq.content)
- deadline = time() + 10
+ deadline = time() + self._timeout
while (not testq.mgmt.flowStopped) and time() < deadline:
testq.mgmt.update()
@@ -357,7 +359,7 @@ class QueueFlowLimitTests(TestBase010):
sender = BlockedSender(self, "kill-q", count=100)
# wait for flow control
- deadline = time() + 10
+ deadline = time() + self._timeout
while (not q.flowStopped) and time() < deadline:
q.update()
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org