You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by kg...@apache.org on 2020/06/15 12:55:43 UTC

[qpid-dispatch] branch master updated: DISPATCH-1650: reduce running time for test_01_parallel_link_routes

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 57f778a  DISPATCH-1650: reduce running time for test_01_parallel_link_routes
57f778a is described below

commit 57f778ac3bfed7b27cc8ee82f09e221ace4382be
Author: Kenneth Giusti <kg...@apache.org>
AuthorDate: Thu Jun 11 15:41:34 2020 -0400

    DISPATCH-1650: reduce running time for test_01_parallel_link_routes
    
    This closes #762
---
 tests/system_tests_link_routes.py | 11 ++++++-----
 1 file changed, 6 insertions(+), 5 deletions(-)

diff --git a/tests/system_tests_link_routes.py b/tests/system_tests_link_routes.py
index ff6178b..e8fb52e 100644
--- a/tests/system_tests_link_routes.py
+++ b/tests/system_tests_link_routes.py
@@ -2458,7 +2458,7 @@ class LinkRoute3Hop(TestCase):
         same session.
         """
         send_clients = 10
-        send_batch = 25
+        send_batch = 10
         total = send_clients * send_batch
 
         start_in = self.fake_service.in_count
@@ -2485,15 +2485,16 @@ class LinkRoute3Hop(TestCase):
 
         senders = [_spawn_sender(s) for s in range(send_clients)]
 
-        if rx.wait(timeout=TIMEOUT):
-            raise Exception("Receiver failed to consume all messages in=%s out=%s",
-                            self.fake_service.in_count,
-                            self.fake_service.out_count)
         for tx in senders:
             out_text, out_err = tx.communicate(timeout=TIMEOUT)
             if tx.returncode:
                 raise Exception("Sender failed: %s %s" % (out_text, out_err))
 
+        if rx.wait(timeout=TIMEOUT):
+            raise Exception("Receiver failed to consume all messages in=%s out=%s",
+                            self.fake_service.in_count,
+                            self.fake_service.out_count)
+
         self.assertEqual(start_in + total, self.fake_service.in_count)
         self.assertEqual(start_out + total, self.fake_service.out_count)
 


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