diff options
Diffstat (limited to 'qpid/cpp/src/tests')
| -rw-r--r-- | qpid/cpp/src/tests/brokertest.py | 1 | ||||
| -rwxr-xr-x | qpid/cpp/src/tests/ha_tests.py | 3 |
2 files changed, 3 insertions, 1 deletions
diff --git a/qpid/cpp/src/tests/brokertest.py b/qpid/cpp/src/tests/brokertest.py index fbbaadc350..220c5f4367 100644 --- a/qpid/cpp/src/tests/brokertest.py +++ b/qpid/cpp/src/tests/brokertest.py @@ -534,6 +534,7 @@ class NumberedSender(Thread): self.received = 0 self.stopped = False self.error = None + self.queue = queue def write_message(self, n): self.sender.stdin.write(str(n)+"\n") diff --git a/qpid/cpp/src/tests/ha_tests.py b/qpid/cpp/src/tests/ha_tests.py index a42810dcc0..2235e87dc5 100755 --- a/qpid/cpp/src/tests/ha_tests.py +++ b/qpid/cpp/src/tests/ha_tests.py @@ -949,7 +949,8 @@ class LongTests(HaBrokerTest): def check(): r.check() # Verify no exceptions return r.received > n + 100 - assert retry(check), "Stalled %s at %s"%(r.queue, n) + assert retry(check), "Stalled %s waiting for %s, sent %s"%( + r.queue, n, [s for s in senders if s.queue==r.queue][0].sent) for r in receivers: wait_passed(r, 0) |