/* -*- c-basic-offset: 2 -*-

 * vi:si:et:sw=2:sts=8:ts=8:expandtab

 *

 * GStreamer

 * Copyright (C) 1999-2001 Erik Walthinsen <omega@cse.ogi.edu>

 * Copyright (C) 2005 Andy Wingo <wingo@pobox.com>

 *

 * 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.

 */

/**

 * SECTION:element-volume

 *

 * The volume element changes the volume of the audio data.

 * <title>Example launch line</title>

 * gst-launch -v -m audiotestsrc ! volume volume=0.5 ! level ! fakesink silent=TRUE

 * (peak values are around -6 dB and RMS around -9 dB) compared to

 * the same pipeline without the volume element.

 * </refsect2>

 */

#ifdef HAVE_CONFIG_H

#include "config.h"

#endif

#include <gst/gst_global.h>

#include <string.h>

#include <gst/gst.h>

#include <gst/base/gstbasetransform.h>

#include <gst/audio/audio.h>

#include <gst/interfaces/mixer.h>

#include <gst/controller/gstcontroller.h>

#include <gst/audio/audio.h>

#include <gst/audio/gstaudiofilter.h>

#include "gstvolume.h"

/* some defines for audio processing */

/* the volume factor is a range from 0.0 to (arbitrary) VOLUME_MAX_DOUBLE = 10.0

 * we map 1.0 to VOLUME_UNITY_INT*

 */

#define VOLUME_UNITY_INT8            32 /* internal int for unity 2^(8-3) */

#define VOLUME_UNITY_INT8_BIT_SHIFT  5  /* number of bits to shift for unity */

#define VOLUME_UNITY_INT16           8192       /* internal int for unity 2^(16-3) */

#define VOLUME_UNITY_INT16_BIT_SHIFT 13 /* number of bits to shift for unity */

#define VOLUME_UNITY_INT24           2097152    /* internal int for unity 2^(24-3) */

#define VOLUME_UNITY_INT24_BIT_SHIFT 21 /* number of bits to shift for unity */

#define VOLUME_UNITY_INT32           134217728  /* internal int for unity 2^(32-5) */

#define VOLUME_UNITY_INT32_BIT_SHIFT 27

#define VOLUME_MAX_DOUBLE            10.0

#define VOLUME_MAX_INT8              G_MAXINT8

#define VOLUME_MIN_INT8              G_MININT8

#define VOLUME_MAX_INT16             G_MAXINT16

#define VOLUME_MIN_INT16             G_MININT16

#define VOLUME_MAX_INT24             8388607

#define VOLUME_MIN_INT24             -8388608

#define VOLUME_MAX_INT32             G_MAXINT32

#define VOLUME_MIN_INT32             G_MININT32

/* number of steps we use for the mixer interface to go from 0.0 to 1.0 */

# define VOLUME_STEPS           100

#define GST_CAT_DEFAULT gst_volume_debug

GST_DEBUG_CATEGORY_STATIC (GST_CAT_DEFAULT);

/* Filter signals and args */

enum

{

  /* FILL ME */

  LAST_SIGNAL

};

enum

{

  PROP_0,

  PROP_MUTE,

  PROP_VOLUME

};

#define ALLOWED_CAPS \

        "audio/x-raw-float, " \

        "rate = (int) [ 1, MAX ], " \

        "channels = (int) [ 1, MAX ], " \

        "endianness = (int) BYTE_ORDER, " \

        "width = (int) {32, 64}; " \

        "audio/x-raw-int, " \

        "channels = (int) [ 1, MAX ], " \

        "rate = (int) [ 1,  MAX ], " \

        "endianness = (int) BYTE_ORDER, " \

        "width = (int) 8, " \

        "depth = (int) 8, " \

        "signed = (bool) TRUE; " \

        "audio/x-raw-int, " \

        "channels = (int) [ 1, MAX ], " \

        "rate = (int) [ 1,  MAX ], " \

        "endianness = (int) BYTE_ORDER, " \

        "width = (int) 16, " \

        "depth = (int) 16, " \

        "signed = (bool) TRUE; " \

        "audio/x-raw-int, " \

        "channels = (int) [ 1, MAX ], " \

        "rate = (int) [ 1,  MAX ], " \

        "endianness = (int) BYTE_ORDER, " \

        "width = (int) 24, " \

        "depth = (int) 24, " \

        "signed = (bool) TRUE; " \

        "audio/x-raw-int, " \

        "channels = (int) [ 1, MAX ], " \

        "rate = (int) [ 1,  MAX ], " \

        "endianness = (int) BYTE_ORDER, " \

        "width = (int) 32, " \

	"depth = (int) 32, " \

	"signed = (bool) TRUE"

static void gst_volume_interface_init (GstImplementsInterfaceClass * klass);

static void gst_volume_mixer_init (GstMixerClass * iface);

#define _init_interfaces(type)                                          \

  {                                                                     \

    static const GInterfaceInfo voliface_info = {                     \

      (GInterfaceInitFunc) gst_volume_interface_init,                   \

      NULL,                                                             \

      NULL                                                              \

    };                                                                  \

    static const GInterfaceInfo volmixer_info = {                     \

      (GInterfaceInitFunc) gst_volume_mixer_init,                       \

      NULL,                                                             \

      NULL                                                              \

    };                                                                  \

                                                                        \

    g_type_add_interface_static (type, GST_TYPE_IMPLEMENTS_INTERFACE,   \

        &voliface_info);                                                \

    g_type_add_interface_static (type, GST_TYPE_MIXER, &volmixer_info); \

  }

GST_BOILERPLATE_FULL (GstVolume, gst_volume, GstAudioFilter,

    GST_TYPE_AUDIO_FILTER, _init_interfaces);

static void volume_set_property (GObject * object, guint prop_id,

    const GValue * value, GParamSpec * pspec);

static void volume_get_property (GObject * object, guint prop_id,

    GValue * value, GParamSpec * pspec);

static GstFlowReturn volume_transform_ip (GstBaseTransform * base,

    GstBuffer * outbuf);

static gboolean volume_setup (GstAudioFilter * filter,

    GstRingBufferSpec * format);

static void volume_process_double (GstVolume * this, gpointer bytes,

    guint n_bytes);

static void volume_process_float (GstVolume * this, gpointer bytes,

    guint n_bytes);

static void volume_process_int32 (GstVolume * this, gpointer bytes,

    guint n_bytes);

static void volume_process_int32_clamp (GstVolume * this, gpointer bytes,

    guint n_bytes);

static void volume_process_int24 (GstVolume * this, gpointer bytes,

    guint n_bytes);

static void volume_process_int24_clamp (GstVolume * this, gpointer bytes,

    guint n_bytes);

static void volume_process_int16 (GstVolume * this, gpointer bytes,

    guint n_bytes);

static void volume_process_int16_clamp (GstVolume * this, gpointer bytes,

    guint n_bytes);

static void volume_process_int8 (GstVolume * this, gpointer bytes,

    guint n_bytes);

static void volume_process_int8_clamp (GstVolume * this, gpointer bytes,

    guint n_bytes);

/* helper functions */

static gboolean

volume_choose_func (GstVolume * this)

{

  this->process = NULL;

  if (GST_AUDIO_FILTER (this)->format.caps == NULL)

    return FALSE;

  switch (GST_AUDIO_FILTER (this)->format.type) {

    case GST_BUFTYPE_LINEAR:

      switch (GST_AUDIO_FILTER (this)->format.width) {

        case 32:

          /* only clamp if the gain is greater than 1.0

           */

            this->process = volume_process_int32_clamp;

          else

            this->process = volume_process_int32;

          break;

        case 24:

          /* only clamp if the gain is greater than 1.0

           */

            this->process = volume_process_int24_clamp;

          else

            this->process = volume_process_int24;

          break;

        case 16:

          /* only clamp if the gain is greater than 1.0

           */

            this->process = volume_process_int16_clamp;

          else

            this->process = volume_process_int16;

          break;

        case 8:

          /* only clamp if the gain is greater than 1.0

           */

            this->process = volume_process_int8_clamp;

          else

            this->process = volume_process_int8;

          break;

      }

      break;

    case GST_BUFTYPE_FLOAT:

      switch (GST_AUDIO_FILTER (this)->format.width) {

        case 32:

          this->process = volume_process_float;

          break;

        case 64:

          this->process = volume_process_double;

          break;

      }

      break;

    default:

      break;

  }

  return (this->process != NULL);

}

{

  } else {

  }

  gst_base_transform_set_passthrough (GST_BASE_TRANSFORM (this), passthrough);

}

/* Mixer interface */

static gboolean

gst_volume_interface_supported (GstImplementsInterface * iface, GType type)

{

  return TRUE;

}

static void

gst_volume_interface_init (GstImplementsInterfaceClass * klass)

{

  klass->supported = gst_volume_interface_supported;

}

static const GList *

gst_volume_list_tracks (GstMixer * mixer)

{

  GstVolume *this = GST_VOLUME (mixer);

  g_return_val_if_fail (this != NULL, NULL);

  g_return_val_if_fail (GST_IS_VOLUME (this), NULL);

  return this->tracklist;

}

static void

gst_volume_set_volume (GstMixer * mixer, GstMixerTrack * track, gint * volumes)

{

  GstVolume *this = GST_VOLUME (mixer);

  g_return_if_fail (this != NULL);

  g_return_if_fail (GST_IS_VOLUME (this));

}

static void

gst_volume_get_volume (GstMixer * mixer, GstMixerTrack * track, gint * volumes)

{

  GstVolume *this = GST_VOLUME (mixer);

  g_return_if_fail (this != NULL);

  g_return_if_fail (GST_IS_VOLUME (this));

}

static void

gst_volume_set_mute (GstMixer * mixer, GstMixerTrack * track, gboolean mute)

{

  GstVolume *this = GST_VOLUME (mixer);

  g_return_if_fail (this != NULL);

  g_return_if_fail (GST_IS_VOLUME (this));

  this->mute = mute;

}

static void

gst_volume_mixer_init (GstMixerClass * klass)

{

  GST_MIXER_TYPE (klass) = GST_MIXER_SOFTWARE;

  /* default virtual functions */

  klass->list_tracks = gst_volume_list_tracks;

  klass->set_volume = gst_volume_set_volume;

  klass->get_volume = gst_volume_get_volume;

  klass->set_mute = gst_volume_set_mute;

}

/* Element class */

static void

gst_volume_dispose (GObject * object)

{

  GstVolume *volume = GST_VOLUME (object);

  if (volume->tracklist) {

    if (volume->tracklist->data)

      g_object_unref (volume->tracklist->data);

    g_list_free (volume->tracklist);

    volume->tracklist = NULL;

  }

  G_OBJECT_CLASS (parent_class)->dispose (object);

}

static void

gst_volume_base_init (gpointer g_class)

{

  GstElementClass *element_class = GST_ELEMENT_CLASS (g_class);

  GstAudioFilterClass *filter_class = GST_AUDIO_FILTER_CLASS (g_class);

  GstCaps *caps;

  caps = gst_caps_from_string (ALLOWED_CAPS);

  gst_audio_filter_class_add_pad_templates (filter_class, caps);

  gst_caps_unref (caps);

}

static void

gst_volume_class_init (GstVolumeClass * klass)

{

  GObjectClass *gobject_class;

  GstBaseTransformClass *trans_class;

  GstAudioFilterClass *filter_class;

  gobject_class = (GObjectClass *) klass;

  trans_class = (GstBaseTransformClass *) klass;

  filter_class = (GstAudioFilterClass *) (klass);

  gobject_class->set_property = volume_set_property;

  gobject_class->get_property = volume_get_property;

  gobject_class->dispose = gst_volume_dispose;

  g_object_class_install_property (gobject_class, PROP_MUTE,

      g_param_spec_boolean ("mute", "Mute", "mute channel",

  g_object_class_install_property (gobject_class, PROP_VOLUME,

  trans_class->transform_ip = GST_DEBUG_FUNCPTR (volume_transform_ip);

  filter_class->setup = GST_DEBUG_FUNCPTR (volume_setup);

}

static void

gst_volume_init (GstVolume * this, GstVolumeClass * g_class)

{

  GstMixerTrack *track = NULL;

  this->tracklist = NULL;

  track = g_object_new (GST_TYPE_MIXER_TRACK, NULL);

  if (GST_IS_MIXER_TRACK (track)) {

    track->label = g_strdup ("volume");

    track->num_channels = 1;

    track->min_volume = 0;

    track->max_volume = VOLUME_STEPS;

    track->flags = GST_MIXER_TRACK_SOFTWARE;

    this->tracklist = g_list_append (this->tracklist, track);

  }

  gst_base_transform_set_gap_aware (GST_BASE_TRANSFORM (this), TRUE);

}

static void

volume_process_double (GstVolume * this, gpointer bytes, guint n_bytes)

{

  gdouble *data = (gdouble *) bytes;

}

static void

volume_process_float (GstVolume * this, gpointer bytes, guint n_bytes)

{

  gfloat *data = (gfloat *) bytes;

  guint num_samples = n_bytes / sizeof (gfloat);

   */

}

static void

volume_process_int32 (GstVolume * this, gpointer bytes, guint n_bytes)

{

  gint *data = (gint *) bytes;

  guint i, num_samples;

  gint64 val;

  num_samples = n_bytes / sizeof (gint);

  for (i = 0; i < num_samples; i++) {

    /* we use bitshifting instead of dividing by UNITY_INT for speed */

    val = (gint64) * data;

    *data++ = (gint32) val;

  }

}

static void

volume_process_int32_clamp (GstVolume * this, gpointer bytes, guint n_bytes)

{

  gint *data = (gint *) bytes;

  guint i, num_samples;

  gint64 val;

  num_samples = n_bytes / sizeof (gint);

  for (i = 0; i < num_samples; i++) {