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

msdkvpp: do not hold too many input buffers in locked list

Browse Source 
If the surface is locked before vpp, upstream takes the reference.
We do not need to take a reference for msdk in vpp.

Part-of: <https://gitlab.freedesktop.org/gstreamer/gst-plugins-bad/-/merge_requests/1490>
This commit is contained in:
Xu Guangxin 2020-08-04 17:14:44 +08:00 committed by Haihao Xiang
parent ea0aac4c19
commit 9123b9ba39
1 changed files with 12 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
sys/msdk/gstmsdkvpp.c
View File

@ -200,9 +200,16 @@ release_msdk_surface (GstMsdkVPP * thiz, MsdkSurface * surface, GList ** list)
} }
static void static void
release_in_surface (GstMsdkVPP * thiz, MsdkSurface * surface) release_in_surface (GstMsdkVPP * thiz, MsdkSurface * surface,
gboolean locked_by_others)
{ {
if (locked_by_others) {
/* mfxFrameSurface1 locked by others, others will hold the surface->buf reference */
/* we are good to release it here */
free_msdk_surface (surface);
} else {
release_msdk_surface (thiz, surface, &thiz->locked_in_surfaces); release_msdk_surface (thiz, surface, &thiz->locked_in_surfaces);
}
} }
static void static void
@ -841,6 +848,7 @@ gst_msdkvpp_transform (GstBaseTransform * trans, GstBuffer * inbuf,
mfxFrameInfo *in_info = NULL; mfxFrameInfo *in_info = NULL;
MsdkSurface *in_surface = NULL; MsdkSurface *in_surface = NULL;
MsdkSurface *out_surface = NULL; MsdkSurface *out_surface = NULL;
gboolean locked_by_others;
timestamp = GST_BUFFER_TIMESTAMP (inbuf); timestamp = GST_BUFFER_TIMESTAMP (inbuf);
free_unlocked_msdk_surfaces (thiz); free_unlocked_msdk_surfaces (thiz);
@ -854,6 +862,7 @@ gst_msdkvpp_transform (GstBaseTransform * trans, GstBuffer * inbuf,
free_msdk_surface (in_surface); free_msdk_surface (in_surface);
return GST_FLOW_ERROR; return GST_FLOW_ERROR;
} }
locked_by_others = ! !in_surface->surface->Data.Locked;
if (gst_msdk_is_msdk_buffer (outbuf)) { if (gst_msdk_is_msdk_buffer (outbuf)) {
out_surface = g_slice_new0 (MsdkSurface); out_surface = g_slice_new0 (MsdkSurface);
@ -944,7 +953,7 @@ error_push_buffer:
gst_flow_get_name (ret)); gst_flow_get_name (ret));
transform_end: transform_end:
release_in_surface (thiz, in_surface); release_in_surface (thiz, in_surface, locked_by_others);
release_out_surface (thiz, out_surface); release_out_surface (thiz, out_surface);
return ret; return ret;