This is an automated email from the ASF dual-hosted git repository. kgiusti pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/qpid-dispatch.git
The following commit(s) were added to refs/heads/master by this push: new ff971d4 DISPATCH-1431: fix system_tests_one_router multicast test client race ff971d4 is described below commit ff971d416bc20048f0576176b54c36ef7ebcea38 Author: Kenneth Giusti <kgiu...@apache.org> AuthorDate: Wed Oct 2 16:45:06 2019 -0400 DISPATCH-1431: fix system_tests_one_router multicast test client race --- tests/system_tests_one_router.py | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/tests/system_tests_one_router.py b/tests/system_tests_one_router.py index ad1ac0d..c3dfa9a 100644 --- a/tests/system_tests_one_router.py +++ b/tests/system_tests_one_router.py @@ -686,6 +686,7 @@ class SemanticsMulticast(MessagingHandler): self.n_received_b = 0 self.n_received_c = 0 self.n_accepts = 0 + self.n_recv_ready = 0 self.timer = None self.conn_1 = None self.conn_2 = None @@ -698,7 +699,6 @@ class SemanticsMulticast(MessagingHandler): self.timer = event.reactor.schedule(TIMEOUT, Timeout(self)) self.conn_1 = event.container.connect(self.address) self.conn_2 = event.container.connect(self.address) - self.sender = event.container.create_sender(self.conn_1, self.dest) self.receiver_a = event.container.create_receiver(self.conn_2, self.dest, name="A") self.receiver_b = event.container.create_receiver(self.conn_1, self.dest, name="B") self.receiver_c = event.container.create_receiver(self.conn_2, self.dest, name="C") @@ -720,6 +720,12 @@ class SemanticsMulticast(MessagingHandler): self.conn_1.close() self.conn_2.close() + def on_link_opened(self, event): + if event.receiver: + self.n_recv_ready += 1 + if self.n_recv_ready == self.count: + self.sender = event.container.create_sender(self.conn_1, self.dest) + def on_sendable(self, event): if self.n_sent == 0: msg = Message(body="SemanticsMulticast-Test") --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org For additional commands, e-mail: commits-h...@qpid.apache.org