mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2024-11-26 19:51:11 +00:00
Code Issues 1 Projects Releases Wiki Activity

urisourcebin: Check for live source when generating element

Browse source 
Instead of at a later stage

Part-of: <https://gitlab.freedesktop.org/gstreamer/gstreamer/-/merge_requests/2784>
This commit is contained in:
Edward Hervey 2022-10-25 10:46:40 +02:00 committed by GStreamer Marge Bot
parent e8f9e17744
commit 638633dea3
1 changed files with 13 additions and 23 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

36
subprojects/gst-plugins-base/gst/playback/gsturisourcebin.c
View file

@ -1526,11 +1526,21 @@ gen_source_element (GstURISourceBin * urisrc)
} }
gst_query_unref (query); gst_query_unref (query);
GST_LOG_OBJECT (urisrc, "source is stream: %d", urisrc->is_stream);
source_class = G_OBJECT_GET_CLASS (source); source_class = G_OBJECT_GET_CLASS (source);
if (urisrc->is_stream) {
/* Live sources are not streamable */
pspec = g_object_class_find_property (source_class, "is-live");
if (pspec && G_PARAM_SPEC_VALUE_TYPE (pspec) == G_TYPE_BOOLEAN) {
gboolean is_live;
g_object_get (G_OBJECT (source), "is-live", &is_live, NULL);
if (is_live)
urisrc->is_stream = FALSE;
}
}
GST_LOG_OBJECT (urisrc, "source is stream: %d", urisrc->is_stream);
pspec = g_object_class_find_property (source_class, "connection-speed"); pspec = g_object_class_find_property (source_class, "connection-speed");
if (pspec != NULL) { if (pspec != NULL) {
guint64 speed = urisrc->connection_speed / 1000; guint64 speed = urisrc->connection_speed / 1000;
@ -2254,23 +2264,6 @@ source_new_pad (GstElement * element, GstPad * pad, GstURISourceBin * urisrc)
} }
} }
static gboolean
is_live_source (GstElement * source)
{
GObjectClass *source_class = NULL;
gboolean is_live = FALSE;
GParamSpec *pspec;
source_class = G_OBJECT_GET_CLASS (source);
pspec = g_object_class_find_property (source_class, "is-live");
if (!pspec || G_PARAM_SPEC_VALUE_TYPE (pspec) != G_TYPE_BOOLEAN)
return FALSE;
g_object_get (G_OBJECT (source), "is-live", &is_live, NULL);
return is_live;
}
/* construct and run the source and demuxer elements until we found /* construct and run the source and demuxer elements until we found
* all the streams or until a preroll queue has been filled. * all the streams or until a preroll queue has been filled.
*/ */
@ -2298,9 +2291,6 @@ setup_source (GstURISourceBin * urisrc)
g_signal_emit (urisrc, gst_uri_source_bin_signals[SIGNAL_SOURCE_SETUP], g_signal_emit (urisrc, gst_uri_source_bin_signals[SIGNAL_SOURCE_SETUP],
0, urisrc->source); 0, urisrc->source);
if (is_live_source (urisrc->source))
urisrc->is_stream = FALSE;
/* see if the source element emits raw audio/video all by itself, /* see if the source element emits raw audio/video all by itself,
* if so, we can create streams for the pads and be done with it. * if so, we can create streams for the pads and be done with it.
* Also check that is has source pads, if not, we assume it will * Also check that is has source pads, if not, we assume it will