Initial revision

Original commit message from CVS:
Initial revision

4 files changed, 392 insertions, 0 deletions

diff --git a/gst/auparse/.gitignore b/gst/auparse/.gitignore
new file mode 100644
index 00000000..08f5ed37
--- /dev/null
+++ b/gst/auparse/.gitignore
@@ -0,0 +1,7 @@
+Makefile
+Makefile.in
+*.o
+*.lo
+*.la
+.deps
+.libs
diff --git a/gst/auparse/Makefile.am b/gst/auparse/Makefile.am
new file mode 100644
index 00000000..0a7ff222
--- /dev/null
+++ b/gst/auparse/Makefile.am
@@ -0,0 +1,8 @@
+filterdir = $(libdir)/gst
+
+filter_LTLIBRARIES = libgstparseau.la
+
+libgstparseau_la_SOURCES = gstparseau.c
+libgstparseau_la_CFLAGS = $(GLIB_CFLAGS) $(XML_CFLAGS) $(GST_CFLAGS)
+
+noinst_HEADERS = gstparseau.h
diff --git a/gst/auparse/gstparseau.c b/gst/auparse/gstparseau.c
new file mode 100644
index 00000000..782148d7
--- /dev/null
+++ b/gst/auparse/gstparseau.c
@@ -0,0 +1,303 @@
+/* Gnome-Streamer
+ * Copyright (C) <1999> Erik Walthinsen <omega@cse.ogi.edu>
+ *
+ * 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.
+ */
+
+/* 2001/04/03 - Updated parseau to use caps nego
+ *              Zaheer Merali <zaheer@grid9.net
+ */
+
+#include <stdlib.h>
+#include <string.h>
+
+#include <gstparseau.h>
+
+
+/* elementfactory information */
+static GstElementDetails gst_parseau_details = {
+  ".au parser",
+  "Parser/Audio",
+  "Parse an .au file into raw audio",
+  VERSION,
+  "Erik Walthinsen <omega@cse.ogi.edu>",
+  "(C) 1999",
+};
+
+static GstCaps*
+au_typefind (GstBuffer *buf, gpointer private)
+{
+  GstCaps *new = NULL;
+  gulong *head = (gulong *) GST_BUFFER_DATA (buf);
+
+  if (*head == 0x2e736e64 || *head == 0x646e732e)
+    new = gst_caps_new ("au_typefind", "audio/au", NULL);
+
+  return new;
+}
+
+/* typefactory for 'au' */
+static GstTypeDefinition audefinition = {
+  "parseau_audio/au",
+  "audio/au",
+  ".au",
+  au_typefind,
+};
+
+GST_PADTEMPLATE_FACTORY (sink_factory_templ,
+  "sink",
+  GST_PAD_SINK,
+  GST_PAD_ALWAYS,
+  GST_CAPS_NEW (
+    "auparse_sink",
+    "audio/au",
+    NULL
+  )
+)
+
+
+GST_PADTEMPLATE_FACTORY (src_factory_templ,
+  "src",
+  GST_PAD_SRC,
+  GST_PAD_ALWAYS,
+  GST_CAPS_NEW (
+    "auparse_src",
+    "audio/raw",
+      "format",     GST_PROPS_STRING ("int"),
+      //"law",        GST_PROPS_INT_RANGE (0, 2),
+      "law",        GST_PROPS_INT (0),
+      "endianness", GST_PROPS_INT (G_BYTE_ORDER),
+      "signed",     GST_PROPS_LIST(
+		      GST_PROPS_BOOLEAN (FALSE),
+		      GST_PROPS_BOOLEAN (TRUE)
+	  	    ),
+      "width",      GST_PROPS_LIST(
+		      GST_PROPS_INT (8),
+		      GST_PROPS_INT (16)
+		    ),
+      "depth",      GST_PROPS_LIST(
+		      GST_PROPS_INT (8),
+		      GST_PROPS_INT (16)
+		    ),
+      "rate",       GST_PROPS_INT_RANGE (8000,48000),
+      "channels",   GST_PROPS_INT_RANGE (1, 2)
+  )
+)
+
+/* ParseAu signals and args */
+enum {
+  /* FILL ME */
+  LAST_SIGNAL
+};
+
+enum {
+  ARG_0,
+  /* FILL ME */
+};
+
+static void 	gst_parseau_class_init		(GstParseAuClass *klass);
+static void 	gst_parseau_init		(GstParseAu *parseau);
+
+static void 	gst_parseau_chain		(GstPad *pad,GstBuffer *buf);
+
+static GstElementClass *parent_class = NULL;
+//static guint gst_parseau_signals[LAST_SIGNAL] = { 0 };
+
+GType
+gst_parseau_get_type (void) 
+{
+  static GType parseau_type = 0;
+
+  if (!parseau_type) {
+    static const GTypeInfo parseau_info = {
+      sizeof(GstParseAuClass),      NULL,
+      NULL,
+      (GClassInitFunc) gst_parseau_class_init,
+      NULL,
+      NULL,
+      sizeof(GstParseAu),
+      0,
+      (GInstanceInitFunc) gst_parseau_init,
+    };
+    parseau_type = g_type_register_static (GST_TYPE_ELEMENT, "GstParseAu", &parseau_info, 0);
+  }
+  return parseau_type;
+}
+
+static void
+gst_parseau_class_init (GstParseAuClass *klass) 
+{
+  GstElementClass *gstelement_class;
+
+  gstelement_class = (GstElementClass*) klass;
+
+  parent_class = g_type_class_ref (GST_TYPE_ELEMENT);
+}
+
+static void 
+gst_parseau_init (GstParseAu *parseau) 
+{
+  parseau->sinkpad = gst_pad_new_from_template (
+		  GST_PADTEMPLATE_GET (sink_factory_templ), "sink");
+  gst_pad_set_caps (parseau->sinkpad, gst_pad_get_padtemplate_caps (parseau->sinkpad));
+  gst_element_add_pad (GST_ELEMENT (parseau), parseau->sinkpad);
+  gst_pad_set_chain_function (parseau->sinkpad, gst_parseau_chain);
+
+  parseau->srcpad = gst_pad_new_from_template (
+		  GST_PADTEMPLATE_GET (src_factory_templ), "src");
+  gst_element_add_pad (GST_ELEMENT (parseau), parseau->srcpad);
+
+  parseau->offset = 0;
+  parseau->size = 0;
+  parseau->encoding = 0;
+  parseau->frequency = 0;
+  parseau->channels = 0;
+}
+
+static void 
+gst_parseau_chain (GstPad *pad, GstBuffer *buf) 
+{
+  GstParseAu *parseau;
+  gchar *data;
+  glong size;
+  GstCaps* tempcaps;
+
+  g_return_if_fail (pad != NULL);
+  g_return_if_fail (GST_IS_PAD (pad));
+  g_return_if_fail (buf != NULL);
+
+  parseau = GST_PARSEAU (gst_pad_get_parent (pad));
+  
+  GST_DEBUG (0, "gst_parseau_chain: got buffer in '%s'\n",
+          gst_element_get_name (GST_ELEMENT (parseau)));
+
+  data = GST_BUFFER_DATA (buf);
+  size = GST_BUFFER_SIZE (buf);
+
+  /* if we haven't seen any data yet... */
+  if (parseau->size == 0) {
+    GstBuffer *newbuf;
+    gulong *head = (gulong *)data;
+
+    /* normal format is big endian (au is a Sparc format) */
+    if (GULONG_FROM_BE (*(head++)) == 0x2e736e64) {
+      parseau->le = 0;
+      parseau->offset 		= GULONG_FROM_BE (*(head++));
+      parseau->size 		= GULONG_FROM_BE (*(head++));
+      parseau->encoding 	= GULONG_FROM_BE (*(head++));
+      parseau->frequency 	= GULONG_FROM_BE (*(head++));
+      parseau->channels 	= GULONG_FROM_BE (*(head++));
+
+    /* but I wouldn't be surprised by a little endian version */
+    } else if (GULONG_FROM_LE (*(head++)) == 0x2e736e64) {
+      parseau->le = 1;
+      parseau->offset 		= GULONG_FROM_LE(*(head++));
+      parseau->size 		= GULONG_FROM_LE(*(head++));
+      parseau->encoding 	= GULONG_FROM_LE(*(head++));
+      parseau->frequency 	= GULONG_FROM_LE(*(head++));
+      parseau->channels 	= GULONG_FROM_LE(*(head++));
+
+    } else {
+      g_warning ("help, dunno what I'm looking at!\n");
+      gst_buffer_unref(buf);
+      return;
+    }
+
+    g_print ("offset %ld, size %ld, encoding %ld, frequency %ld, channels %ld\n",
+             parseau->offset,parseau->size,parseau->encoding,
+             parseau->frequency,parseau->channels);
+    GST_DEBUG (0, "offset %ld, size %ld, encoding %ld, frequency %ld, channels %ld\n",
+             parseau->offset,parseau->size,parseau->encoding,
+             parseau->frequency,parseau->channels);
+
+    tempcaps = gst_caps_copy (gst_pad_get_padtemplate_caps (parseau->srcpad));
+    
+    gst_caps_set (tempcaps, "format", GST_PROPS_STRING ("int"));
+    gst_caps_set (tempcaps, "rate", GST_PROPS_INT (parseau->frequency));
+    gst_caps_set (tempcaps, "channels", GST_PROPS_INT (parseau->channels));
+
+    switch (parseau->encoding) {
+      case 1:
+	gst_caps_set (tempcaps, "law", GST_PROPS_INT (1));
+	gst_caps_set (tempcaps, "depth", GST_PROPS_INT (8));
+        gst_caps_set (tempcaps, "width", GST_PROPS_INT (8));
+        gst_caps_set (tempcaps, "signed", GST_PROPS_BOOLEAN (FALSE));
+	break;
+      case 2:
+	gst_caps_set (tempcaps, "law", GST_PROPS_INT (0));
+	gst_caps_set (tempcaps, "depth", GST_PROPS_INT (8));
+	gst_caps_set (tempcaps, "width", GST_PROPS_INT (8));
+	gst_caps_set (tempcaps, "signed", GST_PROPS_BOOLEAN (TRUE));
+	break;
+      case 3:
+	gst_caps_set (tempcaps, "law", GST_PROPS_INT (0));
+	gst_caps_set (tempcaps, "depth", GST_PROPS_INT (16));
+	gst_caps_set (tempcaps, "width", GST_PROPS_INT (16));
+	gst_caps_set (tempcaps, "signed", GST_PROPS_BOOLEAN (TRUE));
+	break;
+      default:
+	g_warning ("help!, dont know how to deal with this format yet\n");
+	return;
+    }
+
+    gst_pad_set_caps (parseau->srcpad, tempcaps);
+
+    newbuf = gst_buffer_new ();
+    GST_BUFFER_DATA (newbuf) = (gpointer) malloc (size-(parseau->offset));
+    memcpy (GST_BUFFER_DATA (newbuf), data+24, size-(parseau->offset));
+    GST_BUFFER_SIZE (newbuf) = size-(parseau->offset);
+
+    gst_buffer_unref (buf);
+
+    gst_pad_push (parseau->srcpad, newbuf);
+    return;
+  }
+
+
+  gst_pad_push (parseau->srcpad, buf);
+}
+
+
+static gboolean
+plugin_init (GModule *module, GstPlugin *plugin)
+{
+  GstElementFactory *factory;
+  GstTypeFactory *type;
+
+  /* create the plugin structure */
+  /* create an elementfactory for the parseau element and list it */
+  factory = gst_elementfactory_new ("parseau", GST_TYPE_PARSEAU,
+                                    &gst_parseau_details);
+  g_return_val_if_fail (factory != NULL, FALSE);
+
+  gst_elementfactory_add_padtemplate (factory, GST_PADTEMPLATE_GET (sink_factory_templ));
+  gst_elementfactory_add_padtemplate (factory, GST_PADTEMPLATE_GET (src_factory_templ));
+
+  type = gst_typefactory_new (&audefinition);
+
+  gst_plugin_add_feature (plugin, GST_PLUGIN_FEATURE (factory));
+  gst_plugin_add_feature (plugin, GST_PLUGIN_FEATURE (type));
+
+  return TRUE;
+}
+
+GstPluginDesc plugin_desc = {
+  GST_VERSION_MAJOR,
+  GST_VERSION_MINOR,
+  "parseau",
+  plugin_init
+};
+
diff --git a/gst/auparse/gstparseau.h b/gst/auparse/gstparseau.h
new file mode 100644
index 00000000..1bfd852e
--- /dev/null
+++ b/gst/auparse/gstparseau.h
@@ -0,0 +1,74 @@
+/* Gnome-Streamer
+ * Copyright (C) <1999> Erik Walthinsen <omega@cse.ogi.edu>
+ *
+ * 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_PARSEAU_H__
+#define __GST_PARSEAU_H__
+
+
+#include <config.h>
+#include <gst/gst.h>
+
+
+#ifdef __cplusplus
+extern "C" {
+#endif /* __cplusplus */
+
+
+#define GST_TYPE_PARSEAU \
+  (gst_parseau_get_type())
+#define GST_PARSEAU(obj) \
+  (G_TYPE_CHECK_INSTANCE_CAST((obj),GST_TYPE_PARSEAU,GstParseAu))
+#define GST_PARSEAU_CLASS(klass) \
+  (G_TYPE_CHECK_CLASS_CAST((klass),GST_TYPE_PARSEAU,GstParseAu))
+#define GST_IS_PARSEAU(obj) \
+  (G_TYPE_CHECK_INSTANCE_TYPE((obj),GST_TYPE_PARSEAU))
+#define GST_IS_PARSEAU_CLASS(obj) \
+  (G_TYPE_CHECK_CLASS_TYPE((klass),GST_TYPE_PARSEAU))
+
+typedef struct _GstParseAu GstParseAu;
+typedef struct _GstParseAuClass GstParseAuClass;
+
+struct _GstParseAu {
+  GstElement element;
+
+  GstPad *sinkpad,*srcpad;
+
+  guchar le;
+  glong offset;
+  glong size;
+  glong encoding;
+  glong frequency;
+  glong channels;
+
+};
+
+struct _GstParseAuClass {
+  GstElementClass parent_class;
+};
+
+GType gst_parseau_get_type (void);
+
+
+#ifdef __cplusplus
+}
+#endif /* __cplusplus */
+
+
+#endif /* __GST_PARSEAU_H__ */