diff options
Diffstat (limited to 'ext/ladspa/gstladspa.c')
| -rw-r--r-- | ext/ladspa/gstladspa.c | 877 |
1 files changed, 877 insertions, 0 deletions
diff --git a/ext/ladspa/gstladspa.c b/ext/ladspa/gstladspa.c new file mode 100644 index 00000000..81740c25 --- /dev/null +++ b/ext/ladspa/gstladspa.c @@ -0,0 +1,877 @@ +/* GStreamer + * Copyright (C) <1999> Erik Walthinsen <omega@cse.ogi.edu> + * <2001> Steve Baker <stevebaker_org@yahoo.co.uk> + * + * 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 <string.h> +#include <math.h> + +//#define DEBUG_ENABLED +#include "gstladspa.h" +#include "ladspa.h" +#include "search.h" +#include "utils.h" + + +static GstPadTemplate* +ladspa_src_factory (void) +{ + return + gst_padtemplate_new ( + "src", + GST_PAD_SRC, + GST_PAD_ALWAYS, + gst_caps_new ( + "ladspa_src", + "audio/raw", + gst_props_new ( + "format", GST_PROPS_STRING ("float"), + "layout", GST_PROPS_STRING ("gfloat"), + "intercept", GST_PROPS_FLOAT(0.0), + "slope", GST_PROPS_FLOAT(1.0), + "channels", GST_PROPS_INT (1), + "rate", GST_PROPS_INT_RANGE (0,G_MAXINT), + NULL)), + NULL); +} + +static GstPadTemplate* +ladspa_sink_factory (void) +{ + return + gst_padtemplate_new ( + "sink", + GST_PAD_SINK, + GST_PAD_ALWAYS, + gst_caps_new ( + "float2int_sink", + "audio/raw", + gst_props_new ( + "format", GST_PROPS_STRING ("float"), + "layout", GST_PROPS_STRING ("gfloat"), + "intercept", GST_PROPS_FLOAT(0.0), + "slope", GST_PROPS_FLOAT(1.0), + "channels", GST_PROPS_INT (1), + "rate", GST_PROPS_INT_RANGE (0,G_MAXINT), + NULL)), + NULL); +} + +enum { + ARG_0, + ARG_LOOP_BASED, + ARG_SAMPLERATE, + ARG_BUFFERSIZE, + ARG_LAST, +}; + +static GstPadTemplate *srctempl, *sinktempl; + +static void gst_ladspa_class_init (GstLADSPAClass *klass); +static void gst_ladspa_init (GstLADSPA *ladspa); + +static GstPadNegotiateReturn gst_ladspa_negotiate_sink_mono (GstPad *pad, GstCaps **caps, gpointer *data); +static GstPadNegotiateReturn gst_ladspa_negotiate_src_mono (GstPad *pad, GstCaps **caps, gpointer *data); +static GstPadNegotiateReturn gst_ladspa_negotiate_src_get_mono (GstPad *pad, GstCaps **caps, gpointer *data); +static void gst_ladspa_force_caps(GstLADSPA *ladspa, GstPad *pad); + +static void gst_ladspa_set_property (GObject *object, guint prop_id, const GValue *value, GParamSpec *pspec); +static void gst_ladspa_get_property (GObject *object, guint prop_id, GValue *value, GParamSpec *pspec); + +static gboolean gst_ladspa_instantiate (GstLADSPA *ladspa); +static void gst_ladspa_activate(GstLADSPA *ladspa); +static void gst_ladspa_deactivate(GstLADSPA *ladspa); + +static GstElementStateReturn gst_ladspa_change_state (GstElement *element); +static void gst_ladspa_loop (GstElement *element); +static void gst_ladspa_chain_inplace_mono (GstPad *pad,GstBuffer *buf); +static GstBuffer * gst_ladspa_get_mono(GstPad *pad); +static GstBuffer * gst_ladspa_get(GstPad *pad); + +static GstElementClass *parent_class = NULL; +//static guint gst_ladspa_signals[LAST_SIGNAL] = { 0 }; + +static GstPlugin *ladspa_plugin; +static GHashTable *ladspa_descriptors; + +static void +gst_ladspa_class_init (GstLADSPAClass *klass) +{ + GObjectClass *gobject_class; + GstElementClass *gstelement_class; + LADSPA_Descriptor *desc; + gint i,current_portnum,sinkcount,srccount,controlcount; + gint hintdesc; + gint argtype,argperms; + GParamSpec *paramspec = NULL; + gchar *argname; + + gobject_class = (GObjectClass*)klass; + gstelement_class = (GstElementClass*)klass; + + gobject_class->set_property = gst_ladspa_set_property; + gobject_class->get_property = gst_ladspa_get_property; + + gstelement_class->change_state = gst_ladspa_change_state; + + g_object_class_install_property(G_OBJECT_CLASS(klass), ARG_LOOP_BASED, + g_param_spec_boolean("loop-based","loop-based","loop-based", + FALSE,G_PARAM_READWRITE)); + + // look up and store the ladspa descriptor + klass->descriptor = g_hash_table_lookup(ladspa_descriptors,GINT_TO_POINTER(G_TYPE_FROM_CLASS(klass))); + desc = klass->descriptor; + + klass->numports = desc->PortCount; + + klass->numsinkpads = 0; + klass->numsrcpads = 0; + klass->numcontrols = 0; + + // walk through the ports, count the input, output and control ports + for (i=0;i<desc->PortCount;i++) { + if (LADSPA_IS_PORT_AUDIO(desc->PortDescriptors[i]) && + LADSPA_IS_PORT_INPUT(desc->PortDescriptors[i])){ + klass->numsinkpads++; + } + + if (LADSPA_IS_PORT_AUDIO(desc->PortDescriptors[i]) && + LADSPA_IS_PORT_OUTPUT(desc->PortDescriptors[i])){ + klass->numsrcpads++; + } + + if (LADSPA_IS_PORT_CONTROL(desc->PortDescriptors[i]) && + LADSPA_IS_PORT_INPUT(desc->PortDescriptors[i])){ + klass->numcontrols++; + } + } + + klass->srcpad_portnums = g_new0(gint,klass->numsrcpads); + klass->sinkpad_portnums = g_new0(gint,klass->numsinkpads); + klass->control_portnums = g_new0(gint,klass->numcontrols); + sinkcount = 0; + srccount = 0; + controlcount = 0; + + // walk through the ports, note the portnums for srcpads, sinkpads and control params + for (i=0;i<desc->PortCount;i++) { + if (LADSPA_IS_PORT_AUDIO(desc->PortDescriptors[i]) && + LADSPA_IS_PORT_INPUT(desc->PortDescriptors[i])){ + //g_print("input port %d\n", i); + klass->sinkpad_portnums[sinkcount++] = i; + } + + if (LADSPA_IS_PORT_AUDIO(desc->PortDescriptors[i]) && + LADSPA_IS_PORT_OUTPUT(desc->PortDescriptors[i])){ + //g_print("output port %d\n", i); + klass->srcpad_portnums[srccount++] = i; + } + + if (LADSPA_IS_PORT_CONTROL(desc->PortDescriptors[i]) && + LADSPA_IS_PORT_INPUT(desc->PortDescriptors[i])){ + //g_print("control port %d\n", i); + klass->control_portnums[controlcount++] = i; + } + } + + // no sink pads - we'll use get mode and add params for samplerate and buffersize + if (klass->numsinkpads == 0 && klass->numsrcpads > 0){ + g_object_class_install_property(G_OBJECT_CLASS(klass), ARG_SAMPLERATE, + g_param_spec_int("samplerate","samplerate","samplerate", + 0,G_MAXINT,44100,G_PARAM_READWRITE)); + g_object_class_install_property(G_OBJECT_CLASS(klass), ARG_BUFFERSIZE, + g_param_spec_int("buffersize","buffersize","buffersize", + 0,G_MAXINT,64,G_PARAM_READWRITE)); + + } + + // now build the contorl info from the control ports + klass->control_info = g_new0(ladspa_control_info,klass->numcontrols); + + for (i=0;i<klass->numcontrols;i++) { + + current_portnum = klass->control_portnums[i]; + + // short name for hint descriptor + hintdesc = desc->PortRangeHints[current_portnum].HintDescriptor; + + // get the various bits + if (LADSPA_IS_HINT_TOGGLED(hintdesc)) + klass->control_info[i].toggled = TRUE; + if (LADSPA_IS_HINT_LOGARITHMIC(hintdesc)) + klass->control_info[i].logarithmic = TRUE; + if (LADSPA_IS_HINT_INTEGER(hintdesc)) + klass->control_info[i].integer = TRUE; + + // figure out the argument details + if (klass->control_info[i].toggled) argtype = G_TYPE_BOOLEAN; + else if (klass->control_info[i].integer) argtype = G_TYPE_INT; + else argtype = G_TYPE_FLOAT; + + // grab the bounds + if (LADSPA_IS_HINT_BOUNDED_BELOW(hintdesc)) { + klass->control_info[i].lower = TRUE; + klass->control_info[i].lowerbound = + desc->PortRangeHints[current_portnum].LowerBound; + } else { + if (argtype==G_TYPE_INT) klass->control_info[i].lowerbound = (gfloat)G_MININT; + if (argtype==G_TYPE_FLOAT) klass->control_info[i].lowerbound = G_MINFLOAT; + } + + if (LADSPA_IS_HINT_BOUNDED_ABOVE(hintdesc)) { + klass->control_info[i].upper = TRUE; + klass->control_info[i].upperbound = + desc->PortRangeHints[current_portnum].UpperBound; + if (LADSPA_IS_HINT_SAMPLE_RATE(hintdesc)) + klass->control_info[i].samplerate = TRUE; + } else { + if (argtype==G_TYPE_INT) klass->control_info[i].upperbound = (gfloat)G_MAXINT; + if (argtype==G_TYPE_FLOAT) klass->control_info[i].upperbound = G_MAXFLOAT; + } + + if (LADSPA_IS_PORT_INPUT(desc->PortDescriptors[current_portnum])) { + argperms = G_PARAM_READWRITE; + klass->control_info[i].writable = TRUE; + } else { + argperms = G_PARAM_READABLE; + klass->control_info[i].writable = FALSE; + } + + klass->control_info[i].name = g_strdup(desc->PortNames[current_portnum]); + argname = g_strdup(klass->control_info[i].name); + // this is the same thing that param_spec_* will do + g_strcanon (argname, G_CSET_A_2_Z G_CSET_a_2_z G_CSET_DIGITS "-", '-'); + + // check for duplicate property names + if (g_object_class_find_property(G_OBJECT_CLASS(klass), argname) != NULL){ + gint numarg=1; + gchar *numargname = g_strdup_printf("%s_%d",argname,numarg++); + while (g_object_class_find_property(G_OBJECT_CLASS(klass), numargname) != NULL){ + g_free(numargname); + numargname = g_strdup_printf("%s_%d",argname,numarg++); + } + argname = numargname; + } + + if (argtype==G_TYPE_BOOLEAN){ + paramspec = g_param_spec_boolean(argname,argname,argname, FALSE, argperms); + } else if (argtype==G_TYPE_INT){ + paramspec = g_param_spec_int(argname,argname,argname, + (gint)klass->control_info[i].lowerbound, (gint)klass->control_info[i].upperbound, 0, argperms); + } else { + paramspec = g_param_spec_float(argname,argname,argname, + klass->control_info[i].lowerbound, klass->control_info[i].upperbound, + (klass->control_info[i].lowerbound + klass->control_info[i].upperbound) / 2.0f, argperms); + } + g_object_class_install_property(G_OBJECT_CLASS(klass), i+ARG_LAST, paramspec); + + g_print("added arg %s from %s\n",argname, klass->control_info[i].name); + } +} + +static void +gst_ladspa_init (GstLADSPA *ladspa) +{ + GstLADSPAClass *oclass = (GstLADSPAClass*)(G_OBJECT_GET_CLASS(ladspa)); + + LADSPA_Descriptor *desc; + gint i,sinkcount,srccount,controlcount; + + desc = oclass->descriptor; + ladspa->descriptor = oclass->descriptor; + + // allocate the various arrays + ladspa->srcpads = g_new0(GstPad*,oclass->numsrcpads); + ladspa->sinkpads = g_new0(GstPad*,oclass->numsinkpads); + ladspa->controls = g_new(gfloat,oclass->numcontrols); + + // walk through the ports and add all the pads + sinkcount = 0; + srccount = 0; + controlcount = 0; + for (i=0;i<desc->PortCount;i++) { + if (LADSPA_IS_PORT_AUDIO(desc->PortDescriptors[i]) && + LADSPA_IS_PORT_INPUT(desc->PortDescriptors[i])) { + ladspa->sinkpads[sinkcount] = gst_pad_new_from_template + (sinktempl, (gchar *)desc->PortNames[i]); + gst_element_add_pad(GST_ELEMENT(ladspa),ladspa->sinkpads[sinkcount]); + sinkcount++; + } + if (LADSPA_IS_PORT_AUDIO(desc->PortDescriptors[i]) && + LADSPA_IS_PORT_OUTPUT(desc->PortDescriptors[i])) { + ladspa->srcpads[srccount] = gst_pad_new_from_template + (srctempl, (gchar *)desc->PortNames[i]); + gst_element_add_pad(GST_ELEMENT(ladspa),ladspa->srcpads[srccount]); + srccount++; + } + if (LADSPA_IS_PORT_CONTROL(desc->PortDescriptors[i]) && + LADSPA_IS_PORT_INPUT(desc->PortDescriptors[i])) { + + // use the lowerbound as the default value if it exists + if (oclass->control_info[controlcount].lower){ + ladspa->controls[controlcount]=oclass->control_info[controlcount].lowerbound; + } else { + ladspa->controls[controlcount] = 0.0; + } + controlcount++; + } + } + + ladspa->samplerate = 0; + ladspa->buffersize = 0; + ladspa->newcaps = FALSE; + ladspa->activated = FALSE; + + // mono chain + if (sinkcount==1 && srccount==1){ + //g_print("inplace mono chain mode\n"); + gst_pad_set_negotiate_function (ladspa->sinkpads[0], gst_ladspa_negotiate_sink_mono); + gst_pad_set_chain_function(ladspa->sinkpads[0],gst_ladspa_chain_inplace_mono); + gst_pad_set_negotiate_function (ladspa->srcpads[0], gst_ladspa_negotiate_src_mono); + } + + // mono get (no sink pads) + if (sinkcount==0 && srccount == 1){ + //g_print("get mode\n"); + ladspa->newcaps = TRUE; + ladspa->samplerate = 44100; + ladspa->buffersize = 64; + gst_pad_set_get_function(ladspa->srcpads[0],gst_ladspa_get_mono); + gst_pad_set_negotiate_function (ladspa->srcpads[0], gst_ladspa_negotiate_src_get_mono); + gst_ladspa_instantiate(ladspa); + } + + // multi srcpad get + if (sinkcount==0 && srccount > 1){ + //g_print("multi get mode\n"); + ladspa->newcaps = TRUE; + ladspa->samplerate = 44100; + ladspa->buffersize = 64; + gst_pad_set_get_function(ladspa->srcpads[0],gst_ladspa_get); + gst_pad_set_negotiate_function (ladspa->srcpads[0], gst_ladspa_negotiate_src_get_mono); + gst_ladspa_instantiate(ladspa); + ladspa->buffers = g_new0(GstBuffer*,oclass->numsrcpads); + } +} + +static GstPadNegotiateReturn +gst_ladspa_negotiate_src_mono (GstPad *pad, GstCaps **caps, gpointer *data) +{ + GstLADSPA *ladspa = (GstLADSPA*)GST_OBJECT_PARENT (pad); + + // have to instantiate ladspa plugin when samplerate changes (groan) + if (ladspa->samplerate != gst_caps_get_int (*caps, "rate")){ + ladspa->samplerate = gst_caps_get_int (*caps, "rate"); + if (!gst_ladspa_instantiate(ladspa)) return GST_PAD_NEGOTIATE_FAIL; + } + return gst_pad_negotiate_proxy (pad, ladspa->sinkpads[0], caps); +} + +static GstPadNegotiateReturn +gst_ladspa_negotiate_sink_mono (GstPad *pad, GstCaps **caps, gpointer *data) +{ + GstLADSPA *ladspa = (GstLADSPA*)GST_OBJECT_PARENT (pad); + + // have to instantiate ladspa plugin when samplerate changes (groan) + if (ladspa->samplerate != gst_caps_get_int (*caps, "rate")){ + ladspa->samplerate = gst_caps_get_int (*caps, "rate"); + if (!gst_ladspa_instantiate(ladspa)) return GST_PAD_NEGOTIATE_FAIL; + } + return gst_pad_negotiate_proxy (pad, ladspa->srcpads[0], caps); +} + +static GstPadNegotiateReturn +gst_ladspa_negotiate_src_get_mono (GstPad *pad, GstCaps **caps, gpointer *data) +{ + GstLADSPA *ladspa; + //g_print("gst_ladspa_negotiate_src_get_mono\n"); + if (*caps) { + g_return_val_if_fail (pad != NULL, GST_PAD_NEGOTIATE_FAIL); + ladspa = (GstLADSPA*)GST_OBJECT_PARENT (pad); + ladspa->samplerate = gst_caps_get_int (*caps, "rate"); + if (!gst_ladspa_instantiate(ladspa)) return GST_PAD_NEGOTIATE_FAIL; + return GST_PAD_NEGOTIATE_AGREE; + } + return GST_PAD_NEGOTIATE_FAIL; +} + +static void +gst_ladspa_force_caps(GstLADSPA *ladspa, GstPad *pad) { + + // g_print("forcing caps\n"); + gst_pad_set_caps (pad, gst_caps_new ( + "ladspa_src_caps", + "audio/raw", + gst_props_new ( + "format", GST_PROPS_STRING ("float"), + "layout", GST_PROPS_STRING ("gfloat"), + "intercept", GST_PROPS_FLOAT(0.0), + "slope", GST_PROPS_FLOAT(1.0), + "rate", GST_PROPS_INT (ladspa->samplerate), + "channels", GST_PROPS_INT (1), + NULL + ) + )); + ladspa->newcaps=FALSE; +} + +static void +gst_ladspa_set_property (GObject *object, guint prop_id, const GValue *value, GParamSpec *pspec) +{ + GstLADSPA *ladspa = (GstLADSPA*)object; + gint cid = prop_id - ARG_LAST; + GstLADSPAClass *oclass; + ladspa_control_info *control_info; + gfloat val=0.0; + + // these are only registered in get mode + switch (prop_id) { + case ARG_SAMPLERATE: + ladspa->samplerate = g_value_get_int (value); + ladspa->newcaps=TRUE; + break; + case ARG_BUFFERSIZE: + ladspa->buffersize = g_value_get_int (value); + break; + } + + // is it a ladspa plugin arg? + if (cid<0) return; + +/* + if (id == ARG_LOOP_BASED) { + // we can only do this in NULL state + g_return_if_fail (GST_STATE(object) != GST_STATE_NULL); + ladspa->loopbased = g_value_get_boolean (value); + if (ladspa->loopbased) { + gst_element_set_loop_function (GST_ELEMENT (ladspa), gst_ladspa_loop); + } else { + gst_element_set_loop_function (GST_ELEMENT (ladspa), NULL); + } + } +*/ + + oclass = (GstLADSPAClass*)(G_OBJECT_GET_CLASS (object)); + + // verify it exists and is a control (not a port) + g_return_if_fail(cid < oclass->numcontrols); + + control_info = &(oclass->control_info[cid]); + g_return_if_fail (control_info->name != NULL); + + // check to see if it's writable + g_return_if_fail (control_info->writable); + + // g_print("set arg %s to %f\n",control_info->name,ladspa->controls[cid]); + + // now see what type it is + if (control_info->toggled) { + if (g_value_get_boolean (value)) + ladspa->controls[cid] = 1.0; + else + ladspa->controls[cid] = 0.0; + } else if (control_info->integer) { + val = (gfloat)g_value_get_int (value); + ladspa->controls[cid] = val; + } else { + val = g_value_get_float (value); + ladspa->controls[cid] = val; + } +} + +static void +gst_ladspa_get_property (GObject *object, guint prop_id, GValue *value, GParamSpec *pspec) +{ + GstLADSPA *ladspa = (GstLADSPA*)object; + gint cid = prop_id - ARG_LAST; + GstLADSPAClass *oclass = (GstLADSPAClass*)(G_OBJECT_GET_CLASS (object)); + ladspa_control_info *control_info; + + // these are only registered in get mode + switch (prop_id){ + case ARG_SAMPLERATE: + g_value_set_int (value, ladspa->samplerate); + break; + case ARG_BUFFERSIZE: + g_value_set_int (value, ladspa->buffersize); + break; + } + + if (cid<0) return; + // verify it exists and is a control (not a port) + if (cid >= oclass->numcontrols) return; + control_info = &(oclass->control_info[cid]); + if (control_info->name == NULL) return; + + //g_print("got arg %s as %f\n",control_info->name,ladspa->controls[cid]); + + // now see what type it is + if (control_info->toggled) { + if (ladspa->controls[cid] == 1.0) + g_value_set_boolean (value, TRUE); + else + g_value_set_boolean (value, FALSE); + } else if (control_info->integer) { + g_value_set_int (value, (gint)ladspa->controls[cid]); + } else { + g_value_set_float (value, ladspa->controls[cid]); + } +} + +static gboolean +gst_ladspa_instantiate (GstLADSPA *ladspa) +{ + LADSPA_Descriptor *desc; + int i; + GstLADSPAClass *oclass = (GstLADSPAClass*)(G_OBJECT_GET_CLASS (ladspa)); + gboolean was_activated; + + desc = ladspa->descriptor; + + // check for old handle + was_activated = ladspa->activated; + if (ladspa->handle != NULL){ + gst_ladspa_deactivate(ladspa); + desc->cleanup(ladspa->handle); + } + + // instantiate the plugin + ladspa->handle = desc->instantiate(desc,ladspa->samplerate); + g_return_val_if_fail (ladspa->handle != NULL, FALSE); + + // walk through the ports and add all the arguments + for (i=0;i<oclass->numcontrols;i++) { + // connect the argument to the plugin + //g_print("added control port %d\n", oclass->control_portnums[i]); + desc->connect_port(ladspa->handle, + oclass->control_portnums[i], + &(ladspa->controls[i])); + } + + // reactivate if it was activated before the reinstantiation + if (was_activated){ + gst_ladspa_activate(ladspa); + } + return TRUE; +} + +static GstElementStateReturn +gst_ladspa_change_state (GstElement *element) +{ + LADSPA_Descriptor *desc; + GstLADSPA *ladspa = (GstLADSPA*)element; +// GstLADSPAClass *oclass = (GstLADSPAClass*)(G_OBJECT(ladspa)->klass); + desc = ladspa->descriptor; + + //g_print("changing state\n"); + switch (GST_STATE_TRANSITION (element)) { + case GST_STATE_NULL_TO_READY: + gst_ladspa_activate(ladspa); + break; + case GST_STATE_READY_TO_NULL: + gst_ladspa_deactivate(ladspa); + break; + default: + break; + } + + if (GST_ELEMENT_CLASS (parent_class)->change_state) + return GST_ELEMENT_CLASS (parent_class)->change_state (element); + + return GST_STATE_SUCCESS; +} + +static void +gst_ladspa_activate(GstLADSPA *ladspa) +{ + LADSPA_Descriptor *desc; + desc = ladspa->descriptor; + + if (ladspa->activated){ + gst_ladspa_deactivate(ladspa); + } + + //g_print("activating\n"); + + // activate the plugin (function might be null) + if (desc->activate != NULL){ + desc->activate(ladspa->handle); + } + + ladspa->activated = TRUE; +} + +static void +gst_ladspa_deactivate(GstLADSPA *ladspa) +{ + LADSPA_Descriptor *desc; + desc = ladspa->descriptor; + + //g_print("deactivating\n"); + + // deactivate the plugin (function might be null) + if (ladspa->activated && desc->deactivate != NULL){ + desc->deactivate(ladspa->handle); + } + ladspa->activated = FALSE; +} + +static void +gst_ladspa_loop (GstElement *element) +{ + int i; + GstLADSPA *ladspa = (GstLADSPA *)element; + GstLADSPAClass *oclass = (GstLADSPAClass*)(G_OBJECT_GET_CLASS (ladspa)); + LADSPA_Descriptor *desc; + + desc = ladspa->descriptor; + do { + printf("looping something\n"); + + // first get all the necessary data from the input ports + for (i=0;i<oclass->numsinkpads;i++){ + ladspa->buffers[i] = gst_pad_pull(ladspa->sinkpads[i]); + printf("pulling buffer %d\n", i); + } + + for (i=0;i<oclass->numsinkpads;i++) { +// desc->connect_port(ladspa->handle,i,&(ladspa->controls[i])); + } + + for (i=0;i<oclass->numsrcpads && i<oclass->numsinkpads;i++){ + printf("pushing buffer %d\n", i); + gst_pad_push (ladspa->srcpads[i], ladspa->buffers[i]); + ladspa->buffers[i] = NULL; + } + + } while (!GST_ELEMENT_IS_COTHREAD_STOPPING (element)); +} + +static void +gst_ladspa_chain_inplace_mono (GstPad *pad,GstBuffer *buf) +{ + LADSPA_Descriptor *desc; + LADSPA_Data *data; + unsigned long num_samples; + + GstLADSPA *ladspa; + GstLADSPAClass *oclass; + + g_return_if_fail(pad != NULL); + g_return_if_fail(GST_IS_PAD(pad)); + g_return_if_fail(buf != NULL); + + ladspa = (GstLADSPA *)gst_pad_get_parent (pad); + g_return_if_fail(ladspa != NULL); + + // this might happen if caps nego hasn't happened + g_return_if_fail(ladspa->handle != NULL); + + oclass = (GstLADSPAClass*)(G_OBJECT_GET_CLASS (ladspa)); + data=(LADSPA_Data*)GST_BUFFER_DATA(buf); + num_samples = GST_BUFFER_SIZE(buf) / sizeof(gfloat); + + desc = ladspa->descriptor; + + desc->connect_port(ladspa->handle,oclass->sinkpad_portnums[0],data); + desc->connect_port(ladspa->handle,oclass->srcpad_portnums[0],data); + + desc->run(ladspa->handle,num_samples); + + desc->connect_port(ladspa->handle,oclass->sinkpad_portnums[0],NULL); + desc->connect_port(ladspa->handle,oclass->srcpad_portnums[0],NULL); + + gst_pad_push (ladspa->srcpads[0], buf); +} + +static GstBuffer * +gst_ladspa_get_mono(GstPad *pad) +{ + LADSPA_Descriptor *desc; + LADSPA_Data *data; + + GstLADSPA *ladspa; + GstLADSPAClass *oclass; + GstBuffer *buf; + + g_return_val_if_fail(pad != NULL, NULL); + g_return_val_if_fail(GST_IS_PAD(pad), NULL); + + ladspa = (GstLADSPA *)gst_pad_get_parent (pad); + g_return_val_if_fail(ladspa != NULL, NULL); + + // this might happen if caps nego hasn't happened + g_return_val_if_fail(ladspa->handle != NULL, NULL); + + oclass = (GstLADSPAClass*)(G_OBJECT_GET_CLASS(ladspa)); + + if (ladspa->newcaps) { + gst_ladspa_force_caps(ladspa, ladspa->srcpads[0]); + } + + buf = gst_buffer_new(); + g_return_val_if_fail (buf, NULL); + data = g_new(LADSPA_Data, ladspa->buffersize); + GST_BUFFER_DATA(buf) = (gpointer) data; + GST_BUFFER_SIZE(buf) = sizeof(LADSPA_Data) * ladspa->buffersize; + GST_BUFFER_TIMESTAMP(buf) = ladspa->timestamp; + + desc = ladspa->descriptor; + desc->connect_port(ladspa->handle,oclass->srcpad_portnums[0],data); + desc->run(ladspa->handle,(unsigned long)ladspa->buffersize); + desc->connect_port(ladspa->handle,oclass->srcpad_portnums[0],NULL); + + return buf; +} + +static GstBuffer * +gst_ladspa_get(GstPad *pad) +{ + LADSPA_Descriptor *desc; + LADSPA_Data *data; + + GstLADSPA *ladspa; + GstLADSPAClass *oclass; + GstBuffer *buf; + + g_return_val_if_fail(pad != NULL, NULL); + g_return_val_if_fail(GST_IS_PAD(pad), NULL); + + ladspa = (GstLADSPA *)gst_pad_get_parent (pad); + g_return_val_if_fail(ladspa != NULL, NULL); + + // this might happen if caps nego hasn't happened + g_return_val_if_fail(ladspa->handle != NULL, NULL); + + oclass = (GstLADSPAClass*)(G_OBJECT_GET_CLASS(ladspa)); + + if (ladspa->newcaps) { + gst_ladspa_force_caps(ladspa, ladspa->srcpads[0]); + } + + buf = gst_buffer_new(); + g_return_val_if_fail (buf, NULL); + data = g_new(LADSPA_Data, ladspa->buffersize); + GST_BUFFER_DATA(buf) = (gpointer) data; + GST_BUFFER_SIZE(buf) = sizeof(LADSPA_Data) * ladspa->buffersize; + GST_BUFFER_TIMESTAMP(buf) = ladspa->timestamp; + ladspa->timestamp+= ladspa->buffersize * ladspa->samplerate * 10^9; + + desc = ladspa->descriptor; + desc->connect_port(ladspa->handle,oclass->srcpad_portnums[0],data); + desc->run(ladspa->handle,(unsigned long)ladspa->buffersize); + desc->connect_port(ladspa->handle,oclass->srcpad_portnums[0],NULL); + + return buf; +} + +static void +ladspa_describe_plugin(const char *pcFullFilename, + void *pvPluginHandle, + LADSPA_Descriptor_Function pfDescriptorFunction) +{ + const LADSPA_Descriptor *desc; + int i,j; + + GstElementDetails *details; + GTypeInfo typeinfo = { + sizeof(GstLADSPAClass), NULL, + NULL, + (GClassInitFunc)gst_ladspa_class_init, + NULL, + NULL, + sizeof(GstLADSPA), + 0, + (GInstanceInitFunc)gst_ladspa_init, + }; + GType type; + GstElementFactory *factory; + + // walk through all the plugins in this pluginlibrary + i = 0; + while ((desc = pfDescriptorFunction(i++))) { + gchar *type_name; + + // construct the type + type_name = g_strdup_printf("ladspa_%s",desc->Label); + g_strcanon (type_name, G_CSET_A_2_Z G_CSET_a_2_z G_CSET_DIGITS "-_+", '-'); + // if it's already registered, drop it + if (g_type_from_name(type_name)) { + g_free(type_name); + continue; + } + // create the type now + type = g_type_register_static(GST_TYPE_ELEMENT, type_name , &typeinfo, 0); + + // construct the element details struct + details = g_new0(GstElementDetails,1); + details->longname = g_strdup(desc->Name); + details->klass = "Filter/LADSPA"; + details->description = details->longname; + details->version = g_strdup_printf("%ld",desc->UniqueID); + details->author = g_strdup(desc->Maker); + details->copyright = g_strdup(desc->Copyright); + + // register the plugin with gstreamer + factory = gst_elementfactory_new(type_name,type,details); + g_return_if_fail(factory != NULL); + gst_plugin_add_feature (ladspa_plugin, GST_PLUGIN_FEATURE (factory)); + + // add this plugin to the hash + g_hash_table_insert(ladspa_descriptors, + GINT_TO_POINTER(type), + (gpointer)desc); + + + // only add sink padtemplate if there are sinkpads + for (j=0;j<desc->PortCount;j++) { + if (LADSPA_IS_PORT_AUDIO(desc->PortDescriptors[j]) && + LADSPA_IS_PORT_INPUT(desc->PortDescriptors[j])) { + sinktempl = ladspa_sink_factory(); + gst_elementfactory_add_padtemplate (factory, sinktempl); + break; + } + } + + srctempl = ladspa_src_factory(); + gst_elementfactory_add_padtemplate (factory, srctempl); + + } +} + +static gboolean +plugin_init (GModule *module, GstPlugin *plugin) +{ + + ladspa_descriptors = g_hash_table_new(NULL,NULL); + parent_class = g_type_class_ref(GST_TYPE_ELEMENT); + + ladspa_plugin = plugin; + + LADSPAPluginSearch(ladspa_describe_plugin); + + return TRUE; +} + +GstPluginDesc plugin_desc = { + GST_VERSION_MAJOR, + GST_VERSION_MINOR, + "ladspa", + plugin_init +}; + |