This is an automated email from the ASF dual-hosted git repository.
chug 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 49e37aa DISPATCH-2205: Do not process MAU after test shutdown in
effect
49e37aa is described below
commit 49e37aa2c775a21b31f1f2eb5742f5ca78c26272
Author: Chuck Rolke <c...@apache.org>
AuthorDate: Wed Jul 21 12:25:22 2021 -0400
DISPATCH-2205: Do not process MAU after test shutdown in effect
A legitimate MAU will arrive after "mobile_address" is closed.
Stop processing updates after test success is declared.
---
tests/system_tests_routing_protocol.py | 4 ++++
1 file changed, 4 insertions(+)
diff --git a/tests/system_tests_routing_protocol.py
b/tests/system_tests_routing_protocol.py
index 7360177..f97584e 100644
--- a/tests/system_tests_routing_protocol.py
+++ b/tests/system_tests_routing_protocol.py
@@ -135,6 +135,7 @@ class RejectHigherVersionMARTest(MessagingHandler):
self.receiver = None
self.hello_count = 0
self.mar_count = 0
+ self.finished = False
def timeout(self):
self.error = "Timeout Expired - hello_count: %d, mar_count: %d" %
(self.hello_count, self.mar_count)
@@ -168,6 +169,8 @@ class RejectHigherVersionMARTest(MessagingHandler):
self.sender.target.capabilities.put_object(symbol("qd.router"))
def on_message(self, event):
+ if self.finished:
+ return
opcode = event.message.properties['opcode']
body = event.message.body
rid = body['id']
@@ -183,6 +186,7 @@ class RejectHigherVersionMARTest(MessagingHandler):
elif opcode == 'RA':
if self.mar_count > 2:
+ self.finished = True
self.fail(None)
return
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org
For additional commands, e-mail: commits-h...@qpid.apache.org
