From 8534b5e71e048c6fef788c6a561881f71972eee0 Mon Sep 17 00:00:00 2001 From: Mathis Hofer Date: Mon, 10 Jul 2006 14:42:15 +0000 Subject: Ported the gstfilter plugin to GStreamer 0.10. Original commit message from CVS: Patch by: Mathis Hofer * configure.ac: * gst/filter/Makefile.am: * gst/filter/gstbpwsinc.c: (gst_bpwsinc_dispose), (gst_bpwsinc_base_init), (gst_bpwsinc_class_init), (gst_bpwsinc_init), (bpwsinc_set_caps), (bpwsinc_transform_ip), (bpwsinc_set_property), (bpwsinc_get_property): * gst/filter/gstfilter.c: (plugin_init): * gst/filter/gstfilter.h: * gst/filter/gstiir.c: (gst_iir_dispose), (gst_iir_base_init), (gst_iir_class_init), (gst_iir_init), (iir_set_caps), (iir_transform_ip), (iir_set_property), (iir_get_property): * gst/filter/gstlpwsinc.c: (gst_lpwsinc_dispose), (gst_lpwsinc_base_init), (gst_lpwsinc_class_init), (gst_lpwsinc_init), (lpwsinc_set_caps), (lpwsinc_transform_ip), (lpwsinc_set_property), (lpwsinc_get_property): Ported the gstfilter plugin to GStreamer 0.10. --- gst/filter/gstlpwsinc.c | 339 ++++++++++++++++++++++-------------------------- 1 file changed, 156 insertions(+), 183 deletions(-) (limited to 'gst/filter/gstlpwsinc.c') diff --git a/gst/filter/gstlpwsinc.c b/gst/filter/gstlpwsinc.c index d7b1a5ec..4a7b2679 100644 --- a/gst/filter/gstlpwsinc.c +++ b/gst/filter/gstlpwsinc.c @@ -1,6 +1,8 @@ /* -*- c-basic-offset: 2 -*- + * * GStreamer * Copyright (C) 1999-2001 Erik Walthinsen + * 2006 Dreamlab Technologies Ltd. * * This library is free software; you can redistribute it and/or * modify it under the terms of the GNU Library General Public @@ -16,15 +18,14 @@ * License along with this library; if not, write to the * Free Software Foundation, Inc., 59 Temple Place - Suite 330, * Boston, MA 02111-1307, USA. - */ - -/* this windowed sinc filter is taken from the freely downloadable DSP book, + * + * + * this windowed sinc filter is taken from the freely downloadable DSP book, * "The Scientist and Engineer's Guide to Digital Signal Processing", * chapter 16 * available at http://www.dspguide.com/ - */ - -/* FIXME: + * + * FIXME: * - this filter is totally unoptimized ! * - we do not destroy the allocated memory for filters and residue * - this might be improved upon with bytestream @@ -33,17 +34,27 @@ #ifdef HAVE_CONFIG_H #include "config.h" #endif + +#include +#include #include -#include "gstfilter.h" -#include /* M_PI */ -#include /* memmove */ +#include +#include + +#include "gstlpwsinc.h" + +#define GST_CAT_DEFAULT gst_lpwsinc_debug +GST_DEBUG_CATEGORY_STATIC (GST_CAT_DEFAULT); -static const GstElementDetails gst_lpwsinc_details = +static const GstElementDetails lpwsinc_details = GST_ELEMENT_DETAILS ("Low-pass Windowed sinc filter", "Filter/Effect/Audio", "Low-pass Windowed sinc filter", - "Thomas , " "Steven W. Smith"); + "Thomas , " + "Steven W. Smith, " + "Dreamlab Technologies Ltd. "); +/* Filter signals and args */ enum { /* FILL ME */ @@ -52,80 +63,53 @@ enum enum { - ARG_0, - ARG_LENGTH, - ARG_FREQUENCY -}; - -#define GST_TYPE_LPWSINC \ - (gst_lpwsinc_get_type()) -#define GST_LPWSINC(obj) \ - (G_TYPE_CHECK_INSTANCE_CAST((obj),GST_TYPE_LPWSINC,GstLPWSinc)) -#define GST_LPWSINC_CLASS(klass) \ - (G_TYPE_CHECK_CLASS_CAST((klass),GST_TYPE_ULAW,GstLPWSinc)) -#define GST_IS_LPWSINC(obj) \ - (G_TYPE_CHECK_INSTANCE_TYPE((obj),GST_TYPE_LPWSINC)) -#define GST_IS_LPWSINC_CLASS(obj) \ - (G_TYPE_CHECK_CLASS_TYPE((klass),GST_TYPE_LPWSINC)) - -typedef struct _GstLPWSinc GstLPWSinc; -typedef struct _GstLPWSincClass GstLPWSincClass; - -struct _GstLPWSinc -{ - GstElement element; - - GstPad *sinkpad, *srcpad; - - double frequency; - int wing_size; /* length of a "wing" of the filter; - actual length is 2 * wing_size + 1 */ - - gfloat *residue; /* buffer for left-over samples from previous buffer */ - double *kernel; -}; - -struct _GstLPWSincClass -{ - GstElementClass parent_class; + PROP_0, + PROP_LENGTH, + PROP_FREQUENCY }; -static void gst_lpwsinc_base_init (gpointer g_class); -static void gst_lpwsinc_class_init (GstLPWSincClass * klass); -static void gst_lpwsinc_init (GstLPWSinc * filter); - -static void gst_lpwsinc_set_property (GObject * object, guint prop_id, +static GstStaticPadTemplate lpwsinc_sink_template = +GST_STATIC_PAD_TEMPLATE ("sink", + GST_PAD_SINK, + GST_PAD_ALWAYS, + GST_STATIC_CAPS ("audio/x-raw-float, " + "rate = (int) [ 1, MAX ], " + "channels = (int) [ 1, MAX ], " + "endianness = (int) BYTE_ORDER, " "width = (int) 32") + ); + +static GstStaticPadTemplate lpwsinc_src_template = GST_STATIC_PAD_TEMPLATE + ("src", + GST_PAD_SRC, + GST_PAD_ALWAYS, + GST_STATIC_CAPS ("audio/x-raw-float, " + "rate = (int) [ 1, MAX ], " + "channels = (int) [ 1, MAX ], " + "endianness = (int) BYTE_ORDER, " "width = (int) 32") + ); + +#define DEBUG_INIT(bla) \ + GST_DEBUG_CATEGORY_INIT (gst_lpwsinc_debug, "lpwsinc", 0, "Low-pass Windowed sinc filter plugin"); + +GST_BOILERPLATE_FULL (GstLPWSinc, gst_lpwsinc, GstBaseTransform, + GST_TYPE_BASE_TRANSFORM, DEBUG_INIT); + +static void lpwsinc_set_property (GObject * object, guint prop_id, const GValue * value, GParamSpec * pspec); -static void gst_lpwsinc_get_property (GObject * object, guint prop_id, +static void lpwsinc_get_property (GObject * object, guint prop_id, GValue * value, GParamSpec * pspec); -static void gst_lpwsinc_chain (GstPad * pad, GstData * _data); -static GstPadLinkReturn -gst_lpwsinc_sink_connect (GstPad * pad, const GstCaps * caps); +static GstFlowReturn lpwsinc_transform_ip (GstBaseTransform * base, + GstBuffer * outbuf); +static gboolean lpwsinc_set_caps (GstBaseTransform * base, GstCaps * incaps, + GstCaps * outcaps); -static GstElementClass *parent_class = NULL; +/* Element class */ -/*static guint gst_lpwsinc_signals[LAST_SIGNAL] = { 0 }; */ - -GType -gst_lpwsinc_get_type (void) +static void +gst_lpwsinc_dispose (GObject * object) { - static GType lpwsinc_type = 0; - - if (!lpwsinc_type) { - static const GTypeInfo lpwsinc_info = { - sizeof (GstLPWSincClass), - gst_lpwsinc_base_init, - NULL, - (GClassInitFunc) gst_lpwsinc_class_init, NULL, NULL, - sizeof (GstLPWSinc), 0, - (GInstanceInitFunc) gst_lpwsinc_init, - }; - - lpwsinc_type = g_type_register_static (GST_TYPE_ELEMENT, "GstLPWSinc", - &lpwsinc_info, 0); - } - return lpwsinc_type; + G_OBJECT_CLASS (parent_class)->dispose (object); } static void @@ -133,145 +117,138 @@ gst_lpwsinc_base_init (gpointer g_class) { GstElementClass *element_class = GST_ELEMENT_CLASS (g_class); - /* register src pads */ gst_element_class_add_pad_template (element_class, - gst_static_pad_template_get (&gst_filter_src_template)); + gst_static_pad_template_get (&lpwsinc_src_template)); gst_element_class_add_pad_template (element_class, - gst_static_pad_template_get (&gst_filter_sink_template)); - - gst_element_class_set_details (element_class, &gst_lpwsinc_details); + gst_static_pad_template_get (&lpwsinc_sink_template)); + gst_element_class_set_details (element_class, &lpwsinc_details); } static void gst_lpwsinc_class_init (GstLPWSincClass * klass) { GObjectClass *gobject_class; - GstElementClass *gstelement_class; + GstBaseTransformClass *trans_class; gobject_class = (GObjectClass *) klass; - gstelement_class = (GstElementClass *) klass; + trans_class = (GstBaseTransformClass *) klass; - parent_class = g_type_class_peek_parent (klass); + gobject_class->set_property = lpwsinc_set_property; + gobject_class->get_property = lpwsinc_get_property; + gobject_class->dispose = gst_lpwsinc_dispose; - g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_FREQUENCY, + g_object_class_install_property (gobject_class, PROP_FREQUENCY, g_param_spec_double ("frequency", "Frequency", - "Cut-off Frequency relative to sample rate)", + "Cut-off Frequency relative to sample rate", 0.0, 0.5, 0, G_PARAM_READWRITE)); - g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_LENGTH, + + g_object_class_install_property (gobject_class, PROP_LENGTH, g_param_spec_int ("length", "Length", "N such that the filter length = 2N + 1", 1, G_MAXINT, 1, G_PARAM_READWRITE)); - gobject_class->set_property = gst_lpwsinc_set_property; - gobject_class->get_property = gst_lpwsinc_get_property; + trans_class->transform_ip = GST_DEBUG_FUNCPTR (lpwsinc_transform_ip); + trans_class->set_caps = GST_DEBUG_FUNCPTR (lpwsinc_set_caps); } static void -gst_lpwsinc_init (GstLPWSinc * filter) +gst_lpwsinc_init (GstLPWSinc * this, GstLPWSincClass * g_class) { - filter->sinkpad = - gst_pad_new_from_template (gst_static_pad_template_get - (&gst_filter_sink_template), "sink"); - gst_pad_set_chain_function (filter->sinkpad, gst_lpwsinc_chain); - gst_pad_set_link_function (filter->sinkpad, gst_lpwsinc_sink_connect); - gst_element_add_pad (GST_ELEMENT (filter), filter->sinkpad); - - filter->srcpad = - gst_pad_new_from_template (gst_static_pad_template_get - (&gst_filter_src_template), "src"); - gst_element_add_pad (GST_ELEMENT (filter), filter->srcpad); - - filter->wing_size = 50; - filter->frequency = 0.25; - filter->kernel = NULL; + this->wing_size = 50; + this->frequency = 0.25; + this->kernel = NULL; } -static GstPadLinkReturn -gst_lpwsinc_sink_connect (GstPad * pad, const GstCaps * caps) + +/* GstBaseTransform vmethod implementations */ + +/* get notified of caps and plug in the correct process function */ +static gboolean +lpwsinc_set_caps (GstBaseTransform * base, GstCaps * incaps, GstCaps * outcaps) { int i = 0; double sum = 0.0; int len = 0; - GstLPWSinc *filter = GST_LPWSINC (gst_pad_get_parent (pad)); - GstPadLinkReturn set_retval; - - g_assert (GST_IS_PAD (pad)); - g_assert (caps != NULL); - - set_retval = gst_pad_try_set_caps (filter->srcpad, caps); - - if (set_retval > 0) { - /* connection works, so init the filter */ - /* FIXME: remember to free it */ - /* fill the kernel */ - g_print ("DEBUG: initing filter kernel\n"); - len = filter->wing_size; - GST_DEBUG ("lpwsinc: initializing filter kernel of length %d", len * 2 + 1); - filter->kernel = (double *) g_malloc (sizeof (double) * (2 * len + 1)); - - for (i = 0; i <= len * 2; ++i) { - if (i == len) - filter->kernel[i] = 2 * M_PI * filter->frequency; - else - filter->kernel[i] = sin (2 * M_PI * filter->frequency * (i - len)) - / (i - len); - /* windowing */ - filter->kernel[i] *= (0.54 - 0.46 * cos (M_PI * i / len)); - } - - /* normalize for unity gain at DC - * FIXME: sure this is not supposed to be quadratic ? */ - for (i = 0; i <= len * 2; ++i) - sum += filter->kernel[i]; - for (i = 0; i <= len * 2; ++i) - filter->kernel[i] /= sum; - - /* set up the residue memory space */ - filter->residue = (gfloat *) g_malloc (sizeof (gfloat) * (len * 2 + 1)); - for (i = 0; i <= len * 2; ++i) - filter->residue[i] = 0.0; + GstLPWSinc *this = GST_LPWSINC (base); + + GST_DEBUG_OBJECT (this, + "set_caps: in %" GST_PTR_FORMAT " out %" GST_PTR_FORMAT, incaps, outcaps); + + /* FIXME: remember to free it */ + /* fill the kernel */ + g_print ("DEBUG: initing filter kernel\n"); + len = this->wing_size; + GST_DEBUG ("lpwsinc: initializing filter kernel of length %d", len * 2 + 1); + this->kernel = (double *) g_malloc (sizeof (double) * (2 * len + 1)); + + for (i = 0; i <= len * 2; ++i) { + if (i == len) + this->kernel[i] = 2 * M_PI * this->frequency; + else + this->kernel[i] = + sin (2 * M_PI * this->frequency * (i - len)) / (i - len); + /* windowing */ + this->kernel[i] *= (0.54 - 0.46 * cos (M_PI * i / len)); } - return set_retval; + /* normalize for unity gain at DC + * FIXME: sure this is not supposed to be quadratic ? */ + for (i = 0; i <= len * 2; ++i) + sum += this->kernel[i]; + for (i = 0; i <= len * 2; ++i) + this->kernel[i] /= sum; + + /* set up the residue memory space */ + this->residue = (gfloat *) g_malloc (sizeof (gfloat) * (len * 2 + 1)); + for (i = 0; i <= len * 2; ++i) + this->residue[i] = 0.0; + + return TRUE; } -static void -gst_lpwsinc_chain (GstPad * pad, GstData * _data) +static GstFlowReturn +lpwsinc_transform_ip (GstBaseTransform * base, GstBuffer * outbuf) { - GstBuffer *buf = GST_BUFFER (_data); - GstLPWSinc *filter; + GstLPWSinc *this = GST_LPWSINC (base); + GstClockTime timestamp; + + /* don't process data in passthrough-mode */ + if (gst_base_transform_is_passthrough (base)) + return GST_FLOW_OK; + + /* FIXME: subdivide GST_BUFFER_SIZE into small chunks for smooth fades */ + timestamp = GST_BUFFER_TIMESTAMP (outbuf); + + if (GST_CLOCK_TIME_IS_VALID (timestamp)) + gst_object_sync_values (G_OBJECT (this), timestamp); + gfloat *src; gfloat *input; - gint residue_samples; + int residue_samples; gint input_samples; gint total_samples; int i, j; - filter = GST_LPWSINC (gst_pad_get_parent (pad)); - /* FIXME: out of laziness, we copy the left-over bit from last buffer * together with the incoming buffer to a new buffer to make the loop * easy; this could be a lot more optimized though * to make amends we keep the incoming buffer around and write our * output samples there */ - /* get a writable buffer */ - buf = gst_buffer_copy_on_write (buf); - - src = (gfloat *) GST_BUFFER_DATA (buf); - residue_samples = filter->wing_size * 2 + 1; - input_samples = GST_BUFFER_SIZE (buf) / sizeof (gfloat); + src = (gfloat *) GST_BUFFER_DATA (outbuf); + residue_samples = this->wing_size * 2 + 1; + input_samples = GST_BUFFER_SIZE (outbuf) / sizeof (gfloat); total_samples = residue_samples + input_samples; input = (gfloat *) g_malloc (sizeof (gfloat) * total_samples); /* copy the left-over bit */ - memcpy (input, filter->residue, sizeof (gfloat) * residue_samples); + memcpy (input, this->residue, sizeof (gfloat) * residue_samples); /* copy the new buffer */ memcpy (&input[residue_samples], src, sizeof (gfloat) * input_samples); /* copy the tail of the current input buffer to the residue */ - memcpy (filter->residue, &src[input_samples - residue_samples], + memcpy (this->residue, &src[input_samples - residue_samples], sizeof (gfloat) * residue_samples); /* convolution */ @@ -280,51 +257,47 @@ gst_lpwsinc_chain (GstPad * pad, GstData * _data) for (i = 0; i < input_samples; ++i) { src[i] = 0.0; for (j = 0; j < residue_samples; ++j) - src[i] += input[i - j + residue_samples] * filter->kernel[j]; + src[i] += input[i - j + residue_samples] * this->kernel[j]; } g_free (input); - gst_pad_push (filter->srcpad, GST_DATA (buf)); + + return GST_FLOW_OK; } static void -gst_lpwsinc_set_property (GObject * object, guint prop_id, const GValue * value, +lpwsinc_set_property (GObject * object, guint prop_id, const GValue * value, GParamSpec * pspec) { - GstLPWSinc *filter; + GstLPWSinc *this = GST_LPWSINC (object); - g_return_if_fail (GST_IS_LPWSINC (object)); - - filter = GST_LPWSINC (object); + g_return_if_fail (GST_IS_LPWSINC (this)); switch (prop_id) { - case ARG_LENGTH: - filter->wing_size = g_value_get_int (value); + case PROP_LENGTH: + this->wing_size = g_value_get_int (value); break; - case ARG_FREQUENCY: - filter->frequency = g_value_get_double (value); + case PROP_FREQUENCY: + this->frequency = g_value_get_double (value); break; default: + G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec); break; } } static void -gst_lpwsinc_get_property (GObject * object, guint prop_id, GValue * value, +lpwsinc_get_property (GObject * object, guint prop_id, GValue * value, GParamSpec * pspec) { - GstLPWSinc *filter; - - g_return_if_fail (GST_IS_LPWSINC (object)); - - filter = GST_LPWSINC (object); + GstLPWSinc *this = GST_LPWSINC (object); switch (prop_id) { - case ARG_LENGTH: - g_value_set_int (value, filter->wing_size); + case PROP_LENGTH: + g_value_set_int (value, this->wing_size); break; - case ARG_FREQUENCY: - g_value_set_double (value, filter->frequency); + case PROP_FREQUENCY: + g_value_set_double (value, this->frequency); break; default: G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec); -- cgit v1.2.1