QPID-5015: increase timeouts for queue flow tests

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1506613 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 6 insertions, 4 deletions

diff --git a/cpp/src/tests/queue_flow_limit_tests.py b/cpp/src/tests/queue_flow_limit_tests.py
index c7361a629e..83e31e979b 100644
--- a/cpp/src/tests/queue_flow_limit_tests.py
+++ b/cpp/src/tests/queue_flow_limit_tests.py
@@ -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()