*/
#include "gstadder.h"
+#include <gst/audio/audio.h>
#include <string.h> /* strcmp */
#define GST_ADDER_BUFFER_SIZE 4096
"N-to-1 audio adder/mixer",
VERSION,
"Thomas <thomas@apestaart.org>",
- "(C) 2001",
+ "(C) 2001, 2002",
};
/* Adder signals and args */
enum {
ARG_0,
ARG_NUM_PADS,
+ ARG_FORMAT,
+ ARG_RATE,
+ ARG_WIDTH,
+ ARG_CHANNELS
/* FILL ME */
};
"law", GST_PROPS_INT (0),
"endianness", GST_PROPS_INT (G_BYTE_ORDER),
"signed", 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 (4000, 48000), /* FIXME */
+ "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 (GST_AUDIO_MIN_RATE,
+ GST_AUDIO_MAX_RATE),
"channels", GST_PROPS_INT_RANGE (1, 2)
),
GST_CAPS_NEW (
"float_src",
"audio/raw",
- "format", GST_PROPS_STRING("float"),
+ "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_RANGE (4000, 96000),
+ "rate", GST_PROPS_INT_RANGE (GST_AUDIO_MIN_RATE,
+ GST_AUDIO_MAX_RATE),
"channels", GST_PROPS_INT_RANGE (1, 2)
)
);
"law", GST_PROPS_INT (0),
"endianness", GST_PROPS_INT (G_BYTE_ORDER),
"signed", 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 (4000, 48000), /* FIXME */
+ "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 (GST_AUDIO_MIN_RATE,
+ GST_AUDIO_MAX_RATE),
"channels", GST_PROPS_INT_RANGE (1, 2)
),
GST_CAPS_NEW (
"float_sink",
"audio/raw",
- "format", GST_PROPS_STRING("float"),
+ "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_RANGE (4000, 96000),
+ "rate", GST_PROPS_INT_RANGE (GST_AUDIO_MIN_RATE,
+ GST_AUDIO_MAX_RATE),
"channels", GST_PROPS_INT_RANGE (1, 2)
)
);
-static void gst_adder_class_init (GstAdderClass *klass);
-static void gst_adder_init (GstAdder *adder);
+static void gst_adder_class_init (GstAdderClass *klass);
+static void gst_adder_init (GstAdder *adder);
-static void gst_adder_get_property (GObject *object, guint prop_id,
- GValue *value, GParamSpec *pspec);
+static void gst_adder_get_property (GObject *object, guint prop_id,
+ GValue *value, GParamSpec *pspec);
+static void gst_adder_set_property (GObject *object, guint prop_id,
+ const GValue *value,
+ GParamSpec *pspec);
-static GstPad* gst_adder_request_new_pad (GstElement *element, GstPadTemplate *temp,
- const gchar *unused);
+static GstPad* gst_adder_request_new_pad (GstElement *element,
+ GstPadTemplate *temp,
+ const gchar *unused);
/* we do need a loop function */
-static void gst_adder_loop (GstElement *element);
+static void gst_adder_loop (GstElement *element);
static GstElementClass *parent_class = NULL;
/* static guint gst_adder_signals[LAST_SIGNAL] = { 0 }; */
GType
-gst_adder_get_type(void) {
+gst_adder_get_type (void) {
static GType adder_type = 0;
if (!adder_type) {
static const GTypeInfo adder_info = {
- sizeof(GstAdderClass), NULL,
- NULL,
- (GClassInitFunc)gst_adder_class_init,
- NULL,
- NULL,
- sizeof(GstAdder),
+ sizeof (GstAdderClass), NULL, NULL,
+ (GClassInitFunc) gst_adder_class_init, NULL, NULL,
+ sizeof (GstAdder),
0,
- (GInstanceInitFunc)gst_adder_init,
+ (GInstanceInitFunc) gst_adder_init,
};
- adder_type = g_type_register_static (GST_TYPE_ELEMENT, "GstAdder", &adder_info, 0);
+ adder_type = g_type_register_static (GST_TYPE_ELEMENT, "GstAdder",
+ &adder_info, 0);
}
return adder_type;
}
gst_adder_parse_caps (GstAdder *adder, GstCaps *caps)
{
const gchar *format;
+ GstElement *el = GST_ELEMENT (adder);
gst_caps_get_string (caps, "format", &format);
/* the caps haven't been set yet at all, so we need to go ahead and set all
the relevant values. */
if (strcmp (format, "int") == 0) {
+ GST_DEBUG (GST_CAT_PLUGIN_INFO, "parse_caps sets adder to format int");
adder->format = GST_ADDER_FORMAT_INT;
gst_caps_get_int (caps, "width", &adder->width);
gst_caps_get_int (caps, "depth", &adder->depth);
gst_caps_get_int (caps, "channels", &adder->channels);
gst_caps_get_int (caps, "rate", &adder->rate);
} else if (strcmp (format, "float") == 0) {
+ GST_DEBUG (GST_CAT_PLUGIN_INFO, "parse_caps sets adder to format float");
adder->format = GST_ADDER_FORMAT_FLOAT;
gst_caps_get_string (caps, "layout", &adder->layout);
gst_caps_get_float (caps, "intercept", &adder->intercept);
gst_caps_get_boolean (caps, "signed", &is_signed);
gst_caps_get_int (caps, "rate", &rate);
- if ((adder->format != GST_ADDER_FORMAT_INT) ||
- (adder->width != width) ||
- (adder->channels != channels) ||
- (adder->is_signed != is_signed) ||
- (adder->rate != rate)) {
- return FALSE;
+ /* provide an error message if we can't connect */
+ if (adder->format != GST_ADDER_FORMAT_INT) {
+ gst_element_error (el,
+ "can't connect a non-int pad to an int adder");
+ return FALSE;
+ }
+ if (adder->channels != channels) {
+ gst_element_error (el,
+ "can't connect %d-channel pad with %d-channel adder",
+ channels, adder->channels);
+ return FALSE;
+ }
+ if (adder->rate != rate) {
+ gst_element_error (el, "can't connect %d Hz pad with %d Hz adder",
+ rate, adder->rate);
+ return FALSE;
+ }
+ if (adder->width != width) {
+ gst_element_error (el, "can't connect %d-bit pad with %d-bit adder",
+ width, adder->width);
+ return FALSE;
+ }
+ if (adder->is_signed != is_signed) {
+ gst_element_error (el,
+ "can't connect %ssigned pad with %ssigned adder",
+ adder->is_signed ? "" : "un",
+ is_signed ? "" : "un");
+ return FALSE;
}
} else if (strcmp (format, "float") == 0) {
gint channels, rate;
gst_caps_get_int (caps, "channels", &channels);
gst_caps_get_int (caps, "rate", &rate);
- if ((adder->format != GST_ADDER_FORMAT_FLOAT) ||
- (adder->channels != channels) ||
- (adder->rate != rate)) {
- return FALSE;
+ if (adder->format != GST_ADDER_FORMAT_FLOAT) {
+ gst_element_error (el,
+ "can't connect a non-float pad to a float adder");
+ return FALSE;
+ }
+ if (adder->channels != channels) {
+ gst_element_error (el,
+ "can't connect %d-channel pad with %d-channel adder",
+ channels, adder->channels);
+ return FALSE;
+ }
+ if (adder->rate != rate) {
+ gst_element_error (el, "can't connect %d Hz pad with %d Hz adder",
+ rate, adder->rate);
+ return FALSE;
}
} else {
/* whoa, we don't know what's trying to connect with us ! barf ! */
+ gst_element_error (el, "can't connect unknown type of pad to adder");
return FALSE;
}
}
p = (GstPad*) sinkpads->data;
if (p != pad && p != adder->srcpad) {
if (!gst_pad_try_set_caps (p, caps)) {
- GST_DEBUG (0, "caps mismatch; disconnecting and removing pad %s:%s (peer %s:%s)",
- GST_DEBUG_PAD_NAME (p), GST_DEBUG_PAD_NAME (GST_PAD_PEER (p)));
+ GST_DEBUG (GST_CAT_PLUGIN_INFO,
+ "caps mismatch; disconnecting and removing pad %s:%s "
+ "(peer %s:%s)",
+ GST_DEBUG_PAD_NAME (p),
+ GST_DEBUG_PAD_NAME (GST_PAD_PEER (p)));
gst_pad_disconnect (GST_PAD (GST_PAD_PEER (p)), p);
remove = g_list_prepend (remove, p);
}
sinkpads = g_list_next (sinkpads);
}
while (remove) {
- gst_element_remove_pad (GST_ELEMENT (adder), GST_PAD_CAST (remove->data));
+ gst_element_remove_pad (GST_ELEMENT (adder),
+ GST_PAD_CAST (remove->data));
restart:
channels = adder->input_channels;
while (channels) {
GstAdderInputChannel *channel = (GstAdderInputChannel*) channels->data;
if (channel->sinkpad == GST_PAD_CAST (remove->data)) {
gst_bytestream_destroy (channel->bytestream);
- adder->input_channels = g_slist_remove_link (adder->input_channels, channels);
+ adder->input_channels = g_slist_remove_link (adder->input_channels,
+ channels);
adder->numsinkpads--;
goto restart;
}
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_NUM_PADS,
- g_param_spec_int("num_pads","num_pads","num_pads",
- G_MININT, G_MAXINT, 0, G_PARAM_READABLE));
-
- gobject_class->get_property = gst_adder_get_property;
+ 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_NUM_PADS,
+ g_param_spec_int ("num_pads", "number of pads", "Number Of Pads",
+ 0, G_MAXINT, 0, G_PARAM_READABLE));
+ g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_FORMAT,
+ g_param_spec_string ("format", "data format", "Format of Data (int/float)",
+ "int", G_PARAM_READWRITE));
+ g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_RATE,
+ g_param_spec_int ("rate", "Rate", "Sample Rate (Hz)",
+ GST_AUDIO_MIN_RATE, GST_AUDIO_MAX_RATE,
+ GST_AUDIO_DEF_RATE, G_PARAM_READWRITE));
+ g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_WIDTH,
+ g_param_spec_int ("width", "Bit Width", "Bit Width",
+ 8, 16,
+ 16, G_PARAM_READWRITE));
+ g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_CHANNELS,
+ g_param_spec_int ("channels", "Channels", "Number of channels",
+ 1, G_MAXINT,
+ 2, G_PARAM_READWRITE));
+
+ gobject_class->get_property = GST_DEBUG_FUNCPTR (gst_adder_get_property);
+ gobject_class->set_property = GST_DEBUG_FUNCPTR (gst_adder_set_property);
gstelement_class->request_new_pad = gst_adder_request_new_pad;
}
static void
gst_adder_init (GstAdder *adder)
{
- adder->srcpad = gst_pad_new_from_template (gst_adder_src_template_factory (), "src");
+ adder->srcpad = gst_pad_new_from_template (gst_adder_src_template_factory (),
+ "src");
gst_element_add_pad (GST_ELEMENT (adder), adder->srcpad);
gst_element_set_loop_function (GST_ELEMENT (adder), gst_adder_loop);
gst_pad_set_connect_function (adder->srcpad, gst_adder_connect);
adder->format = GST_ADDER_FORMAT_UNSET;
+ /* defaults */
+ adder->rate = GST_AUDIO_DEF_RATE;
+ adder->channels = 1;
+ adder->width = 16;
+ adder->depth = 16;
+
/* keep track of the sinkpads requested */
adder->numsinkpads = 0;
}
static GstPad*
-gst_adder_request_new_pad (GstElement *element, GstPadTemplate *templ, const gchar *unused)
+gst_adder_request_new_pad (GstElement *element, GstPadTemplate *templ,
+ const gchar *unused)
{
gchar *name;
GstAdder *adder;
}
static void
-gst_adder_get_property (GObject *object, guint prop_id, GValue *value, GParamSpec *pspec)
+gst_adder_get_property (GObject *object, guint prop_id,
+ GValue *value, GParamSpec *pspec)
{
GstAdder *adder;
case ARG_NUM_PADS:
g_value_set_int (value, adder->numsinkpads);
break;
+ case ARG_FORMAT:
+ /* FIXME: check if this causes memleaks */
+ if (adder->format == GST_ADDER_FORMAT_INT)
+ g_value_set_string (value, g_strdup ("int"));
+ else if (adder->format == GST_ADDER_FORMAT_FLOAT)
+ g_value_set_string (value, g_strdup ("float"));
+ else
+ g_value_set_string (value, g_strdup ("unknown"));
+ break;
+ case ARG_RATE:
+ g_value_set_int (value, adder->rate);
+ break;
+ case ARG_WIDTH:
+ g_value_set_int (value, adder->depth);
+ break;
+ case ARG_CHANNELS:
+ g_value_set_int (value, adder->channels);
+ break;
default:
G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
break;
}
}
+static void
+gst_adder_set_property (GObject *object, guint prop_id,
+ const GValue *value, GParamSpec *pspec)
+{
+ GstAdder *adder;
+ GstElementState state;
+
+ g_return_if_fail (GST_IS_ADDER (object));
+
+ adder = GST_ADDER (object);
+ state = gst_element_get_state (GST_ELEMENT (adder));
+
+ /* none of these properties can be set when not in NULL */
+ if (state != GST_STATE_NULL)
+ {
+ gst_element_error (GST_ELEMENT (adder),
+ "trying to set properties on adder when not in NULL.");
+ return;
+ }
+ switch (prop_id) {
+ case ARG_NUM_PADS:
+ g_warning ("Trying to change read-only parameter num_pads\n");
+ break;
+ case ARG_FORMAT:
+ if (strcmp (g_value_get_string (value), "int") == 0)
+ {
+ GST_DEBUG (GST_CAT_PLUGIN_INFO, "adder: setting format to int\n");
+ adder->format = GST_ADDER_FORMAT_INT;
+ }
+ else if (strcmp (g_value_get_string (value), "float") == 0)
+ {
+ GST_DEBUG (GST_CAT_PLUGIN_INFO, "adder: setting format to float\n");
+ adder->format = GST_ADDER_FORMAT_FLOAT;
+ }
+ else
+ {
+ g_warning ("adder: unknown format %s specified\n",
+ g_value_get_string (value));
+ adder->format = GST_ADDER_FORMAT_UNSET;
+ }
+ break;
+
+ case ARG_RATE:
+ adder->rate = g_value_get_int (value);
+ break;
+ case ARG_WIDTH:
+ adder->width = g_value_get_int (value);
+ adder->depth = g_value_get_int (value);
+ break;
+ case ARG_CHANNELS:
+ adder->channels = g_value_get_int (value);
+ break;
+ default:
+ G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
+ break;
+ }
+}
+
/* use this loop */
static void
gst_adder_loop (GstElement *element)
adder = GST_ADDER (element);
adder->bufpool = gst_pad_get_bufferpool (adder->srcpad);
if (adder->bufpool == NULL) {
- adder->bufpool = gst_buffer_pool_get_default(GST_ADDER_BUFFER_SIZE, GST_ADDER_NUM_BUFFERS);
+ adder->bufpool = gst_buffer_pool_get_default (GST_ADDER_BUFFER_SIZE,
+ GST_ADDER_NUM_BUFFERS);
}
do {
buf_out = gst_buffer_new_from_pool (adder->bufpool, 0, 0);
if (buf_out == NULL)
- GST_ERROR (0, "could not get new output buffer !\n");
+ GST_ERROR (GST_ELEMENT (adder), "could not get new output buffer !");
/* initialize the output data to 0 */
zero_out = (gint8 *) GST_BUFFER_DATA (buf_out);
/* get data from all of the sinks */
inputs = adder->input_channels;
- GST_DEBUG (0, "starting to cycle through channels");
+ GST_DEBUG (GST_CAT_PLUGIN_INFO, "starting to cycle through channels");
while (inputs) {
input = (GstAdderInputChannel *) inputs->data;
- GST_DEBUG (0, "looking into channel %p", input);
+ GST_DEBUG (GST_CAT_PLUGIN_INFO, "looking into channel %p", input);
if (!GST_PAD_IS_USABLE (input->sinkpad)) {
- GST_DEBUG (0, "adder ignoring pad %s:%s", GST_DEBUG_PAD_NAME (input->sinkpad));
+ GST_DEBUG (GST_CAT_PLUGIN_INFO, "adder ignoring pad %s:%s",
+ GST_DEBUG_PAD_NAME (input->sinkpad));
inputs = inputs->next;
continue;
}
- /* get data from the bytestream of each input channel. we need to check for
- events before passing on the data to the output buffer. */
- got_bytes = gst_bytestream_peek_bytes (input->bytestream, &raw_in, GST_BUFFER_SIZE (buf_out));
+ /* Get data from the bytestream of each input channel.
+ * We need to check for events before passing on the data to
+ * the output buffer. */
+ got_bytes = gst_bytestream_peek_bytes (input->bytestream, &raw_in,
+ GST_BUFFER_SIZE (buf_out));
- /* FIXME we should do something with the data if got_bytes is more than zero */
- if (got_bytes < GST_BUFFER_SIZE(buf_out)) {
+ /* FIXME we should do something with the data
+ * if got_bytes is more than zero */
+ if (got_bytes < GST_BUFFER_SIZE (buf_out)) {
/* we need to check for an event. */
gst_bytestream_get_status (input->bytestream, &waiting, &event);
if (event) {
- if (GST_EVENT_TYPE(event) == GST_EVENT_EOS) {
+ if (GST_EVENT_TYPE (event) == GST_EVENT_EOS) {
/* if we get an EOS event from one of our sink pads, we assume that
pad's finished handling data. delete the bytestream, free up the
pad, and free up the memory associated with the input channel. */
- GST_DEBUG (0, "got an EOS event");
+ GST_DEBUG (GST_CAT_PLUGIN_INFO, "got an EOS event");
gst_bytestream_destroy (input->bytestream);
- /* gst_object_unref (GST_OBJECT (input->sinkpad)); this causes problems */
+ /* gst_object_unref (GST_OBJECT (input->sinkpad));
+ * this causes problems */
g_free (input);
adder->input_channels = g_slist_delete_link (inputs, inputs);
/* here's where the data gets copied. this is a little nasty looking
because it's the same code pretty much 3 times, except each time uses
different data types and clamp limits. */
- GST_DEBUG (0, "copying %d bytes from channel %p to output data %p in buffer %p",
- GST_BUFFER_SIZE (buf_out), input, GST_BUFFER_DATA (buf_out), buf_out);
+ GST_DEBUG (GST_CAT_PLUGIN_INFO,
+ "copying %d bytes from channel %p to output data %p "
+ "in buffer %p",
+ GST_BUFFER_SIZE (buf_out), input,
+ GST_BUFFER_DATA (buf_out), buf_out);
if (adder->format == GST_ADDER_FORMAT_INT) {
if (adder->width == 16) {
for (i = 0; i < GST_BUFFER_SIZE (buf_out); i++)
out[i] = CLAMP(out[i] + in[i], -128, 127);
} else {
- GST_ERROR (0, "invalid width (%d) for int format in gstadder\n", adder->width);
+ GST_ERROR (GST_ELEMENT (adder),
+ "invalid width (%d) for int format in gstadder\n",
+ adder->width);
}
} else if (adder->format == GST_ADDER_FORMAT_FLOAT) {
gfloat *in = (gfloat *) raw_in;
for (i = 0; i < GST_BUFFER_SIZE (buf_out) / sizeof (gfloat); i++)
out[i] += in[i];
} else {
- GST_ERROR (0, "invalid audio format (%d) in gstadder\n", adder->format);
+ GST_ERROR (GST_ELEMENT (adder),
+ "invalid audio format (%d) in gstadder\n",
+ adder->format);
}
gst_bytestream_flush (input->bytestream, GST_BUFFER_SIZE (buf_out));
- GST_DEBUG (0, "done copying data");
+ GST_DEBUG (GST_CAT_PLUGIN_INFO, "done copying data");
}
inputs = g_slist_next (inputs);
/* send it out */
- GST_DEBUG (0, "pushing buf_out");
+ GST_DEBUG (GST_CAT_PLUGIN_INFO, "pushing buf_out");
gst_pad_push (adder->srcpad, buf_out);
/* give another element a chance to do something */