2017-04-17 20:57:07 +02:00
|
|
|
//
|
|
|
|
// 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 <stdlib.h>
|
|
|
|
#include <stdio.h>
|
|
|
|
#include <assert.h>
|
|
|
|
#include <dlfcn.h>
|
|
|
|
#include "AudioInputALSA.h"
|
|
|
|
#include "../../logging.h"
|
2017-05-04 23:44:23 +02:00
|
|
|
#include "../../VoIPController.h"
|
2017-04-17 20:57:07 +02:00
|
|
|
|
|
|
|
using namespace tgvoip::audio;
|
|
|
|
|
|
|
|
#define BUFFER_SIZE 960
|
2017-10-31 09:19:00 +01:00
|
|
|
#define CHECK_ERROR(res, msg) if(res<0){LOGE(msg ": %s", _snd_strerror(res)); failed=true; return;}
|
2017-04-17 20:57:07 +02:00
|
|
|
#define CHECK_DL_ERROR(res, msg) if(!res){LOGE(msg ": %s", dlerror()); failed=true; return;}
|
|
|
|
#define LOAD_FUNCTION(lib, name, ref) {ref=(typeof(ref))dlsym(lib, name); CHECK_DL_ERROR(ref, "Error getting entry point for " name);}
|
|
|
|
|
2017-05-04 23:44:23 +02:00
|
|
|
AudioInputALSA::AudioInputALSA(std::string devID){
|
2017-04-17 20:57:07 +02:00
|
|
|
isRecording=false;
|
2017-05-06 01:18:34 +02:00
|
|
|
handle=NULL;
|
2017-04-17 20:57:07 +02:00
|
|
|
|
2017-05-09 20:25:27 +02:00
|
|
|
lib=dlopen("libasound.so.2", RTLD_LAZY);
|
|
|
|
if(!lib)
|
|
|
|
lib=dlopen("libasound.so", RTLD_LAZY);
|
2017-04-17 20:57:07 +02:00
|
|
|
if(!lib){
|
|
|
|
LOGE("Error loading libasound: %s", dlerror());
|
|
|
|
failed=true;
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
LOAD_FUNCTION(lib, "snd_pcm_open", _snd_pcm_open);
|
|
|
|
LOAD_FUNCTION(lib, "snd_pcm_set_params", _snd_pcm_set_params);
|
|
|
|
LOAD_FUNCTION(lib, "snd_pcm_close", _snd_pcm_close);
|
|
|
|
LOAD_FUNCTION(lib, "snd_pcm_readi", _snd_pcm_readi);
|
|
|
|
LOAD_FUNCTION(lib, "snd_pcm_recover", _snd_pcm_recover);
|
|
|
|
LOAD_FUNCTION(lib, "snd_strerror", _snd_strerror);
|
|
|
|
|
2017-05-04 23:44:23 +02:00
|
|
|
SetCurrentDevice(devID);
|
2017-04-17 20:57:07 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
AudioInputALSA::~AudioInputALSA(){
|
2017-05-06 01:18:34 +02:00
|
|
|
if(handle)
|
|
|
|
_snd_pcm_close(handle);
|
|
|
|
if(lib)
|
|
|
|
dlclose(lib);
|
2017-04-17 20:57:07 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
void AudioInputALSA::Configure(uint32_t sampleRate, uint32_t bitsPerSample, uint32_t channels){
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
void AudioInputALSA::Start(){
|
|
|
|
if(failed || isRecording)
|
|
|
|
return;
|
|
|
|
|
|
|
|
isRecording=true;
|
|
|
|
start_thread(thread, AudioInputALSA::StartThread, this);
|
|
|
|
}
|
|
|
|
|
|
|
|
void AudioInputALSA::Stop(){
|
|
|
|
if(!isRecording)
|
|
|
|
return;
|
|
|
|
|
|
|
|
isRecording=false;
|
|
|
|
join_thread(thread);
|
|
|
|
}
|
|
|
|
|
|
|
|
void* AudioInputALSA::StartThread(void* arg){
|
|
|
|
((AudioInputALSA*)arg)->RunThread();
|
|
|
|
}
|
|
|
|
|
|
|
|
void AudioInputALSA::RunThread(){
|
|
|
|
unsigned char buffer[BUFFER_SIZE*2];
|
|
|
|
snd_pcm_sframes_t frames;
|
|
|
|
while(isRecording){
|
|
|
|
frames=_snd_pcm_readi(handle, buffer, BUFFER_SIZE);
|
|
|
|
if (frames < 0){
|
|
|
|
frames = _snd_pcm_recover(handle, frames, 0);
|
|
|
|
}
|
|
|
|
if (frames < 0) {
|
|
|
|
LOGE("snd_pcm_readi failed: %s\n", _snd_strerror(frames));
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
InvokeCallback(buffer, sizeof(buffer));
|
|
|
|
}
|
2017-05-04 23:44:23 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
void AudioInputALSA::SetCurrentDevice(std::string devID){
|
|
|
|
bool wasRecording=isRecording;
|
|
|
|
isRecording=false;
|
|
|
|
if(handle){
|
|
|
|
join_thread(thread);
|
|
|
|
_snd_pcm_close(handle);
|
|
|
|
}
|
|
|
|
currentDevice=devID;
|
|
|
|
|
|
|
|
int res=_snd_pcm_open(&handle, devID.c_str(), SND_PCM_STREAM_CAPTURE, 0);
|
|
|
|
if(res<0)
|
|
|
|
res=_snd_pcm_open(&handle, "default", SND_PCM_STREAM_CAPTURE, 0);
|
|
|
|
CHECK_ERROR(res, "snd_pcm_open failed");
|
|
|
|
|
|
|
|
res=_snd_pcm_set_params(handle, SND_PCM_FORMAT_S16, SND_PCM_ACCESS_RW_INTERLEAVED, 1, 48000, 1, 100000);
|
|
|
|
CHECK_ERROR(res, "snd_pcm_set_params failed");
|
|
|
|
|
|
|
|
if(wasRecording){
|
|
|
|
isRecording=true;
|
|
|
|
start_thread(thread, AudioInputALSA::StartThread, this);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
void AudioInputALSA::EnumerateDevices(std::vector<AudioInputDevice>& devs){
|
|
|
|
int (*_snd_device_name_hint)(int card, const char* iface, void*** hints);
|
|
|
|
char* (*_snd_device_name_get_hint)(const void* hint, const char* id);
|
|
|
|
int (*_snd_device_name_free_hint)(void** hinst);
|
2017-05-09 20:25:27 +02:00
|
|
|
void* lib=dlopen("libasound.so.2", RTLD_LAZY);
|
|
|
|
if(!lib)
|
|
|
|
dlopen("libasound.so", RTLD_LAZY);
|
2017-05-04 23:44:23 +02:00
|
|
|
if(!lib)
|
|
|
|
return;
|
|
|
|
|
|
|
|
_snd_device_name_hint=(typeof(_snd_device_name_hint))dlsym(lib, "snd_device_name_hint");
|
|
|
|
_snd_device_name_get_hint=(typeof(_snd_device_name_get_hint))dlsym(lib, "snd_device_name_get_hint");
|
|
|
|
_snd_device_name_free_hint=(typeof(_snd_device_name_free_hint))dlsym(lib, "snd_device_name_free_hint");
|
|
|
|
|
|
|
|
if(!_snd_device_name_hint || !_snd_device_name_get_hint || !_snd_device_name_free_hint){
|
|
|
|
dlclose(lib);
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
char** hints;
|
|
|
|
int err=_snd_device_name_hint(-1, "pcm", (void***)&hints);
|
|
|
|
if(err!=0){
|
|
|
|
dlclose(lib);
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
char** n=hints;
|
|
|
|
while(*n){
|
|
|
|
char* name=_snd_device_name_get_hint(*n, "NAME");
|
|
|
|
if(strncmp(name, "surround", 8)==0 || strcmp(name, "null")==0){
|
|
|
|
free(name);
|
|
|
|
n++;
|
|
|
|
continue;
|
|
|
|
}
|
|
|
|
char* desc=_snd_device_name_get_hint(*n, "DESC");
|
|
|
|
char* ioid=_snd_device_name_get_hint(*n, "IOID");
|
|
|
|
if(!ioid || strcmp(ioid, "Input")==0){
|
|
|
|
char* l1=strtok(desc, "\n");
|
|
|
|
char* l2=strtok(NULL, "\n");
|
|
|
|
char* tmp=strtok(l1, ",");
|
|
|
|
char* actualName=tmp;
|
|
|
|
while((tmp=strtok(NULL, ","))){
|
|
|
|
actualName=tmp;
|
|
|
|
}
|
|
|
|
if(actualName[0]==' ')
|
|
|
|
actualName++;
|
|
|
|
AudioInputDevice dev;
|
|
|
|
dev.id=std::string(name);
|
|
|
|
if(l2){
|
|
|
|
char buf[256];
|
|
|
|
snprintf(buf, sizeof(buf), "%s (%s)", actualName, l2);
|
|
|
|
dev.displayName=std::string(buf);
|
|
|
|
}else{
|
|
|
|
dev.displayName=std::string(actualName);
|
|
|
|
}
|
|
|
|
devs.push_back(dev);
|
|
|
|
}
|
|
|
|
free(name);
|
|
|
|
free(desc);
|
|
|
|
free(ioid);
|
|
|
|
n++;
|
|
|
|
}
|
|
|
|
|
|
|
|
dlclose(lib);
|
2017-04-17 20:57:07 +02:00
|
|
|
}
|