From ad6ed7da2d0d15eecc924dfe408320652481e885 Mon Sep 17 00:00:00 2001 From: Andy Wingo Date: Sat, 22 Dec 2001 23:26:33 +0000 Subject: Initial revision Original commit message from CVS: Initial revision --- gst/passthrough/.gitignore | 7 + gst/passthrough/Makefile.am | 10 ++ gst/passthrough/filter.func | 18 ++ gst/passthrough/gstpassthrough.c | 351 +++++++++++++++++++++++++++++++++++++++ gst/passthrough/gstpassthrough.h | 103 ++++++++++++ 5 files changed, 489 insertions(+) create mode 100644 gst/passthrough/.gitignore create mode 100644 gst/passthrough/Makefile.am create mode 100644 gst/passthrough/filter.func create mode 100644 gst/passthrough/gstpassthrough.c create mode 100644 gst/passthrough/gstpassthrough.h (limited to 'gst/passthrough') diff --git a/gst/passthrough/.gitignore b/gst/passthrough/.gitignore new file mode 100644 index 00000000..08f5ed37 --- /dev/null +++ b/gst/passthrough/.gitignore @@ -0,0 +1,7 @@ +Makefile +Makefile.in +*.o +*.lo +*.la +.deps +.libs diff --git a/gst/passthrough/Makefile.am b/gst/passthrough/Makefile.am new file mode 100644 index 00000000..500d4679 --- /dev/null +++ b/gst/passthrough/Makefile.am @@ -0,0 +1,10 @@ +filterdir = $(libdir)/gst + +filter_LTLIBRARIES = libgstpassthrough.la + +libgstpassthrough_la_SOURCES = gstpassthrough.c +libgstpassthrough_la_CFLAGS = $(GST_CFLAGS) + +noinst_HEADERS = gstpassthrough.h filter.func + +EXTRA_DIST = diff --git a/gst/passthrough/filter.func b/gst/passthrough/filter.func new file mode 100644 index 00000000..99a9308b --- /dev/null +++ b/gst/passthrough/filter.func @@ -0,0 +1,18 @@ +{ + guint j; + static long int sample = 0; /* you can use this to count samples */ + + /* + * process data here + * *data contains the original 8 or 16 bit samples and is modified in place + * channels are interleaved in input data + */ + + /* do nothing */ + + for (j = 0; j < num_samples; j++) + { + data[j] = data[j]; + } + sample += num_samples; +} diff --git a/gst/passthrough/gstpassthrough.c b/gst/passthrough/gstpassthrough.c new file mode 100644 index 00000000..dc50e626 --- /dev/null +++ b/gst/passthrough/gstpassthrough.c @@ -0,0 +1,351 @@ +/* -*- c-basic-offset: 2 -*- + * GStreamer + * Copyright (C) 1999-2001 Erik Walthinsen + * + * 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. + */ + +#include +#include +#include +#include "gstpassthrough.h" + + + +static GstElementDetails passthrough_details = { + "Passthrough", + "Filter/Effect", + "Transparent filter for audio/raw (boilerplate for effects)", + VERSION, + "Thomas , "\ + "Andy Wingo ", + "(C) 2001", +}; + + +/* Filter signals and args */ +enum { + /* FILL ME */ + LAST_SIGNAL +}; + +enum { + ARG_0, + ARG_SILENT +}; + +static GstPadTemplate* +passthrough_sink_factory (void) +{ + static GstPadTemplate *template = NULL; + + if (!template) { + template = gst_padtemplate_new + ("sink", GST_PAD_SINK, GST_PAD_ALWAYS, + gst_caps_append(gst_caps_new ("sink_int", "audio/raw", + GST_AUDIO_INT_PAD_TEMPLATE_PROPS), + gst_caps_new ("sink_float", "audio/raw", + GST_AUDIO_FLOAT_MONO_PAD_TEMPLATE_PROPS)), + NULL); + } + return template; +} + +static GstPadTemplate* +passthrough_src_factory (void) +{ + static GstPadTemplate *template = NULL; + + if (!template) + template = gst_padtemplate_new + ("src", GST_PAD_SRC, GST_PAD_ALWAYS, + gst_caps_append (gst_caps_new ("src_float", "audio/raw", + GST_AUDIO_FLOAT_MONO_PAD_TEMPLATE_PROPS), + gst_caps_new ("src_int", "audio/raw", + GST_AUDIO_INT_PAD_TEMPLATE_PROPS)), + NULL); + + return template; +} + +static void passthrough_class_init (GstPassthroughClass *klass); +static void passthrough_init (GstPassthrough *filter); + +static void passthrough_set_property (GObject *object, guint prop_id, const GValue *value, GParamSpec *pspec); +static void passthrough_get_property (GObject *object, guint prop_id, GValue *value, GParamSpec *pspec); + +static gint passthrough_parse_caps (GstPassthrough *filter, GstCaps *caps); + +static void passthrough_chain (GstPad *pad, GstBuffer *buf); +static void inline passthrough_fast_float_chain (gfloat* data, guint numsamples); +static void inline passthrough_fast_16bit_chain (gint16* data, guint numsamples); +static void inline passthrough_fast_8bit_chain (gint8* data, guint numsamples); + +static GstElementClass *parent_class = NULL; +//static guint gst_filter_signals[LAST_SIGNAL] = { 0 }; + +static GstBufferPool* +passthrough_get_bufferpool (GstPad *pad) +{ + GstPassthrough *filter; + + filter = GST_PASSTHROUGH (gst_pad_get_parent (pad)); + + return gst_pad_get_bufferpool (filter->srcpad); +} + +static GstPadNegotiateReturn +passthrough_negotiate_src (GstPad *pad, GstCaps **caps, gpointer *data) +{ + GstPassthrough* filter = GST_PASSTHROUGH (gst_pad_get_parent (pad)); + + if (*caps==NULL) + return GST_PAD_NEGOTIATE_FAIL; + + if (passthrough_parse_caps(filter, *caps)) + return GST_PAD_NEGOTIATE_FAIL; + + return gst_pad_negotiate_proxy(pad,filter->sinkpad,caps); +} + +static GstPadNegotiateReturn +passthrough_negotiate_sink (GstPad *pad, GstCaps **caps, gpointer *data) +{ + GstPassthrough* filter = GST_PASSTHROUGH (gst_pad_get_parent (pad)); + + if (*caps==NULL) + return GST_PAD_NEGOTIATE_FAIL; + + if (passthrough_parse_caps(filter, *caps)) + return GST_PAD_NEGOTIATE_FAIL; + + return gst_pad_negotiate_proxy(pad,filter->srcpad,caps); +} + +static gint +passthrough_parse_caps (GstPassthrough *filter, GstCaps *caps) +{ + const gchar *format; + + g_return_val_if_fail(filter!=NULL,-1); + g_return_val_if_fail(caps!=NULL,-1); + + format = gst_caps_get_string(caps, "format"); + + filter->rate = gst_caps_get_int (caps, "rate"); + filter->channels = gst_caps_get_int (caps, "channels"); + + if (strcmp(format, "int")==0) { + filter->format = GST_PASSTHROUGH_FORMAT_INT; + filter->width = gst_caps_get_int (caps, "width"); + filter->depth = gst_caps_get_int (caps, "depth"); + filter->law = gst_caps_get_int (caps, "law"); + filter->endianness = gst_caps_get_int (caps, "endianness"); + filter->is_signed = gst_caps_get_int (caps, "signed"); + if (!filter->silent) { + g_print ("Passthrough : channels %d, rate %d\n", + filter->channels, filter->rate); + g_print ("Passthrough : format int, bit width %d, endianness %d, signed %s\n", + filter->width, filter->endianness, filter->is_signed ? "yes" : "no"); + } + } else if (strcmp(format, "float")==0) { + filter->format = GST_PASSTHROUGH_FORMAT_FLOAT; + filter->layout = gst_caps_get_string(caps, "layout"); + filter->intercept = gst_caps_get_float(caps, "intercept"); + filter->slope = gst_caps_get_float(caps, "slope"); + if (!filter->silent) { + g_print ("Passthrough : channels %d, rate %d\n", + filter->channels, filter->rate); + g_print ("Passthrough : format float, layout %s, intercept %f, slope %f\n", + filter->layout, filter->intercept, filter->slope); + } + } else { + return -1; + } + return 0; +} + + +GType +gst_passthrough_get_type(void) { + static GType passthrough_type = 0; + + if (!passthrough_type) { + static const GTypeInfo passthrough_info = { + sizeof(GstPassthroughClass), NULL, + NULL, + (GClassInitFunc)passthrough_class_init, + NULL, + NULL, + sizeof(GstPassthrough), + 0, + (GInstanceInitFunc)passthrough_init, + }; + passthrough_type = g_type_register_static(GST_TYPE_ELEMENT, "GstPassthrough", &passthrough_info, 0); + } + return passthrough_type; +} + +static void +passthrough_class_init (GstPassthroughClass *klass) +{ + GObjectClass *gobject_class; + GstElementClass *gstelement_class; + + gobject_class = (GObjectClass*)klass; + gstelement_class = (GstElementClass*)klass; + + parent_class = g_type_class_ref(GST_TYPE_ELEMENT); + + g_object_class_install_property(G_OBJECT_CLASS(klass), ARG_SILENT, + g_param_spec_boolean("silent","silent","silent", + TRUE,G_PARAM_READWRITE)); // CHECKME + + gobject_class->set_property = passthrough_set_property; + gobject_class->get_property = passthrough_get_property; +} + +static void +passthrough_init (GstPassthrough *filter) +{ + filter->sinkpad = gst_pad_new_from_template(passthrough_sink_factory (),"sink"); + gst_pad_set_negotiate_function(filter->sinkpad,passthrough_negotiate_sink); + gst_pad_set_bufferpool_function(filter->sinkpad,passthrough_get_bufferpool); + filter->srcpad = gst_pad_new_from_template(passthrough_src_factory (),"src"); + gst_pad_set_negotiate_function(filter->srcpad,passthrough_negotiate_src); + + gst_element_add_pad(GST_ELEMENT(filter),filter->sinkpad); + gst_element_add_pad(GST_ELEMENT(filter),filter->srcpad); + gst_pad_set_chain_function(filter->sinkpad,passthrough_chain); + filter->silent = FALSE; +} + +static void +passthrough_chain (GstPad *pad, GstBuffer *buf) +{ + GstPassthrough *filter; + gint16 *int_data; + gfloat *float_data; + + g_return_if_fail(pad != NULL); + g_return_if_fail(GST_IS_PAD(pad)); + g_return_if_fail(buf != NULL); + + filter = GST_PASSTHROUGH(GST_OBJECT_PARENT (pad)); + g_return_if_fail(filter != NULL); + g_return_if_fail(GST_IS_PASSTHROUGH(filter)); + + switch (filter->format) { + case GST_PASSTHROUGH_FORMAT_INT: + int_data = (gint16 *)GST_BUFFER_DATA(buf); + + switch (filter->width) { + case 16: + passthrough_fast_16bit_chain(int_data,GST_BUFFER_SIZE(buf)/2); + break; + case 8: + passthrough_fast_8bit_chain((gint8*)int_data,GST_BUFFER_SIZE(buf)); + break; + } + + break; + case GST_PASSTHROUGH_FORMAT_FLOAT: + float_data = (gfloat *)GST_BUFFER_DATA(buf); + + passthrough_fast_float_chain(float_data,GST_BUFFER_SIZE(buf)/sizeof(float)); + + break; + } + + gst_pad_push(filter->srcpad,buf); +} + +static void inline +passthrough_fast_float_chain(gfloat* data, + guint num_samples) +#include "filter.func" + +static void inline +passthrough_fast_16bit_chain(gint16* data, + guint num_samples) +#include "filter.func" + +static void inline +passthrough_fast_8bit_chain(gint8* data, + guint num_samples) +#include "filter.func" + +static void +passthrough_set_property (GObject *object, guint prop_id, const GValue *value, GParamSpec *pspec) +{ + GstPassthrough *filter; + + /* it's not null if we got it, but it might not be ours */ + g_return_if_fail(GST_IS_PASSTHROUGH(object)); + filter = GST_PASSTHROUGH(object); + + switch (prop_id) + { + case ARG_SILENT: + filter->silent = g_value_get_boolean (value); + break; + default: + break; + } +} + +static void +passthrough_get_property (GObject *object, guint prop_id, GValue *value, GParamSpec *pspec) +{ + GstPassthrough *filter; + + /* it's not null if we got it, but it might not be ours */ + g_return_if_fail(GST_IS_PASSTHROUGH(object)); + filter = GST_PASSTHROUGH(object); + + switch (prop_id) { + case ARG_SILENT: + g_value_set_boolean (value, filter->silent); + break; + default: + G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec); + break; + } +} + +static gboolean +plugin_init (GModule *module, GstPlugin *plugin) +{ + GstElementFactory *factory; + + factory = gst_elementfactory_new("passthrough",GST_TYPE_PASSTHROUGH, + &passthrough_details); + g_return_val_if_fail(factory != NULL, FALSE); + + gst_elementfactory_add_padtemplate (factory, passthrough_src_factory ()); + gst_elementfactory_add_padtemplate (factory, passthrough_sink_factory ()); + + gst_plugin_add_feature (plugin, GST_PLUGIN_FEATURE (factory)); + + return TRUE; +} + +GstPluginDesc plugin_desc = { + GST_VERSION_MAJOR, + GST_VERSION_MINOR, + "passthrough", + plugin_init +}; diff --git a/gst/passthrough/gstpassthrough.h b/gst/passthrough/gstpassthrough.h new file mode 100644 index 00000000..d8c2f63e --- /dev/null +++ b/gst/passthrough/gstpassthrough.h @@ -0,0 +1,103 @@ +/* -*- c-basic-offset: 2 -*- + * GStreamer + * Copyright (C) <1999> Erik Walthinsen + * + * 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_PASSTHROUGH_H__ +#define __GST_PASSTHROUGH_H__ + + +#include +#include +// #include + + +#ifdef __cplusplus +extern "C" { +#endif /* __cplusplus */ + + +#define GST_TYPE_PASSTHROUGH \ + (gst_passthrough_get_type()) +#define GST_PASSTHROUGH(obj) \ + (G_TYPE_CHECK_INSTANCE_CAST((obj),GST_TYPE_PASSTHROUGH,GstPassthrough)) +#define GST_PASSTHROUGH_CLASS(klass) \ + (G_TYPE_CHECK_CLASS_CAST((klass),GST_TYPE_ULAW,GstPassthrough)) +#define GST_IS_PASSTHROUGH(obj) \ + (G_TYPE_CHECK_INSTANCE_TYPE((obj),GST_TYPE_PASSTHROUGH)) +#define GST_IS_PASSTHROUGH_CLASS(obj) \ + (G_TYPE_CHECK_CLASS_TYPE((klass),GST_TYPE_PASSTHROUGH)) + +typedef struct _GstPassthrough GstPassthrough; +typedef struct _GstPassthroughClass GstPassthroughClass; +typedef enum _GstPassthroughFormat GstPassthroughFormat; + +enum _GstPassthroughFormat { + GST_PASSTHROUGH_FORMAT_INT, + GST_PASSTHROUGH_FORMAT_FLOAT +}; + +struct _GstPassthrough { + GstElement element; + + GstPad *sinkpad, *srcpad; + + gboolean silent; + + /* the next three are valid for both int and float */ + + GstPassthroughFormat format; + + guint rate; + + guint channels; + + /* the next five are valid only for format==GST_PASSTHROUGH_FORMAT_INT */ + + guint width; + + guint depth; + + guint endianness; + + guint law; + + gboolean is_signed; + + /* the next three are valid only for format==GST_PASSTHROUGH_FORMAT_FLOAT */ + + const gchar *layout; + + gfloat slope; + + gfloat intercept; +}; + +struct _GstPassthroughClass { + GstElementClass parent_class; +}; + +GType gst_passthrough_get_type(void); + +#ifdef __cplusplus +} +#endif /* __cplusplus */ + + +#endif /* __GST_PASSTHROUGH_H__ */ -- cgit v1.2.1