diff options
Diffstat (limited to 'qpid/cpp/src')
| -rwxr-xr-x | qpid/cpp/src/tests/qpid-cpp-benchmark | 9 |
1 files changed, 6 insertions, 3 deletions
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) |