---

gapeaudioinput.cpp

//GapeAudioInput.cpp
//Dave Chisholm dkc@ccrma.stanford.edu 12/1/00
#include "gapeaudioinput.h"
#include <limits.h>

GapeAudioInput::GapeAudioInput(GapeController* c, int numChannels, int device)
: GapeUnit(c, numChannels),
properInitializationReportedFlag(false),
tickCounter(INT_MAX),
hasBeenMuted(false) {
    properlyInitialized = true;
    if (numChannels > GAPE_MAX_NUM_CHANNELS) {
        numChannels = GAPE_MAX_NUM_CHANNELS;
        GapeConsts::reportError("GapeAudioInput does not support the requested number of channels - the max number of channels is being used instead. Redefine GAPE_MAX_NUM_CHANNELS and re-compile if necesary.");
    }
    try {
        input = new RtAudio(numChannels, GapeConsts::sampleRate, "record", device);
    } catch (StkError& e) {
        QString message("GapeAudioInput - unable to initialize - ");
        message.append(e.getMessage());
        GapeConsts::reportError(message.latin1());
        properlyInitialized = false;
    }
    soundBufferSize =   GAPE_RT_IO_BUFFER_SIZE * numChannels;
    soundBuffer = new GapeIntSample[soundBufferSize];
    currentBufferPosition = soundBufferSize;
}

GapeAudioInput::~GapeAudioInput() {
    delete []soundBuffer;
    soundBuffer = NULL;
    delete input;
    input = NULL;
}


void GapeAudioInput::setMute(bool b) {
    if (muted == b) return;
    //GapeConsts::reportError("changing mute\n");
    updateMutex.lock();
    /*
    if (b) {
        //stop();//removed b/c new mutex code needs this to be in main
    } else {
        //start();
    }*/
    muted = b;
    updateMutex.unlock();
    emit emitMute(b);
}


void GapeAudioInput::stop() {
    //GapeConsts::reportError("stopinput\n");
    currentBufferPosition = soundBufferSize;
    #ifdef DIRECTX_API
        input->stopRecord();
    #endif
}


void GapeAudioInput::start() {
    //GapeConsts::reportError("startinput\n");
    #ifdef DIRECTX_API
        input->startRecord();
    #endif
}


void GapeAudioInput::receiveTick(const GapeFloat* values, int numValues) {
    static bool properInitializtionReportedFlag;
    int i;

    if (!properlyInitialized) {
            if (!properInitializtionReportedFlag) {
                properInitializtionReportedFlag = true;
                GapeConsts::reportError("GapeAudioInput was not properly initialized! Not inputting samples.\n");
            }
        emit emitTick(values, numValues);
        return;
    }


    //some terse code and a redundant boolean (changed) to ensure we're thread safe and
    //don't double start or stop b/c of thread stuff, but still keep critical section small
    if (tickCounter >= GapeConsts::updateMutexPeriod) {
        //GapeConsts::reportError("checking mute\n");
        bool changed = false;

        updateMutex.lock();
        if (hasBeenMuted != muted) {
            //GapeConsts::reportError("checking mute change\n");
            hasBeenMuted = muted;
            changed = true;
        }
        updateMutex.unlock();
        if (changed) {
            if (hasBeenMuted) {
                stop();
            } else {
                start();
            }
        }
        tickCounter = 0;
    }
    tickCounter++;

    if (hasBeenMuted) {
            emit emitTick(values, numValues);
            return;
    }


//if (updateMutex.locked()) GapeConsts::reportError("locked GAI\n");
    //updateMutex.lock();
    if (currentBufferPosition == soundBufferSize) {
        getMoreData();
        currentBufferPosition = 0;
    }

    GapeFloat output[GAPE_MAX_NUM_CHANNELS];

    if (numValues > GAPE_MAX_NUM_CHANNELS) {
        numValues = GAPE_MAX_NUM_CHANNELS;
    }

    if ((values == NULL) || (numValues == 0)) {
        numValues = numChannels;
        for (i = 0;i < numChannels; i++) {
            output[i] = GapeConsts::IntToFloat(soundBuffer[currentBufferPosition + i]);
        }
    } else {
        for (i =0; i < numValues; i++) {
            output[i] = values[i];
        }
        for (i = 0; i < numChannels; i++) {
            output[i] += GapeConsts::IntToFloat(soundBuffer[currentBufferPosition + i]);
        }
        if (numValues < numChannels) {
            numValues = numChannels;
        }
    }

    currentBufferPosition += numChannels;
    //updateMutex.unlock();

    emit emitTick(output, numValues);
}


//i should put a try/catch clause here.
void GapeAudioInput::getMoreData() {
    input->recordBuffer(soundBuffer, numChannels * soundBufferSize);
}

---