mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2025-01-19 13:55:41 +00:00
Code Issues 1 Projects Releases Wiki Activity

bin: keep the element flags up-to-date

Browse source 
Keep the require/provide_clock flags up to date.
This commit is contained in:
Wim Taymans 2011-11-29 15:53:01 +01:00
parent 9d6b8d14c3
commit 09514f251e
1 changed files with 35 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

39
gst/gstbin.c
View file

@ -1045,7 +1045,7 @@ gst_bin_add_func (GstBin * bin, GstElement * element)
{ {
gchar *elem_name; gchar *elem_name;
GstIterator *it; GstIterator *it;
gboolean is_sink, is_source, provides_clock; gboolean is_sink, is_source, provides_clock, requires_clock;
GstMessage *clock_message = NULL, *async_message = NULL; GstMessage *clock_message = NULL, *async_message = NULL;
GstStateChangeReturn ret; GstStateChangeReturn ret;
@ -1062,6 +1062,8 @@ gst_bin_add_func (GstBin * bin, GstElement * element)
is_source = GST_OBJECT_FLAG_IS_SET (element, GST_ELEMENT_FLAG_SOURCE); is_source = GST_OBJECT_FLAG_IS_SET (element, GST_ELEMENT_FLAG_SOURCE);
provides_clock = provides_clock =
GST_OBJECT_FLAG_IS_SET (element, GST_ELEMENT_FLAG_PROVIDE_CLOCK); GST_OBJECT_FLAG_IS_SET (element, GST_ELEMENT_FLAG_PROVIDE_CLOCK);
requires_clock =
GST_OBJECT_FLAG_IS_SET (element, GST_ELEMENT_FLAG_REQUIRE_CLOCK);
GST_OBJECT_UNLOCK (element); GST_OBJECT_UNLOCK (element);
GST_OBJECT_LOCK (bin); GST_OBJECT_LOCK (bin);
@ -1093,6 +1095,11 @@ gst_bin_add_func (GstBin * bin, GstElement * element)
GST_DEBUG_OBJECT (bin, "element \"%s\" can provide a clock", elem_name); GST_DEBUG_OBJECT (bin, "element \"%s\" can provide a clock", elem_name);
clock_message = clock_message =
gst_message_new_clock_provide (GST_OBJECT_CAST (element), NULL, TRUE); gst_message_new_clock_provide (GST_OBJECT_CAST (element), NULL, TRUE);
GST_OBJECT_FLAG_SET (bin, GST_ELEMENT_FLAG_PROVIDE_CLOCK);
}
if (requires_clock) {
GST_DEBUG_OBJECT (bin, "element \"%s\" requires a clock", elem_name);
GST_OBJECT_FLAG_SET (bin, GST_ELEMENT_FLAG_REQUIRE_CLOCK);
} }
bin->children = g_list_prepend (bin->children, element); bin->children = g_list_prepend (bin->children, element);
@ -1257,7 +1264,8 @@ gst_bin_remove_func (GstBin * bin, GstElement * element)
{ {
gchar *elem_name; gchar *elem_name;
GstIterator *it; GstIterator *it;
gboolean is_sink, is_source, othersink, othersource, found; gboolean is_sink, is_source, provides_clock, requires_clock;
gboolean othersink, othersource, otherprovider, otherrequirer, found;
GstMessage *clock_message = NULL; GstMessage *clock_message = NULL;
GstClock **provided_clock_p; GstClock **provided_clock_p;
GstElement **clock_provider_p; GstElement **clock_provider_p;
@ -1279,6 +1287,10 @@ gst_bin_remove_func (GstBin * bin, GstElement * element)
elem_name = g_strdup (GST_ELEMENT_NAME (element)); elem_name = g_strdup (GST_ELEMENT_NAME (element));
is_sink = GST_OBJECT_FLAG_IS_SET (element, GST_ELEMENT_FLAG_SINK); is_sink = GST_OBJECT_FLAG_IS_SET (element, GST_ELEMENT_FLAG_SINK);
is_source = GST_OBJECT_FLAG_IS_SET (element, GST_ELEMENT_FLAG_SOURCE); is_source = GST_OBJECT_FLAG_IS_SET (element, GST_ELEMENT_FLAG_SOURCE);
provides_clock =
GST_OBJECT_FLAG_IS_SET (element, GST_ELEMENT_FLAG_PROVIDE_CLOCK);
requires_clock =
GST_OBJECT_FLAG_IS_SET (element, GST_ELEMENT_FLAG_REQUIRE_CLOCK);
GST_OBJECT_UNLOCK (element); GST_OBJECT_UNLOCK (element);
/* unlink all linked pads */ /* unlink all linked pads */
@ -1290,6 +1302,8 @@ gst_bin_remove_func (GstBin * bin, GstElement * element)
found = FALSE; found = FALSE;
othersink = FALSE; othersink = FALSE;
othersource = FALSE; othersource = FALSE;
otherprovider = FALSE;
otherrequirer = FALSE;
have_no_preroll = FALSE; have_no_preroll = FALSE;
/* iterate the elements, we collect which ones are async and no_preroll. We /* iterate the elements, we collect which ones are async and no_preroll. We
* also remove the element when we find it. */ * also remove the element when we find it. */
@ -1303,16 +1317,24 @@ gst_bin_remove_func (GstBin * bin, GstElement * element)
/* remove the element */ /* remove the element */
bin->children = g_list_delete_link (bin->children, walk); bin->children = g_list_delete_link (bin->children, walk);
} else { } else {
gboolean child_sink, child_source; gboolean child_sink, child_source, child_provider, child_requirer;
GST_OBJECT_LOCK (child); GST_OBJECT_LOCK (child);
child_sink = GST_OBJECT_FLAG_IS_SET (child, GST_ELEMENT_FLAG_SINK); child_sink = GST_OBJECT_FLAG_IS_SET (child, GST_ELEMENT_FLAG_SINK);
child_source = GST_OBJECT_FLAG_IS_SET (child, GST_ELEMENT_FLAG_SOURCE); child_source = GST_OBJECT_FLAG_IS_SET (child, GST_ELEMENT_FLAG_SOURCE);
child_provider =
GST_OBJECT_FLAG_IS_SET (child, GST_ELEMENT_FLAG_PROVIDE_CLOCK);
child_requirer =
GST_OBJECT_FLAG_IS_SET (child, GST_ELEMENT_FLAG_REQUIRE_CLOCK);
/* when we remove a sink, check if there are other sinks. */ /* when we remove a sink, check if there are other sinks. */
if (is_sink && !othersink && child_sink) if (is_sink && !othersink && child_sink)
othersink = TRUE; othersink = TRUE;
if (is_source && !othersource && child_source) if (is_source && !othersource && child_source)
othersource = TRUE; othersource = TRUE;
if (provides_clock && !otherprovider && child_provider)
otherprovider = TRUE;
if (requires_clock && !otherrequirer && child_requirer)
otherrequirer = TRUE;
/* check if we have NO_PREROLL children */ /* check if we have NO_PREROLL children */
if (GST_STATE_RETURN (child) == GST_STATE_CHANGE_NO_PREROLL) if (GST_STATE_RETURN (child) == GST_STATE_CHANGE_NO_PREROLL)
have_no_preroll = TRUE; have_no_preroll = TRUE;
@ -1340,7 +1362,16 @@ gst_bin_remove_func (GstBin * bin, GstElement * element)
GST_DEBUG_OBJECT (bin, "we removed the last source"); GST_DEBUG_OBJECT (bin, "we removed the last source");
GST_OBJECT_FLAG_UNSET (bin, GST_ELEMENT_FLAG_SOURCE); GST_OBJECT_FLAG_UNSET (bin, GST_ELEMENT_FLAG_SOURCE);
} }
if (provides_clock && !otherprovider) {
/* we're not a clock provider anymore */
GST_DEBUG_OBJECT (bin, "we removed the last clock provider");
GST_OBJECT_FLAG_UNSET (bin, GST_ELEMENT_FLAG_PROVIDE_CLOCK);
}
if (requires_clock && !otherrequirer) {
/* we're not a clock requirer anymore */
GST_DEBUG_OBJECT (bin, "we removed the last clock requirer");
GST_OBJECT_FLAG_UNSET (bin, GST_ELEMENT_FLAG_REQUIRE_CLOCK);
}
/* if the clock provider for this element is removed, we lost /* if the clock provider for this element is removed, we lost
* the clock as well, we need to inform the parent of this * the clock as well, we need to inform the parent of this