[qpid-dispatch] branch master updated: DISPATCH-1431: fix system_tests_one_router multicast test client race

[kg...@apache.org]

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 <kg...@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-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org