<div dir="ltr"><div>Any news on that ? Thanks</div><div><br></div><div>Julien<br></div></div><br><div class="gmail_quote"><div dir="ltr" class="gmail_attr">On Thu, Aug 10, 2023 at 6:09 PM jhascoet <<a href="mailto:ju.hascoet@gmail.com">ju.hascoet@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">From: Julien Hascoet <<a href="mailto:ju.hascoet@gmail.com" target="_blank">ju.hascoet@gmail.com</a>><br>
<br>
In case of ring full state, we retry the enqueue<br>
operation in order to avoid mbuf loss.<br>
<br>
Fixes: af75078fece ("first public release")<br>
<br>
Signed-off-by: Julien Hascoet <<a href="mailto:ju.hascoet@gmail.com" target="_blank">ju.hascoet@gmail.com</a>><br>
---<br>
 app/test/test_mbuf.c | 15 ++++++++++++---<br>
 1 file changed, 12 insertions(+), 3 deletions(-)<br>
<br>
diff --git a/app/test/test_mbuf.c b/app/test/test_mbuf.c<br>
index efac01806b..ad18bf6378 100644<br>
--- a/app/test/test_mbuf.c<br>
+++ b/app/test/test_mbuf.c<br>
@@ -1033,12 +1033,21 @@ test_refcnt_iter(unsigned int lcore, unsigned int iter,<br>
                tref += ref;<br>
                if ((ref & 1) != 0) {<br>
                        rte_pktmbuf_refcnt_update(m, ref);<br>
-                       while (ref-- != 0)<br>
-                               rte_ring_enqueue(refcnt_mbuf_ring, m);<br>
+                       while (ref-- != 0) {<br>
+                               /* retry in case of failure */<br>
+                               while (rte_ring_enqueue(refcnt_mbuf_ring, m) != 0) {<br>
+                                       /* let others consume */<br>
+                                       rte_pause();<br>
+                               }<br>
+                       }<br>
                } else {<br>
                        while (ref-- != 0) {<br>
                                rte_pktmbuf_refcnt_update(m, 1);<br>
-                               rte_ring_enqueue(refcnt_mbuf_ring, m);<br>
+                               /* retry in case of failure */<br>
+                               while (rte_ring_enqueue(refcnt_mbuf_ring, m) != 0) {<br>
+                                       /* let others consume */<br>
+                                       rte_pause();<br>
+                               }<br>
                        }<br>
                }<br>
                rte_pktmbuf_free(m);<br>
-- <br>
2.34.1<br>
<br>
</blockquote></div>