From e480aebcf20101f648b2a22773380160956c5bc7 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Fran=C3=A7ois=20Laignel?= <francois@centricular.com>
Date: Thu, 28 Aug 2025 16:08:06 +0200
Subject: [PATCH] threadshare: runtime/pad: lower log level pushing Buffer to
 flushing pad

Part-of: <https://gitlab.freedesktop.org/gstreamer/gst-plugins-rs/-/merge_requests/2512>
---
 generic/threadshare/src/runtime/pad.rs | 21 ++++++++++++++-------
 1 file changed, 14 insertions(+), 7 deletions(-)

diff --git a/generic/threadshare/src/runtime/pad.rs b/generic/threadshare/src/runtime/pad.rs
index cae7ea5c5..ad323fba6 100644
--- a/generic/threadshare/src/runtime/pad.rs
+++ b/generic/threadshare/src/runtime/pad.rs
@@ -203,15 +203,22 @@ impl PadSrcInner {
     }
 
     pub async fn push(&self, buffer: gst::Buffer) -> Result<FlowSuccess, FlowError> {
-        gst::log!(RUNTIME_CAT, obj = self.gst_pad, "Pushing {:?}", buffer);
+        gst::log!(RUNTIME_CAT, obj = self.gst_pad, "Pushing {buffer:?}");
 
         let success = self.gst_pad.push(buffer).inspect_err(|&err| {
-            gst::error!(
-                RUNTIME_CAT,
-                obj = self.gst_pad,
-                "Failed to push Buffer to PadSrc: {:?}",
-                err,
-            );
+            if err == gst::FlowError::Flushing {
+                gst::debug!(
+                    RUNTIME_CAT,
+                    obj = self.gst_pad,
+                    "Failed to push Buffer to PadSrc: Flushing"
+                );
+            } else {
+                gst::error!(
+                    RUNTIME_CAT,
+                    obj = self.gst_pad,
+                    "Failed to push Buffer to PadSrc: {err:?}"
+                );
+            }
         })?;
 
         gst::log!(