From e6e3ffef994596c912b4038512e359ece513072d Mon Sep 17 00:00:00 2001
From: Arnaud de Turckheim <quarium@gmail.com>
Date: Fri, 28 Mar 2025 14:29:30 +0100
Subject: [PATCH] upipe_transfer: block when queue is full

---
 lib/upipe-modules/upipe_transfer.c | 5 +----
 1 file changed, 1 insertion(+), 4 deletions(-)

diff --git a/lib/upipe-modules/upipe_transfer.c b/lib/upipe-modules/upipe_transfer.c
index 8d726aacd..49c577522 100644
--- a/lib/upipe-modules/upipe_transfer.c
+++ b/lib/upipe-modules/upipe_transfer.c
@@ -580,10 +580,7 @@ static int upipe_xfer_mgr_send(struct upipe_mgr *mgr, int type,
     msg->upipe_remote = upipe_remote;
     msg->arg = arg;
 
-    if (unlikely(!uqueue_push(&xfer_mgr->uqueue, msg))) {
-        upipe_xfer_msg_free(mgr, msg);
-        return UBASE_ERR_EXTERNAL;
-    }
+    while (!uqueue_push(&xfer_mgr->uqueue, msg));
     return UBASE_ERR_NONE;
 }