From 0a80ab090499dd3e61c49641dea7420e7bd0aa97 Mon Sep 17 00:00:00 2001
From: Xu Chen <112069142+XuChen-MSFT@users.noreply.github.com>
Date: Thu, 25 Jan 2024 10:57:25 +0800
Subject: [PATCH] fix 6100 testQosSaiLossyQueue failure caused by leakout
 (#11365)

---
 tests/saitests/py3/sai_qos_tests.py | 7 +++++++
 1 file changed, 7 insertions(+)

diff --git a/tests/saitests/py3/sai_qos_tests.py b/tests/saitests/py3/sai_qos_tests.py
index 38176e3ee6a..95068db3a5c 100644
--- a/tests/saitests/py3/sai_qos_tests.py
+++ b/tests/saitests/py3/sai_qos_tests.py
@@ -3680,9 +3680,16 @@ def runTest(self):
                 send_packet(self, src_port_id, pkt, pkts_num_egr_mem +
                             pkts_num_leak_out + pkts_num_trig_egr_drp - 1 - margin)
             else:
+                if check_leackout_compensation_support(asic_type, hwsku):
+                    pkts_num_leak_out = 0
                 # send packets short of triggering egress drop
                 send_packet(self, src_port_id, pkt, pkts_num_leak_out +
                             pkts_num_trig_egr_drp - 1 - margin)
+                if check_leackout_compensation_support(asic_type, hwsku):
+                    time.sleep(5)
+                    dynamically_compensate_leakout(self.dst_client, asic_type, sai_thrift_read_port_counters,
+                                                   port_list['dst'][dst_port_id], TRANSMITTED_PKTS,
+                                                   xmit_counters_base, self, src_port_id, pkt, 10)
 
             if hwsku == 'Arista-7050CX3-32S-D48C8' or hwsku == 'Arista-7050CX3-32S-C32' or \
                     hwsku == 'DellEMC-Z9332f-O32' or hwsku == 'DellEMC-Z9332f-M-O16C64':