/* GStreamer

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

 *               2000,2005 Wim Taymans <wim@fluendo.com>

 *

 * gstdevsoundsrc.c:

 *

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

 */

#ifdef HAVE_CONFIG_H

#include "config.h"

#endif

#include <gqueue.h>

#include "common.h"

#include "gstdevsoundsrc.h"

#include <glib_global.h>

#include "gstg711encoderinterface.h"

#include "gstspeechencoderconfig.h"

#include "gstg729encoderinterface.h"

#include "gstilbcencoderinterface.h"

#include "string.h"

GST_DEBUG_CATEGORY_EXTERN (devsoundsrc_debug);

#ifdef GST_CAT_DEFAULT

#undef GST_CAT_DEFAULT

#endif

#define GST_CAT_DEFAULT devsoundsrc_debug

/* elementfactory information */

static const GstElementDetails gst_devsound_src_details=

GST_ELEMENT_DETAILS ("Audio Src (DEVSOUND)",

        "Src/Audio",

        "Record via Devsound",

        " "

);

static void gst_devsound_src_base_init(gpointer g_class);

static void gst_devsound_src_class_init(GstDevsoundSrcClass * klass);

static void gst_devsound_src_init(GstDevsoundSrc * devsoundsrc);

static void gst_devsound_src_dispose(GObject * object);

static void gst_devsound_src_get_property(GObject * object, guint prop_id,

        GValue * value, GParamSpec * pspec);

static void gst_devsound_src_set_property(GObject * object, guint prop_id,

        const GValue * value, GParamSpec * pspec);

static GstCaps *gst_devsound_src_getcaps(GstBaseSrc * bsrc);

static gboolean gst_devsound_src_setcaps(GstBaseSrc *bsrc, GstCaps *caps);

static gboolean gst_devsound_src_start(GstBaseSrc * bsrc);

static gboolean gst_devsound_src_stop(GstBaseSrc * bsrc);

static gboolean gst_devsound_src_unlock(GstBaseSrc * bsrc);

static gboolean gst_devsound_src_unlock_stop(GstBaseSrc * bsrc);

static gboolean gst_devsound_src_is_seekable(GstBaseSrc * bsrc);

static gboolean gst_devsound_src_get_size(GstBaseSrc * src, guint64 * size);

static GstFlowReturn gst_devsound_src_create(GstBaseSrc *src, guint64 offset,

        guint size, GstBuffer **buf);

static void *StartDevSoundThread(void *threadid);

static gboolean gst_devsound_src_event(GstBaseSrc * asrc, GstEvent * event);

static GstStateChangeReturn gst_devsound_src_change_state (GstElement * element,

    GstStateChange transition);

/*********************************

 * Speech Encoder Config Interface

 * ******************************/

static void gst_speech_encoder_config_handler_init(gpointer g_iface,

        gpointer iface_data);

static gint gst_get_speech_encoder_bit_rate(guint* aBitrate);

static gint gst_get_speech_encoder_supported_bit_rates(

        GList** aSupportedBitrates);

static gint gst_get_speech_encoder_vad_mode(gboolean* aVadMode);

static gint gst_set_speech_encoder_bit_rate(guint aBitrate);

static gint gst_set_speech_encoder_vad_mode(gboolean aVadMode);

static void gst_Apply_SpeechEncoder_Update(GstDevsoundSrc *devsoundsrc );

/*************************

 * G711 Encoder Interface

 * ***********************/

static void gst_g711_encoder_handler_init(gpointer g_iface,

        gpointer iface_data);

static gint gst_get_g711_encoder_vad_mode(gboolean* aVadMode);

static gint gst_set_g711_encoder_mode(enum TG711EncodeMode aEncodeMode);

static gint gst_set_g711_vad_mode(gboolean aVadMode);

static void gst_Apply_G711Encoder_Update(GstDevsoundSrc *devsoundsrc );

/*************************

 * 729 Encoder Interface

 * ***********************/

static void gst_g729_encoder_handler_init(gpointer g_iface,

        gpointer iface_data);

static gint gst_set_g729_vad_mode(TBool aVadMode);

static gint gst_get_g729_vad_mode(TBool* aVadMode);

static void gst_Apply_G729Encoder_Update(GstDevsoundSrc *devsoundsrc );

/*************************

 * ilbc Encoder Interface

 * ***********************/

static void gst_ilbc_encoder_handler_init(gpointer g_iface,

        gpointer iface_data);

static gint gst_set_ilbc_encoder_mode(enum TIlbcEncodeMode aEncodeMode);

static gint gst_set_ilbc_vad_mode(gboolean aVadMode);

static gint gst_get_ilbc_vad_mode(gboolean* aVadMode);

static void gst_Apply_IlbcEncoder_Update(GstDevsoundSrc *devsoundsrc );

static gint gst_devsound_src_get_rate(gint rate);

typedef struct _GstCustomIfaceUpdate GstCustomIfaceUpdate;

struct _GstCustomIfaceUpdate{

gboolean  speechbitrateupdate;

gboolean  speechvadmodeupdate;

gboolean  g711encodermodeupdate;

gboolean  g711vadmodeupdate;

gboolean  g729vadmodeupdate;

gboolean  ilbcencodermodeupdate;

gboolean  ilbcvadmodeupdate;

};

GstCustomIfaceUpdate customInfaceUpdate = {0,0,0,0,0,0,0};

guint speechbitrate;

gboolean speechvadmode;

enum TG711EncodeMode g711encodemode;

gboolean g711vadmode;

GList* supportedbitrates;

gint numofbitrates;

gboolean g729vadmode;

enum TIlbcEncodeMode ilbcencodemode;

gboolean ilbcvadmode;

pthread_t ds_thread;

pthread_mutex_t create_mutex1;

pthread_cond_t create_condition1;

enum consumer_thread_state_enum {

   CONSUMER_THREAD_UNINITIALIZED,

   CONSUMER_THREAD_INITIALIZING,

   CONSUMER_THREAD_INITIALIZED

};

enum consumer_thread_state_enum consumer_thread_state;

GQueue* dataqueue= NULL;

GstBuffer* popBuffer= NULL;

int dataleft = 0;

int dataCopied = 0;

enum command_to_consumer_thread_enum

    {

    OPEN = 2,

    RECORDING,

    PAUSE,

    RESUME,

    STOP,

    /*UPDATE,*/

    CLOSE

    };

enum command_to_consumer_thread_enum cmd;

enum

    {

    LAST_SIGNAL

    };

#define DEFAULT_DEVICE  "default"

enum

    {

    PROP_0,

    PROP_DEVICE,

    GAIN,

    MAXGAIN,

    CHANNELS,

    LEFTBALANCE,

    RIGHTBALANCE,

    RATE,

    PRIORITY,

    PREFERENCE,

    SAMPLESRECORDED

    };

static GstStaticPadTemplate devsound_src_factory=

    GST_STATIC_PAD_TEMPLATE ("src",

        GST_PAD_SRC,

        GST_PAD_ALWAYS,

        GST_STATIC_CAPS ("audio/x-raw-int, "

                "endianness = (int) { " G_STRINGIFY (G_BYTE_ORDER) " }, "

                "signed = (boolean) TRUE, "

                "width = (int) 16, "

                "depth = (int) 16, "

                "rate = (int) [ 8000, 48000 ],"

                "channels = (int) [ 1, 2 ]; "

                "audio/amr, "

                "rate = (int) [ 8000, 48000 ], "

                "channels = (int) [ 1, 2 ]; "

                "audio/x-alaw, "

                "rate = (int) [ 8000, 48000 ], "

                "channels = (int) [ 1, 2 ]; "

                "audio/g729, "

                "rate = (int) [ 8000, 48000 ], "

                "channels = (int) [ 1, 2 ]; "

                "audio/ilbc, "

                "rate = (int) [ 8000, 48000 ], "

                "channels = (int) [ 1, 2 ]; "

                "audio/x-mulaw, "

                "rate = (int) [ 8000, 48000 ], "

                "channels = (int) [ 1, 2 ]")

                );

static GstElementClass *parent_class= NULL;

static void gst_devsound_src_base_init(gpointer g_class)

    {

    GstElementClass *element_class= GST_ELEMENT_CLASS (g_class);

    gst_element_class_set_details(element_class, &gst_devsound_src_details);

    gst_element_class_add_pad_template(element_class,

            gst_static_pad_template_get(&devsound_src_factory));

    }

GType gst_devsound_src_get_type(void)

    {

    static GType devsoundsrc_type = 0;

    if (!devsoundsrc_type)

        {

        static const GTypeInfo devsoundsrc_info =

            {

            sizeof(GstDevsoundSrcClass), gst_devsound_src_base_init, NULL,

                    (GClassInitFunc) gst_devsound_src_class_init, NULL, NULL,

                    sizeof(GstDevsoundSrc), 0,

                    (GInstanceInitFunc) gst_devsound_src_init

,        };

    static const GInterfaceInfo speech_encoder_config_info =

        {

        gst_speech_encoder_config_handler_init,

        NULL,

        NULL

        };

    static const GInterfaceInfo g711_encoder_info =

        {

        gst_g711_encoder_handler_init,

        NULL,

        NULL

        };

    static const GInterfaceInfo g729_encoder_info =

         {

         gst_g729_encoder_handler_init,

         NULL,

         NULL

         };

    static const GInterfaceInfo ilbc_encoder_info =

         {

         gst_ilbc_encoder_handler_init,

         NULL,

         NULL

         };

    devsoundsrc_type =

    g_type_register_static (GST_TYPE_PUSH_SRC, "GstDevsoundSrc",

            &devsoundsrc_info, (GTypeFlags)0);

    g_type_add_interface_static (devsoundsrc_type, GST_TYPE_SPEECH_ENCODER_CONFIG,

            &speech_encoder_config_info);

    g_type_add_interface_static (devsoundsrc_type, GST_TYPE_G711_ENCODER,

            &g711_encoder_info);

    g_type_add_interface_static (devsoundsrc_type, GST_TYPE_G729_ENCODER,

              &g729_encoder_info);

    g_type_add_interface_static (devsoundsrc_type, GST_TYPE_ILBC_ENCODER,

              &ilbc_encoder_info);

    }

return devsoundsrc_type;

}

static void gst_devsound_src_dispose(GObject * object)

    {

    GstDevsoundSrc *devsoundsrc= GST_DEVSOUND_SRC (object);

    G_OBJECT_CLASS (parent_class)->dispose (object);

    }

static void gst_devsound_src_class_init(GstDevsoundSrcClass * klass)

    {

    GObjectClass *gobject_class;

    GstElementClass *gstelement_class;

    GstBaseSrcClass *gstbasesrc_class;

    GstPushSrcClass *gstpushsrc_class;

    gobject_class = (GObjectClass *) klass;

    gstelement_class = (GstElementClass *) klass;

    gstbasesrc_class = (GstBaseSrcClass *) klass;

    gstpushsrc_class = (GstPushSrcClass *) klass;

    parent_class = g_type_class_peek_parent(klass);

    gobject_class->dispose = GST_DEBUG_FUNCPTR (gst_devsound_src_dispose);

    gobject_class->get_property = GST_DEBUG_FUNCPTR (gst_devsound_src_get_property);

    gobject_class->set_property = GST_DEBUG_FUNCPTR (gst_devsound_src_set_property);

    gstelement_class->change_state = GST_DEBUG_FUNCPTR (gst_devsound_src_change_state);

    g_object_class_install_property(gobject_class, PROP_DEVICE,

            g_param_spec_string("device", "Device", "Devsound device ",

                    DEFAULT_DEVICE, (GParamFlags)G_PARAM_READWRITE));

    g_object_class_install_property(gobject_class, GAIN, g_param_spec_int(

            "gain", "Gain", "Devsound src gain", -1, G_MAXINT, -1,

            (GParamFlags)G_PARAM_READWRITE));

    g_object_class_install_property(gobject_class, MAXGAIN, g_param_spec_int(

            "maxgain", "MaxGain", "Devsound src max gain", -1, G_MAXINT, -1,

            G_PARAM_READABLE));

    g_object_class_install_property(gobject_class, LEFTBALANCE,

            g_param_spec_int("leftbalance", "Left Balance", "Left Balance",

                    -1, G_MAXINT, -1, (GParamFlags)G_PARAM_READWRITE));

    g_object_class_install_property(gobject_class, RIGHTBALANCE,

            g_param_spec_int("rightbalance", "Right Balance",

                    "Right Balance", -1, G_MAXINT, -1, (GParamFlags)G_PARAM_READWRITE));

    g_object_class_install_property(gobject_class, SAMPLESRECORDED,

            g_param_spec_int("samplesrecorded", "Samples Recorded",

                    "Samples Recorded", -1, G_MAXINT, -1, G_PARAM_READABLE));

    g_object_class_install_property(gobject_class, PRIORITY,

            g_param_spec_int("priority", "Priority", "Priority ", -1,

            G_MAXINT, -1,

            (GParamFlags)G_PARAM_READWRITE));

    g_object_class_install_property(gobject_class, PREFERENCE,

            g_param_spec_int("preference", "Preference", "Preference ", -1,

            G_MAXINT, -1,

            (GParamFlags)G_PARAM_READWRITE));

    g_object_class_install_property(gobject_class, RATE,

            g_param_spec_int("rate", "Rate", "Rate ", -1,

                    G_MAXINT, -1,

                    (GParamFlags)G_PARAM_READWRITE));

    g_object_class_install_property(gobject_class, CHANNELS,

            g_param_spec_int("channels", "Channels", "Channels ", -1,

                    G_MAXINT, -1,

                    (GParamFlags)G_PARAM_READWRITE));

    gstbasesrc_class->start = GST_DEBUG_FUNCPTR (gst_devsound_src_start);

    gstbasesrc_class->stop = GST_DEBUG_FUNCPTR (gst_devsound_src_stop);

    gstbasesrc_class->get_caps = GST_DEBUG_FUNCPTR (gst_devsound_src_getcaps);

    gstbasesrc_class->set_caps = GST_DEBUG_FUNCPTR (gst_devsound_src_setcaps);

    gstbasesrc_class->event = GST_DEBUG_FUNCPTR (gst_devsound_src_event);

    gstbasesrc_class->create = GST_DEBUG_FUNCPTR (gst_devsound_src_create);

    }

static void gst_devsound_src_init(GstDevsoundSrc * devsoundsrc)

    {

    GST_DEBUG_OBJECT(devsoundsrc, "initializing devsoundsrc");

    gst_base_src_set_live(GST_BASE_SRC(devsoundsrc), TRUE);

    //gst_debug_log(devsound_debug, GST_LEVEL_LOG, "", "", 0, (GObject *) devsoundsrc, "gst_devsound_src_init ENTER ",NULL);

    devsoundsrc->device = g_strdup(DEFAULT_DEVICE);

    devsoundsrc->handle=NULL;

    devsoundsrc->preference = 0; //default=>EMdaPriorityPreferenceNone;

    devsoundsrc->priority = 0;   //default=>EMdaPriorityNormal;

    devsoundsrc->firstimecreatecalled = 0;

//    pthread_mutex_init(&create_mutex1, NULL);

//    pthread_cond_init(&create_condition1, NULL);

    //gst_debug_log(devsound_debug, GST_LEVEL_LOG, "", "", 0, (GObject *) devsoundsrc, "gst_devsound_src_init EXIT ",NULL);

    }

static void *StartDevSoundThread(void *threadarg)

    {

    GstDevsoundSrc *devsoundsrc= GST_DEVSOUND_SRC (threadarg);

    int buffersize;

    TUint8* gBuffer;

    GstBuffer* pushBuffer= NULL;

    //gst_debug_log(devsound_debug, GST_LEVEL_LOG, "", "", 0, (GObject *) devsoundsrc, "StartDevSoundThread ",NULL);

    open_devsound(&(devsoundsrc->handle));

    getsupporteddatatypes(devsoundsrc);

// TODO obtain mutex to update variable here???

    consumer_thread_state = CONSUMER_THREAD_INITIALIZED;

    //pre_init_setconf(devsoundsrc);

    //gst_debug_log(devsound_debug, GST_LEVEL_LOG, "", "", 0, (GObject *) devsoundsrc, "After Record Init ",NULL);

    pthread_mutex_lock(&(create_mutex1));

    pthread_cond_signal(&(create_condition1));

    pthread_mutex_unlock(&(create_mutex1));

    // Wait until we receive a command from the main thread

    // TODO obtain mutex to read variable here???

    while ( cmd == OPEN )

        {

        pthread_mutex_lock(&create_mutex1);

        pthread_cond_wait(&create_condition1, &create_mutex1);

        pthread_mutex_unlock(&create_mutex1);

        }

    // This could happen if client creates sink and deletes it

    // without putting it to play state

    if ( cmd != CLOSE )

        {

        initialize_devsound(devsoundsrc);

        recordinit(devsoundsrc->handle);

        initproperties(devsoundsrc);

        }

    while (TRUE)

        {

        switch (cmd)

            {

            case PAUSE:

                pause_devsound(devsoundsrc);

                break;

            case RESUME:

                resume_devsound(devsoundsrc);

                break;

            case STOP:

                stop_devsound(devsoundsrc);

                break;

            case RECORDING:

                {

                pre_init_setconf(devsoundsrc);

                gst_Apply_SpeechEncoder_Update(devsoundsrc);

                gst_Apply_G711Encoder_Update(devsoundsrc);

                gst_Apply_G729Encoder_Update(devsoundsrc );

                gst_Apply_IlbcEncoder_Update(devsoundsrc );

                populateproperties(devsoundsrc);

                supportedbitrates = devsoundsrc->supportedbitrates;

                //numofbitrates = devsoundsrc->numofbitrates;

                speechbitrate = devsoundsrc->speechbitrate;

                speechvadmode = devsoundsrc->speechvadmode;

                g711vadmode = devsoundsrc->g711vadmode;

                g729vadmode  = devsoundsrc->g729vadmode;

                ilbcvadmode = devsoundsrc->ilbcvadmode;

                buffersize = get_databuffer_size(devsoundsrc->handle);

                get_databuffer(devsoundsrc->handle, &gBuffer);

                pushBuffer = gst_buffer_new_and_alloc(buffersize);

                memcpy(GST_BUFFER_DATA(pushBuffer),gBuffer,buffersize);

                GST_OBJECT_LOCK(devsoundsrc);

                g_queue_push_head (dataqueue,pushBuffer);

                GST_OBJECT_UNLOCK(devsoundsrc);

                record_data(devsoundsrc->handle);

                }

                break;

            case CLOSE:

                {

                //gst_debug_log(devsound_debug, GST_LEVEL_LOG, "", "", 0, (GObject *) devsoundsrc, "Before Close DevSound ",NULL);

                close_devsound(devsoundsrc);

                //gst_debug_log(devsound_debug, GST_LEVEL_LOG, "", "", 0, (GObject *) devsoundsrc, "After Close DevSound ",NULL);

                devsoundsrc->handle= NULL;

                //gst_debug_log(devsound_debug, GST_LEVEL_LOG, "", "", 0, (GObject *) devsoundsrc, "After handle NULL ",NULL);

                pthread_mutex_lock(&(create_mutex1));

                pthread_cond_signal(&(create_condition1));

                pthread_mutex_unlock(&(create_mutex1));

                // TODO obtain mutex here

                consumer_thread_state = CONSUMER_THREAD_UNINITIALIZED;

                devsoundsrc->firstimecreatecalled = 0;

                pthread_exit(NULL);

                }

                break;

            default:

                // TODO obtain mutex here

                consumer_thread_state = CONSUMER_THREAD_UNINITIALIZED;          

                pthread_exit(NULL);

                break;

            }

        pthread_mutex_lock(&(create_mutex1));

        pthread_cond_signal(&(create_condition1));

        pthread_mutex_unlock(&(create_mutex1));

        pthread_mutex_lock(&create_mutex1);

        pthread_cond_wait(&create_condition1, &create_mutex1);

        pthread_mutex_unlock(&create_mutex1);

        }