You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by gm...@apache.org on 2019/06/10 19:47:08 UTC
[qpid-dispatch] branch master updated: DISPATCH-1361 - Fixed
system_tests_fallback_dest test to send expected number of messages
This is an automated email from the ASF dual-hosted git repository.
gmurthy 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 87b696f DISPATCH-1361 - Fixed system_tests_fallback_dest test to send expected number of messages
87b696f is described below
commit 87b696f468e5268cb7de07f622b3c5a543b4bc98
Author: Ganesh Murthy <gm...@apache.org>
AuthorDate: Mon Jun 10 15:46:26 2019 -0400
DISPATCH-1361 - Fixed system_tests_fallback_dest test to send expected number of messages
---
tests/system_tests_fallback_dest.py | 20 ++++++++++++++------
1 file changed, 14 insertions(+), 6 deletions(-)
diff --git a/tests/system_tests_fallback_dest.py b/tests/system_tests_fallback_dest.py
index 031525c..6688b90 100644
--- a/tests/system_tests_fallback_dest.py
+++ b/tests/system_tests_fallback_dest.py
@@ -692,11 +692,14 @@ class SenderFirstAutoLinkTest(MessagingHandler):
if event.sender == self.sender:
self.receiver_conn = event.container.connect(self.receiver_host)
+ def send(self):
+ while self.sender.credit > 0 and self.n_tx < self.count:
+ self.sender.send(Message("Message %d" % self.n_tx))
+ self.n_tx += 1
+
def on_sendable(self, event):
if event.sender == self.sender:
- while self.sender.credit > 0 and self.n_tx < self.count:
- self.sender.send(Message("Message %d" % self.n_tx))
- self.n_tx += 1
+ self.send()
def on_message(self, event):
self.n_rx += 1
@@ -706,6 +709,7 @@ class SenderFirstAutoLinkTest(MessagingHandler):
def on_released(self, event):
self.n_rel += 1
self.n_tx -= 1
+ self.send()
def run(self):
Container(self).run()
@@ -758,11 +762,14 @@ class ReceiverFirstAutoLinkTest(MessagingHandler):
self.sender_conn = event.container.connect(self.sender_host)
self.sender = event.container.create_sender(self.sender_conn, self.addr)
+ def send(self):
+ while self.sender.credit > 0 and self.n_tx < self.count:
+ self.sender.send(Message("Message %d" % self.n_tx))
+ self.n_tx += 1
+
def on_sendable(self, event):
if event.sender == self.sender:
- while self.sender.credit > 0 and self.n_tx < self.count:
- self.sender.send(Message("Message %d" % self.n_tx))
- self.n_tx += 1
+ self.send()
def on_message(self, event):
self.n_rx += 1
@@ -772,6 +779,7 @@ class ReceiverFirstAutoLinkTest(MessagingHandler):
def on_released(self, event):
self.n_rel += 1
self.n_tx -= 1
+ self.send()
def run(self):
Container(self).run()
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org