<div dir="ltr"><div dir="ltr"><br></div><br><div class="gmail_quote"><div dir="ltr" class="gmail_attr">On Thu, Jan 18, 2024 at 1:22 AM Kumara Parameshwaran <<a href="mailto:kumaraparamesh92@gmail.com">kumaraparamesh92@gmail.com</a>> wrote:<br></div><blockquote class="gmail_quote" style="margin:0px 0px 0px 0.8ex;border-left:1px solid rgb(204,204,204);padding-left:1ex"><div>In heavy-weight mode GRO which is based on timer, the GRO packets will not be<br>
flushed inspite of timer expiry if there is no packet in the current poll.<br>
If timer mode GRO is enabled the rte_gro_timeout_flush API should be invoked.<br>
<br>
Signed-off-by: Kumara Parameshwaran <<a href="mailto:kumaraparamesh92@gmail.com" target="_blank">kumaraparamesh92@gmail.com</a>><br>
---<br>
v1:<br>
    Changes to make sure that the GRO flush API is invoked if there are no packets in <br>
    current poll and timer expiry.<br>
<br>
 app/test-pmd/csumonly.c | 16 ++++++++++++----<br>
 1 file changed, 12 insertions(+), 4 deletions(-)<br>
<br>
diff --git a/app/test-pmd/csumonly.c b/app/test-pmd/csumonly.c<br>
index c103e54111..42f105ac16 100644<br>
--- a/app/test-pmd/csumonly.c<br>
+++ b/app/test-pmd/csumonly.c<br>
@@ -863,16 +863,24 @@ pkt_burst_checksum_forward(struct fwd_stream *fs)<br>
<br>
        /* receive a burst of packet */<br>
        nb_rx = common_fwd_stream_receive(fs, pkts_burst, nb_pkt_per_burst);<br>
-       if (unlikely(nb_rx == 0))<br>
+       if (unlikely(nb_rx == 0)) {<br>
+#ifdef RTE_LIB_GRO<br>
+               gro_enable = gro_ports[fs->rx_port].enable;<br>
+               if (unlikely(gro_enable && (gro_flush_cycles != GRO_DEFAULT_FLUSH_CYCLES))) {<br>
+                       goto init;<br>
+               } else {<br>
+                       return false;<br>
+               }<br>
+#else<br>
                return false;<br>
+#endif<br>
+       }<br>
<br>
+init:<br>
        rx_bad_ip_csum = 0;<br>
        rx_bad_l4_csum = 0;<br>
        rx_bad_outer_l4_csum = 0;<br>
        rx_bad_outer_ip_csum = 0;<br>
-#ifdef RTE_LIB_GRO<br>
-       gro_enable = gro_ports[fs->rx_port].enable;<br>
-#endif<br>
<br>
        txp = &ports[fs->tx_port];<br>
        tx_offloads = txp->dev_conf.txmode.offloads;<br>
-- <br>
2.25.1<br></div>>>Please ignore this patch, this has an issue will raise a new one. <br><div>
<br>
</div></blockquote></div></div>