From c8860c7351d96d6698b06c6d64e62ba5a0a8b00a Mon Sep 17 00:00:00 2001 From: Gordon Sim Date: Fri, 19 Feb 2016 23:00:25 +0000 Subject: QPID-7076: Avoid error with qpid-cpp-benchmark with 0 senders. Patch from yuelongguang@letv.com git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1731309 13f79535-47bb-0310-9956-ffa450edef68 --- qpid/cpp/src/tests/qpid-cpp-benchmark | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) (limited to 'qpid/cpp/src/tests/qpid-cpp-benchmark') diff --git a/qpid/cpp/src/tests/qpid-cpp-benchmark b/qpid/cpp/src/tests/qpid-cpp-benchmark index 2d5ec711fe..3a5419de5e 100755 --- a/qpid/cpp/src/tests/qpid-cpp-benchmark +++ b/qpid/cpp/src/tests/qpid-cpp-benchmark @@ -340,16 +340,19 @@ def main(): # First fill the queues, then drain them start = time.time() senders = start_senders() - for p in senders: p.wait() + for p in senders: + if p: p.wait() receivers = start_receivers() - for p in receivers: p.wait() + for p in receivers: + if p: p.wait() else: # Run senders and receivers in parallel receivers = start_receivers() ready_receiver.wait(filter(None, receivers)) # Wait for receivers ready start = time.time() senders = start_senders() - for p in senders + receivers: p.wait() + for p in senders + receivers: + if p: p.wait() total_sent = opts.queues * opts.senders * opts.messages total_tp = total_sent / (time.time()-start) -- cgit v1.2.1