FaSTTUBe/GST-Tensordecoder-ov_ep
37
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

appsrc: Don't leak buffer list while wrongly unreffing buffer on EOS/flushing

Browse Source 
Part-of: <https://gitlab.freedesktop.org/gstreamer/gst-plugins-base/-/merge_requests/1134>
This commit is contained in:
Sebastian Dröge 2021-05-02 20:45:01 +03:00 committed by GStreamer Marge Bot
parent fc7d65b107
commit da9a3da8aa
1 changed files with 12 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
gst-libs/gst/app/gstappsrc.c
View File

@ -2003,16 +2003,24 @@ gst_app_src_push_internal (GstAppSrc * appsrc, GstBuffer * buffer,
flushing: flushing:
{ {
GST_DEBUG_OBJECT (appsrc, "refuse buffer %p, we are flushing", buffer); GST_DEBUG_OBJECT (appsrc, "refuse buffer %p, we are flushing", buffer);
if (steal_ref) if (steal_ref) {
if (buflist)
gst_buffer_list_unref (buflist);
else
gst_buffer_unref (buffer); gst_buffer_unref (buffer);
}
g_mutex_unlock (&priv->mutex); g_mutex_unlock (&priv->mutex);
return GST_FLOW_FLUSHING; return GST_FLOW_FLUSHING;
} }
eos: eos:
{ {
GST_DEBUG_OBJECT (appsrc, "refuse buffer %p, we are EOS", buffer); GST_DEBUG_OBJECT (appsrc, "refuse buffer %p, we are EOS", buffer);
if (steal_ref) if (steal_ref) {
if (buflist)
gst_buffer_list_unref (buflist);
else
gst_buffer_unref (buffer); gst_buffer_unref (buffer);
}
g_mutex_unlock (&priv->mutex); g_mutex_unlock (&priv->mutex);
return GST_FLOW_EOS; return GST_FLOW_EOS;
} }