[kafka] branch trunk updated: KAFKA-13312; 'NetworkDegradeTest#test_rate' should wait until iperf server is listening (#11344)

[da...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

dajac pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new f650a14  KAFKA-13312; 'NetworkDegradeTest#test_rate' should wait until iperf server is listening (#11344)
f650a14 is described below

commit f650a14d56c0cc33263c29d8d242760406943c5b
Author: David Jacot <dj...@confluent.io>
AuthorDate: Tue Sep 21 10:26:46 2021 +0200

    KAFKA-13312; 'NetworkDegradeTest#test_rate' should wait until iperf server is listening (#11344)
    
    Reviewers: Jason Gustafson <ja...@confluent.io>
---
 tests/kafkatest/tests/core/network_degrade_test.py | 7 +++++++
 1 file changed, 7 insertions(+)

diff --git a/tests/kafkatest/tests/core/network_degrade_test.py b/tests/kafkatest/tests/core/network_degrade_test.py
index 76af8b0..68cce85 100644
--- a/tests/kafkatest/tests/core/network_degrade_test.py
+++ b/tests/kafkatest/tests/core/network_degrade_test.py
@@ -105,6 +105,13 @@ class NetworkDegradeTest(Test):
         # Run iperf server on zk1, iperf client on zk0
         iperf_server = zk1.account.ssh_capture("iperf -s")
 
+        # Wait until iperf server is listening before starting the client
+        for line in iperf_server:
+          self.logger.debug("iperf server output %s" % line)
+          if "server listening" in line.lower():
+            self.logger.info("iperf server is ready")
+            break
+
         # Capture the measured kbps between the two nodes.
         # [  3]  0.0- 1.0 sec  2952576 KBytes  24187503 Kbits/sec
         r = re.compile(r"^.*\s(?P<rate>[\d.]+)\sKbits/sec$")