mirror of https://github.com/procxx/kepka.git
126 lines
3.2 KiB
C++
126 lines
3.2 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 <sys/time.h>
|
|
#include <unistd.h>
|
|
#include <assert.h>
|
|
#include "AudioOutputAudioUnit.h"
|
|
#include "../../logging.h"
|
|
#include "AudioUnitIO.h"
|
|
|
|
#define BUFFER_SIZE 960
|
|
const int8_t permutation[33]={0,1,2,3,4,4,5,5,5,5,6,6,6,6,6,7,7,7,7,8,8,8,9,9,9,9,9,9,9,9,9,9,9};
|
|
|
|
using namespace tgvoip;
|
|
using namespace tgvoip::audio;
|
|
|
|
AudioOutputAudioUnit::AudioOutputAudioUnit(std::string deviceID){
|
|
isPlaying=false;
|
|
remainingDataSize=0;
|
|
level=0.0;
|
|
this->io=AudioUnitIO::Get();
|
|
#if TARGET_OS_OSX
|
|
io->SetCurrentDevice(false, deviceID);
|
|
#endif
|
|
io->AttachOutput(this);
|
|
failed=io->IsFailed();
|
|
}
|
|
|
|
AudioOutputAudioUnit::~AudioOutputAudioUnit(){
|
|
io->DetachOutput();
|
|
AudioUnitIO::Release();
|
|
}
|
|
|
|
void AudioOutputAudioUnit::Configure(uint32_t sampleRate, uint32_t bitsPerSample, uint32_t channels){
|
|
io->Configure(sampleRate, bitsPerSample, channels);
|
|
}
|
|
|
|
bool AudioOutputAudioUnit::IsPhone(){
|
|
return false;
|
|
}
|
|
|
|
void AudioOutputAudioUnit::EnableLoudspeaker(bool enabled){
|
|
|
|
}
|
|
|
|
void AudioOutputAudioUnit::Start(){
|
|
isPlaying=true;
|
|
io->EnableOutput(true);
|
|
failed=io->IsFailed();
|
|
}
|
|
|
|
void AudioOutputAudioUnit::Stop(){
|
|
isPlaying=false;
|
|
io->EnableOutput(false);
|
|
}
|
|
|
|
bool AudioOutputAudioUnit::IsPlaying(){
|
|
return isPlaying;
|
|
}
|
|
|
|
float AudioOutputAudioUnit::GetLevel(){
|
|
return level / 9.0;
|
|
}
|
|
|
|
void AudioOutputAudioUnit::HandleBufferCallback(AudioBufferList *ioData){
|
|
int i;
|
|
unsigned int k;
|
|
int16_t absVal=0;
|
|
for(i=0;i<ioData->mNumberBuffers;i++){
|
|
AudioBuffer buf=ioData->mBuffers[i];
|
|
if(!isPlaying){
|
|
memset(buf.mData, 0, buf.mDataByteSize);
|
|
return;
|
|
}
|
|
while(remainingDataSize<buf.mDataByteSize){
|
|
assert(remainingDataSize+BUFFER_SIZE*2<10240);
|
|
InvokeCallback(remainingData+remainingDataSize, BUFFER_SIZE*2);
|
|
remainingDataSize+=BUFFER_SIZE*2;
|
|
}
|
|
#if TARGET_OS_OSX
|
|
float* dst=reinterpret_cast<float*>(buf.mData);
|
|
int16_t* src=reinterpret_cast<int16_t*>(remainingData);
|
|
for(k=0;k<buf.mDataByteSize/4;k++){
|
|
dst[k]=src[k]/(float)INT16_MAX;
|
|
}
|
|
remainingDataSize-=buf.mDataByteSize/2;
|
|
memmove(remainingData, remainingData+buf.mDataByteSize/2, remainingDataSize);
|
|
#else
|
|
memcpy(buf.mData, remainingData, buf.mDataByteSize);
|
|
remainingDataSize-=buf.mDataByteSize;
|
|
memmove(remainingData, remainingData+buf.mDataByteSize, remainingDataSize);
|
|
#endif
|
|
|
|
/*unsigned int samples=buf.mDataByteSize/sizeof(int16_t);
|
|
for (k=0;k<samples;k++){
|
|
int16_t absolute=(int16_t)abs(*((int16_t *)buf.mData+k));
|
|
if (absolute>absVal)
|
|
absVal=absolute;
|
|
}
|
|
|
|
if (absVal>absMax)
|
|
absMax=absVal;
|
|
|
|
count++;
|
|
if (count>=10) {
|
|
count=0;
|
|
|
|
short position=absMax/1000;
|
|
if (position==0 && absMax>250) {
|
|
position=1;
|
|
}
|
|
level=permutation[position];
|
|
absMax>>=2;
|
|
}*/
|
|
}
|
|
}
|
|
|
|
#if TARGET_OS_OSX
|
|
void AudioOutputAudioUnit::SetCurrentDevice(std::string deviceID){
|
|
io->SetCurrentDevice(false, deviceID);
|
|
}
|
|
#endif
|