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

urisourcebin: Configure typefind element for non-streaming uri

Browse source 
To ensure configuring adaptivedemux if needed,
setup typefind element even if uri is not matched to streaming protocol.

https://bugzilla.gnome.org/show_bug.cgi?id=776458
This commit is contained in:
Seungha Yang 2017-01-10 21:52:34 +09:00 committed by Jan Schmidt
parent 5d0628ff52
commit 7bd7b2209a
1 changed files with 34 additions and 16 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

42
gst/playback/gsturisourcebin.c
View file

@ -1901,6 +1901,13 @@ handle_new_pad (GstURISourceBin * urisrc, GstPad * srcpad, GstCaps * caps)
goto could_not_link; goto could_not_link;
gst_element_sync_state_with_parent (urisrc->demuxer); gst_element_sync_state_with_parent (urisrc->demuxer);
} else if (!urisrc->is_stream) {
GstPad *pad;
/* We don't need slot here, expose immediately */
GST_URI_SOURCE_BIN_LOCK (urisrc);
pad = create_output_pad (urisrc, srcpad);
expose_output_pad (urisrc, pad);
GST_URI_SOURCE_BIN_UNLOCK (urisrc);
} else { } else {
OutputSlotInfo *slot; OutputSlotInfo *slot;
@ -1968,11 +1975,11 @@ type_found (GstElement * typefind, guint probability,
gst_object_unref (GST_OBJECT (srcpad)); gst_object_unref (GST_OBJECT (srcpad));
} }
/* setup a streaming source. This will first plug a typefind element to the /* setup typefind for any source. This will first plug a typefind element to the
* source. After we find the type, we decide to whether to plug an adaptive * source. After we find the type, we decide to whether to plug an adaptive
* demuxer, or just link through queue2 and expose the data. */ * demuxer, or just link through queue2 (if needed) and expose the data */
static gboolean static gboolean
setup_streaming (GstURISourceBin * urisrc) setup_typefind (GstURISourceBin * urisrc, GstPad * srcpad)
{ {
GstElement *typefind; GstElement *typefind;
@ -1983,8 +1990,20 @@ setup_streaming (GstURISourceBin * urisrc)
gst_bin_add (GST_BIN_CAST (urisrc), typefind); gst_bin_add (GST_BIN_CAST (urisrc), typefind);
if (!srcpad) {
if (!gst_element_link_pads (urisrc->source, NULL, typefind, "sink")) if (!gst_element_link_pads (urisrc->source, NULL, typefind, "sink"))
goto could_not_link; goto could_not_link;
} else {
GstPad *sinkpad = gst_element_get_static_pad (typefind, "sink");
GstPadLinkReturn ret;
ret = gst_pad_link (srcpad, sinkpad);
gst_object_unref (sinkpad);
if (ret != GST_PAD_LINK_OK)
goto could_not_link;
}
gst_element_sync_state_with_parent (typefind);
urisrc->typefinds = g_list_append (urisrc->typefinds, typefind); urisrc->typefinds = g_list_append (urisrc->typefinds, typefind);
@ -2106,9 +2125,11 @@ source_new_pad (GstElement * element, GstPad * pad, GstURISourceBin * urisrc)
GST_DEBUG_PAD_NAME (pad), GST_ELEMENT_NAME (element)); GST_DEBUG_PAD_NAME (pad), GST_ELEMENT_NAME (element));
caps = gst_pad_get_current_caps (pad); caps = gst_pad_get_current_caps (pad);
if (caps == NULL) if (caps == NULL)
caps = gst_pad_query_caps (pad, NULL); setup_typefind (urisrc, pad);
else {
handle_new_pad (urisrc, pad, caps); handle_new_pad (urisrc, pad, caps);
gst_caps_unref (caps); gst_caps_unref (caps);
}
} }
static gboolean static gboolean
@ -2191,7 +2212,7 @@ setup_source (GstURISourceBin * urisrc)
if (urisrc->is_stream) { if (urisrc->is_stream) {
GST_DEBUG_OBJECT (urisrc, "Setting up streaming"); GST_DEBUG_OBJECT (urisrc, "Setting up streaming");
/* do the stream things here */ /* do the stream things here */
if (!setup_streaming (urisrc)) if (!setup_typefind (urisrc, NULL))
goto streaming_failed; goto streaming_failed;
} else { } else {
GstIterator *pads_iter; GstIterator *pads_iter;
@ -2215,18 +2236,15 @@ setup_source (GstURISourceBin * urisrc)
break; break;
case GST_ITERATOR_OK: case GST_ITERATOR_OK:
pad = g_value_get_object (&item); pad = g_value_get_object (&item);
/* no streaming source, expose pads directly */ if (!setup_typefind (urisrc, pad)) {
GST_URI_SOURCE_BIN_LOCK (urisrc); gst_iterator_free (pads_iter);
pad = create_output_pad (urisrc, pad); goto streaming_failed;
GST_URI_SOURCE_BIN_UNLOCK (urisrc); }
expose_output_pad (urisrc, pad);
g_value_reset (&item); g_value_reset (&item);
break; break;
} }
} }
gst_iterator_free (pads_iter); gst_iterator_free (pads_iter);
gst_element_no_more_pads (GST_ELEMENT_CAST (urisrc));
do_async_done (urisrc);
} }
} }
return TRUE; return TRUE;