This is an automated email from the ASF dual-hosted git repository.
gmurthy pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/qpid-dispatch.git
The following commit(s) were added to refs/heads/main by this push:
new 210571f DISPATCH-2266: Added more debugging to see why the
AsyncReceiver is quitting.
210571f is described below
commit 210571f9c354961fdc636dedc9e440b877047afa
Author: Ganesh Murthy <[email protected]>
AuthorDate: Mon Nov 15 11:03:47 2021 -0500
DISPATCH-2266: Added more debugging to see why the AsyncReceiver is
quitting.
---
tests/system_test.py | 14 ++++++++++----
tests/system_tests_edge_router.py | 2 ++
2 files changed, 12 insertions(+), 4 deletions(-)
diff --git a/tests/system_test.py b/tests/system_test.py
index 0b6390c..46d3e42 100755
--- a/tests/system_test.py
+++ b/tests/system_test.py
@@ -928,13 +928,19 @@ class AsyncTestReceiver(MessagingHandler):
def _main(self):
self._container.timeout = 0.5
self._container.start()
- self._logger.log("Starting reactor")
+ self._logger.log("AsyncTestReceiver Starting reactor")
while self._container.process():
if self._stop_thread:
if self._conn:
self._conn.close()
self._conn = None
- self._logger.log("reactor thread done")
+ self._logger.log("AsyncTestReceiver reactor thread done")
+
+ def on_connection_error(self, event):
+ self._logger.log("AsyncTestReceiver on_connection_error=%s" %
event.connection.remote_condition.description)
+
+ def on_link_error(self, event):
+ self._logger.log("AsyncTestReceiver on_link_error=%s" %
event.link.remote_condition.description)
def stop(self, timeout=TIMEOUT):
self._stop_thread = True
@@ -1028,10 +1034,10 @@ class AsyncTestSender(MessagingHandler):
def _main(self):
self._container.timeout = 0.5
self._container.start()
- self._logger.log("Starting reactor")
+ self._logger.log("AsyncTestSender Starting reactor")
while self._container.process():
self._check_if_done()
- self._logger.log("reactor thread done")
+ self._logger.log("AsyncTestSender reactor thread done")
def get_msg_stats(self):
return self.msg_stats % (self.sent, self.accepted, self.released,
self.modified, self.rejected)
diff --git a/tests/system_tests_edge_router.py
b/tests/system_tests_edge_router.py
index 6b7653e..31e6b29 100644
--- a/tests/system_tests_edge_router.py
+++ b/tests/system_tests_edge_router.py
@@ -1895,6 +1895,8 @@ class LinkRouteProxyTest(TestCase):
if self.skip['test_51'] :
self.skipTest("Test skipped during development.")
+ self.INT_B.wait_address_unsubscribed("CfgLinkRoute1")
+
# We are logging each step of this test as we go. The log statements
will print to console
logger = Logger(title="test_51_link_route_proxy_configured",
print_to_console=True)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
