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

uridecodebin: Only add a queue2 for buffering for non-adaptive streaming streams

Browse Source
This commit is contained in:
Sebastian Dröge 2014-02-19 10:06:13 +01:00
parent 89c9e23bfe
commit a2837a22a5
1 changed files with 48 additions and 42 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

90
gst/playback/gsturidecodebin.c
View File

@ -1877,7 +1877,7 @@ static void
type_found (GstElement * typefind, guint probability, type_found (GstElement * typefind, guint probability,
GstCaps * caps, GstURIDecodeBin * decoder) GstCaps * caps, GstURIDecodeBin * decoder)
{ {
GstElement *dec_elem, *queue; GstElement *src_elem, *dec_elem, *queue = NULL;
GstStructure *s; GstStructure *s;
const gchar *media_type; const gchar *media_type;
gboolean do_download = FALSE; gboolean do_download = FALSE;
@ -1901,68 +1901,74 @@ type_found (GstElement * typefind, guint probability,
if (!dec_elem) if (!dec_elem)
goto no_decodebin; goto no_decodebin;
queue = gst_element_factory_make ("queue2", NULL); if (decoder->is_adaptive) {
if (!queue) src_elem = typefind;
goto no_queue2; } else {
queue = gst_element_factory_make ("queue2", NULL);
if (!queue)
goto no_queue2;
g_object_set (queue, "use-buffering", TRUE, NULL); g_object_set (queue, "use-buffering", TRUE, NULL);
g_object_set (queue, "ring-buffer-max-size", decoder->ring_buffer_max_size, g_object_set (queue, "ring-buffer-max-size", decoder->ring_buffer_max_size,
NULL); NULL);
decoder->queue = queue; decoder->queue = queue;
GST_DEBUG_OBJECT (decoder, "check media-type %s, %d", media_type, GST_DEBUG_OBJECT (decoder, "check media-type %s, %d", media_type,
do_download); do_download);
if (do_download) { if (do_download) {
gchar *temp_template, *filename; gchar *temp_template, *filename;
const gchar *tmp_dir, *prgname; const gchar *tmp_dir, *prgname;
tmp_dir = g_get_user_cache_dir (); tmp_dir = g_get_user_cache_dir ();
prgname = g_get_prgname (); prgname = g_get_prgname ();
if (prgname == NULL) if (prgname == NULL)
prgname = "GStreamer"; prgname = "GStreamer";
filename = g_strdup_printf ("%s-XXXXXX", prgname); filename = g_strdup_printf ("%s-XXXXXX", prgname);
/* build our filename */ /* build our filename */
temp_template = g_build_filename (tmp_dir, filename, NULL); temp_template = g_build_filename (tmp_dir, filename, NULL);
GST_DEBUG_OBJECT (decoder, "enable download buffering in %s (%s, %s, %s)", GST_DEBUG_OBJECT (decoder, "enable download buffering in %s (%s, %s, %s)",
temp_template, tmp_dir, prgname, filename); temp_template, tmp_dir, prgname, filename);
/* configure progressive download for selected media types */ /* configure progressive download for selected media types */
g_object_set (queue, "temp-template", temp_template, NULL); g_object_set (queue, "temp-template", temp_template, NULL);
g_free (filename); g_free (filename);
g_free (temp_template); g_free (temp_template);
}
/* Disable max-size-buffers */
g_object_set (queue, "max-size-buffers", 0, NULL);
/* If buffer size or duration are set, set them on the queue2 element */
if (decoder->buffer_size != -1)
g_object_set (queue, "max-size-bytes", decoder->buffer_size, NULL);
if (decoder->buffer_duration != -1)
g_object_set (queue, "max-size-time", decoder->buffer_duration, NULL);
gst_bin_add (GST_BIN_CAST (decoder), queue);
if (!gst_element_link_pads (typefind, "src", queue, "sink"))
goto could_not_link;
src_elem = queue;
} }
/* Disable max-size-buffers */
g_object_set (queue, "max-size-buffers", 0, NULL);
/* If buffer size or duration are set, set them on the queue2 element */
if (decoder->buffer_size != -1)
g_object_set (queue, "max-size-bytes", decoder->buffer_size, NULL);
if (decoder->buffer_duration != -1)
g_object_set (queue, "max-size-time", decoder->buffer_duration, NULL);
gst_bin_add (GST_BIN_CAST (decoder), queue);
if (!gst_element_link_pads (typefind, "src", queue, "sink"))
goto could_not_link;
/* to force caps on the decodebin element and avoid reparsing stuff by /* to force caps on the decodebin element and avoid reparsing stuff by
* typefind. It also avoids a deadlock in the way typefind activates pads in * typefind. It also avoids a deadlock in the way typefind activates pads in
* the state change */ * the state change */
g_object_set (dec_elem, "sink-caps", caps, NULL); g_object_set (dec_elem, "sink-caps", caps, NULL);
if (!gst_element_link_pads (queue, "src", dec_elem, "sink")) if (!gst_element_link_pads (src_elem, "src", dec_elem, "sink"))
goto could_not_link; goto could_not_link;
/* PLAYING in one go might fail (see bug #632782) */ /* PLAYING in one go might fail (see bug #632782) */
gst_element_set_state (dec_elem, GST_STATE_PAUSED); gst_element_set_state (dec_elem, GST_STATE_PAUSED);
gst_element_set_state (dec_elem, GST_STATE_PLAYING); gst_element_set_state (dec_elem, GST_STATE_PLAYING);
gst_element_set_state (queue, GST_STATE_PLAYING); if (queue)
gst_element_set_state (queue, GST_STATE_PLAYING);
do_async_done (decoder); do_async_done (decoder);