mirror of
https://github.com/danog/php-libtgvoip.git
synced 2024-11-30 04:19:26 +01:00
126 lines
3.6 KiB
C++
126 lines
3.6 KiB
C++
//
|
|
// 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 "AudioOutputModule.h"
|
|
#include <stdio.h>
|
|
#include "../libtgvoip/logging.h"
|
|
#include <unistd.h>
|
|
#include <phpcpp.h>
|
|
|
|
using namespace tgvoip;
|
|
using namespace tgvoip::audio;
|
|
|
|
AudioOutputModule::AudioOutputModule(std::string deviceID, VoIPController *controller)
|
|
{
|
|
isRunningThread = false;
|
|
wrapper = (VoIP *)(controller->implData);
|
|
wrapper->out = this;
|
|
wrapper->outputState = AUDIO_STATE_CREATED;
|
|
}
|
|
AudioOutputModule::~AudioOutputModule()
|
|
{
|
|
wrapper->outputState = AUDIO_STATE_NONE;
|
|
wrapper->out = NULL;
|
|
LOGD("before check join receiverThread");
|
|
if (isRunningThread)
|
|
{
|
|
LOGD("before join receiverThread");
|
|
join_thread(receiverThread);
|
|
}
|
|
}
|
|
|
|
void AudioOutputModule::Configure(uint32_t sampleRate, uint32_t bitsPerSample, uint32_t channels)
|
|
{
|
|
outputSampleNumber = 960;
|
|
outputSampleRate = sampleRate;
|
|
outputBitsPerSample = bitsPerSample;
|
|
outputChannels = channels;
|
|
outputSamplePeriod = 1.0 / sampleRate * 1000000;
|
|
outputWritePeriod = 1.0 / sampleRate * outputSampleNumber * 1000000;
|
|
outputSamplePeriodSec = 1.0 / sampleRate;
|
|
outputWritePeriodSec = 1.0 / sampleRate * outputSampleNumber;
|
|
outputSamplesSize = outputSampleNumber * outputChannels * outputBitsPerSample / 8;
|
|
outputCSamplesSize = outputSampleNumber * outputChannels * outputBitsPerSample / 8 * sizeof(unsigned char);
|
|
|
|
wrapper->outputState = AUDIO_STATE_CONFIGURED;
|
|
}
|
|
|
|
void AudioOutputModule::Start()
|
|
{
|
|
if (wrapper->outputState == AUDIO_STATE_RUNNING)
|
|
return;
|
|
wrapper->outputState = AUDIO_STATE_RUNNING;
|
|
|
|
LOGE("STARTING RECEIVER THREAD");
|
|
isRunningThread = true;
|
|
start_thread(receiverThread, StartReceiverThread, this);
|
|
set_thread_priority(receiverThread, get_thread_max_priority());
|
|
set_thread_name(receiverThread, "voip-receiver");
|
|
}
|
|
|
|
void AudioOutputModule::Stop()
|
|
{
|
|
if (wrapper->outputState != AUDIO_STATE_RUNNING)
|
|
return;
|
|
wrapper->outputState = AUDIO_STATE_CONFIGURED;
|
|
}
|
|
|
|
bool AudioOutputModule::IsPlaying()
|
|
{
|
|
return wrapper->outputState == AUDIO_STATE_RUNNING;
|
|
}
|
|
|
|
float AudioOutputModule::GetLevel()
|
|
{
|
|
return outputLevel;
|
|
}
|
|
|
|
void *AudioOutputModule::StartReceiverThread(void *output)
|
|
{
|
|
((AudioOutputModule *)output)->RunReceiverThread();
|
|
return NULL;
|
|
}
|
|
|
|
void AudioOutputModule::RunReceiverThread()
|
|
{
|
|
unsigned char *data = (unsigned char *)malloc(outputCSamplesSize);
|
|
double time = VoIPController::GetCurrentTime();
|
|
double sleeptime;
|
|
|
|
while (wrapper->outputState == AUDIO_STATE_RUNNING)
|
|
{
|
|
lock_mutex(wrapper->outputMutex);
|
|
|
|
while (!wrapper->configuringOutput && wrapper->outputState == AUDIO_STATE_RUNNING)
|
|
{
|
|
if ((sleeptime = (outputWritePeriodSec - (VoIPController::GetCurrentTime() - time)) * 1000000.0) < 0)
|
|
{
|
|
LOGE("Receiver: I'm late!");
|
|
}
|
|
else
|
|
{
|
|
usleep(sleeptime);
|
|
}
|
|
|
|
time = VoIPController::GetCurrentTime();
|
|
InvokeCallback(data, outputCSamplesSize);
|
|
if (wrapper->outputFile != NULL)
|
|
{
|
|
if (fwrite(data, sizeof(unsigned char), outputSamplesSize, wrapper->outputFile) != outputCSamplesSize)
|
|
{
|
|
LOGE("COULD NOT WRITE DATA TO FILE");
|
|
}
|
|
}
|
|
}
|
|
unlock_mutex(wrapper->outputMutex);
|
|
}
|
|
free(data);
|
|
}
|
|
|
|
void AudioOutputModule::EnumerateDevices(std::vector<AudioOutputDevice> &devs)
|
|
{
|
|
}
|