mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2024-12-01 06:01:04 +00:00
Code Issues 1 Projects Releases Wiki Activity

Decode as many surfaces as possible in gst_vaapidecode_step().

Browse source
This commit is contained in:
gb 2010-04-30 15:50:19 +00:00 committed by Gwenole Beauchesne
parent a4d201aaf9
commit a556e08e83
1 changed files with 30 additions and 28 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

58
gst/vaapidecode/gstvaapidecode.c
View file

@ -99,35 +99,37 @@ gst_vaapidecode_step(GstVaapiDecode *decode)
GstBuffer *buffer; GstBuffer *buffer;
GstFlowReturn ret; GstFlowReturn ret;
proxy = gst_vaapi_decoder_get_surface(decode->decoder, &status); for (;;) {
if (!proxy) { proxy = gst_vaapi_decoder_get_surface(decode->decoder, &status);
if (status != GST_VAAPI_DECODER_STATUS_ERROR_NO_DATA) if (!proxy) {
goto error_decode; if (status != GST_VAAPI_DECODER_STATUS_ERROR_NO_DATA)
/* More data is needed */ goto error_decode;
return GST_FLOW_OK; /* More data is needed */
break;
}
buffer = NULL;
ret = gst_pad_alloc_buffer(
decode->srcpad,
0, 0,
GST_PAD_CAPS(decode->srcpad),
&buffer
);
if (ret != GST_FLOW_OK || !buffer)
goto error_create_buffer;
GST_BUFFER_TIMESTAMP(buffer) = GST_VAAPI_SURFACE_PROXY_TIMESTAMP(proxy);
gst_vaapi_video_buffer_set_surface_proxy(
GST_VAAPI_VIDEO_BUFFER(buffer),
proxy
);
ret = gst_pad_push(decode->srcpad, buffer);
if (ret != GST_FLOW_OK)
goto error_commit_buffer;
g_object_unref(proxy);
} }
buffer = NULL;
ret = gst_pad_alloc_buffer(
decode->srcpad,
0, 0,
GST_PAD_CAPS(decode->srcpad),
&buffer
);
if (ret != GST_FLOW_OK || !buffer)
goto error_create_buffer;
GST_BUFFER_TIMESTAMP(buffer) = GST_VAAPI_SURFACE_PROXY_TIMESTAMP(proxy);
gst_vaapi_video_buffer_set_surface_proxy(
GST_VAAPI_VIDEO_BUFFER(buffer),
proxy
);
ret = gst_pad_push(decode->srcpad, buffer);
if (ret != GST_FLOW_OK)
goto error_commit_buffer;
g_object_unref(proxy);
return GST_FLOW_OK; return GST_FLOW_OK;
/* ERRORS */ /* ERRORS */