--- /dev/null
+/* RTP DTMF muxer element for GStreamer
+ *
+ * gstrtpdtmfmux.c:
+ *
+ * Copyright (C) <2007> Nokia Corporation.
+ * Contact: Zeeshan Ali <zeeshan.ali@nokia.com>
+ * Copyright (C) 1999,2000 Erik Walthinsen <omega@cse.ogi.edu>
+ * 2000,2005 Wim Taymans <wim@fluendo.com>
+ *
+ * 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.
+ */
+
+/**
+ * SECTION:element-rtpdtmfmux
+ * @short_description: Muxer that takes one or several RTP streams
+ * and muxes them to a single rtp stream.
+ *
+ * <refsect2>
+ * </refsect2>
+ */
+
+#ifdef HAVE_CONFIG_H
+#include "config.h"
+#endif
+
+#include <gst/gst.h>
+#include <gstrtpdtmfmux.h>
+#include <string.h>
+
+GST_DEBUG_CATEGORY_STATIC (gst_rtp_dtmf_mux_debug);
+#define GST_CAT_DEFAULT gst_rtp_dtmf_mux_debug
+
+/* elementfactory information */
+static const GstElementDetails gst_rtp_dtmf_mux_details =
+GST_ELEMENT_DETAILS ("RTP muxer",
+ "Codec/Muxer",
+ "mixes RTP DTMF streams into other RTP streams",
+ "Zeeshan Ali <first.last@nokia.com>");
+
+static void gst_rtp_dtmf_mux_base_init (gpointer g_class);
+static void gst_rtp_dtmf_mux_class_init (GstRTPDTMFMuxClass * klass);
+static void gst_rtp_dtmf_mux_finalize (GObject * object);
+
+static gboolean gst_rtp_dtmf_mux_sink_event (GstPad * pad,
+ GstEvent * event);
+static GstFlowReturn gst_rtp_dtmf_mux_chain (GstPad * pad,
+ GstBuffer * buffer);
+
+static GstRTPMuxClass *parent_class = NULL;
+
+GType
+gst_rtp_dtmf_mux_get_type (void)
+{
+ static GType mux_type = 0;
+
+ if (!mux_type) {
+ static const GTypeInfo mux_info = {
+ sizeof (GstRTPDTMFMuxClass),
+ gst_rtp_dtmf_mux_base_init,
+ NULL,
+ (GClassInitFunc) gst_rtp_dtmf_mux_class_init,
+ NULL,
+ NULL,
+ sizeof (GstRTPDTMFMux),
+ 0,
+ (GInstanceInitFunc) NULL,
+ };
+
+ mux_type =
+ g_type_register_static (GST_TYPE_RTP_MUX, "GstRTPDTMFMux",
+ &mux_info, 0);
+ }
+ return mux_type;
+}
+
+static void
+gst_rtp_dtmf_mux_base_init (gpointer g_class)
+{
+ GstElementClass *element_class = GST_ELEMENT_CLASS (g_class);
+
+ gst_element_class_set_details (element_class, &gst_rtp_dtmf_mux_details);
+}
+
+static void
+gst_rtp_dtmf_mux_class_init (GstRTPDTMFMuxClass * klass)
+{
+ GObjectClass *gobject_class;
+ GstElementClass *gstelement_class;
+ GstRTPMuxClass *gstrtpmux_class;
+
+ gobject_class = (GObjectClass *) klass;
+ gstelement_class = (GstElementClass *) klass;
+ gstrtpmux_class = (GstRTPMuxClass *) klass;
+
+ parent_class = g_type_class_peek_parent (klass);
+
+ gobject_class->finalize = gst_rtp_dtmf_mux_finalize;
+ gstrtpmux_class->chain_func = gst_rtp_dtmf_mux_chain;
+ gstrtpmux_class->sink_event_func = gst_rtp_dtmf_mux_sink_event;
+}
+
+static void
+gst_rtp_dtmf_mux_finalize (GObject * object)
+{
+ GstRTPDTMFMux *mux;
+
+ mux = GST_RTP_DTMF_MUX (object);
+
+ G_OBJECT_CLASS (parent_class)->finalize (object);
+}
+
+static GstFlowReturn
+gst_rtp_dtmf_mux_chain (GstPad * pad, GstBuffer * buffer)
+{
+ GstRTPDTMFMux *mux;
+ gboolean drop = FALSE;
+ GstFlowReturn ret;
+
+ mux = GST_RTP_DTMF_MUX (gst_pad_get_parent (pad));
+
+ GST_OBJECT_LOCK (mux);
+ if (mux->special_pad != NULL &&
+ mux->special_pad != pad) {
+ drop = TRUE;
+ }
+
+ if (drop) {
+ gst_buffer_unref (buffer);
+ ret = GST_FLOW_OK;
+ GST_OBJECT_UNLOCK (mux);
+ }
+
+ else {
+ GST_OBJECT_UNLOCK (mux);
+ if (parent_class->chain_func)
+ ret = parent_class->chain_func (pad, buffer);
+ else
+ ret = GST_FLOW_ERROR;
+ }
+
+ gst_object_unref (mux);
+ return ret;
+}
+
+static gboolean
+gst_rtp_dtmf_mux_sink_event (GstPad * pad, GstEvent * event)
+{
+ GstRTPDTMFMux *mux;
+ GstEventType type;
+ gboolean ret = FALSE;
+
+ type = event ? GST_EVENT_TYPE (event) : GST_EVENT_UNKNOWN;
+
+ mux = (GstRTPDTMFMux *) gst_pad_get_parent (pad);
+
+ switch (type) {
+ case GST_EVENT_CUSTOM_DOWNSTREAM_OOB:
+ {
+ const GstStructure *structure;
+
+ structure = gst_event_get_structure (event);
+ /* FIXME: is this event generic enough to be given a generic name? */
+ if (structure && gst_structure_has_name (structure, "stream-lock")) {
+ gboolean lock;
+
+ if (!gst_structure_get_boolean (structure, "lock", &lock))
+ break;
+
+ GST_OBJECT_LOCK (mux);
+ if (lock) {
+ if (mux->special_pad != NULL) {
+ GST_WARNING_OBJECT (mux,
+ "Stream lock already acquired by pad %s",
+ GST_ELEMENT_NAME (mux->special_pad));
+ }
+
+ else
+ mux->special_pad = gst_object_ref (pad);
+ }
+
+ else {
+ if (mux->special_pad == NULL) {
+ GST_WARNING_OBJECT (mux,
+ "Stream lock not acquired, can't release it");
+ }
+
+ else if (pad != mux->special_pad) {
+ GST_WARNING_OBJECT (mux,
+ "pad %s attempted to release Stream lock"
+ " which was acquired by pad %s", GST_ELEMENT_NAME (pad),
+ GST_ELEMENT_NAME (mux->special_pad));
+ }
+
+ else {
+ gst_object_unref (mux->special_pad);
+ mux->special_pad = NULL;
+ }
+ }
+
+ GST_OBJECT_UNLOCK (mux);
+ }
+
+ ret = TRUE;
+ break;
+ }
+ default:
+ {
+ if (parent_class->sink_event_func) {
+ /* Give the parent a chance to handle the event first */
+ ret = parent_class->sink_event_func (pad, event);
+ }
+
+ else
+ ret = gst_pad_event_default (pad, event);
+ break;
+ }
+ }
+
+ gst_object_unref (mux);
+
+ return ret;
+}
+
+gboolean
+gst_rtp_dtmf_mux_plugin_init (GstPlugin * plugin)
+{
+ GST_DEBUG_CATEGORY_INIT (gst_rtp_dtmf_mux_debug, "rtpdtmfmux", 0,
+ "rtp dtmf muxer");
+
+ return gst_element_register (plugin, "rtpdtmfmux", GST_RANK_NONE,
+ GST_TYPE_RTP_DTMF_MUX);
+}
+
--- /dev/null
+/* RTP muxer element for GStreamer
+ *
+ * gstrtpdtmfmux.h:
+ *
+ * Copyright (C) <2007> Nokia Corporation.
+ * Contact: Zeeshan Ali <zeeshan.ali@nokia.com>
+ * Copyright (C) 1999,2000 Erik Walthinsen <omega@cse.ogi.edu>
+ * 2000,2005 Wim Taymans <wim@fluendo.com>
+ *
+ * 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.
+ */
+
+#ifndef __GST_RTP_DTMF_MUX_H__
+#define __GST_RTP_DTMF_MUX_H__
+
+#include <gst/gst.h>
+#include <gstrtpmux.h>
+
+G_BEGIN_DECLS
+
+#define GST_TYPE_RTP_DTMF_MUX (gst_rtp_dtmf_mux_get_type())
+#define GST_RTP_DTMF_MUX(obj) (G_TYPE_CHECK_INSTANCE_CAST((obj),GST_TYPE_RTP_DTMF_MUX, GstRTPDTMFMux))
+#define GST_RTP_DTMF_MUX_CLASS(klass) (G_TYPE_CHECK_CLASS_CAST((klass),GST_TYPE_RTP_DTMF_MUX, GstRTPDTMFMux))
+#define GST_IS_RTP_DTMF_MUX(obj) (G_TYPE_CHECK_INSTANCE_TYPE((obj),GST_TYPE_RTP_DTMF_MUX))
+#define GST_IS_RTP_DTMF_MUX_CLASS(obj) (G_TYPE_CHECK_CLASS_TYPE((klass),GST_TYPE_RTP_DTMF_MUX))
+
+typedef struct _GstRTPDTMFMux GstRTPDTMFMux;
+typedef struct _GstRTPDTMFMuxClass GstRTPDTMFMuxClass;
+
+/**
+ * GstRTPDTMFMux:
+ *
+ * The opaque #GstRTPDTMFMux structure.
+ */
+struct _GstRTPDTMFMux
+{
+ GstRTPMux mux;
+
+ /* our special pad */
+ GstPad *special_pad;
+};
+
+struct _GstRTPDTMFMuxClass
+{
+ GstRTPMuxClass parent_class;
+};
+
+GType gst_rtp_dtmf_mux_get_type (void);
+gboolean gst_rtp_dtmf_mux_plugin_init (GstPlugin * plugin);
+
+G_END_DECLS
+
+#endif /* __GST_RTP_DTMF_MUX_H__ */
+
--- /dev/null
+/* GStreamer RTP Muxer Plugins
+ *
+ * gstrtpdtmf.c:
+ *
+ * Copyright (C) <2007> Nokia Corporation.
+ * Contact: Zeeshan Ali <zeeshan.ali@nokia.com>
+ * Copyright (C) 1999,2000 Erik Walthinsen <omega@cse.ogi.edu>
+ * 2000,2005 Wim Taymans <wim@fluendo.com>
+ *
+ * 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.
+ */
+
+#ifdef HAVE_CONFIG_H
+# include "config.h"
+#endif
+
+#include "gstrtpmux.h"
+#include "gstrtpdtmfmux.h"
+
+static gboolean
+plugin_init (GstPlugin * plugin)
+{
+ if (!gst_rtp_mux_plugin_init (plugin))
+ return FALSE;
+ if (!gst_rtp_dtmf_mux_plugin_init (plugin))
+ return FALSE;
+
+ return TRUE;
+}
+
+GST_PLUGIN_DEFINE (GST_VERSION_MAJOR,
+ GST_VERSION_MINOR,
+ "rtpmuxer",
+ "RTP Muxer plugins",
+ plugin_init, "0.1" , "LGPL", "Farsight", "http://farsight.sf.net");
projects / platform / upstream / gstreamer.git / commitdiff