diff options
| author | Kenneth Anthony Giusti <kgiusti@apache.org> | 2013-07-24 16:18:39 +0000 |
|---|---|---|
| committer | Kenneth Anthony Giusti <kgiusti@apache.org> | 2013-07-24 16:18:39 +0000 |
| commit | 4c7a795f08f8e35f3f9991daff1e4dc97eb04bf9 (patch) | |
| tree | 4755dd2d6341589ce801bfe0c9637a85de9e6c11 | |
| parent | 18fd12734205695b92699f1a92a72515c952a14d (diff) | |
| download | qpid-python-4c7a795f08f8e35f3f9991daff1e4dc97eb04bf9.tar.gz | |
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
| -rw-r--r-- | cpp/src/tests/queue_flow_limit_tests.py | 10 |
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() |