mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2024-10-06 10:42:22 +00:00
Code Issues 1 Projects Releases Wiki Activity

fixing CLAMPING

Browse source 
Original commit message from CVS:
fixing CLAMPING
This commit is contained in:
Thomas Vander Stichele 2004-03-31 17:11:14 +00:00
parent 1241a83bd7
commit a9d2e74cd3
2 changed files with 45 additions and 17 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
ChangeLog
View file

@ -1,3 +1,12 @@
2004-03-31 Thomas Vander Stichele <thomas at apestaart dot org>
* gst/adder/gstadder.c: (gst_adder_get_type), (gst_adder_loop):
fix integer addition with help of Stefan Kost
2004-03-31 Thomas Vander Stichele <thomas at apestaart dot org>
* po/nl.po: updated Dutch translation (Elros Cyriatan)
2004-03-30 David Schleef <ds@schleef.org> 2004-03-30 David Schleef <ds@schleef.org>
* ext/mpeg2dec/gstmpeg2dec.c: (gst_mpeg2dec_alloc_buffer), * ext/mpeg2dec/gstmpeg2dec.c: (gst_mpeg2dec_alloc_buffer),
@ -26,6 +35,7 @@
* ext/kio/kiosrc.cpp: (process_events): * ext/kio/kiosrc.cpp: (process_events):
update handling event processing if inside KDE - untested update handling event processing if inside KDE - untested
>>>>>>> 1.489
2004-03-29 David Schleef <ds@schleef.org> 2004-03-29 David Schleef <ds@schleef.org>
* ext/hermes/gsthermescolorspace.c: (plugin_init): decrease rank * ext/hermes/gsthermescolorspace.c: (plugin_init): decrease rank

52
gst/adder/gstadder.c
View file

@ -29,9 +29,24 @@
#include <gst/audio/audio.h> #include <gst/audio/audio.h>
#include <string.h> /* strcmp */ #include <string.h> /* strcmp */
/* highest positive/lowest negative x-bit value we can use for clamping */
//#define MAX_INT_x ((guint) 1 << (x - 1))
#define MAX_INT_32 2147483647L
#define MAX_INT_16 32767
#define MAX_INT_8 127
//#define MIN_INT_x (-((guint) 1 << (x - 1)))
/* to make non-C90 happy we need to specify the constant differently */
#define MIN_INT_32 (-2147483647L -1L)
#define MIN_INT_16 -32768
#define MIN_INT_8 -128
#define GST_ADDER_BUFFER_SIZE 4096 #define GST_ADDER_BUFFER_SIZE 4096
#define GST_ADDER_NUM_BUFFERS 8 #define GST_ADDER_NUM_BUFFERS 8
GST_DEBUG_CATEGORY_STATIC (gst_adder_debug);
#define GST_CAT_DEFAULT gst_adder_debug
/* elementfactory information */ /* elementfactory information */
static GstElementDetails adder_details = GST_ELEMENT_DETAILS ("Adder", static GstElementDetails adder_details = GST_ELEMENT_DETAILS ("Adder",
"Generic/Audio", "Generic/Audio",
@ -57,7 +72,7 @@ static GstStaticPadTemplate gst_adder_src_template =
GST_PAD_SRC, GST_PAD_SRC,
GST_PAD_ALWAYS, GST_PAD_ALWAYS,
GST_STATIC_CAPS (GST_AUDIO_INT_PAD_TEMPLATE_CAPS "; " GST_STATIC_CAPS (GST_AUDIO_INT_PAD_TEMPLATE_CAPS "; "
GST_AUDIO_FLOAT_STANDARD_PAD_TEMPLATE_CAPS) GST_AUDIO_FLOAT_PAD_TEMPLATE_CAPS)
); );
static GstStaticPadTemplate gst_adder_sink_template = static GstStaticPadTemplate gst_adder_sink_template =
@ -65,7 +80,7 @@ static GstStaticPadTemplate gst_adder_sink_template =
GST_PAD_SINK, GST_PAD_SINK,
GST_PAD_REQUEST, GST_PAD_REQUEST,
GST_STATIC_CAPS (GST_AUDIO_INT_PAD_TEMPLATE_CAPS "; " GST_STATIC_CAPS (GST_AUDIO_INT_PAD_TEMPLATE_CAPS "; "
GST_AUDIO_FLOAT_STANDARD_PAD_TEMPLATE_CAPS) GST_AUDIO_FLOAT_PAD_TEMPLATE_CAPS)
); );
static void gst_adder_class_init (GstAdderClass * klass); static void gst_adder_class_init (GstAdderClass * klass);
@ -100,6 +115,8 @@ gst_adder_get_type (void)
adder_type = g_type_register_static (GST_TYPE_ELEMENT, "GstAdder", adder_type = g_type_register_static (GST_TYPE_ELEMENT, "GstAdder",
&adder_info, 0); &adder_info, 0);
GST_DEBUG_CATEGORY_INIT (gst_adder_debug, "adder", 0,
"audio channel mixing element");
} }
return adder_type; return adder_type;
} }
@ -321,7 +338,7 @@ gst_adder_loop (GstElement * element)
/* get data from all of the sinks */ /* get data from all of the sinks */
inputs = adder->input_channels; inputs = adder->input_channels;
GST_DEBUG ("starting to cycle through channels"); GST_LOG ("starting to cycle through channels");
while (inputs) { while (inputs) {
guint32 got_bytes; guint32 got_bytes;
@ -332,10 +349,10 @@ gst_adder_loop (GstElement * element)
inputs = inputs->next; inputs = inputs->next;
GST_DEBUG ("looking into channel %p", input); GST_LOG (" looking into channel %p", input);
if (!GST_PAD_IS_USABLE (input->sinkpad)) { if (!GST_PAD_IS_USABLE (input->sinkpad)) {
GST_DEBUG ("adder ignoring pad %s:%s", GST_LOG (" adder ignoring pad %s:%s",
GST_DEBUG_PAD_NAME (input->sinkpad)); GST_DEBUG_PAD_NAME (input->sinkpad));
continue; continue;
} }
@ -358,12 +375,12 @@ gst_adder_loop (GstElement * element)
case GST_EVENT_EOS: case GST_EVENT_EOS:
/* if we get an EOS event from one of our sink pads, we assume that /* if we get an EOS event from one of our sink pads, we assume that
pad's finished handling data. just skip this pad. */ pad's finished handling data. just skip this pad. */
GST_DEBUG ("got an EOS event"); GST_DEBUG (" got an EOS event");
gst_event_unref (event); gst_event_unref (event);
continue; continue;
case GST_EVENT_INTERRUPT: case GST_EVENT_INTERRUPT:
gst_event_unref (event); gst_event_unref (event);
GST_DEBUG ("got an interrupt event"); GST_DEBUG (" got an interrupt event");
/* we have to call interrupt here, the scheduler will switch out /* we have to call interrupt here, the scheduler will switch out
this element ASAP or returns TRUE if we need to exit the loop */ this element ASAP or returns TRUE if we need to exit the loop */
if (gst_element_interrupt (GST_ELEMENT (adder))) { if (gst_element_interrupt (GST_ELEMENT (adder))) {
@ -377,9 +394,11 @@ gst_adder_loop (GstElement * element)
} else { } else {
/* here's where the data gets copied. */ /* here's where the data gets copied. */
GST_DEBUG ("copying %d bytes from channel %p to output data %p " GST_LOG (" copying %d bytes (format %d,%d)",
"in buffer %p", GST_BUFFER_SIZE (buf_out), adder->format, adder->width);
GST_BUFFER_SIZE (buf_out), input, GST_BUFFER_DATA (buf_out), buf_out); GST_LOG (" from channel %p from input data %p", input, raw_in);
GST_LOG (" to output data %p in buffer %p",
GST_BUFFER_DATA (buf_out), buf_out);
if (adder->format == GST_ADDER_FORMAT_INT) { if (adder->format == GST_ADDER_FORMAT_INT) {
if (adder->width == 32) { if (adder->width == 32) {
@ -387,19 +406,19 @@ gst_adder_loop (GstElement * element)
gint32 *out = (gint32 *) GST_BUFFER_DATA (buf_out); gint32 *out = (gint32 *) GST_BUFFER_DATA (buf_out);
for (i = 0; i < GST_BUFFER_SIZE (buf_out) / 4; i++) for (i = 0; i < GST_BUFFER_SIZE (buf_out) / 4; i++)
out[i] = CLAMP (out[i] + in[i], 0x80000000, 0x7fffffff); out[i] = CLAMP (out[i] + in[i], MIN_INT_32, MAX_INT_32);
} else if (adder->width == 16) { } else if (adder->width == 16) {
gint16 *in = (gint16 *) raw_in; gint16 *in = (gint16 *) raw_in;
gint16 *out = (gint16 *) GST_BUFFER_DATA (buf_out); gint16 *out = (gint16 *) GST_BUFFER_DATA (buf_out);
for (i = 0; i < GST_BUFFER_SIZE (buf_out) / 2; i++) for (i = 0; i < GST_BUFFER_SIZE (buf_out) / 2; i++)
out[i] = CLAMP (out[i] + in[i], 0x8000, 0x7fff); out[i] = CLAMP (out[i] + in[i], MIN_INT_16, MAX_INT_16);
} else if (adder->width == 8) { } else if (adder->width == 8) {
gint8 *in = (gint8 *) raw_in; gint8 *in = (gint8 *) raw_in;
gint8 *out = (gint8 *) GST_BUFFER_DATA (buf_out); gint8 *out = (gint8 *) GST_BUFFER_DATA (buf_out);
for (i = 0; i < GST_BUFFER_SIZE (buf_out); i++) for (i = 0; i < GST_BUFFER_SIZE (buf_out); i++)
out[i] = CLAMP (out[i] + in[i], 0x80, 0x7f); out[i] = CLAMP (out[i] + in[i], MIN_INT_8, MAX_INT_8);
} else { } else {
GST_ELEMENT_ERROR (adder, STREAM, FORMAT, (NULL), GST_ELEMENT_ERROR (adder, STREAM, FORMAT, (NULL),
("invalid width (%u) for integer audio in gstadder", ("invalid width (%u) for integer audio in gstadder",
@ -432,14 +451,13 @@ gst_adder_loop (GstElement * element)
gst_bytestream_flush (input->bytestream, GST_BUFFER_SIZE (buf_out)); gst_bytestream_flush (input->bytestream, GST_BUFFER_SIZE (buf_out));
GST_DEBUG ("done copying data"); GST_LOG ("done copying data");
} }
} }
GST_BUFFER_TIMESTAMP (buf_out) = adder->timestamp; GST_BUFFER_TIMESTAMP (buf_out) = adder->timestamp;
if (adder->format == GST_ADDER_FORMAT_FLOAT) if (adder->format == GST_ADDER_FORMAT_FLOAT)
adder->offset += adder->offset += GST_BUFFER_SIZE (buf_out) / adder->width / adder->channels;
GST_BUFFER_SIZE (buf_out) / sizeof (gfloat) / adder->channels;
else else
adder->offset += adder->offset +=
GST_BUFFER_SIZE (buf_out) * 8 / adder->width / adder->channels; GST_BUFFER_SIZE (buf_out) * 8 / adder->width / adder->channels;
@ -447,7 +465,7 @@ gst_adder_loop (GstElement * element)
/* send it out */ /* send it out */
GST_DEBUG ("pushing buf_out"); GST_LOG ("pushing buf_out");
gst_pad_push (adder->srcpad, GST_DATA (buf_out)); gst_pad_push (adder->srcpad, GST_DATA (buf_out));
} }