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 0a1459e DISPATCH-2266: Added some log statements to see where the
test stalls
0a1459e is described below
commit 0a1459e190dbd489b30be3edef7a40d3dea27f0d
Author: Ganesh Murthy <gmur...@apache.org>
AuthorDate: Fri Oct 29 12:52:39 2021 -0400
DISPATCH-2266: Added some log statements to see where the test stalls
---
tests/system_tests_edge_router.py | 25 ++++++++++++++++++++++++-
1 file changed, 24 insertions(+), 1 deletion(-)
diff --git a/tests/system_tests_edge_router.py
b/tests/system_tests_edge_router.py
index 628f72b..34073c6 100644
--- a/tests/system_tests_edge_router.py
+++ b/tests/system_tests_edge_router.py
@@ -1886,19 +1886,31 @@ class LinkRouteProxyTest(TestCase):
if self.skip['test_51'] :
self.skipTest("Test skipped during development.")
- a_type = 'org.apache.qpid.dispatch.router.address'
+ # 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)
test_msg = Message(body="test_51_link_route_proxy_configured")
fs = FakeService(self.EA1.route_container)
+
+ logger.log("test_51_link_route_proxy_configured Created FakeService")
+
self.INT_B.wait_address("CfgLinkRoute1", count=2)
+ logger.log("test_51_link_route_proxy_configured Wait done on
CfgLinkRoute1")
+
out = self._test_traffic(self.INT_B.listener,
self.INT_B.listener,
"CfgLinkRoute1/hi",
count=5,
message=test_msg)
+
+ logger.log("test_51_link_route_proxy_configured _test_traffic done on
CfgLinkRoute1/hi")
+
fs.join()
+ logger.log("test_51_link_route_proxy_configured _test_traffic first
join() completed")
+
try:
self.assertIsNone(out, out)
self.assertEqual(5, fs.in_count)
@@ -1911,22 +1923,33 @@ class LinkRouteProxyTest(TestCase):
# active:
self._wait_address_gone(self.INT_A, "CfgLinkRoute1")
+ logger.log("test_51_link_route_proxy_configured CfgLinkRoute1
_wait_address_gone")
+
# repeat test, but this time with patterns:
fs = FakeService(self.EB1.route_container)
self.INT_A.wait_address("*.cfg.pattern.#", count=2)
+ logger.log("test_51_link_route_proxy_configured wait_address pattern
*.cfg.pattern.#")
+
out = self._test_traffic(self.INT_A.listener,
self.INT_A.listener,
"MATCH.cfg.pattern",
count=5,
message=test_msg)
+
+ logger.log("test_51_link_route_proxy_configured _test_traffic
MATCH.cfg.pattern")
+
fs.join()
+
+ logger.log("test_51_link_route_proxy_configured _test_traffic second
join() completed")
+
self.assertIsNone(out, out)
self.assertEqual(5, fs.in_count)
self.assertEqual(5, fs.out_count)
self._wait_address_gone(self.INT_A, "*.cfg.pattern.#")
+ logger.log("test_51_link_route_proxy_configured *.cfg.pattern.#
_wait_address_gone")
def test_52_conn_link_route_proxy(self):
"""
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org
For additional commands, e-mail: commits-h...@qpid.apache.org
