renatofilho@609: /* concat muxer plugin for GStreamer
renatofilho@609:  * Copyright (C) 2004 Renato Filhps <renato.filho@indt.org.br>
renatofilho@609:  *
renatofilho@609:  * This library is free software; you can redistribute it and/or
renatofilho@609:  * modify it under the terms of the GNU Library General Public
renatofilho@609:  * License as published by the Free Software Foundation; either
renatofilho@609:  * version 2 of the License, or (at your option) any later version.
renatofilho@609:  *
renatofilho@609:  * This library is distributed in the hope that it will be useful,
renatofilho@609:  * but WITHOUT ANY WARRANTY; without even the implied warranty of
renatofilho@609:  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
renatofilho@609:  * Library General Public License for more details.
renatofilho@609:  *
renatofilho@609:  * You should have received a copy of the GNU Library General Public
renatofilho@609:  * License along with this library; if not, write to the
renatofilho@609:  * Free Software Foundation, Inc., 59 Temple Place - Suite 330,
renatofilho@609:  * Boston, MA 02111-1307, USA.
renatofilho@609:  */
renatofilho@609: 
renatofilho@609: /**
renatofilho@609:  * SECTION:element-concatmux
renatofilho@609:  * @short_description: Concat that takes one or several digital streams
renatofilho@609:  * and muxes them to a single stream.
renatofilho@609:  *
renatofilho@609:  * <refsect2>
renatofilho@609:  * <title>Sample pipelines</title>
renatofilho@609:  * <para>
renatofilho@609:  * Here is a simple pipeline to concat 2 files into a another file:
renatofilho@609:  * <programlisting>
renatofilho@609:  * gst-launch concatmux name=m ! filesink location=output.txt  filesrc location=file_a.txt !  m. filesrc location=file_b.txt ! m.
renatofilho@609:  * </programlisting>
renatofilho@609:  * </para>
renatofilho@609:  * </refsect2>
renatofilho@609:  */
renatofilho@609: 
renatofilho@609: #ifdef HAVE_CONFIG_H
renatofilho@609: #include "config.h"
renatofilho@609: #endif
renatofilho@609: 
renatofilho@609: #include <gst/gst.h>
renatofilho@609: #include <gst/base/gstcollectpads.h>
renatofilho@609: 
renatofilho@609: #include <string.h>
renatofilho@609: 
renatofilho@609: GST_DEBUG_CATEGORY_STATIC (gst_concat_mux_debug);
renatofilho@609: #define GST_CAT_DEFAULT gst_concat_mux_debug
renatofilho@609: 
renatofilho@609: #define GST_TYPE_CONCAT_MUX (gst_concat_mux_get_type())
renatofilho@609: #define GST_CONCAT_MUX(obj) (G_TYPE_CHECK_INSTANCE_CAST((obj),GST_TYPE_CONCAT_MUX, GstConcatMux))
renatofilho@609: #define GST_CONCAT_MUX_CLASS(klass) (G_TYPE_CHECK_CLASS_CAST((klass),GST_TYPE_CONCAT_MUX, GstConcatMux))
renatofilho@609: #define GST_IS_CONCAT_MUX(obj) (G_TYPE_CHECK_INSTANCE_TYPE((obj),GST_TYPE_CONCAT_MUX))
renatofilho@609: #define GST_IS_CONCAT_MUX_CLASS(klass) (G_TYPE_CHECK_CLASS_TYPE((klass),GST_TYPE_CONCAT_MUX))
renatofilho@609: 
renatofilho@609: typedef struct _GstConcatMux GstConcatMux;
renatofilho@609: typedef struct _GstConcatMuxClass GstConcatMuxClass;
renatofilho@609: 
renatofilho@609: /**
renatofilho@609:  * GstConcatMux:
renatofilho@609:  *
renatofilho@609:  * The opaque #GstConcatMux structure.
renatofilho@609:  */
renatofilho@609: struct _GstConcatMux
renatofilho@609: {
renatofilho@609:   GstElement element;
renatofilho@609: 
renatofilho@609:   /* Caps */
renatofilho@609:   GstCaps *sink_caps;
renatofilho@609: 
renatofilho@609:   /* pad */
renatofilho@609:   GstPad *srcpad;
renatofilho@609:   GstPad *sinkpad;
renatofilho@609: 
renatofilho@609:   /* sinkpads */
renatofilho@609:   GSList *sinks;
renatofilho@609:   gint numpads;
renatofilho@609: 
renatofilho@609:   /* offset in stream */
renatofilho@609:   guint64 offset;
renatofilho@609:   guint64 timeoffset;
renatofilho@609:   guint64 start_time;
renatofilho@609: 
renatofilho@609:   gboolean negotiated;
renatofilho@609:   gboolean resync;
renatofilho@609:   gboolean done;
renatofilho@609: };
renatofilho@609: 
renatofilho@609: struct _GstConcatMuxClass
renatofilho@609: {
renatofilho@609:   GstElementClass parent_class;
renatofilho@609: };
renatofilho@609: 
renatofilho@609: /* elementfactory information */
renatofilho@609: static const GstElementDetails gst_concat_mux_details =
renatofilho@609: GST_ELEMENT_DETAILS ("Concat muxer",
renatofilho@609:     "Codec/Muxer",
renatofilho@609:     "mux concat streams",
renatofilho@609:     "Renato Filho <renato.filho@indt.org>");
renatofilho@609: 
renatofilho@609: static GstStaticPadTemplate src_factory = GST_STATIC_PAD_TEMPLATE ("src",
renatofilho@609:     GST_PAD_SRC,
renatofilho@609:     GST_PAD_ALWAYS,
renatofilho@609:     GST_STATIC_CAPS_ANY
renatofilho@609:     );
renatofilho@609: 
renatofilho@609: static GstStaticPadTemplate sink_factory = GST_STATIC_PAD_TEMPLATE ("sink_%d",
renatofilho@609:     GST_PAD_SINK,
renatofilho@609:     GST_PAD_REQUEST,
renatofilho@609:     GST_STATIC_CAPS_ANY         
renatofilho@609:     );
renatofilho@609: 
renatofilho@609: static void gst_concat_mux_base_init (gpointer g_class);
renatofilho@609: static void gst_concat_mux_class_init (GstConcatMuxClass * klass);
renatofilho@609: static void gst_concat_mux_init (GstConcatMux * concat_mux);
renatofilho@609: 
renatofilho@609: static void gst_concat_mux_finalize (GObject * object);
renatofilho@609: 
renatofilho@609: static gboolean gst_concat_mux_handle_src_event (GstPad * pad,
renatofilho@609:     GstEvent * event);
renatofilho@609: static gboolean gst_concat_mux_handle_sink_event (GstPad * pad,
renatofilho@609:     GstEvent * event);
renatofilho@609: 
renatofilho@609: static GstPad *gst_concat_mux_request_new_pad (GstElement * element,
renatofilho@609:     GstPadTemplate * templ, const gchar * name);
renatofilho@609: static GstStateChangeReturn gst_concat_mux_change_state (GstElement *
renatofilho@609:     element, GstStateChange transition);
renatofilho@609: 
renatofilho@609: static GstFlowReturn gst_concat_mux_chain (GstPad * pad,  GstBuffer * buf);
renatofilho@609: static void gst_concat_mux_clear (GstConcatMux *mux);
renatofilho@609: 
renatofilho@609: 
renatofilho@609: static GstElementClass *parent_class = NULL;
renatofilho@609: 
renatofilho@609: GType
renatofilho@609: gst_concat_mux_get_type (void)
renatofilho@609: {
renatofilho@609:   static GType concat_mux_type = 0;
renatofilho@609: 
renatofilho@609:   if (!concat_mux_type) {
renatofilho@609:     static const GTypeInfo concat_mux_info = {
renatofilho@609:       sizeof (GstConcatMuxClass),
renatofilho@609:       gst_concat_mux_base_init,
renatofilho@609:       NULL,
renatofilho@609:       (GClassInitFunc) gst_concat_mux_class_init,
renatofilho@609:       NULL,
renatofilho@609:       NULL,
renatofilho@609:       sizeof (GstConcatMux),
renatofilho@609:       0,
renatofilho@609:       (GInstanceInitFunc) gst_concat_mux_init,
renatofilho@609:     };
renatofilho@609: 
renatofilho@609:     concat_mux_type =
renatofilho@609:         g_type_register_static (GST_TYPE_ELEMENT, "GstConcatMux",
renatofilho@609:         &concat_mux_info, 0);
renatofilho@609:   }
renatofilho@609:   return concat_mux_type;
renatofilho@609: }
renatofilho@609: 
renatofilho@609: static void
renatofilho@609: gst_concat_mux_base_init (gpointer g_class)
renatofilho@609: {
renatofilho@609:   GstElementClass *element_class = GST_ELEMENT_CLASS (g_class);
renatofilho@609: 
renatofilho@609:   gst_element_class_add_pad_template (element_class,
renatofilho@609:       gst_static_pad_template_get (&src_factory));
renatofilho@609:   gst_element_class_add_pad_template (element_class,
renatofilho@609:       gst_static_pad_template_get (&sink_factory));
renatofilho@609: 
renatofilho@609:   gst_element_class_set_details (element_class, &gst_concat_mux_details);
renatofilho@609: }
renatofilho@609: 
renatofilho@609: static void
renatofilho@609: gst_concat_mux_class_init (GstConcatMuxClass * klass)
renatofilho@609: {
renatofilho@609:   GObjectClass *gobject_class;
renatofilho@609:   GstElementClass *gstelement_class;
renatofilho@609: 
renatofilho@609:   gobject_class = (GObjectClass *) klass;
renatofilho@609:   gstelement_class = (GstElementClass *) klass;
renatofilho@609: 
renatofilho@609:   parent_class = g_type_class_peek_parent (klass);
renatofilho@609: 
renatofilho@609:   gobject_class->finalize = gst_concat_mux_finalize;
renatofilho@609: 
renatofilho@609:   gstelement_class->request_new_pad = gst_concat_mux_request_new_pad;
renatofilho@609:   gstelement_class->change_state = gst_concat_mux_change_state;
renatofilho@609: }
renatofilho@609: 
renatofilho@609: static void
renatofilho@609: gst_concat_mux_init (GstConcatMux * concat_mux)
renatofilho@609: {
renatofilho@609:   GstElementClass *klass = GST_ELEMENT_GET_CLASS (concat_mux);
renatofilho@609: 
renatofilho@609:   concat_mux->srcpad =
renatofilho@609:       gst_pad_new_from_template (gst_element_class_get_pad_template (klass,
renatofilho@609:           "src"), "src");
renatofilho@609:   gst_pad_set_event_function (concat_mux->srcpad,
renatofilho@609:       gst_concat_mux_handle_src_event);
renatofilho@609:   gst_element_add_pad (GST_ELEMENT (concat_mux), concat_mux->srcpad);
renatofilho@609: }
renatofilho@609: 
renatofilho@609: static void
renatofilho@609: gst_concat_mux_finalize (GObject * object)
renatofilho@609: {
renatofilho@609:   GstConcatMux *concat_mux;
renatofilho@609: 
renatofilho@609:   concat_mux = GST_CONCAT_MUX (object);
renatofilho@609:   gst_concat_mux_clear (GST_CONCAT_MUX (object));
renatofilho@609: 
renatofilho@609:   G_OBJECT_CLASS (parent_class)->finalize (object);
renatofilho@609: }
renatofilho@609: 
renatofilho@609: static void
renatofilho@609: gst_concat_mux_free_pad (gpointer data,
renatofilho@609:                             gpointer user_data)
renatofilho@609: {
renatofilho@609:    GMutex *mux;
renatofilho@609: 
renatofilho@609:    mux = gst_pad_get_element_private (GST_PAD (data));
renatofilho@609:    g_mutex_unlock (mux);
renatofilho@609:    g_mutex_free (mux);
renatofilho@609:    gst_object_unref (GST_OBJECT (data)); 
renatofilho@609: }
renatofilho@609: 
renatofilho@609: static void
renatofilho@609: gst_concat_mux_clear (GstConcatMux *mux)
renatofilho@609: {
renatofilho@609:   mux->resync = TRUE;
renatofilho@609:   mux->timeoffset = 0;
renatofilho@609:   mux->offset = 0;
renatofilho@609:   mux->negotiated = FALSE;
renatofilho@609:   mux->done = TRUE;
renatofilho@609:   if (mux->sinks != NULL) {
renatofilho@609:     g_slist_foreach (mux->sinks, gst_concat_mux_free_pad, mux);
renatofilho@609:     g_slist_free (mux->sinks);
renatofilho@609:     mux->sinks = NULL;
renatofilho@609:   }
renatofilho@609: }
renatofilho@609: 
renatofilho@609: 
renatofilho@609: static GstPadLinkReturn
renatofilho@609: gst_concat_mux_sinkconnect (GstPad * pad, GstPad * peer)
renatofilho@609: {
renatofilho@609:   gchar *pad_name = NULL;
renatofilho@609:   GstConcatMux *concat_mux;
renatofilho@609: 
renatofilho@609:   concat_mux = GST_CONCAT_MUX (gst_pad_get_parent (pad));
renatofilho@609: 
renatofilho@609:   if (concat_mux->sink_caps != NULL) {
renatofilho@609:       GstCaps *peer_caps = gst_pad_get_caps (peer);
renatofilho@609:       GstCaps *intersect;
renatofilho@609: 
renatofilho@609:       intersect =  gst_caps_intersect (concat_mux->sink_caps, peer_caps);
renatofilho@609:       if (intersect == NULL) {
renatofilho@609:           gst_caps_unref (peer_caps);
renatofilho@609:           return GST_PAD_LINK_NOFORMAT;
renatofilho@609:       }
renatofilho@609:       gst_caps_unref (peer_caps);
renatofilho@609:       gst_caps_unref (intersect);
renatofilho@609:   } else {
renatofilho@609:       concat_mux->sink_caps = gst_pad_get_caps (pad);
renatofilho@609:   }
renatofilho@609: 
renatofilho@609:   pad_name = gst_pad_get_name (pad);
renatofilho@609: 
renatofilho@609:   GST_DEBUG_OBJECT (concat_mux, "sinkconnect triggered on %s", pad_name);
renatofilho@609: 
renatofilho@609:   g_free (pad_name);
renatofilho@609: 
renatofilho@609:   gst_object_unref (concat_mux);
renatofilho@609: 
renatofilho@609:   return GST_PAD_LINK_OK;
renatofilho@609: }
renatofilho@609: 
renatofilho@609: static GstPad *
renatofilho@609: gst_concat_mux_request_new_pad (GstElement * element,
renatofilho@609:     GstPadTemplate * templ, const gchar * req_name)
renatofilho@609: {
renatofilho@609:   GstConcatMux *concat_mux;
renatofilho@609:   GstPad *newpad;
renatofilho@609:   GstElementClass *klass = GST_ELEMENT_GET_CLASS (element);
renatofilho@609:   GMutex *mutex;
renatofilho@609: 
renatofilho@609:   g_return_val_if_fail (templ != NULL, NULL);
renatofilho@609: 
renatofilho@609:   if (templ->direction != GST_PAD_SINK) {
renatofilho@609:     g_warning ("concat_mux: request pad that is not a SINK pad\n");
renatofilho@609:     return NULL;
renatofilho@609:   }
renatofilho@609: 
renatofilho@609:   g_return_val_if_fail (GST_IS_CONCAT_MUX (element), NULL);
renatofilho@609: 
renatofilho@609:   concat_mux = GST_CONCAT_MUX (element);
renatofilho@609: 
renatofilho@609:   if (templ == gst_element_class_get_pad_template (klass, "sink_%d")) {
renatofilho@609:     gchar *name;
renatofilho@609: 
renatofilho@609:     /* create new pad with the name */
renatofilho@609:     name = g_strdup_printf ("sink_%02d", concat_mux->numpads);
renatofilho@609:     g_debug ("NEw pad %s", name);
renatofilho@609:     newpad = gst_pad_new_from_template (templ, name);
renatofilho@609:     g_free (name);
renatofilho@609:     concat_mux->sinks = g_slist_append (concat_mux->sinks, newpad);
renatofilho@609:     g_debug ("New sink %p / %d", newpad, g_slist_length (concat_mux->sinks));
renatofilho@609:     concat_mux->numpads++;
renatofilho@609:   } else {
renatofilho@609:     g_warning ("concat_mux: this is not our template!\n");
renatofilho@609:     return NULL;
renatofilho@609:   }
renatofilho@609: 
renatofilho@609:   mutex = g_mutex_new ();
renatofilho@609: 
renatofilho@609:   if (concat_mux->sinkpad == NULL) {
renatofilho@609:       concat_mux->sinkpad = newpad;
renatofilho@609:   }
renatofilho@609:   else {
renatofilho@609:       g_mutex_lock (mutex);
renatofilho@609:   }
renatofilho@609: 
renatofilho@609:   gst_pad_set_element_private (newpad, mutex);
renatofilho@609:   /* setup some pad functions */
renatofilho@609:   gst_pad_set_link_function (newpad, gst_concat_mux_sinkconnect);
renatofilho@609:   gst_pad_set_event_function (newpad, gst_concat_mux_handle_sink_event);
renatofilho@609:   gst_pad_set_chain_function (newpad, gst_concat_mux_chain);
renatofilho@609: 
renatofilho@609:   /* add the pad to the element */
renatofilho@609:   gst_element_add_pad (element, newpad);
renatofilho@609: 
renatofilho@609:   return newpad;
renatofilho@609: }
renatofilho@609: 
renatofilho@609: /* handle events */
renatofilho@609: static gboolean
renatofilho@609: gst_concat_mux_handle_src_event (GstPad * pad, GstEvent * event)
renatofilho@609: {
renatofilho@609:   GstConcatMux *concat_mux;
renatofilho@609:   GstEventType type;
renatofilho@609: 
renatofilho@609:   concat_mux = GST_CONCAT_MUX (gst_pad_get_parent (pad));
renatofilho@609: 
renatofilho@609:   type = event ? GST_EVENT_TYPE (event) : GST_EVENT_UNKNOWN;
renatofilho@609: 
renatofilho@609:   switch (type) {
renatofilho@609:     case GST_EVENT_SEEK:
renatofilho@609:       /* disable seeking for now */
renatofilho@609:       return FALSE;
renatofilho@609:     default:
renatofilho@609:       break;
renatofilho@609:   }
renatofilho@609: 
renatofilho@609:   gst_object_unref (concat_mux);
renatofilho@609: 
renatofilho@609:   return gst_pad_event_default (pad, event);
renatofilho@609: }
renatofilho@609: 
renatofilho@609: /* handle events */
renatofilho@609: static gboolean
renatofilho@609: gst_concat_mux_handle_sink_event (GstPad * pad, GstEvent * event)
renatofilho@609: {
renatofilho@609:   GstConcatMux *mux;
renatofilho@609:   GstEventType type;
renatofilho@609: 
renatofilho@609:   mux = GST_CONCAT_MUX (gst_pad_get_parent (pad));
renatofilho@609: 
renatofilho@609:   type = event ? GST_EVENT_TYPE (event) : GST_EVENT_UNKNOWN;
renatofilho@609: 
renatofilho@609:   switch (type) {
renatofilho@609:     case GST_EVENT_EOS:
renatofilho@609:     {
renatofilho@609:         mux->resync = TRUE;
renatofilho@609:         g_debug ("sink EOS %p / %d", pad, g_slist_length (mux->sinks));
renatofilho@609:         /* mark pad eos */
renatofilho@609:         mux->sinks  = g_slist_remove (mux->sinks, pad);
renatofilho@609:         g_debug ("sink len %d", g_slist_length (mux->sinks));
renatofilho@609:         if (g_slist_length (mux->sinks) != 0) {
renatofilho@609:            GMutex *mutex;
renatofilho@609:            mux->sinkpad = mux->sinks->data;
renatofilho@609:            mutex = (GMutex *) gst_pad_get_element_private (mux->sinkpad);
renatofilho@609:            g_mutex_unlock (mutex);
renatofilho@609:            g_debug ("sink pad %p", mux->sinkpad);
renatofilho@609:            return TRUE;
renatofilho@609:         }
renatofilho@609: 
renatofilho@609:         g_debug ("sink list is empty");
renatofilho@609:     }
renatofilho@609:     default:
renatofilho@609:       break;
renatofilho@609:   }
renatofilho@609: 
renatofilho@609:   gst_object_unref (mux);
renatofilho@609: 
renatofilho@609:   return gst_pad_event_default (pad, event);
renatofilho@609: }
renatofilho@609: 
renatofilho@609: static GstFlowReturn
renatofilho@609: gst_concat_mux_chain (GstPad * pad,  GstBuffer * buf)
renatofilho@609: {
renatofilho@609:   GstConcatMux *mux = (GstConcatMux *) GST_PAD_PARENT (pad);
renatofilho@609:   GstBuffer *databuf = NULL;
renatofilho@609:   GstFlowReturn ret = GST_FLOW_OK;
renatofilho@609:   GMutex *mutex;
renatofilho@609: 
renatofilho@609: 
renatofilho@609:   mutex = (GMutex*) gst_pad_get_element_private (pad);
renatofilho@609: 
renatofilho@609:   g_mutex_lock (mutex);
renatofilho@609:   if (mux->done) {
renatofilho@609:       g_debug ("DONE pad %p", pad);
renatofilho@609:       return GST_FLOW_OK;
renatofilho@609:   }
renatofilho@609: 
renatofilho@609:   databuf = gst_buffer_make_metadata_writable (buf);
renatofilho@609: 
renatofilho@609:   if (!mux->negotiated) {
renatofilho@609:       /*
renatofilho@609:     GstCaps *newcaps;
renatofilho@609:     newcaps = gst_pad_get_caps (mux->sinkpad);
renatofilho@609: 
renatofilho@609:     g_debug ("CAPS: %s",gst_caps_to_string (newcaps));
renatofilho@609: 
renatofilho@609:     if (!gst_pad_set_caps (mux->srcpad, newcaps))
renatofilho@609:       goto nego_error;
renatofilho@609:     */
renatofilho@609:     mux->negotiated = TRUE;            
renatofilho@609:   } 
renatofilho@609: 
renatofilho@609:   g_debug ("Running [%s]\n"
renatofilho@609:         "\tTOFFSET    [%"G_GUINT64_FORMAT"]\n"
renatofilho@609:         "\tB_TSTAMP   [%"G_GUINT64_FORMAT"]\n"
renatofilho@609:         "\tB_DURATION [%"G_GUINT64_FORMAT"]\n"
renatofilho@609:         "\tOFFSET     [%"G_GUINT64_FORMAT"]\n"
renatofilho@609:         "\tB_OFFSET   [%"G_GUINT64_FORMAT"]",
renatofilho@609:         gst_element_get_name (mux),
renatofilho@609:         mux->timeoffset, 
renatofilho@609:         GST_BUFFER_TIMESTAMP (databuf),
renatofilho@609:         GST_BUFFER_DURATION (databuf),
renatofilho@609:         mux->offset,
renatofilho@609:         GST_BUFFER_OFFSET (databuf));
renatofilho@609: 
renatofilho@609: 
renatofilho@609:   if (mux->resync) {
renatofilho@609:     g_debug ("RESYNC [%s]", gst_element_get_name (mux));
renatofilho@609:     mux->timeoffset += GST_BUFFER_TIMESTAMP (databuf);
renatofilho@609:     GST_BUFFER_TIMESTAMP (databuf) = mux->timeoffset;
renatofilho@609:     mux->timeoffset += GST_BUFFER_DURATION (databuf);
renatofilho@609: 
renatofilho@609:     mux->offset += GST_BUFFER_OFFSET (databuf);
renatofilho@609:     GST_BUFFER_OFFSET (databuf) = mux->offset;
renatofilho@609:     mux->offset += GST_BUFFER_SIZE (databuf);
renatofilho@609:     mux->resync = FALSE;
renatofilho@609:   } else {
renatofilho@609: 
renatofilho@609:     GST_BUFFER_TIMESTAMP (databuf) = mux->timeoffset;
renatofilho@609:     mux->timeoffset += GST_BUFFER_DURATION (databuf);
renatofilho@609: 
renatofilho@609:     GST_BUFFER_OFFSET (databuf) = mux->offset;
renatofilho@609:     mux->offset += GST_BUFFER_SIZE (databuf);
renatofilho@609:   }
renatofilho@609: 
renatofilho@609:   gst_buffer_set_caps (databuf, GST_PAD_CAPS (pad));
renatofilho@609:   ret = gst_pad_push (mux->srcpad, databuf);
renatofilho@609: 
renatofilho@609:   //gst_buffer_unref (buf);
renatofilho@609: 
renatofilho@609:   g_mutex_unlock (mutex);
renatofilho@609:   return ret;
renatofilho@609: /*
renatofilho@609: nego_error:
renatofilho@609:   {
renatofilho@609:     GST_WARNING_OBJECT (mux, "failed to set caps");
renatofilho@609:     GST_ELEMENT_ERROR (mux, CORE, NEGOTIATION, (NULL), (NULL));
renatofilho@609:     return GST_FLOW_NOT_NEGOTIATED;
renatofilho@609:   }
renatofilho@609:   */
renatofilho@609:   /*
renatofilho@609: no_caps:
renatofilho@609:   {
renatofilho@609:     GST_WARNING_OBJECT (mux, "no caps on the incoming buffer %p", best->buffer);
renatofilho@609:     GST_ELEMENT_ERROR (mux, CORE, NEGOTIATION, (NULL), (NULL));
renatofilho@609:     ret = GST_FLOW_NOT_NEGOTIATED;
renatofilho@609:     goto beach;
renatofilho@609:   }
renatofilho@609:   */
renatofilho@609: }
renatofilho@609: 
renatofilho@609: static GstStateChangeReturn
renatofilho@609: gst_concat_mux_change_state (GstElement * element, GstStateChange transition)
renatofilho@609: {
renatofilho@609:   GstConcatMux *concat_mux;
renatofilho@609:   GstStateChangeReturn ret;
renatofilho@609: 
renatofilho@609:   concat_mux = GST_CONCAT_MUX (element);
renatofilho@609: 
renatofilho@609:   switch (transition) {
renatofilho@609:     case GST_STATE_CHANGE_READY_TO_PAUSED:
renatofilho@609:       concat_mux->done = FALSE;
renatofilho@609:       concat_mux->resync = TRUE;
renatofilho@609:       GST_DEBUG_OBJECT (concat_mux, "starting collect pads");
renatofilho@609:       break;
renatofilho@609:     case GST_STATE_CHANGE_PAUSED_TO_READY:
renatofilho@609:       GST_DEBUG_OBJECT (concat_mux, "stopping collect pads");
renatofilho@609:       gst_concat_mux_clear (concat_mux);
renatofilho@609:       break;
renatofilho@609:     default:
renatofilho@609:       break;
renatofilho@609:   }
renatofilho@609: 
renatofilho@609:   ret = GST_ELEMENT_CLASS (parent_class)->change_state (element, transition);
renatofilho@609:   if (ret == GST_STATE_CHANGE_FAILURE)
renatofilho@609:     return ret;
renatofilho@609: 
renatofilho@609:   switch (transition) {
renatofilho@609:     default:
renatofilho@609:       break;
renatofilho@609:   }
renatofilho@609: 
renatofilho@609:   return ret;
renatofilho@609: }
renatofilho@609: 
renatofilho@609: gboolean
renatofilho@609: gst_concat_mux_plugin_init (GstPlugin * plugin)
renatofilho@609: {
renatofilho@609: #ifdef ENABLE_NLS
renatofilho@609:   setlocale (LC_ALL, "");
renatofilho@609:   bindtextdomain (GETTEXT_PACKAGE, LOCALEDIR);
renatofilho@609: #endif /* ENABLE_NLS */
renatofilho@609: 
renatofilho@609:   GST_DEBUG_CATEGORY_INIT (gst_concat_mux_debug, "concatmux", 0,
renatofilho@609:       "concat muxer");
renatofilho@609:       
renatofilho@609:   return gst_element_register (plugin, "concatmux", GST_RANK_NONE,
renatofilho@609:       GST_TYPE_CONCAT_MUX);
renatofilho@609: }
renatofilho@609: 
renatofilho@609: GST_PLUGIN_DEFINE (GST_VERSION_MAJOR,
renatofilho@609:     GST_VERSION_MINOR,
renatofilho@609:     "concat muxer",
renatofilho@609:     "Concat streamers",
renatofilho@609:      plugin_init, VERSION, "LGPL", "ConcatMux", "")
renatofilho@609: