php-libtgvoip/audio/AudioInputModule.cpp

//
// libtgvoip is free and unencumbered public domain software.
// For more information, see http://unlicense.org or the UNLICENSE file
// you should have received with this source code distribution.
//

#include "AudioInputModule.h"
#include <stdio.h>
#include "../libtgvoip/logging.h"
#include <queue>
#include <unistd.h>

using namespace tgvoip;
using namespace tgvoip::audio;

AudioInputModule::AudioInputModule(std::string deviceID, VoIPController *controller)
{
    wrapper = (VoIP *)(controller->implData);
    wrapper->in = this;
    wrapper->inputState = AUDIO_STATE_CREATED;
}

AudioInputModule::~AudioInputModule()
{
    wrapper->inputState = AUDIO_STATE_NONE;
    wrapper->in = NULL;

    if (senderThread)
    {
        LOGD("before join senderThread");
        join_thread(senderThread);
    }
}

void AudioInputModule::Configure(uint32_t sampleRate, uint32_t bitsPerSample, uint32_t channels)
{
    inputSampleNumber = 960;
    inputSampleRate = sampleRate;
    inputBitsPerSample = bitsPerSample;
    inputChannels = channels;
    inputSamplePeriod = 1.0 / sampleRate * 1000000;
    inputWritePeriod = 1.0 / sampleRate * inputSampleNumber * 1000000;
    inputSamplePeriodSec = 1.0 / sampleRate;
    inputWritePeriodSec = 1.0 / sampleRate * inputSampleNumber;
    inputSamplesSize = inputSampleNumber * inputChannels * inputBitsPerSample / 8;
    inputCSamplesSize = inputSampleNumber * inputChannels * inputBitsPerSample / 8 * sizeof(unsigned char);

    wrapper->inputState = AUDIO_STATE_CONFIGURED;
}

void AudioInputModule::Start()
{
    if (wrapper->inputState == AUDIO_STATE_RUNNING)
        return;
    wrapper->inputState = AUDIO_STATE_RUNNING;

    LOGE("STARTING SENDER THREAD");
    start_thread(senderThread, StartSenderThread, this);
    set_thread_priority(senderThread, get_thread_max_priority());
    set_thread_name(senderThread, "voip-sender");
}

void AudioInputModule::Stop()
{
    if (wrapper->inputState != AUDIO_STATE_RUNNING)
        return;
    wrapper->inputState = AUDIO_STATE_CONFIGURED;
}

void *AudioInputModule::StartSenderThread(void *input)
{
    ((AudioInputModule *)input)->RunSenderThread();
    return NULL;
}

void AudioInputModule::RunSenderThread()
{
    unsigned char *data = (unsigned char *)malloc(inputCSamplesSize);
    size_t read;
    double time = VoIPController::GetCurrentTime();
    double sleeptime;
    while (wrapper->inputState == AUDIO_STATE_RUNNING)
    {
        lock_mutex(wrapper->inputMutex);
        while (!wrapper->configuringInput && wrapper->inputState == AUDIO_STATE_RUNNING)
        {
            if ((sleeptime = (inputWritePeriodSec - (VoIPController::GetCurrentTime() - time)) * 1000000.0) < 0)
            {
                LOGE("Sender: I'm late!");
            }
            else
            {
                usleep(sleeptime);
            }
            time = VoIPController::GetCurrentTime();

            if (!wrapper->inputFiles.empty())
            {
                if ((read = fread(data, sizeof(unsigned char), inputSamplesSize, wrapper->inputFiles.front())) != inputCSamplesSize)
                {
                    fclose(wrapper->inputFiles.front());
                    wrapper->inputFiles.pop();
                    memset(data + (read % inputCSamplesSize), 0, inputCSamplesSize - (read % inputCSamplesSize));
                }
                wrapper->playing = true;
            }
            else
            {
                wrapper->playing = false;
                if (wrapper->holdFiles.empty())
                {
                    memset(data, 0, inputCSamplesSize);
                }
                else
                {
                    if ((read = fread(data, sizeof(unsigned char), inputSamplesSize, wrapper->holdFiles.front())) != inputCSamplesSize)
                    {
                        fseek(wrapper->holdFiles.front(), 0, SEEK_SET);
                        wrapper->holdFiles.push(wrapper->holdFiles.front());
                        wrapper->holdFiles.pop();
                        memset(data + (read % inputCSamplesSize), 0, inputCSamplesSize - (read % inputCSamplesSize));
                    }
                }
            }
            InvokeCallback(data, inputCSamplesSize);
        }
        unlock_mutex(wrapper->inputMutex);
    }
    free(data);
}

void AudioInputModule::EnumerateDevices(std::vector<AudioInputDevice> &devs)
{
}