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 2bd3328  DISPATCH-1237 - Added additional small message test
2bd3328 is described below

commit 2bd3328448e03849d94dd821dfb2f056df8a9076
Author: Ganesh Murthy <gmur...@redhat.com>
AuthorDate: Thu Jan 10 15:45:58 2019 -0500

    DISPATCH-1237 - Added additional small message test
---
 tests/system_tests_edge_router.py | 14 ++++++++++++--
 1 file changed, 12 insertions(+), 2 deletions(-)

diff --git a/tests/system_tests_edge_router.py 
b/tests/system_tests_edge_router.py
index 6a90e33..62e026c 100644
--- a/tests/system_tests_edge_router.py
+++ b/tests/system_tests_edge_router.py
@@ -650,6 +650,16 @@ class RouterTest(TestCase):
         test.run()
         self.assertEqual(None, test.error)
 
+    def test_41_drop_rx_client_multicast_small_message(self):
+        # test what happens if some multicast receivers close in the middle of
+        # a multiframe transfer
+        test = MobileAddrMcastDroppedRxTest(self.routers[2].addresses[0],
+                                            self.routers[2].addresses[0],
+                                            self.routers[2].addresses[0],
+                                            self.routers[2].addresses[0],
+                                            "multicast.40",large_msg=False)
+        test.run()
+        self.assertEqual(None, test.error)
 
 class LinkRouteProxyTest(TestCase):
     """
@@ -1502,14 +1512,14 @@ class 
MobileAddrMcastDroppedRxTest(MobileAddressMulticastTest):
     # failure scenario - cause some receiving clients to close while a large
     # message is in transit
     def __init__(self, receiver1_host, receiver2_host, receiver3_host,
-                 sender_host, address, check_addr_host=None):
+                 sender_host, address, check_addr_host=None, large_msg=True):
         super(MobileAddrMcastDroppedRxTest, self).__init__(receiver1_host,
                                                            receiver2_host,
                                                            receiver3_host,
                                                            sender_host,
                                                            address,
                                                            
check_addr_host=check_addr_host,
-                                                           large_msg=True)
+                                                           large_msg=large_msg)
         self.n_accepted = 0
         self.n_released = 0
         self.recv1_closed = False


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org
For additional commands, e-mail: commits-h...@qpid.apache.org

Reply via email to