2000-12-28 22:12:02 +00:00
|
|
|
/* GStreamer
|
|
|
|
* Copyright (C) 1999,2000 Erik Walthinsen <omega@cse.ogi.edu>
|
|
|
|
* 2000 Wim Taymans <wtay@chello.be>
|
|
|
|
*
|
|
|
|
* gstbin.c: GstBin container object and support code
|
2000-01-30 09:03:00 +00:00
|
|
|
*
|
|
|
|
* This library is free software; you can redistribute it and/or
|
|
|
|
* modify it under the terms of the GNU Library General Public
|
|
|
|
* License as published by the Free Software Foundation; either
|
|
|
|
* version 2 of the License, or (at your option) any later version.
|
|
|
|
*
|
|
|
|
* This library is distributed in the hope that it will be useful,
|
|
|
|
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
|
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
|
|
|
|
* Library General Public License for more details.
|
|
|
|
*
|
|
|
|
* You should have received a copy of the GNU Library General Public
|
|
|
|
* License along with this library; if not, write to the
|
|
|
|
* Free Software Foundation, Inc., 59 Temple Place - Suite 330,
|
|
|
|
* Boston, MA 02111-1307, USA.
|
|
|
|
*/
|
|
|
|
|
2000-12-29 19:45:45 +00:00
|
|
|
//#define GST_DEBUG_ENABLED
|
2000-12-28 22:12:02 +00:00
|
|
|
#include "gst_private.h"
|
2000-12-08 18:24:16 +00:00
|
|
|
|
2000-12-15 01:57:34 +00:00
|
|
|
#include "gstbin.h"
|
2000-08-21 21:20:38 +00:00
|
|
|
|
2000-12-26 23:51:04 +00:00
|
|
|
#include "gstscheduler.h"
|
|
|
|
|
2001-01-20 03:10:44 +00:00
|
|
|
GstElementDetails gst_bin_details = {
|
2000-01-30 09:03:00 +00:00
|
|
|
"Generic bin",
|
|
|
|
"Bin",
|
|
|
|
"Simple container object",
|
|
|
|
VERSION,
|
|
|
|
"Erik Walthinsen <omega@cse.ogi.edu>",
|
|
|
|
"(C) 1999",
|
|
|
|
};
|
|
|
|
|
2001-10-21 18:00:31 +00:00
|
|
|
GType _gst_bin_type = 0;
|
2000-01-30 09:03:00 +00:00
|
|
|
|
2001-09-28 19:16:02 +00:00
|
|
|
static void gst_bin_dispose (GObject *object);
|
2000-01-30 09:03:00 +00:00
|
|
|
|
2001-01-20 03:10:44 +00:00
|
|
|
static GstElementStateReturn gst_bin_change_state (GstElement *element);
|
|
|
|
static GstElementStateReturn gst_bin_change_state_norecurse (GstBin *bin);
|
|
|
|
static gboolean gst_bin_change_state_type (GstBin *bin,
|
|
|
|
GstElementState state,
|
2001-06-25 01:20:11 +00:00
|
|
|
GType type);
|
2001-12-04 22:12:50 +00:00
|
|
|
static void gst_bin_child_state_change (GstBin *bin, GstElementState old,
|
|
|
|
GstElementState new, GstElement *child);
|
2000-01-30 09:03:00 +00:00
|
|
|
|
2001-01-20 17:59:25 +00:00
|
|
|
static gboolean gst_bin_iterate_func (GstBin *bin);
|
2000-01-30 09:03:00 +00:00
|
|
|
|
2001-06-25 06:45:56 +00:00
|
|
|
#ifndef GST_DISABLE_LOADSAVE
|
2001-01-29 00:06:02 +00:00
|
|
|
static xmlNodePtr gst_bin_save_thyself (GstObject *object, xmlNodePtr parent);
|
|
|
|
static void gst_bin_restore_thyself (GstObject *object, xmlNodePtr self);
|
2001-06-24 21:18:28 +00:00
|
|
|
#endif
|
2000-01-30 09:03:00 +00:00
|
|
|
|
|
|
|
/* Bin signals and args */
|
|
|
|
enum {
|
|
|
|
OBJECT_ADDED,
|
|
|
|
LAST_SIGNAL
|
|
|
|
};
|
|
|
|
|
|
|
|
enum {
|
|
|
|
ARG_0,
|
|
|
|
/* FILL ME */
|
|
|
|
};
|
|
|
|
|
|
|
|
|
2000-11-04 18:54:07 +00:00
|
|
|
static void gst_bin_class_init (GstBinClass *klass);
|
|
|
|
static void gst_bin_init (GstBin *bin);
|
2000-01-30 09:03:00 +00:00
|
|
|
|
|
|
|
|
|
|
|
static GstElementClass *parent_class = NULL;
|
|
|
|
static guint gst_bin_signals[LAST_SIGNAL] = { 0 };
|
|
|
|
|
2001-06-25 01:20:11 +00:00
|
|
|
GType
|
2001-01-20 03:10:44 +00:00
|
|
|
gst_bin_get_type (void)
|
2000-11-04 18:54:07 +00:00
|
|
|
{
|
2001-10-21 18:00:31 +00:00
|
|
|
if (!_gst_bin_type) {
|
2001-06-25 01:20:11 +00:00
|
|
|
static const GTypeInfo bin_info = {
|
2000-01-30 09:03:00 +00:00
|
|
|
sizeof(GstBinClass),
|
2001-06-25 01:20:11 +00:00
|
|
|
NULL,
|
|
|
|
NULL,
|
|
|
|
(GClassInitFunc)gst_bin_class_init,
|
|
|
|
NULL,
|
|
|
|
NULL,
|
|
|
|
sizeof(GstBin),
|
|
|
|
8,
|
|
|
|
(GInstanceInitFunc)gst_bin_init,
|
2001-09-14 22:16:47 +00:00
|
|
|
NULL
|
2000-01-30 09:03:00 +00:00
|
|
|
};
|
2001-10-21 18:00:31 +00:00
|
|
|
_gst_bin_type = g_type_register_static (GST_TYPE_ELEMENT, "GstBin", &bin_info, 0);
|
2000-01-30 09:03:00 +00:00
|
|
|
}
|
2001-10-21 18:00:31 +00:00
|
|
|
return _gst_bin_type;
|
2000-01-30 09:03:00 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
static void
|
2001-01-20 03:10:44 +00:00
|
|
|
gst_bin_class_init (GstBinClass *klass)
|
2000-11-04 18:54:07 +00:00
|
|
|
{
|
2001-06-25 01:20:11 +00:00
|
|
|
GObjectClass *gobject_class;
|
2001-01-29 00:06:02 +00:00
|
|
|
GstObjectClass *gstobject_class;
|
2000-01-30 09:03:00 +00:00
|
|
|
GstElementClass *gstelement_class;
|
|
|
|
|
2001-06-25 01:20:11 +00:00
|
|
|
gobject_class = (GObjectClass*)klass;
|
2001-01-29 00:06:02 +00:00
|
|
|
gstobject_class = (GstObjectClass*)klass;
|
2000-01-30 09:03:00 +00:00
|
|
|
gstelement_class = (GstElementClass*)klass;
|
|
|
|
|
2001-06-25 01:20:11 +00:00
|
|
|
parent_class = g_type_class_ref (GST_TYPE_ELEMENT);
|
2000-01-30 09:03:00 +00:00
|
|
|
|
|
|
|
gst_bin_signals[OBJECT_ADDED] =
|
2001-08-13 19:00:13 +00:00
|
|
|
g_signal_new ("object_added", G_TYPE_FROM_CLASS(klass), G_SIGNAL_RUN_FIRST,
|
2001-06-25 01:20:11 +00:00
|
|
|
G_STRUCT_OFFSET (GstBinClass, object_added), NULL, NULL,
|
2001-09-13 20:13:51 +00:00
|
|
|
gst_marshal_VOID__OBJECT, G_TYPE_NONE, 1,
|
2000-11-04 18:54:07 +00:00
|
|
|
GST_TYPE_ELEMENT);
|
|
|
|
|
2001-10-17 10:21:27 +00:00
|
|
|
klass->change_state_type = GST_DEBUG_FUNCPTR (gst_bin_change_state_type);
|
|
|
|
klass->iterate = GST_DEBUG_FUNCPTR (gst_bin_iterate_func);
|
2000-11-04 18:54:07 +00:00
|
|
|
|
2001-06-25 06:45:56 +00:00
|
|
|
#ifndef GST_DISABLE_LOADSAVE
|
2001-10-17 10:21:27 +00:00
|
|
|
gstobject_class->save_thyself = GST_DEBUG_FUNCPTR (gst_bin_save_thyself);
|
|
|
|
gstobject_class->restore_thyself = GST_DEBUG_FUNCPTR (gst_bin_restore_thyself);
|
2001-06-24 21:18:28 +00:00
|
|
|
#endif
|
2001-01-29 00:06:02 +00:00
|
|
|
|
2001-10-17 10:21:27 +00:00
|
|
|
gstelement_class->change_state = GST_DEBUG_FUNCPTR (gst_bin_change_state);
|
|
|
|
|
|
|
|
gobject_class->dispose = GST_DEBUG_FUNCPTR (gst_bin_dispose);
|
2000-01-30 09:03:00 +00:00
|
|
|
}
|
|
|
|
|
2001-01-20 03:10:44 +00:00
|
|
|
static void
|
|
|
|
gst_bin_init (GstBin *bin)
|
2000-11-04 18:54:07 +00:00
|
|
|
{
|
2000-12-20 09:39:43 +00:00
|
|
|
// in general, we prefer to use cothreads for most things
|
|
|
|
GST_FLAG_SET (bin, GST_BIN_FLAG_PREFER_COTHREADS);
|
|
|
|
|
2000-01-30 09:03:00 +00:00
|
|
|
bin->numchildren = 0;
|
|
|
|
bin->children = NULL;
|
2001-01-13 13:51:08 +00:00
|
|
|
bin->eos_providers = NULL;
|
2001-01-20 17:59:25 +00:00
|
|
|
bin->num_eos_providers = 0;
|
2001-01-21 16:06:42 +00:00
|
|
|
bin->eoscond = g_cond_new ();
|
2000-01-30 09:03:00 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* gst_bin_new:
|
|
|
|
* @name: name of new bin
|
|
|
|
*
|
|
|
|
* Create a new bin with given name.
|
|
|
|
*
|
|
|
|
* Returns: new bin
|
|
|
|
*/
|
2000-11-04 18:54:07 +00:00
|
|
|
GstElement*
|
2001-01-20 03:10:44 +00:00
|
|
|
gst_bin_new (const gchar *name)
|
2000-11-04 18:54:07 +00:00
|
|
|
{
|
2000-12-22 23:23:10 +00:00
|
|
|
return gst_elementfactory_make ("bin", name);
|
2000-01-30 09:03:00 +00:00
|
|
|
}
|
|
|
|
|
2001-05-25 21:00:07 +00:00
|
|
|
static inline void
|
2001-12-04 22:12:50 +00:00
|
|
|
gst_bin_reset_element_sched (GstElement *element, GstScheduler *sched)
|
2001-05-25 21:00:07 +00:00
|
|
|
{
|
|
|
|
GST_INFO_ELEMENT (GST_CAT_PARENTAGE, element, "resetting element's scheduler");
|
|
|
|
|
|
|
|
gst_element_set_sched (element,sched);
|
|
|
|
}
|
|
|
|
|
2001-09-14 22:16:47 +00:00
|
|
|
static void
|
2001-12-04 22:12:50 +00:00
|
|
|
gst_bin_set_element_sched (GstElement *element,GstScheduler *sched)
|
2001-05-25 21:00:07 +00:00
|
|
|
{
|
|
|
|
GList *children;
|
|
|
|
GstElement *child;
|
|
|
|
|
|
|
|
g_return_if_fail (element != NULL);
|
|
|
|
g_return_if_fail (GST_IS_ELEMENT(element));
|
|
|
|
g_return_if_fail (sched != NULL);
|
2001-12-04 22:12:50 +00:00
|
|
|
g_return_if_fail (GST_IS_SCHEDULER(sched));
|
2001-05-25 21:00:07 +00:00
|
|
|
|
|
|
|
GST_INFO (GST_CAT_SCHEDULING, "setting element \"%s\" sched to %p",GST_ELEMENT_NAME(element),
|
|
|
|
sched);
|
|
|
|
|
|
|
|
// if it's actually a Bin
|
|
|
|
if (GST_IS_BIN(element)) {
|
2001-12-04 22:12:50 +00:00
|
|
|
if (GST_FLAG_IS_SET (element, GST_BIN_FLAG_MANAGER)) {
|
2001-05-25 21:00:07 +00:00
|
|
|
GST_INFO_ELEMENT (GST_CAT_PARENTAGE, element, "child is already a manager, not resetting");
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
GST_INFO_ELEMENT (GST_CAT_PARENTAGE, element, "setting children's schedule to parent's");
|
2001-12-04 22:12:50 +00:00
|
|
|
gst_scheduler_add_element (sched, element);
|
2001-05-25 21:00:07 +00:00
|
|
|
|
|
|
|
// set the children's schedule
|
|
|
|
children = GST_BIN(element)->children;
|
|
|
|
while (children) {
|
|
|
|
child = GST_ELEMENT (children->data);
|
|
|
|
children = g_list_next(children);
|
|
|
|
|
|
|
|
gst_bin_set_element_sched (child, sched);
|
|
|
|
}
|
|
|
|
|
|
|
|
// otherwise, if it's just a regular old element
|
|
|
|
} else {
|
2001-12-04 22:12:50 +00:00
|
|
|
gst_scheduler_add_element (sched, element);
|
2001-05-25 21:00:07 +00:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
2001-09-14 22:16:47 +00:00
|
|
|
static void
|
2001-05-25 21:00:07 +00:00
|
|
|
gst_bin_unset_element_sched (GstElement *element)
|
|
|
|
{
|
|
|
|
GList *children;
|
|
|
|
GstElement *child;
|
|
|
|
|
|
|
|
g_return_if_fail (element != NULL);
|
|
|
|
g_return_if_fail (GST_IS_ELEMENT(element));
|
|
|
|
|
|
|
|
GST_INFO (GST_CAT_SCHEDULING, "removing element \"%s\" from it sched %p",
|
|
|
|
GST_ELEMENT_NAME(element),GST_ELEMENT_SCHED(element));
|
|
|
|
|
|
|
|
// if it's actually a Bin
|
|
|
|
if (GST_IS_BIN(element)) {
|
|
|
|
|
|
|
|
if (GST_FLAG_IS_SET(element,GST_BIN_FLAG_MANAGER)) {
|
|
|
|
GST_INFO_ELEMENT (GST_CAT_PARENTAGE, element, "child is already a manager, not unsetting sched");
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
// FIXME this check should be irrelevant
|
|
|
|
if (GST_ELEMENT_SCHED (element))
|
2001-12-04 22:12:50 +00:00
|
|
|
gst_scheduler_remove_element (GST_ELEMENT_SCHED(element), element);
|
2001-05-25 21:00:07 +00:00
|
|
|
|
|
|
|
// for each child, remove them from their schedule
|
|
|
|
children = GST_BIN(element)->children;
|
|
|
|
while (children) {
|
|
|
|
child = GST_ELEMENT (children->data);
|
|
|
|
children = g_list_next(children);
|
|
|
|
|
|
|
|
gst_bin_unset_element_sched (child);
|
|
|
|
}
|
|
|
|
|
|
|
|
// otherwise, if it's just a regular old element
|
|
|
|
} else {
|
|
|
|
// FIXME this check should be irrelevant
|
|
|
|
if (GST_ELEMENT_SCHED (element))
|
2001-12-04 22:12:50 +00:00
|
|
|
gst_scheduler_remove_element (GST_ELEMENT_SCHED(element), element);
|
2001-05-25 21:00:07 +00:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
2000-01-30 09:03:00 +00:00
|
|
|
/**
|
|
|
|
* gst_bin_add:
|
|
|
|
* @bin: #GstBin to add element to
|
|
|
|
* @element: #GstElement to add to bin
|
|
|
|
*
|
|
|
|
* Add the given element to the bin. Set the elements parent, and thus
|
|
|
|
* add a reference.
|
|
|
|
*/
|
2001-01-20 03:10:44 +00:00
|
|
|
void
|
|
|
|
gst_bin_add (GstBin *bin,
|
|
|
|
GstElement *element)
|
2000-11-04 18:54:07 +00:00
|
|
|
{
|
2001-12-10 18:08:35 +00:00
|
|
|
gint state_idx = 0;
|
|
|
|
GstElementState state;
|
|
|
|
|
2000-11-04 18:54:07 +00:00
|
|
|
g_return_if_fail (bin != NULL);
|
|
|
|
g_return_if_fail (GST_IS_BIN (bin));
|
|
|
|
g_return_if_fail (element != NULL);
|
|
|
|
g_return_if_fail (GST_IS_ELEMENT (element));
|
2000-01-30 09:03:00 +00:00
|
|
|
|
2001-05-25 21:00:07 +00:00
|
|
|
GST_DEBUG (GST_CAT_PARENTAGE, "adding element \"%s\" to bin \"%s\"\n",
|
2001-12-04 22:12:50 +00:00
|
|
|
GST_ELEMENT_NAME (element), GST_ELEMENT_NAME (bin));
|
2001-05-25 21:00:07 +00:00
|
|
|
|
|
|
|
// must be not be in PLAYING state in order to modify bin
|
2001-12-04 22:12:50 +00:00
|
|
|
g_return_if_fail (GST_STATE (bin) != GST_STATE_PLAYING);
|
2001-05-25 21:00:07 +00:00
|
|
|
|
|
|
|
// the element must not already have a parent
|
2001-12-04 22:12:50 +00:00
|
|
|
g_return_if_fail (GST_ELEMENT_PARENT (element) == NULL);
|
2001-05-25 21:00:07 +00:00
|
|
|
|
|
|
|
// then check to see if the element's name is already taken in the bin
|
2001-12-04 22:12:50 +00:00
|
|
|
g_return_if_fail (gst_object_check_uniqueness (bin->children, GST_ELEMENT_NAME (element)) == TRUE);
|
2000-07-17 17:14:15 +00:00
|
|
|
|
2001-05-25 21:00:07 +00:00
|
|
|
// set the element's parent and add the element to the bin's list of children
|
|
|
|
gst_object_set_parent (GST_OBJECT (element), GST_OBJECT (bin));
|
2001-12-04 22:12:50 +00:00
|
|
|
g_signal_connect_object (G_OBJECT (element), "state_change", gst_bin_child_state_change, G_OBJECT (bin));
|
|
|
|
|
2000-11-04 18:54:07 +00:00
|
|
|
bin->children = g_list_append (bin->children, element);
|
2000-01-30 09:03:00 +00:00
|
|
|
bin->numchildren++;
|
|
|
|
|
2001-12-10 18:08:35 +00:00
|
|
|
// bump our internal state counter
|
|
|
|
state = GST_STATE (element);
|
|
|
|
while (state>>=1) state_idx++;
|
|
|
|
bin->child_states[state_idx]++;
|
|
|
|
|
2001-05-25 21:00:07 +00:00
|
|
|
///// now we have to deal with manager stuff
|
|
|
|
// we can only do this if there's a scheduler:
|
|
|
|
// if we're not a manager, and aren't attached to anything, we have no sched (yet)
|
2001-12-04 22:12:50 +00:00
|
|
|
if (GST_IS_BIN(element) && GST_FLAG_IS_SET (element, GST_BIN_FLAG_MANAGER)) {
|
|
|
|
GST_INFO_ELEMENT (GST_CAT_PARENTAGE, element, "child is a manager");
|
|
|
|
}
|
|
|
|
else if (GST_ELEMENT_SCHED (bin) != NULL) {
|
|
|
|
gst_bin_set_element_sched (element, GST_ELEMENT_SCHED (bin));
|
|
|
|
}
|
2000-12-30 02:41:15 +00:00
|
|
|
|
2001-05-25 21:00:07 +00:00
|
|
|
GST_INFO_ELEMENT (GST_CAT_PARENTAGE, bin, "added child \"%s\"", GST_ELEMENT_NAME (element));
|
2000-01-30 09:03:00 +00:00
|
|
|
|
2001-06-25 01:20:11 +00:00
|
|
|
g_signal_emit (G_OBJECT (bin), gst_bin_signals[OBJECT_ADDED], 0, element);
|
2000-01-30 09:03:00 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* gst_bin_remove:
|
2000-07-17 17:14:15 +00:00
|
|
|
* @bin: #GstBin to remove element from
|
2000-01-30 09:03:00 +00:00
|
|
|
* @element: #GstElement to remove
|
|
|
|
*
|
|
|
|
* Remove the element from its associated bin, unparenting as well.
|
|
|
|
*/
|
2001-01-20 03:10:44 +00:00
|
|
|
void
|
2000-11-04 18:54:07 +00:00
|
|
|
gst_bin_remove (GstBin *bin,
|
2001-01-20 03:10:44 +00:00
|
|
|
GstElement *element)
|
2000-11-04 18:54:07 +00:00
|
|
|
{
|
2001-12-10 18:08:35 +00:00
|
|
|
gint state_idx = 0;
|
|
|
|
GstElementState state;
|
|
|
|
|
2000-11-04 18:54:07 +00:00
|
|
|
g_return_if_fail (bin != NULL);
|
|
|
|
g_return_if_fail (GST_IS_BIN (bin));
|
|
|
|
g_return_if_fail (element != NULL);
|
|
|
|
g_return_if_fail (GST_IS_ELEMENT (element));
|
|
|
|
g_return_if_fail (bin->children != NULL);
|
2000-01-30 09:03:00 +00:00
|
|
|
|
2001-05-25 21:00:07 +00:00
|
|
|
// must not be in PLAYING state in order to modify bin
|
|
|
|
g_return_if_fail (GST_STATE (bin) != GST_STATE_PLAYING);
|
2000-07-17 17:14:15 +00:00
|
|
|
|
2001-05-25 21:00:07 +00:00
|
|
|
// the element must have its parent set to the current bin
|
|
|
|
g_return_if_fail (GST_ELEMENT_PARENT(element) == (GstObject *)bin);
|
|
|
|
|
|
|
|
// the element must be in the bin's list of children
|
2000-12-30 02:41:15 +00:00
|
|
|
if (g_list_find(bin->children, element) == NULL) {
|
|
|
|
// FIXME this should be a warning!!!
|
2001-01-01 03:14:40 +00:00
|
|
|
GST_ERROR_OBJECT(bin,element,"no such element in bin");
|
2000-12-30 02:41:15 +00:00
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
2001-05-25 21:00:07 +00:00
|
|
|
// remove this element from the list of managed elements
|
|
|
|
gst_bin_unset_element_sched (element);
|
|
|
|
|
|
|
|
// now remove the element from the list of elements
|
2000-11-04 18:54:07 +00:00
|
|
|
bin->children = g_list_remove (bin->children, element);
|
2000-01-30 09:03:00 +00:00
|
|
|
bin->numchildren--;
|
2000-07-17 17:14:15 +00:00
|
|
|
|
2001-12-10 18:08:35 +00:00
|
|
|
// bump our internal state counter
|
|
|
|
state = GST_STATE (element);
|
|
|
|
while (state>>=1) state_idx++;
|
|
|
|
bin->child_states[state_idx]--;
|
|
|
|
|
2001-01-29 00:06:02 +00:00
|
|
|
GST_INFO_ELEMENT (GST_CAT_PARENTAGE, bin, "removed child %s", GST_ELEMENT_NAME (element));
|
2000-12-30 02:41:15 +00:00
|
|
|
|
2001-05-25 21:00:07 +00:00
|
|
|
gst_object_unparent (GST_OBJECT (element));
|
|
|
|
|
2000-07-17 17:14:15 +00:00
|
|
|
/* if we're down to zero children, force state to NULL */
|
2001-05-25 21:00:07 +00:00
|
|
|
if (bin->numchildren == 0 && GST_ELEMENT_SCHED (bin) != NULL)
|
2000-11-04 18:54:07 +00:00
|
|
|
gst_element_set_state (GST_ELEMENT (bin), GST_STATE_NULL);
|
2000-01-30 09:03:00 +00:00
|
|
|
}
|
|
|
|
|
2001-12-04 22:12:50 +00:00
|
|
|
static void
|
|
|
|
gst_bin_child_state_change (GstBin *bin, GstElementState old, GstElementState new, GstElement *child)
|
|
|
|
{
|
|
|
|
gint old_idx = 0, new_idx = 0, i;
|
|
|
|
|
|
|
|
GST_INFO (GST_CAT_STATES, "child %s changed state in bin %s from %s to %s",
|
|
|
|
GST_ELEMENT_NAME (child), GST_ELEMENT_NAME (bin),
|
|
|
|
gst_element_statename (old), gst_element_statename (new));
|
|
|
|
|
|
|
|
while (old>>=1) old_idx++;
|
|
|
|
while (new>>=1) new_idx++;
|
|
|
|
|
|
|
|
GST_LOCK (bin);
|
|
|
|
bin->child_states[old_idx]--;
|
|
|
|
bin->child_states[new_idx]++;
|
|
|
|
|
|
|
|
for (i = GST_NUM_STATES-1; i >= 0; i--) {
|
|
|
|
if (bin->child_states[i] != 0) {
|
|
|
|
if (GST_STATE (bin) != (1 << i)) {
|
|
|
|
GST_INFO (GST_CAT_STATES, "bin %s need state change to %s",
|
|
|
|
GST_ELEMENT_NAME (bin), gst_element_statename (1<<i));
|
|
|
|
GST_STATE_PENDING (bin) = (1<<i);
|
|
|
|
gst_bin_change_state_norecurse (bin);
|
|
|
|
}
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
// FIXME, need to setup this array at add/remove time
|
|
|
|
if (i<0) {
|
|
|
|
GST_STATE_PENDING (bin) = GST_STATE_NULL;
|
|
|
|
gst_bin_change_state_norecurse (bin);
|
|
|
|
}
|
|
|
|
|
|
|
|
GST_UNLOCK (bin);
|
|
|
|
}
|
2000-01-30 09:03:00 +00:00
|
|
|
|
2001-01-20 03:10:44 +00:00
|
|
|
static GstElementStateReturn
|
|
|
|
gst_bin_change_state (GstElement *element)
|
2000-11-04 18:54:07 +00:00
|
|
|
{
|
2000-01-30 09:03:00 +00:00
|
|
|
GstBin *bin;
|
|
|
|
GList *children;
|
|
|
|
GstElement *child;
|
2001-03-07 21:52:56 +00:00
|
|
|
GstElementStateReturn ret;
|
2001-12-04 22:12:50 +00:00
|
|
|
GstElementState old_state, pending;
|
|
|
|
gboolean have_async = FALSE;
|
2000-12-20 09:39:43 +00:00
|
|
|
|
2000-11-04 18:54:07 +00:00
|
|
|
g_return_val_if_fail (GST_IS_BIN (element), GST_STATE_FAILURE);
|
Changed the way things are scheduled, especially sources. A Src used to have a push() function, and optionally a pus...
Original commit message from CVS:
Changed the way things are scheduled, especially sources. A Src used to
have a push() function, and optionally a pushregion() to deal with async
reads, etc. That whole thing has gone away, in favor of providing a
pull() function for the output (Src) pad instead, ala chain functions.
This makes constructing cothreaded schedules out of non-loop elements
somewhat easier. Basically there was always a question as to which pad
was being dealt with. In the pullregion case, cothread-specific data was
used to try to pass the region struct to the right place, which is a slow
hack. And in general, the push function severely limited the kind of
tricks that could be played when there's more than one output pad, such as
a multi-out file reader with async capabilities on each pad independently.
This changes the way cothread scheduling occurs. Instead of the hack to
deal with Src's by calling their push() function (or optionally the
pushregion(), in certain cases), we now are working towards a general
mechanism where pads are the only thing that are dealt with directly.
An optimization was made in the process of doing this: the loopfunction
actually run as the outer [stack] frame of the cothread is now set more
intelligently in create_plan() based on what kind of element it is. We
now have:
loopfunc_wrapper: used for loop-based elements, it simply calls the
loopfunc in a loop, paying attention to COTHREAD_STOPPING (see
below). It currently does other, soon to be depracated, stuff.
pullsrc_wrapper: wraps a Src that's not loop-based (since your options
are now loop- or pull-based)
There will be a couple more to deal with other cases, such as Connections
and chain-based elements. The general idea is that it's a lot more
efficient to make the decisions once in create_plan than to keep doing
this huge if/else chain in the wrapper. Just choose the right wrapper up
front. It'll be most apparent performance-wise in the case of whichever
element context is switched to first for each iteration, since the whole
wrapper setup is done for every iteration.
The tricky part is that there is now a bit of overloading of the function
pointers in a pad. The current meanings (possibly to change a bit more
soon) are:
chainfunc: as always, chainfunc pointer is mirrored between peer pads
(this may change, and the chain func may end up in pushfunc)
pushfunc: SrcPad: gst_pad_pushfunc_proxy, cothread_switch to peer
SinkPad: none (may take over chainfunc, see below) pullfunc:
SrcPad: Src or Connection's function to construct buffers
SinkPad: gst_pad_pullfunc_proxy, cothread_switch to peer
There are a number of issues remaining with the scheduling, not the least
of which is the fact that Connections are still dealt with the old way,
with _push() functions and such. I'm trying to figure out a way to unify
the system so it makes sense. Following the scheduling system is hard
enough, trying to change it is murder.
Another useful scheduling addition, mentioned above, is COTHREAD_STOPPING.
It's an element flag that's used to signal whatever code is running in
cothread context that it should be finishing up and exiting soon. An
example of this is in plugins/cobin/spindentity.c. All the loops should
now be composed of do/while loops, rather than while(1) loops:
do {
buf = gst_pad_pull(spindentity->sinkpad);
gst_pad_push(spindentity->srcpad,buf);
} while (!GST_ELEMENT_IS_COTHREAD_STOPPING(element));
The reason for this is that COTHREAD_STOPPING may be set before the above
loop ever gets started. It wouldn't do for the body of the loop to never
once get called, that would simply stall the pipeline. Note that only the
core library code is ever responsible for setting and unsetting this flag.
All elements have to do is respond to it by cleanly exiting the loop and
the function holding it.
This is needed primarily to allow iterations to occur properly.
Basically, there's a single entry point in the cothread scheduling loop,
gst_bin_iterate_func() simply switches to this cothread. If the element
in this context is allowed to loop infinitely, nothing would even switch
back to the context from which the iterate() was originally called. This
is a bit of a problem. The solution is for there to be an implicit switch
back to the originating context. Now, even I'm not sure exactly how this
works, but if the cothread that's switched to actually returns, execution
returns back to the calling context, i.e. iterate_func().
COTHREAD_STOPPING is therefore set just before switching into this
(currently randomly chosen) context, on the assumption that it will return
promptly after finishing its duties. The burden of clearing the flag
falls to the various wrapper functions provided by the Bin code, thus
element writers don't have to worry about doing that at all (and simply
shouldn't).
Related changes:
All the sources in elements/ have been changed to reflect the new system.
FIXMEs:
1) gstpipeline.c calls gst_src_push at some point, dunno why, it's
commented out now.
2) any other sources, including vcdsrc, dvdsrc, and v4lsrc will break
badly and need to be modified to work as pull-based sources.
2000-12-04 10:52:30 +00:00
|
|
|
|
2000-11-04 18:54:07 +00:00
|
|
|
bin = GST_BIN (element);
|
2000-07-17 17:14:15 +00:00
|
|
|
|
2001-12-04 22:12:50 +00:00
|
|
|
old_state = GST_STATE (element);
|
|
|
|
pending = GST_STATE_PENDING (element);
|
2000-12-30 02:41:15 +00:00
|
|
|
|
2001-05-25 21:00:07 +00:00
|
|
|
GST_INFO_ELEMENT (GST_CAT_STATES, element, "changing childrens' state from %s to %s",
|
2001-12-04 22:12:50 +00:00
|
|
|
gst_element_statename (old_state),
|
|
|
|
gst_element_statename (pending));
|
2000-01-30 09:03:00 +00:00
|
|
|
|
|
|
|
children = bin->children;
|
|
|
|
while (children) {
|
2000-11-04 18:54:07 +00:00
|
|
|
child = GST_ELEMENT (children->data);
|
2001-12-04 22:12:50 +00:00
|
|
|
children = g_list_next (children);
|
|
|
|
|
|
|
|
switch (gst_element_set_state (child, pending)) {
|
2000-07-17 17:14:15 +00:00
|
|
|
case GST_STATE_FAILURE:
|
2001-06-25 01:20:11 +00:00
|
|
|
GST_STATE_PENDING (element) = GST_STATE_VOID_PENDING;
|
2001-05-25 21:00:07 +00:00
|
|
|
GST_DEBUG (GST_CAT_STATES,"child '%s' failed to go to state %d(%s)\n", GST_ELEMENT_NAME (child),
|
2001-12-04 22:12:50 +00:00
|
|
|
pending, gst_element_statename (pending));
|
|
|
|
|
|
|
|
gst_element_set_state (child, old_state);
|
|
|
|
if (GST_ELEMENT_SCHED (child) == GST_ELEMENT_SCHED (element)) {
|
|
|
|
return GST_STATE_FAILURE;
|
|
|
|
}
|
2000-07-17 17:14:15 +00:00
|
|
|
break;
|
|
|
|
case GST_STATE_ASYNC:
|
2001-05-25 21:00:07 +00:00
|
|
|
GST_DEBUG (GST_CAT_STATES,"child '%s' is changing state asynchronously\n", GST_ELEMENT_NAME (child));
|
2001-12-04 22:12:50 +00:00
|
|
|
have_async = TRUE;
|
2000-07-17 17:14:15 +00:00
|
|
|
break;
|
2000-01-30 09:03:00 +00:00
|
|
|
}
|
|
|
|
}
|
2001-05-25 21:00:07 +00:00
|
|
|
|
|
|
|
GST_INFO_ELEMENT (GST_CAT_STATES, element, "done changing bin's state from %s to %s",
|
2001-12-04 22:12:50 +00:00
|
|
|
gst_element_statename (old_state),
|
|
|
|
gst_element_statename (pending));
|
|
|
|
|
|
|
|
if (have_async)
|
|
|
|
ret = GST_STATE_ASYNC;
|
|
|
|
else
|
|
|
|
ret = GST_STATE_SUCCESS;
|
2000-01-30 09:03:00 +00:00
|
|
|
|
2001-03-07 21:52:56 +00:00
|
|
|
return ret;
|
2000-07-17 17:14:15 +00:00
|
|
|
}
|
2000-01-30 09:03:00 +00:00
|
|
|
|
|
|
|
|
2001-01-20 03:10:44 +00:00
|
|
|
static GstElementStateReturn
|
|
|
|
gst_bin_change_state_norecurse (GstBin *bin)
|
2000-11-04 18:54:07 +00:00
|
|
|
{
|
2001-05-25 21:00:07 +00:00
|
|
|
if (GST_ELEMENT_CLASS (parent_class)->change_state) {
|
|
|
|
GST_DEBUG_ELEMENT (GST_CAT_STATES, bin, "setting bin's own state\n");
|
2000-11-04 18:54:07 +00:00
|
|
|
return GST_ELEMENT_CLASS (parent_class)->change_state (GST_ELEMENT (bin));
|
2001-05-25 21:00:07 +00:00
|
|
|
} else
|
2000-07-17 17:14:15 +00:00
|
|
|
return GST_STATE_FAILURE;
|
2000-01-30 09:03:00 +00:00
|
|
|
}
|
|
|
|
|
2001-01-20 03:10:44 +00:00
|
|
|
static gboolean
|
2001-12-04 22:12:50 +00:00
|
|
|
gst_bin_change_state_type (GstBin *bin,
|
|
|
|
GstElementState state,
|
|
|
|
GType type)
|
2000-11-04 18:54:07 +00:00
|
|
|
{
|
2000-01-30 09:03:00 +00:00
|
|
|
GList *children;
|
|
|
|
GstElement *child;
|
|
|
|
|
2000-11-04 18:54:07 +00:00
|
|
|
g_return_val_if_fail (GST_IS_BIN (bin), FALSE);
|
|
|
|
g_return_val_if_fail (bin->numchildren != 0, FALSE);
|
2000-01-30 09:03:00 +00:00
|
|
|
|
|
|
|
children = bin->children;
|
|
|
|
while (children) {
|
2000-11-04 18:54:07 +00:00
|
|
|
child = GST_ELEMENT (children->data);
|
|
|
|
if (GST_IS_BIN (child)) {
|
|
|
|
if (!gst_bin_set_state_type (GST_BIN (child), state,type))
|
2000-01-30 09:03:00 +00:00
|
|
|
return FALSE;
|
2001-06-25 01:20:11 +00:00
|
|
|
} else if (G_TYPE_CHECK_INSTANCE_TYPE (child,type)) {
|
2000-11-04 18:54:07 +00:00
|
|
|
if (!gst_element_set_state (child,state))
|
2000-01-30 09:03:00 +00:00
|
|
|
return FALSE;
|
|
|
|
}
|
2000-11-04 18:54:07 +00:00
|
|
|
children = g_list_next (children);
|
2000-01-30 09:03:00 +00:00
|
|
|
}
|
|
|
|
if (type == GST_TYPE_BIN)
|
2001-12-04 22:12:50 +00:00
|
|
|
gst_element_set_state (GST_ELEMENT (bin), state);
|
2000-01-30 09:03:00 +00:00
|
|
|
|
|
|
|
return TRUE;
|
|
|
|
}
|
|
|
|
|
2000-09-14 20:31:03 +00:00
|
|
|
/**
|
|
|
|
* gst_bin_set_state_type:
|
|
|
|
* @bin: #GstBin to set the state
|
|
|
|
* @state: the new state to set the elements to
|
|
|
|
* @type: the type of elements to change
|
|
|
|
*
|
|
|
|
* Sets the state of only those objects of the given type.
|
|
|
|
*
|
|
|
|
* Returns: indication if the state change was successfull
|
|
|
|
*/
|
2001-01-20 03:10:44 +00:00
|
|
|
gboolean
|
2000-11-04 18:54:07 +00:00
|
|
|
gst_bin_set_state_type (GstBin *bin,
|
|
|
|
GstElementState state,
|
2001-06-25 01:20:11 +00:00
|
|
|
GType type)
|
2000-11-04 18:54:07 +00:00
|
|
|
{
|
2000-01-30 09:03:00 +00:00
|
|
|
GstBinClass *oclass;
|
|
|
|
|
2001-05-25 21:00:07 +00:00
|
|
|
GST_DEBUG (GST_CAT_STATES,"gst_bin_set_state_type(\"%s\",%d,%d)\n",
|
2001-01-29 00:06:02 +00:00
|
|
|
GST_ELEMENT_NAME (bin), state,type);
|
2000-01-30 09:03:00 +00:00
|
|
|
|
2000-11-04 18:54:07 +00:00
|
|
|
g_return_val_if_fail (bin != NULL, FALSE);
|
|
|
|
g_return_val_if_fail (GST_IS_BIN (bin), FALSE);
|
2000-01-30 09:03:00 +00:00
|
|
|
|
2001-06-25 01:20:11 +00:00
|
|
|
oclass = GST_BIN_CLASS (G_OBJECT_GET_CLASS(bin));
|
2000-01-30 09:03:00 +00:00
|
|
|
|
|
|
|
if (oclass->change_state_type)
|
2000-11-04 18:54:07 +00:00
|
|
|
(oclass->change_state_type) (bin,state,type);
|
2000-09-24 14:29:49 +00:00
|
|
|
return TRUE;
|
2000-01-30 09:03:00 +00:00
|
|
|
}
|
|
|
|
|
2001-01-20 03:10:44 +00:00
|
|
|
static void
|
2001-09-28 19:16:02 +00:00
|
|
|
gst_bin_dispose (GObject *object)
|
2000-11-04 18:54:07 +00:00
|
|
|
{
|
|
|
|
GstBin *bin = GST_BIN (object);
|
2001-05-25 21:00:07 +00:00
|
|
|
GList *children, *orig;
|
2000-01-30 09:03:00 +00:00
|
|
|
GstElement *child;
|
|
|
|
|
2001-09-28 19:16:02 +00:00
|
|
|
GST_DEBUG (GST_CAT_REFCOUNTING,"dispose\n");
|
2000-01-30 09:03:00 +00:00
|
|
|
|
2001-05-25 21:00:07 +00:00
|
|
|
if (bin->children) {
|
|
|
|
orig = children = g_list_copy (bin->children);
|
|
|
|
while (children) {
|
|
|
|
child = GST_ELEMENT (children->data);
|
|
|
|
//gst_object_unref (GST_OBJECT (child));
|
|
|
|
//gst_object_unparent (GST_OBJECT (child));
|
|
|
|
gst_bin_remove (bin, child);
|
|
|
|
children = g_list_next (children);
|
|
|
|
}
|
|
|
|
g_list_free (orig);
|
|
|
|
g_list_free (bin->children);
|
2000-01-30 09:03:00 +00:00
|
|
|
}
|
2001-05-25 21:00:07 +00:00
|
|
|
bin->children = NULL;
|
|
|
|
bin->numchildren = 0;
|
|
|
|
|
|
|
|
g_cond_free (bin->eoscond);
|
2000-01-30 09:03:00 +00:00
|
|
|
|
2001-09-28 19:16:02 +00:00
|
|
|
G_OBJECT_CLASS (parent_class)->dispose (object);
|
2000-01-30 09:03:00 +00:00
|
|
|
}
|
|
|
|
|
2000-03-27 19:53:43 +00:00
|
|
|
/**
|
|
|
|
* gst_bin_get_by_name:
|
|
|
|
* @bin: #Gstbin to search
|
|
|
|
* @name: the element name to search for
|
|
|
|
*
|
2001-01-06 22:05:15 +00:00
|
|
|
* Get the element with the given name from this bin.
|
2000-03-27 19:53:43 +00:00
|
|
|
*
|
|
|
|
* Returns: the element with the given name
|
|
|
|
*/
|
2000-11-04 18:54:07 +00:00
|
|
|
GstElement*
|
|
|
|
gst_bin_get_by_name (GstBin *bin,
|
2001-01-20 03:10:44 +00:00
|
|
|
const gchar *name)
|
2000-11-04 18:54:07 +00:00
|
|
|
{
|
2000-01-30 09:03:00 +00:00
|
|
|
GList *children;
|
|
|
|
GstElement *child;
|
|
|
|
|
2000-11-04 18:54:07 +00:00
|
|
|
g_return_val_if_fail (bin != NULL, NULL);
|
|
|
|
g_return_val_if_fail (GST_IS_BIN (bin), NULL);
|
|
|
|
g_return_val_if_fail (name != NULL, NULL);
|
2000-01-30 09:03:00 +00:00
|
|
|
|
2001-01-01 03:14:40 +00:00
|
|
|
GST_INFO_ELEMENT (GST_CAT_PARENTAGE, bin, "looking up child element %s", name);
|
2000-12-30 02:41:15 +00:00
|
|
|
|
2000-01-30 09:03:00 +00:00
|
|
|
children = bin->children;
|
|
|
|
while (children) {
|
2000-11-04 18:54:07 +00:00
|
|
|
child = GST_ELEMENT (children->data);
|
2001-05-25 21:00:07 +00:00
|
|
|
if (!strcmp (GST_OBJECT_NAME(child),name))
|
2000-01-30 09:03:00 +00:00
|
|
|
return child;
|
2000-11-04 18:54:07 +00:00
|
|
|
if (GST_IS_BIN (child)) {
|
|
|
|
GstElement *res = gst_bin_get_by_name (GST_BIN (child), name);
|
2001-01-20 03:10:44 +00:00
|
|
|
if (res)
|
2000-09-27 19:33:10 +00:00
|
|
|
return res;
|
|
|
|
}
|
2000-11-04 18:54:07 +00:00
|
|
|
children = g_list_next (children);
|
2000-01-30 09:03:00 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
return NULL;
|
|
|
|
}
|
|
|
|
|
2001-01-29 00:06:02 +00:00
|
|
|
/**
|
|
|
|
* gst_bin_get_by_name_recurse_up:
|
|
|
|
* @bin: #Gstbin to search
|
|
|
|
* @name: the element name to search for
|
|
|
|
*
|
|
|
|
* Get the element with the given name from this bin. If the
|
|
|
|
* element is not found, a recursion is performed on the parent bin.
|
|
|
|
*
|
|
|
|
* Returns: the element with the given name
|
|
|
|
*/
|
|
|
|
GstElement*
|
|
|
|
gst_bin_get_by_name_recurse_up (GstBin *bin,
|
|
|
|
const gchar *name)
|
|
|
|
{
|
|
|
|
GstElement *result = NULL;
|
|
|
|
GstObject *parent;
|
|
|
|
|
|
|
|
g_return_val_if_fail (bin != NULL, NULL);
|
|
|
|
g_return_val_if_fail (GST_IS_BIN (bin), NULL);
|
|
|
|
g_return_val_if_fail (name != NULL, NULL);
|
|
|
|
|
|
|
|
result = gst_bin_get_by_name (bin, name);
|
|
|
|
|
|
|
|
if (result)
|
|
|
|
return result;
|
|
|
|
|
|
|
|
parent = gst_object_get_parent (GST_OBJECT (bin));
|
|
|
|
|
|
|
|
if (parent && GST_IS_BIN (parent)) {
|
|
|
|
result = gst_bin_get_by_name_recurse_up (GST_BIN (parent), name);
|
|
|
|
}
|
|
|
|
|
|
|
|
return result;
|
|
|
|
}
|
|
|
|
|
2000-03-27 19:53:43 +00:00
|
|
|
/**
|
|
|
|
* gst_bin_get_list:
|
|
|
|
* @bin: #Gstbin to get the list from
|
|
|
|
*
|
2001-01-06 22:05:15 +00:00
|
|
|
* Get the list of elements in this bin.
|
2000-03-27 19:53:43 +00:00
|
|
|
*
|
|
|
|
* Returns: a GList of elements
|
|
|
|
*/
|
2000-11-04 18:54:07 +00:00
|
|
|
GList*
|
2001-01-20 03:10:44 +00:00
|
|
|
gst_bin_get_list (GstBin *bin)
|
2000-11-04 18:54:07 +00:00
|
|
|
{
|
|
|
|
g_return_val_if_fail (bin != NULL, NULL);
|
|
|
|
g_return_val_if_fail (GST_IS_BIN (bin), NULL);
|
2000-01-30 09:03:00 +00:00
|
|
|
|
|
|
|
return bin->children;
|
|
|
|
}
|
|
|
|
|
2001-06-25 06:45:56 +00:00
|
|
|
#ifndef GST_DISABLE_LOADSAVE
|
2001-01-20 03:10:44 +00:00
|
|
|
static xmlNodePtr
|
2001-01-29 00:06:02 +00:00
|
|
|
gst_bin_save_thyself (GstObject *object,
|
2001-01-20 03:10:44 +00:00
|
|
|
xmlNodePtr parent)
|
2000-11-04 18:54:07 +00:00
|
|
|
{
|
2001-01-29 00:06:02 +00:00
|
|
|
GstBin *bin = GST_BIN (object);
|
|
|
|
xmlNodePtr childlist, elementnode;
|
2000-01-30 09:03:00 +00:00
|
|
|
GList *children;
|
|
|
|
GstElement *child;
|
|
|
|
|
2001-01-29 00:06:02 +00:00
|
|
|
if (GST_OBJECT_CLASS (parent_class)->save_thyself)
|
|
|
|
GST_OBJECT_CLASS (parent_class)->save_thyself (GST_OBJECT (bin), parent);
|
2000-01-30 09:03:00 +00:00
|
|
|
|
2001-01-29 00:06:02 +00:00
|
|
|
childlist = xmlNewChild (parent, NULL, "children", NULL);
|
2000-01-30 09:03:00 +00:00
|
|
|
|
2001-01-01 03:14:40 +00:00
|
|
|
GST_INFO_ELEMENT (GST_CAT_XML, bin, "saving %d children", bin->numchildren);
|
2000-12-30 02:41:15 +00:00
|
|
|
|
2000-01-30 09:03:00 +00:00
|
|
|
children = bin->children;
|
|
|
|
while (children) {
|
2000-11-04 18:54:07 +00:00
|
|
|
child = GST_ELEMENT (children->data);
|
2001-01-29 00:06:02 +00:00
|
|
|
elementnode = xmlNewChild (childlist, NULL, "element", NULL);
|
|
|
|
gst_object_save_thyself (GST_OBJECT (child), elementnode);
|
2000-11-04 18:54:07 +00:00
|
|
|
children = g_list_next (children);
|
2000-01-30 09:03:00 +00:00
|
|
|
}
|
2000-09-27 19:33:10 +00:00
|
|
|
return childlist;
|
|
|
|
}
|
|
|
|
|
2001-01-20 03:10:44 +00:00
|
|
|
static void
|
2001-01-29 00:06:02 +00:00
|
|
|
gst_bin_restore_thyself (GstObject *object,
|
|
|
|
xmlNodePtr self)
|
2000-11-04 18:54:07 +00:00
|
|
|
{
|
2001-01-29 00:06:02 +00:00
|
|
|
GstBin *bin = GST_BIN (object);
|
|
|
|
xmlNodePtr field = self->xmlChildrenNode;
|
2000-09-27 19:33:10 +00:00
|
|
|
xmlNodePtr childlist;
|
|
|
|
|
|
|
|
while (field) {
|
2000-11-04 18:54:07 +00:00
|
|
|
if (!strcmp (field->name, "children")) {
|
2001-01-29 00:06:02 +00:00
|
|
|
GST_INFO_ELEMENT (GST_CAT_XML, GST_ELEMENT (object), "loading children");
|
2001-01-18 11:16:53 +00:00
|
|
|
childlist = field->xmlChildrenNode;
|
2000-09-27 19:33:10 +00:00
|
|
|
while (childlist) {
|
2000-11-04 18:54:07 +00:00
|
|
|
if (!strcmp (childlist->name, "element")) {
|
2001-05-25 21:00:07 +00:00
|
|
|
GstElement *element = gst_element_restore_thyself (childlist, GST_OBJECT (bin));
|
2000-09-27 19:33:10 +00:00
|
|
|
|
2000-11-04 18:54:07 +00:00
|
|
|
gst_bin_add (bin, element);
|
2000-09-27 19:33:10 +00:00
|
|
|
}
|
|
|
|
childlist = childlist->next;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
field = field->next;
|
|
|
|
}
|
2000-01-30 09:03:00 +00:00
|
|
|
}
|
2001-10-17 10:21:27 +00:00
|
|
|
#endif /* GST_DISABLE_LOADSAVE */
|
2000-01-30 09:03:00 +00:00
|
|
|
|
2001-12-04 22:12:50 +00:00
|
|
|
static gboolean
|
|
|
|
gst_bin_iterate_func (GstBin *bin)
|
|
|
|
{
|
|
|
|
// only iterate if this is the manager bin
|
|
|
|
if (GST_ELEMENT_SCHED(bin)->parent == GST_ELEMENT (bin)) {
|
|
|
|
return gst_scheduler_iterate (GST_ELEMENT_SCHED(bin));
|
|
|
|
} else {
|
|
|
|
g_warning ("bin \"%d\" can't be iterated on!\n", GST_ELEMENT_NAME (bin));
|
|
|
|
}
|
|
|
|
|
|
|
|
return FALSE;
|
|
|
|
}
|
2000-08-14 10:55:35 +00:00
|
|
|
|
2000-03-27 19:53:43 +00:00
|
|
|
/**
|
|
|
|
* gst_bin_iterate:
|
|
|
|
* @bin: #Gstbin to iterate
|
|
|
|
*
|
2001-01-06 22:05:15 +00:00
|
|
|
* Iterates over the elements in this bin.
|
2001-01-21 23:20:46 +00:00
|
|
|
*
|
|
|
|
* Returns: TRUE if the bin did something usefull. This value
|
|
|
|
* can be used to determine it the bin is in EOS.
|
2000-03-27 19:53:43 +00:00
|
|
|
*/
|
2001-01-20 17:59:25 +00:00
|
|
|
gboolean
|
2001-01-20 03:10:44 +00:00
|
|
|
gst_bin_iterate (GstBin *bin)
|
2000-11-04 18:54:07 +00:00
|
|
|
{
|
2000-01-30 09:03:00 +00:00
|
|
|
GstBinClass *oclass;
|
2001-11-14 21:06:15 +00:00
|
|
|
gboolean running = TRUE;
|
2000-01-30 09:03:00 +00:00
|
|
|
|
2001-01-29 00:06:02 +00:00
|
|
|
GST_DEBUG_ENTER("(\"%s\")",GST_ELEMENT_NAME (bin));
|
2000-01-30 09:03:00 +00:00
|
|
|
|
2001-06-25 01:20:11 +00:00
|
|
|
oclass = GST_BIN_CLASS (G_OBJECT_GET_CLASS(bin));
|
2001-01-20 03:10:44 +00:00
|
|
|
|
2000-01-30 09:03:00 +00:00
|
|
|
if (oclass->iterate)
|
2001-11-14 21:06:15 +00:00
|
|
|
running = (oclass->iterate) (bin);
|
Changed the way things are scheduled, especially sources. A Src used to have a push() function, and optionally a pus...
Original commit message from CVS:
Changed the way things are scheduled, especially sources. A Src used to
have a push() function, and optionally a pushregion() to deal with async
reads, etc. That whole thing has gone away, in favor of providing a
pull() function for the output (Src) pad instead, ala chain functions.
This makes constructing cothreaded schedules out of non-loop elements
somewhat easier. Basically there was always a question as to which pad
was being dealt with. In the pullregion case, cothread-specific data was
used to try to pass the region struct to the right place, which is a slow
hack. And in general, the push function severely limited the kind of
tricks that could be played when there's more than one output pad, such as
a multi-out file reader with async capabilities on each pad independently.
This changes the way cothread scheduling occurs. Instead of the hack to
deal with Src's by calling their push() function (or optionally the
pushregion(), in certain cases), we now are working towards a general
mechanism where pads are the only thing that are dealt with directly.
An optimization was made in the process of doing this: the loopfunction
actually run as the outer [stack] frame of the cothread is now set more
intelligently in create_plan() based on what kind of element it is. We
now have:
loopfunc_wrapper: used for loop-based elements, it simply calls the
loopfunc in a loop, paying attention to COTHREAD_STOPPING (see
below). It currently does other, soon to be depracated, stuff.
pullsrc_wrapper: wraps a Src that's not loop-based (since your options
are now loop- or pull-based)
There will be a couple more to deal with other cases, such as Connections
and chain-based elements. The general idea is that it's a lot more
efficient to make the decisions once in create_plan than to keep doing
this huge if/else chain in the wrapper. Just choose the right wrapper up
front. It'll be most apparent performance-wise in the case of whichever
element context is switched to first for each iteration, since the whole
wrapper setup is done for every iteration.
The tricky part is that there is now a bit of overloading of the function
pointers in a pad. The current meanings (possibly to change a bit more
soon) are:
chainfunc: as always, chainfunc pointer is mirrored between peer pads
(this may change, and the chain func may end up in pushfunc)
pushfunc: SrcPad: gst_pad_pushfunc_proxy, cothread_switch to peer
SinkPad: none (may take over chainfunc, see below) pullfunc:
SrcPad: Src or Connection's function to construct buffers
SinkPad: gst_pad_pullfunc_proxy, cothread_switch to peer
There are a number of issues remaining with the scheduling, not the least
of which is the fact that Connections are still dealt with the old way,
with _push() functions and such. I'm trying to figure out a way to unify
the system so it makes sense. Following the scheduling system is hard
enough, trying to change it is murder.
Another useful scheduling addition, mentioned above, is COTHREAD_STOPPING.
It's an element flag that's used to signal whatever code is running in
cothread context that it should be finishing up and exiting soon. An
example of this is in plugins/cobin/spindentity.c. All the loops should
now be composed of do/while loops, rather than while(1) loops:
do {
buf = gst_pad_pull(spindentity->sinkpad);
gst_pad_push(spindentity->srcpad,buf);
} while (!GST_ELEMENT_IS_COTHREAD_STOPPING(element));
The reason for this is that COTHREAD_STOPPING may be set before the above
loop ever gets started. It wouldn't do for the body of the loop to never
once get called, that would simply stall the pipeline. Note that only the
core library code is ever responsible for setting and unsetting this flag.
All elements have to do is respond to it by cleanly exiting the loop and
the function holding it.
This is needed primarily to allow iterations to occur properly.
Basically, there's a single entry point in the cothread scheduling loop,
gst_bin_iterate_func() simply switches to this cothread. If the element
in this context is allowed to loop infinitely, nothing would even switch
back to the context from which the iterate() was originally called. This
is a bit of a problem. The solution is for there to be an implicit switch
back to the originating context. Now, even I'm not sure exactly how this
works, but if the cothread that's switched to actually returns, execution
returns back to the calling context, i.e. iterate_func().
COTHREAD_STOPPING is therefore set just before switching into this
(currently randomly chosen) context, on the assumption that it will return
promptly after finishing its duties. The burden of clearing the flag
falls to the various wrapper functions provided by the Bin code, thus
element writers don't have to worry about doing that at all (and simply
shouldn't).
Related changes:
All the sources in elements/ have been changed to reflect the new system.
FIXMEs:
1) gstpipeline.c calls gst_src_push at some point, dunno why, it's
commented out now.
2) any other sources, including vcdsrc, dvdsrc, and v4lsrc will break
badly and need to be modified to work as pull-based sources.
2000-12-04 10:52:30 +00:00
|
|
|
|
2001-12-10 18:08:35 +00:00
|
|
|
GST_DEBUG_LEAVE("(\"%s\") %d",GST_ELEMENT_NAME (bin), running);
|
2001-01-20 17:59:25 +00:00
|
|
|
|
2001-12-04 22:12:50 +00:00
|
|
|
if (!running) {
|
|
|
|
if (GST_STATE (bin) == GST_STATE_PLAYING && GST_STATE_PENDING (bin) == GST_STATE_VOID_PENDING) {
|
|
|
|
GST_DEBUG_ELEMENT (GST_CAT_DATAFLOW, bin, "waiting for child shutdown after useless iteration\n");
|
|
|
|
//gst_element_set_state (GST_ELEMENT (bin), GST_STATE_PAUSED);
|
|
|
|
gst_element_wait_state_change (GST_ELEMENT (bin));
|
|
|
|
GST_DEBUG_ELEMENT (GST_CAT_DATAFLOW, bin, "child shutdown\n");
|
|
|
|
}
|
|
|
|
}
|
2001-11-14 21:06:15 +00:00
|
|
|
|
|
|
|
return running;
|
2000-01-30 09:03:00 +00:00
|
|
|
}
|
|
|
|
|
2001-01-20 17:59:25 +00:00
|
|
|
/* out internal element fired EOS, we decrement the number of pending EOS childs */
|
2001-06-01 18:30:40 +00:00
|
|
|
G_GNUC_UNUSED static void
|
2001-01-20 17:59:25 +00:00
|
|
|
gst_bin_received_eos (GstElement *element, GstBin *bin)
|
|
|
|
{
|
2001-03-07 21:52:56 +00:00
|
|
|
GST_INFO_ELEMENT (GST_CAT_PLANNING, bin, "child %s fired eos, pending %d", GST_ELEMENT_NAME (element),
|
2001-01-20 17:59:25 +00:00
|
|
|
bin->num_eos_providers);
|
|
|
|
|
2001-01-21 16:06:42 +00:00
|
|
|
GST_LOCK (bin);
|
2001-01-20 17:59:25 +00:00
|
|
|
if (bin->num_eos_providers) {
|
|
|
|
bin->num_eos_providers--;
|
2001-01-21 16:06:42 +00:00
|
|
|
g_cond_signal (bin->eoscond);
|
2001-01-20 17:59:25 +00:00
|
|
|
}
|
2001-01-21 16:06:42 +00:00
|
|
|
GST_UNLOCK (bin);
|
2001-01-20 17:59:25 +00:00
|
|
|
}
|
|
|
|
|