diff mbox series

[net-next,3/3] selftests: lan743x: Add testcase to check throughput of lan743x

Message ID 20240903221549.1215842-4-mohan.prasad@microchip.com
State New
Headers show
Series [net-next,1/3] selftests: lan743x: Add testfile for lan743x network driver | expand

Commit Message

Mohan Prasad J Sept. 3, 2024, 10:15 p.m. UTC
Add testcase to check TCP throughput of lan743x network driver.
Test uses iperf3 to do performance testing of the driver.
TCP data at different speeds is sent, received and verified.

Signed-off-by: Mohan Prasad J <mohan.prasad@microchip.com>
---
 .../net/hw/microchip/lan743x/lan743x.py       | 33 +++++++++++++++++++
 1 file changed, 33 insertions(+)
diff mbox series

Patch

diff --git a/tools/testing/selftests/drivers/net/hw/microchip/lan743x/lan743x.py b/tools/testing/selftests/drivers/net/hw/microchip/lan743x/lan743x.py
index 59f0be2a7..a3dcf7896 100755
--- a/tools/testing/selftests/drivers/net/hw/microchip/lan743x/lan743x.py
+++ b/tools/testing/selftests/drivers/net/hw/microchip/lan743x/lan743x.py
@@ -3,6 +3,7 @@ 
 
 import time
 import re
+import json
 from lib.py import ksft_run, ksft_exit, ksft_pr, ksft_eq
 from lib.py import KsftFailEx, KsftSkipEx
 from lib.py import NetDrvEpEnv
@@ -75,6 +76,38 @@  def test_network_speed(cfg) -> None:
             time.sleep(5)
             verify_speed_and_duplex(cfg.ifname, speed, duplex)
 
+def test_tcp_throughput(cfg) -> None:
+    speeds = ["10", "100", "1000"]
+    """Test duration in seconds"""
+    test_duration = 5
+    target_ip = cfg.remote_addr
+
+    for speed in speeds:
+        set_speed_and_duplex(cfg.ifname, speed, 'full')
+        time.sleep(5)
+        verify_link_up(cfg.ifname)
+        send_command=f"iperf3 -c {target_ip} -t {test_duration} --json"
+        receive_command=f"iperf3 -c {target_ip} -t {test_duration} --reverse --json"
+        send_result = cmd(send_command)
+        receive_result = cmd(receive_command)
+        if send_result.ret != 0 or receive_result.ret != 0:
+            raise KsftSkipEx("No server is running")
+
+        send_output = send_result.stdout
+        receive_output = receive_result.stdout
+
+        send_data = json.loads(send_output)
+        receive_data = json.loads(receive_output)
+        """Convert throughput to Mbps"""
+        send_throughput = round(send_data['end']['sum_sent']['bits_per_second'] / 1e6, 2)
+        receive_throughput = round(receive_data['end']['sum_received']['bits_per_second'] / 1e6, 2)
+
+        ksft_pr(f"Send throughput: {send_throughput} Mbps, Receive throughput: {receive_throughput} Mbps")
+        """Check whether throughput is not below 0.9 times the set speed"""
+        threshold = float(speed) * 0.9
+        if send_throughput < threshold or receive_throughput < threshold:
+            raise KsftFailEx("Throughput is below threshold")
+
 def main() -> None:
     with NetDrvEpEnv(__file__) as cfg:
         ksft_run(globs=globals(), case_pfx={"test_"}, args=(cfg,))