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 ff11223 DISPATCH-2023: Set self.reactor in on_start. This closes #1103. ff11223 is described below commit ff11223b49eaf3fcf1e8f693d40ec836d01f0264 Author: Ganesh Murthy <gmur...@apache.org> AuthorDate: Sun Apr 4 21:28:06 2021 -0400 DISPATCH-2023: Set self.reactor in on_start. This closes #1103. --- tests/system_tests_edge_router.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/tests/system_tests_edge_router.py b/tests/system_tests_edge_router.py index b22d61d..d99664a 100644 --- a/tests/system_tests_edge_router.py +++ b/tests/system_tests_edge_router.py @@ -2594,6 +2594,7 @@ class MobileAddressMulticastTest(MessagingHandler): local_node.close() def on_start(self, event): + self.reactor = event.reactor self.timer = event.reactor.schedule(TIMEOUT, TestTimeout(self)) # Create two receivers self.receiver1_conn = event.container.connect(self.receiver1_host) @@ -2613,7 +2614,6 @@ class MobileAddressMulticastTest(MessagingHandler): event.receiver == self.receiver3: self.r_attaches += 1 if self.r_attaches == 3: - self.reactor = event.reactor self.addr_timer = self.reactor.schedule(1.0, AddrTimer(self)) def on_sendable(self, event): @@ -2794,6 +2794,7 @@ class MobileAddressEventTest(MessagingHandler): self.max_attempts = 5 self.num_attempts = 0 self.check_remote = check_remote + self.reactor = None def timeout(self): if self.dup_msg: @@ -2842,6 +2843,7 @@ class MobileAddressEventTest(MessagingHandler): self.timeout() def on_start(self, event): + self.reactor = event.reactor self.timer = event.reactor.schedule(TIMEOUT, TestTimeout(self)) # Create two receivers --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org For additional commands, e-mail: commits-h...@qpid.apache.org