mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2025-04-14 03:54:11 +00:00
Code Issues 1 Projects Releases Wiki Activity

Fix VC-1 decoding through the playbin2 pipeline.

Browse source
This commit is contained in:
gb 2010-05-16 21:04:32 +00:00 committed by Gwenole Beauchesne
parent 86d0b2ade9
commit adfed50a90
3 changed files with 57 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
NEWS
View file

@ -3,6 +3,7 @@ Copyright (C) 2010 Splitted-Desktop Systems
Version 0.2.3 - DD.May.2010
* Fix memory leak of encoded buffers
* Fix VC-1 decoding through the playbin2 pipeline
Version 0.2.2 - 14.May.2010
* Fix packaging dependencies

59
gst/vaapidecode/gstvaapidecode.c
View file

@ -93,6 +93,14 @@ enum {
PROP_USE_FFMPEG,
};
static void
gst_vaapidecode_release(GstVaapiDecode *decode, GObject *dead_object)
{
g_mutex_lock(decode->decoder_mutex);
g_cond_signal(decode->decoder_ready);
g_mutex_unlock(decode->decoder_mutex);
}
static GstFlowReturn
gst_vaapidecode_step(GstVaapiDecode *decode)
{
@ -104,12 +112,32 @@ gst_vaapidecode_step(GstVaapiDecode *decode)
for (;;) {
proxy = gst_vaapi_decoder_get_surface(decode->decoder, &status);
if (!proxy) {
if (status == GST_VAAPI_DECODER_STATUS_ERROR_NO_SURFACE) {
/* Wait for a VA surface to be displayed and free'd */
GTimeVal timeout;
g_get_current_time(&timeout);
g_time_val_add(&timeout, 100);
g_mutex_lock(decode->decoder_mutex);
g_cond_timed_wait(
decode->decoder_ready,
decode->decoder_mutex,
&timeout
);
g_mutex_unlock(decode->decoder_mutex);
continue;
}
if (status != GST_VAAPI_DECODER_STATUS_ERROR_NO_DATA)
goto error_decode;
/* More data is needed */
break;
}
g_object_weak_ref(
G_OBJECT(proxy),
(GWeakNotify)gst_vaapidecode_release,
decode
);
buffer = NULL;
ret = gst_pad_alloc_buffer(
decode->srcpad,
@ -179,6 +207,14 @@ gst_vaapidecode_create(GstVaapiDecode *decode, GstCaps *caps)
if (!gst_vaapidecode_ensure_display(decode))
return FALSE;
decode->decoder_mutex = g_mutex_new();
if (!decode->decoder_mutex)
return FALSE;
decode->decoder_ready = g_cond_new();
if (!decode->decoder_ready)
return FALSE;
if (decode->use_ffmpeg)
decode->decoder = gst_vaapi_decoder_ffmpeg_new(decode->display, caps);
if (!decode->decoder)
@ -191,6 +227,17 @@ gst_vaapidecode_create(GstVaapiDecode *decode, GstCaps *caps)
static void
gst_vaapidecode_destroy(GstVaapiDecode *decode)
{
if (decode->decoder_ready) {
gst_vaapidecode_release(decode, NULL);
g_cond_free(decode->decoder_ready);
decode->decoder_ready = NULL;
}
if (decode->decoder_mutex) {
g_mutex_free(decode->decoder_mutex);
decode->decoder_mutex = NULL;
}
if (decode->decoder) {
gst_vaapi_decoder_put_buffer(decode->decoder, NULL);
g_object_unref(decode->decoder);
@ -513,11 +560,13 @@ gst_vaapidecode_init(GstVaapiDecode *decode, GstVaapiDecodeClass *klass)
{
GstElementClass * const element_class = GST_ELEMENT_CLASS(klass);
decode->display = NULL;
decode->decoder = NULL;
decode->decoder_caps = NULL;
decode->allowed_caps = NULL;
decode->use_ffmpeg = TRUE;
decode->display = NULL;
decode->decoder = NULL;
decode->decoder_mutex = NULL;
decode->decoder_ready = NULL;
decode->decoder_caps = NULL;
decode->allowed_caps = NULL;
decode->use_ffmpeg = TRUE;
/* Pad through which data comes in to the element */
decode->sinkpad = gst_pad_new_from_template(

2
gst/vaapidecode/gstvaapidecode.h
View file

@ -63,6 +63,8 @@ struct _GstVaapiDecode {
GstPad *srcpad;
GstVaapiDisplay *display;
GstVaapiDecoder *decoder;
GMutex *decoder_mutex;
GCond *decoder_ready;
GstCaps *decoder_caps;
GstCaps *allowed_caps;
unsigned int use_ffmpeg : 1;