Repository: qpid-dispatch Updated Branches: refs/heads/master d8045ca93 -> ddbeb5f7a
DISPATCH-627 - Shortened the batched-settlement test to avoid timeouts on slow systems. Note that this test was added to verify functionality that has since been removed. The test has been left because it still probably has value. Project: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/commit/ddbeb5f7 Tree: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/tree/ddbeb5f7 Diff: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/diff/ddbeb5f7 Branch: refs/heads/master Commit: ddbeb5f7a8602c34dce31d57c650e1befc0e4632 Parents: d8045ca Author: Ted Ross <[email protected]> Authored: Fri Mar 24 16:32:40 2017 -0400 Committer: Ted Ross <[email protected]> Committed: Fri Mar 24 16:32:40 2017 -0400 ---------------------------------------------------------------------- tests/system_tests_one_router.py | 18 ++++++++---------- 1 file changed, 8 insertions(+), 10 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-dispatch/blob/ddbeb5f7/tests/system_tests_one_router.py ---------------------------------------------------------------------- diff --git a/tests/system_tests_one_router.py b/tests/system_tests_one_router.py index 0810105..af16065 100644 --- a/tests/system_tests_one_router.py +++ b/tests/system_tests_one_router.py @@ -1438,8 +1438,8 @@ class BatchedSettlementTest(MessagingHandler): self.address = address self.dest = "balanced.BatchedSettlement" self.error = None - self.count = 20000 - self.batch_count = 200 + self.count = 200 + self.batch_count = 20 self.n_sent = 0 self.n_received = 0 self.n_settled = 0 @@ -1456,21 +1456,19 @@ class BatchedSettlementTest(MessagingHandler): self.conn.close() def on_start(self, event): - self.timer = event.reactor.schedule(120, Timeout(self)) # Long timeout for Valgrind + self.timer = event.reactor.schedule(10, Timeout(self)) self.conn = event.container.connect(self.address) self.sender = event.container.create_sender(self.conn, self.dest) self.receiver = event.container.create_receiver(self.conn, self.dest) def send(self): - if self.n_sent < self.count: - while self.sender.credit > 0: - msg = Message(body="Batch-Test") - self.sender.send(msg) - self.n_sent += 1 + while self.n_sent < self.count and self.sender.credit > 0: + msg = Message(body="Batch-Test") + self.sender.send(msg) + self.n_sent += 1 def on_sendable(self, event): - if self.n_sent < self.count: - self.send() + self.send() def on_message(self, event): self.n_received += 1 --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
