* Boston, MA 02111-1307, USA.
*/
-//#define GST_DEBUG_ENABLED
#include "gst_private.h"
#include "gstpipeline.h"
-#include "gstthread.h"
-#include "gstutils.h"
-#include "gsttype.h"
-#include "gstautoplug.h"
+#include "gstinfo.h"
+#include "gstscheduler.h"
-
-GstElementDetails gst_pipeline_details = {
+static GstElementDetails gst_pipeline_details = GST_ELEMENT_DETAILS (
"Pipeline object",
- "Bin",
+ "Generic/Bin",
"Complete pipeline object",
- VERSION,
- "Erik Walthinsen <omega@cse.ogi.edu>",
- "(C) 1999",
-};
-
+ "Erik Walthinsen <omega@cse.ogi.edu>"
+);
/* Pipeline signals and args */
enum {
};
-static void gst_pipeline_class_init (GstPipelineClass *klass);
-static void gst_pipeline_init (GstPipeline *pipeline);
+static void gst_pipeline_base_init (gpointer g_class);
+static void gst_pipeline_class_init (gpointer g_class,
+ gpointer class_data);
+static void gst_pipeline_init (GTypeInstance *instance,
+ gpointer g_class);
-static GstElementStateReturn gst_pipeline_change_state (GstElement *element);
+static void gst_pipeline_dispose (GObject * object);
-static void gst_pipeline_prepare (GstPipeline *pipeline);
-
-static void gst_pipeline_have_type (GstElement *sink, GstElement *sink2, gpointer data);
-static void gst_pipeline_pads_autoplug (GstElement *src, GstElement *sink);
+static GstElementStateReturn gst_pipeline_change_state (GstElement * element);
static GstBinClass *parent_class = NULL;
-//static guint gst_pipeline_signals[LAST_SIGNAL] = { 0 };
+/* static guint gst_pipeline_signals[LAST_SIGNAL] = { 0 }; */
-GtkType
+GType
gst_pipeline_get_type (void) {
- static GtkType pipeline_type = 0;
+ static GType pipeline_type = 0;
if (!pipeline_type) {
- static const GtkTypeInfo pipeline_info = {
- "GstPipeline",
- sizeof(GstPipeline),
+ static const GTypeInfo pipeline_info = {
sizeof(GstPipelineClass),
- (GtkClassInitFunc)gst_pipeline_class_init,
- (GtkObjectInitFunc)gst_pipeline_init,
- (GtkArgSetFunc)NULL,
- (GtkArgGetFunc)NULL,
- (GtkClassInitFunc)NULL,
+ gst_pipeline_base_init,
+ NULL,
+ (GClassInitFunc)gst_pipeline_class_init,
+ NULL,
+ NULL,
+ sizeof(GstPipeline),
+ 0,
+ gst_pipeline_init,
+ NULL
};
- pipeline_type = gtk_type_unique (gst_bin_get_type (), &pipeline_info);
+ pipeline_type = g_type_register_static (GST_TYPE_BIN, "GstPipeline", &pipeline_info, 0);
}
return pipeline_type;
}
static void
-gst_pipeline_class_init (GstPipelineClass *klass)
-{
- GstElementClass *gstelement_class;
-
- gstelement_class = (GstElementClass*)klass;
-
- parent_class = gtk_type_class(gst_bin_get_type());
-
- gstelement_class->change_state = gst_pipeline_change_state;
-}
-
-static void
-gst_pipeline_init (GstPipeline *pipeline)
-{
- // we're a manager by default
- GST_FLAG_SET (pipeline, GST_BIN_FLAG_MANAGER);
-
- pipeline->src = NULL;
- pipeline->sinks = NULL;
-}
-
-
-/**
- * gst_pipeline_new:
- * @name: name of new pipeline
- *
- * Create a new pipeline with the given name.
- *
- * Returns: newly created GstPipeline
- */
-GstElement*
-gst_pipeline_new (guchar *name)
-{
- return gst_elementfactory_make ("pipeline", name);
-}
-
-static void
-gst_pipeline_prepare (GstPipeline *pipeline)
-{
- DEBUG("GstPipeline: preparing pipeline \"%s\" for playing\n",
- gst_element_get_name(GST_ELEMENT(pipeline)));
-}
-
-static void
-gst_pipeline_have_type (GstElement *sink, GstElement *sink2, gpointer data)
-{
- DEBUG("GstPipeline: pipeline have type %p\n", (gboolean *)data);
-
- *(gboolean *)data = TRUE;
-}
-
-static GstCaps*
-gst_pipeline_typefind (GstPipeline *pipeline, GstElement *element)
+gst_pipeline_base_init (gpointer g_class)
{
- gboolean found = FALSE;
- GstElement *typefind;
- GstCaps *caps = NULL;
-
- DEBUG("GstPipeline: typefind for element \"%s\" %p\n",
- gst_element_get_name(element), &found);
-
- typefind = gst_elementfactory_make ("typefind", "typefind");
- g_return_val_if_fail (typefind != NULL, FALSE);
-
- gtk_signal_connect (GTK_OBJECT (typefind), "have_type",
- GTK_SIGNAL_FUNC (gst_pipeline_have_type), &found);
-
- gst_pad_connect (gst_element_get_pad (element, "src"),
- gst_element_get_pad (typefind, "sink"));
-
- gst_bin_add (GST_BIN (pipeline), typefind);
-
- //gst_bin_create_plan (GST_BIN (pipeline));
- gst_element_set_state (GST_ELEMENT (pipeline), GST_STATE_READY);
- gst_element_set_state (GST_ELEMENT (pipeline), GST_STATE_PLAYING);
-
- // keep pushing buffers... the have_type signal handler will set the found flag
- while (!found) {
- gst_bin_iterate (GST_BIN (pipeline));
- }
-
- gst_element_set_state (GST_ELEMENT (pipeline), GST_STATE_NULL);
-
- if (found) {
- caps = gst_util_get_pointer_arg (GTK_OBJECT (typefind), "caps");
-
- gst_pad_set_caps (gst_element_get_pad (element, "src"), caps);
- }
-
- gst_pad_disconnect (gst_element_get_pad (element, "src"),
- gst_element_get_pad (typefind, "sink"));
- gst_bin_remove (GST_BIN (pipeline), typefind);
- gst_object_unref (GST_OBJECT (typefind));
-
- return caps;
+ GstElementClass *gstelement_class = GST_ELEMENT_CLASS (g_class);
+
+ gst_element_class_set_details (gstelement_class, &gst_pipeline_details);
}
-static gboolean
-gst_pipeline_pads_autoplug_func (GstElement *src, GstPad *pad, GstElement *sink)
+static void
+gst_pipeline_class_init (gpointer g_class, gpointer class_data)
{
- GList *sinkpads;
- gboolean connected = FALSE;
+ GObjectClass *gobject_class = G_OBJECT_CLASS (g_class);
+ GstElementClass *gstelement_class = GST_ELEMENT_CLASS (g_class);
+ GstPipelineClass *klass = GST_PIPELINE_CLASS (g_class);
- DEBUG("gstpipeline: autoplug pad connect function for \"%s\" to \"%s\"\n",
- gst_element_get_name(src), gst_element_get_name(sink));
+ parent_class = g_type_class_peek_parent (klass);
- sinkpads = gst_element_get_pad_list(sink);
- while (sinkpads) {
- GstPad *sinkpad = (GstPad *)sinkpads->data;
-
- // if we have a match, connect the pads
- if (sinkpad->direction == GST_PAD_SINK &&
- !GST_PAD_CONNECTED(sinkpad))
- {
- if (gst_caps_check_compatibility (pad->caps, sinkpad->caps)) {
- gst_pad_connect(pad, sinkpad);
- DEBUG("gstpipeline: autoconnect pad \"%s\" in element %s <-> ", pad->name,
- gst_element_get_name(src));
- DEBUG("pad \"%s\" in element %s\n", sinkpad->name,
- gst_element_get_name(sink));
- connected = TRUE;
- break;
- }
- }
- sinkpads = g_list_next(sinkpads);
- }
+ gobject_class->dispose = GST_DEBUG_FUNCPTR (gst_pipeline_dispose);
- if (!connected) {
- DEBUG("gstpipeline: no path to sinks for type\n");
- }
- return connected;
+ gstelement_class->change_state = GST_DEBUG_FUNCPTR (gst_pipeline_change_state);
}
-static void
-gst_pipeline_pads_autoplug (GstElement *src, GstElement *sink)
+static void
+gst_pipeline_init (GTypeInstance *instance, gpointer g_class)
{
- GList *srcpads;
- gboolean connected = FALSE;
-
- srcpads = gst_element_get_pad_list(src);
+ GstScheduler *scheduler;
+ GstPipeline *pipeline = GST_PIPELINE (instance);
+
+ /* pipelines are managing bins */
+ GST_FLAG_SET (pipeline, GST_BIN_FLAG_MANAGER);
- while (srcpads && !connected) {
- GstPad *srcpad = (GstPad *)srcpads->data;
+ /* get an instance of the default scheduler */
+ scheduler = gst_scheduler_factory_make (NULL, GST_ELEMENT (pipeline));
- if (srcpad->direction == GST_PAD_SRC)
- connected = gst_pipeline_pads_autoplug_func (src, srcpad, sink);
+ /* FIXME need better error handling */
+ if (scheduler == NULL) {
+ const gchar *name = gst_scheduler_factory_get_default_name ();
- srcpads = g_list_next(srcpads);
- }
-
- if (!connected) {
- DEBUG("gstpipeline: delaying pad connections for \"%s\" to \"%s\"\n",
- gst_element_get_name(src), gst_element_get_name(sink));
- gtk_signal_connect(GTK_OBJECT(src),"new_pad",
- GTK_SIGNAL_FUNC(gst_pipeline_pads_autoplug_func), sink);
+ g_error ("Critical error: could not get scheduler \"%s\"\n"
+ "Are you sure you have a registry ?\n"
+ "Run gst-register as root if you haven't done so yet.", name);
}
}
-/**
- * gst_pipeline_add_src:
- * @pipeline: the pipeline to add the src to
- * @src: the src to add to the pipeline
- *
- * Adds a src element to the pipeline. This element
- * will be used as a src for autoplugging. If you add more
- * than one src element, the previously added element will
- * be removed.
- */
-void
-gst_pipeline_add_src (GstPipeline *pipeline, GstElement *src)
+static void
+gst_pipeline_dispose (GObject *object)
{
- g_return_if_fail (pipeline != NULL);
- g_return_if_fail (GST_IS_PIPELINE (pipeline));
- g_return_if_fail (src != NULL);
- g_return_if_fail (GST_IS_ELEMENT (src));
+ GstPipeline *pipeline = GST_PIPELINE (object);
- if (pipeline->src) {
- printf("gstpipeline: *WARNING* removing previously added element \"%s\"\n",
- gst_element_get_name(pipeline->src));
- gst_bin_remove(GST_BIN(pipeline), pipeline->src);
- }
- pipeline->src = src;
- gst_bin_add(GST_BIN(pipeline), src);
-}
-
-/**
- * gst_pipeline_add_sink:
- * @pipeline: the pipeline to add the sink to
- * @sink: the sink to add to the pipeline
- *
- * Adds a sink element to the pipeline. This element
- * will be used as a sink for autoplugging
- */
-void
-gst_pipeline_add_sink (GstPipeline *pipeline, GstElement *sink)
-{
- g_return_if_fail (pipeline != NULL);
- g_return_if_fail (GST_IS_PIPELINE (pipeline));
- g_return_if_fail (sink != NULL);
- g_return_if_fail (GST_IS_ELEMENT (sink));
+ G_OBJECT_CLASS (parent_class)->dispose (object);
- pipeline->sinks = g_list_prepend (pipeline->sinks, sink);
- //gst_bin_add(GST_BIN(pipeline), sink);
+ gst_object_replace ((GstObject **)&GST_ELEMENT_SCHED (pipeline), NULL);
}
/**
- * gst_pipeline_autoplug:
- * @pipeline: the pipeline to autoplug
+ * gst_pipeline_new:
+ * @name: name of new pipeline
*
- * Constructs a complete pipeline by automatically
- * detecting the plugins needed.
+ * Create a new pipeline with the given name.
*
- * Returns: a gboolean indicating success or failure.
+ * Returns: newly created GstPipeline
*/
-gboolean
-gst_pipeline_autoplug (GstPipeline *pipeline)
+GstElement*
+gst_pipeline_new (const gchar *name)
{
- GList *elements;
- GstElement *element, *srcelement = NULL, *sinkelement= NULL;
- GList **factories;
- GList **base_factories;
- GstElementFactory *factory;
- GList *src_pads;
- GstCaps *src_caps = 0;
- guint i, numsinks;
- gboolean use_thread = FALSE, have_common = FALSE;
-
- g_return_val_if_fail(pipeline != NULL, FALSE);
- g_return_val_if_fail(GST_IS_PIPELINE(pipeline), FALSE);
-
- DEBUG("GstPipeline: autopluging pipeline \"%s\"\n",
- gst_element_get_name(GST_ELEMENT(pipeline)));
-
-
- // fase 1, run typedetect on the source if needed...
- if (!pipeline->src) {
- DEBUG("GstPipeline: no source detected, can't autoplug pipeline \"%s\"\n",
- gst_element_get_name(GST_ELEMENT(pipeline)));
- return FALSE;
- }
-
- DEBUG("GstPipeline: source \"%s\" has no MIME type, running typefind...\n",
- gst_element_get_name(pipeline->src));
-
- src_caps = gst_pipeline_typefind(pipeline, pipeline->src);
-
- if (src_caps) {
- DEBUG("GstPipeline: source \"%s\" type found %d\n", gst_element_get_name(pipeline->src),
- src_caps->id);
- }
- else {
- DEBUG("GstPipeline: source \"%s\" has no type\n", gst_element_get_name(pipeline->src));
- return FALSE;
- }
-
- srcelement = pipeline->src;
-
- elements = pipeline->sinks;
-
- numsinks = g_list_length(elements);
- factories = g_new0(GList *, numsinks);
- base_factories = g_new0(GList *, numsinks);
-
- i = 0;
- // fase 2, loop over all the sinks..
- while (elements) {
- GList *pads;
- GstPad *pad;
-
- element = GST_ELEMENT(elements->data);
-
- pad = (GstPad *)gst_element_get_pad_list (element)->data;
-
- base_factories[i] = factories[i] = gst_autoplug_caps (src_caps, pad->caps);
- i++;
-
- elements = g_list_next(elements);
- }
-
- while (factories[0]) {
- // fase 3: add common elements
- factory = (GstElementFactory *)(factories[0]->data);
-
- // check to other paths for mathing elements (factories)
- for (i=1; i<numsinks; i++) {
- if (!factories[i] || (factory != (GstElementFactory *)(factories[i]->data))) {
- goto differ;
- }
- factories[i] = g_list_next(factories[i]);
- }
- factory = (GstElementFactory *)(factories[0]->data);
-
- DEBUG("common factory \"%s\"\n", factory->name);
-
- element = gst_elementfactory_create(factory, factory->name);
- gst_bin_add(GST_BIN(pipeline), element);
-
- gst_pipeline_pads_autoplug(srcelement, element);
-
- srcelement = element;
-
- factories[0] = g_list_next(factories[0]);
-
- have_common = TRUE;
- }
-
-differ:
- // loop over all the sink elements
- elements = pipeline->sinks;
-
- i = 0;
- while (elements) {
- GstElement *thesrcelement = srcelement;
- GstElement *thebin = GST_ELEMENT(pipeline);
-
- if (g_list_length(base_factories[i]) == 0) goto next;
-
- sinkelement = (GstElement *)elements->data;
-
- use_thread = have_common;
-
- while (factories[i] || sinkelement) {
- // fase 4: add other elements...
-
- if (factories[i]) {
- factory = (GstElementFactory *)(factories[i]->data);
- DEBUG("factory \"%s\"\n", factory->name);
- element = gst_elementfactory_create(factory, factory->name);
- factories[i] = g_list_next(factories[i]);
- }
- // we have arived to the final sink element
- else {
- element = sinkelement;
- sinkelement = NULL;
- }
-
- // this element suggests the use of a thread, so we set one up...
- if (GST_ELEMENT_IS_THREAD_SUGGESTED(element) || use_thread) {
- GstElement *queue;
- GList *sinkpads;
- GstPad *srcpad, *sinkpad;
-
- use_thread = FALSE;
-
- DEBUG("sugest new thread for \"%s\" %08x\n", element->name, GST_FLAGS(element));
-
- // create a new queue and add to the previous bin
- queue = gst_elementfactory_make("queue", g_strconcat("queue_", gst_element_get_name(element), NULL));
- DEBUG("adding element \"%s\"\n", element->name);
- gst_bin_add(GST_BIN(thebin), queue);
-
- // this will be the new bin for all following elements
- thebin = gst_elementfactory_make("thread", g_strconcat("thread_", gst_element_get_name(element), NULL));
-
- srcpad = gst_element_get_pad(queue, "src");
-
- sinkpads = gst_element_get_pad_list(element);
- while (sinkpads) {
- sinkpad = (GstPad *)sinkpads->data;
-
- // FIXME connect matching pads, not just the first one...
- if (sinkpad->direction == GST_PAD_SINK &&
- !GST_PAD_CONNECTED(sinkpad)) {
- GstCaps *caps = gst_pad_get_caps (sinkpad);
-
- // the queue has the type of the elements it connects
- gst_pad_set_caps (srcpad, caps);
- gst_pad_set_caps (gst_element_get_pad(queue, "sink"), caps);
- break;
- }
- sinkpads = g_list_next(sinkpads);
- }
- gst_pipeline_pads_autoplug(thesrcelement, queue);
-
- DEBUG("adding element %s\n", gst_element_get_name (element));
- gst_bin_add(GST_BIN(thebin), element);
- DEBUG("adding element %s\n", gst_element_get_name (thebin));
- gst_bin_add(GST_BIN(pipeline), thebin);
- thesrcelement = queue;
- }
- // no thread needed, easy case
- else {
- DEBUG("adding element %s\n", gst_element_get_name (element));
- gst_bin_add(GST_BIN(thebin), element);
- }
- gst_pipeline_pads_autoplug(thesrcelement, element);
-
- // this element is now the new source element
- thesrcelement = element;
- }
-next:
- elements = g_list_next(elements);
- i++;
- }
- return TRUE;
-
- DEBUG("GstPipeline: unable to autoplug pipeline \"%s\"\n",
- gst_element_get_name(GST_ELEMENT(pipeline)));
- return FALSE;
+ return gst_element_factory_make ("pipeline", name);
}
-static GstElementStateReturn
-gst_pipeline_change_state (GstElement *element)
+static GstElementStateReturn
+gst_pipeline_change_state (GstElement *element)
{
- GstPipeline *pipeline;
-
- g_return_val_if_fail (GST_IS_PIPELINE (element), FALSE);
-
- pipeline = GST_PIPELINE (element);
-
- switch (GST_STATE_TRANSITION (pipeline)) {
+ switch (GST_STATE_TRANSITION (element)) {
case GST_STATE_NULL_TO_READY:
- // we need to set up internal state
- gst_pipeline_prepare (pipeline);
+ gst_scheduler_setup (GST_ELEMENT_SCHED (element));
break;
- default:
+ case GST_STATE_READY_TO_PAUSED:
+ case GST_STATE_PAUSED_TO_PLAYING:
+ case GST_STATE_PLAYING_TO_PAUSED:
+ case GST_STATE_PAUSED_TO_READY:
+ break;
+ case GST_STATE_READY_TO_NULL:
+ /* FIXME: calling gst_scheduler_reset() here is bad, since we
+ * might not be in cothread 0 */
+#if 0
+ if (GST_ELEMENT_SCHED (element)) {
+ gst_scheduler_reset (GST_ELEMENT_SCHED (element));
+ }
+#endif
break;
}
-
+
if (GST_ELEMENT_CLASS (parent_class)->change_state)
return GST_ELEMENT_CLASS (parent_class)->change_state (element);
-
+
return GST_STATE_SUCCESS;
}
-
-/**
- * gst_pipeline_iterate:
- * @pipeline: GstPipeline to iterate
- *
- * Cause the pipeline's contents to be run through one full 'iteration'.
- */
-void
-gst_pipeline_iterate (GstPipeline *pipeline)
-{
- g_return_if_fail (pipeline != NULL);
- g_return_if_fail (GST_IS_PIPELINE(pipeline));
-}
projects / platform / upstream / gstreamer.git / blobdiff