From 4d586a4b79faf0ca353b149d6dac8b6b8a074bfe Mon Sep 17 00:00:00 2001 From: selldinesh Date: Wed, 9 Apr 2025 19:54:21 +0000 Subject: [PATCH] [Fix for Issue #17413] Modified the Tx Rx port id list selection for all to all scenario --- .../snappi_tests/pfcwd/files/pfcwd_multi_node_helper.py | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) diff --git a/tests/snappi_tests/pfcwd/files/pfcwd_multi_node_helper.py b/tests/snappi_tests/pfcwd/files/pfcwd_multi_node_helper.py index f1cef2719e9..be42b1cc817 100644 --- a/tests/snappi_tests/pfcwd/files/pfcwd_multi_node_helper.py +++ b/tests/snappi_tests/pfcwd/files/pfcwd_multi_node_helper.py @@ -75,14 +75,19 @@ def run_pfcwd_multi_node_test(api, pfcwd_to_be_configured = set() rx_port = snappi_extra_params.multi_dut_params.multi_dut_ports[0] - rx_port_id_list = [rx_port["port_id"]] egress_duthost = rx_port['duthost'] # Add the port to the set of ports to be configured for PFC pfcwd_to_be_configured.add((egress_duthost, rx_port['asic_value'])) tx_port = [snappi_extra_params.multi_dut_params.multi_dut_ports[1], snappi_extra_params.multi_dut_params.multi_dut_ports[2]] - tx_port_id_list = [tx_port[0]["port_id"], tx_port[1]["port_id"]] + if pattern == 'all to all': + tx_port_id_list = [rx_port["port_id"], tx_port[0]["port_id"], tx_port[1]["port_id"]] + rx_port_id_list = [rx_port["port_id"], tx_port[0]["port_id"], tx_port[1]["port_id"]] + pfcwd_to_be_configured.add((rx_port['duthost'], rx_port['asic_value'])) + elif pattern == 'many to one': + tx_port_id_list = [tx_port[0]["port_id"], tx_port[1]["port_id"]] + rx_port_id_list = [rx_port["port_id"]] # add ingress DUT into the set pfcwd_to_be_configured.add((tx_port[0]['duthost'], tx_port[0]['asic_value'])) pfcwd_to_be_configured.add((tx_port[1]['duthost'], tx_port[1]['asic_value']))