diff --git a/tests/snappi_tests/pfcwd/files/pfcwd_actions_helper.py b/tests/snappi_tests/pfcwd/files/pfcwd_actions_helper.py index 9c4c04e5e47..7c1a28da2bd 100644 --- a/tests/snappi_tests/pfcwd/files/pfcwd_actions_helper.py +++ b/tests/snappi_tests/pfcwd/files/pfcwd_actions_helper.py @@ -100,22 +100,24 @@ def run_pfc_test(api, pytest_assert(testbed_config is not None, 'Fail to get L2/3 testbed config') + rx_port_asic_value = rx_port['asic_value'] if egress_duthost.is_multi_asic else None + tx_port_asic_value = tx_port['asic_value'] if ingress_duthost.is_multi_asic else None if (test_def['enable_pfcwd_drop']): - start_pfcwd(egress_duthost) - start_pfcwd(ingress_duthost) + start_pfcwd(egress_duthost, rx_port_asic_value) + start_pfcwd(ingress_duthost, tx_port_asic_value) elif (test_def['enable_pfcwd_fwd']): - start_pfcwd_fwd(egress_duthost) - start_pfcwd_fwd(ingress_duthost) + start_pfcwd_fwd(egress_duthost, rx_port_asic_value) + start_pfcwd_fwd(ingress_duthost, tx_port_asic_value) else: - stop_pfcwd(egress_duthost) - stop_pfcwd(ingress_duthost) + stop_pfcwd(egress_duthost, rx_port_asic_value) + stop_pfcwd(ingress_duthost, tx_port_asic_value) if (test_def['enable_credit_wd']): - enable_packet_aging(egress_duthost, rx_port['asic_value']) - enable_packet_aging(ingress_duthost, tx_port['asic_value']) + enable_packet_aging(egress_duthost, rx_port_asic_value) + enable_packet_aging(ingress_duthost, tx_port_asic_value) else: - disable_packet_aging(egress_duthost, rx_port['asic_value']) - disable_packet_aging(ingress_duthost, tx_port['asic_value']) + disable_packet_aging(egress_duthost, rx_port_asic_value) + disable_packet_aging(ingress_duthost, tx_port_asic_value) rx_port_id = 0