299 lines
7.0 KiB
C
299 lines
7.0 KiB
C
#include <stdio.h>
|
||
#include <unistd.h>
|
||
#include <string.h>
|
||
#include <components/system.h>
|
||
#include <os/os.h>
|
||
#include <os/mem.h>
|
||
|
||
#include <driver/audio_ring_buff.h>
|
||
#include "audio_transfer.h"
|
||
#include "agora_rtc.h"
|
||
#include "agora_config.h"
|
||
#include "modules/g711.h"
|
||
|
||
#define TAG "agora_audio_tras"
|
||
#define LOGI(...) BK_LOGI(TAG, ##__VA_ARGS__)
|
||
#define LOGE(...) BK_LOGE(TAG, ##__VA_ARGS__)
|
||
#define LOGW(...) BK_LOGW(TAG, ##__VA_ARGS__)
|
||
#define LOGD(...) BK_LOGD(TAG, ##__VA_ARGS__)
|
||
|
||
typedef enum {
|
||
AUD_TRAS_TX_DATA = 0,
|
||
|
||
AUD_TRAS_EXIT,
|
||
} aud_tras_op_t;
|
||
|
||
typedef struct {
|
||
aud_tras_op_t op;
|
||
} aud_tras_msg_t;
|
||
|
||
static beken_thread_t agora_aud_thread_hdl = NULL;
|
||
static beken_queue_t agora_aud_msg_que = NULL;
|
||
static RingBufferContext mic_data_rb;
|
||
static uint8_t *mic_data_buffer = NULL;
|
||
#if defined(CONFIG_USE_G722_CODEC)
|
||
#define MIC_FRAME_SIZE 640
|
||
#elif defined(CONFIG_USE_G711U_CODEC) || defined(CONFIG_USE_G711A_CODEC)
|
||
#define MIC_FRAME_SIZE 320
|
||
#else
|
||
#define MIC_FRAME_SIZE 160
|
||
#endif
|
||
#define MIC_FRAME_NUM 10
|
||
|
||
|
||
static int send_agora_audio_frame(uint8_t *data, unsigned int len)
|
||
{
|
||
//LOGE("len->%d %2X %2X %2X \r\n",len, data[10],data[50],data[150]);
|
||
audio_frame_info_t info = { 0 };
|
||
#if defined(CONFIG_SEND_PCM_DATA)
|
||
info.data_type = AUDIO_DATA_TYPE_PCM;
|
||
#else
|
||
info.data_type = AUDIO_DATA_TYPE_PCMA;
|
||
#endif
|
||
//LOGE("S %2X %2X %2X %2X %2X %2X %2X %2X \r\n",data[20],data[40],data[60],data[70],data[80],data[100],data[120],data[150]);
|
||
int rval = bk_agora_rtc_audio_data_send(data, len, &info);
|
||
if (rval < 0) {
|
||
LOGE("Failed to send audio data, reason: %s\n", agora_rtc_err_2_str(rval));
|
||
return 0;
|
||
}
|
||
return len;
|
||
}
|
||
|
||
static bk_err_t agora_aud_send_msg(void)
|
||
{
|
||
bk_err_t ret;
|
||
aud_tras_msg_t msg;
|
||
|
||
msg.op = AUD_TRAS_TX_DATA;
|
||
|
||
if (agora_aud_msg_que) {
|
||
ret = rtos_push_to_queue(&agora_aud_msg_que, &msg, BEKEN_NO_WAIT);
|
||
if (kNoErr != ret) {
|
||
LOGE("audio send msg: AUD_TRAS_TX_DATA fail \r\n");
|
||
return kOverrunErr;
|
||
}
|
||
|
||
return ret;
|
||
}
|
||
return kNoResourcesErr;
|
||
}
|
||
|
||
int volume_adjust2(int16_t * in_buf, float in_vol)
|
||
{
|
||
int tmp;
|
||
|
||
// in_vol[0, 100]
|
||
float vol = in_vol - 98;
|
||
|
||
if(-98<vol && vol<0)
|
||
vol = 1/(vol*(-1));
|
||
else if(0<=vol && vol<=1)
|
||
vol = 1;
|
||
/*
|
||
else if(1<=vol && vol<=2)
|
||
vol = vol;
|
||
*/
|
||
else if(vol<=-98)
|
||
vol = 0;
|
||
else if(vol>=2)
|
||
vol = 8; //这个值可以根据你的实际情况去调整
|
||
|
||
tmp = (*in_buf)*vol; // 上面所有关于vol的判断，其实都是为了此处*in_buf乘以一个倍数，你可以根据自己的需要去修改
|
||
|
||
// 下面的code主要是为了溢出判断
|
||
if(tmp > 32767)
|
||
tmp = 32767;
|
||
else if(tmp < -32768)
|
||
tmp = -32768;
|
||
*in_buf = tmp;
|
||
return 0;
|
||
}
|
||
|
||
int16_t pcm[320];
|
||
unsigned char pcma[320];
|
||
int volume = 100;
|
||
int send_audio_data_to_agora(uint8_t *data, unsigned int len)
|
||
{
|
||
|
||
//LOGE("audio send msg: data -->%d \r\n",len);
|
||
//send_agora_audio_frame(data,160);
|
||
//send_agora_audio_frame(data+160,160);
|
||
|
||
//
|
||
int16_t decoder_temp = 0;
|
||
for(int i=0 ; i<len ;i++){
|
||
decoder_temp = alaw2linear(data[i]);
|
||
//增大音量
|
||
volume_adjust2(&decoder_temp,volume);
|
||
pcm[i] = decoder_temp;
|
||
}
|
||
//LOGE("pcm data -->%02X %02X %02X %02X %02X %02X \r\n",pcm[0],pcm[10],pcm[20],pcm[30],pcm[40],pcm[50]);
|
||
for(int j = 0 ; j < 320 ; j++){
|
||
int8_t encoder_temp = 0;
|
||
encoder_temp = linear2alaw(pcm[j]);
|
||
pcma[j]=encoder_temp;
|
||
}
|
||
//LOGE("pcma data -->%02X %02X %02X %02X %02X %02X \r\n",pcma[0],pcma[10],pcma[20],pcma[30],pcma[40],pcma[50]);
|
||
send_agora_audio_frame(pcma,160);
|
||
send_agora_audio_frame(pcma+160,160);
|
||
|
||
|
||
|
||
#if 0
|
||
if (ring_buffer_get_free_size(&mic_data_rb) >= len) {
|
||
//GLOBAL_INT_DECLARATION();
|
||
ring_buffer_write(&mic_data_rb, data, len);
|
||
//GLOBAL_INT_RESTORE();
|
||
} else {
|
||
LOGE("audio send full!!!\r\n");
|
||
return 0;
|
||
}
|
||
|
||
if (ring_buffer_get_fill_size(&mic_data_rb) >= MIC_FRAME_SIZE) {
|
||
// addAON_GPIO_Reg0x3 = 2;
|
||
agora_aud_send_msg();
|
||
// addAON_GPIO_Reg0x3 = 0;
|
||
}
|
||
#endif
|
||
return len;
|
||
}
|
||
|
||
static void agora_aud_tras_main(void)
|
||
{
|
||
bk_err_t ret = BK_OK;
|
||
GLOBAL_INT_DECLARATION();
|
||
uint32_t size = 0;
|
||
uint32_t count = 0;
|
||
|
||
uint8_t *mic_temp_buff = NULL;
|
||
|
||
while(1) {
|
||
aud_tras_msg_t msg;
|
||
|
||
ret = rtos_pop_from_queue(&agora_aud_msg_que, &msg, BEKEN_WAIT_FOREVER);
|
||
if (kNoErr == ret) {
|
||
switch (msg.op) {
|
||
case AUD_TRAS_TX_DATA:
|
||
size = ring_buffer_get_fill_size(&mic_data_rb);
|
||
if (size >= MIC_FRAME_SIZE) {
|
||
mic_temp_buff = psram_malloc(MIC_FRAME_SIZE);
|
||
if (mic_temp_buff != NULL) {
|
||
GLOBAL_INT_DISABLE();
|
||
count = ring_buffer_read(&mic_data_rb, mic_temp_buff, MIC_FRAME_SIZE);
|
||
GLOBAL_INT_RESTORE();
|
||
if (count == MIC_FRAME_SIZE) {
|
||
send_agora_audio_frame(mic_temp_buff, count);
|
||
} else {
|
||
LOGD("ring_buffer_read count(%d) != MIC_FRAME_SIZE(160) \r\n", count);
|
||
}
|
||
psram_free(mic_temp_buff);
|
||
}
|
||
|
||
rtos_delay_milliseconds(10);
|
||
agora_aud_send_msg();
|
||
}
|
||
break;
|
||
|
||
case AUD_TRAS_EXIT:
|
||
LOGD("goto: AUD_TRAS_EXIT \r\n");
|
||
goto aud_tras_exit;
|
||
break;
|
||
|
||
default:
|
||
break;
|
||
}
|
||
}
|
||
}
|
||
|
||
aud_tras_exit:
|
||
|
||
ring_buffer_clear(&mic_data_rb);
|
||
|
||
if (mic_data_buffer) {
|
||
psram_free(mic_data_buffer);
|
||
mic_data_buffer = NULL;
|
||
}
|
||
|
||
/* delete msg queue */
|
||
ret = rtos_deinit_queue(&agora_aud_msg_que);
|
||
if (ret != kNoErr) {
|
||
LOGE("delete message queue fail \r\n");
|
||
}
|
||
agora_aud_msg_que = NULL;
|
||
LOGI("delete message queue complete \r\n");
|
||
|
||
/* delete task */
|
||
agora_aud_thread_hdl = NULL;
|
||
rtos_delete_thread(NULL);
|
||
|
||
}
|
||
|
||
bk_err_t audio_tras_init(void)
|
||
{
|
||
bk_err_t ret = BK_OK;
|
||
|
||
mic_data_buffer = psram_malloc(MIC_FRAME_SIZE * MIC_FRAME_NUM);
|
||
if (mic_data_buffer == NULL) {
|
||
LOGE("malloc mic_data_buffer fail \n");
|
||
return BK_FAIL;
|
||
}
|
||
ring_buffer_init(&mic_data_rb, mic_data_buffer, MIC_FRAME_SIZE*MIC_FRAME_NUM, DMA_ID_MAX, RB_DMA_TYPE_NULL);
|
||
|
||
ret = rtos_init_queue(&agora_aud_msg_que,
|
||
"aud_int_que",
|
||
sizeof(aud_tras_msg_t),
|
||
60);
|
||
if (ret != kNoErr) {
|
||
LOGE("ceate agoar audio tras message queue fail \r\n");
|
||
goto audio_tras_init_fail;
|
||
}
|
||
LOGI("ceate audio asr message queue complete \r\n");
|
||
|
||
/* create task to asr */
|
||
ret = rtos_create_thread(&agora_aud_thread_hdl,
|
||
4,
|
||
"agora_audio_tras",
|
||
(beken_thread_function_t)agora_aud_tras_main,
|
||
2048,
|
||
NULL);
|
||
if (ret != kNoErr) {
|
||
LOGE("create audio transfer driver task fail \r\n");
|
||
rtos_deinit_queue(&agora_aud_msg_que);
|
||
agora_aud_msg_que= NULL;
|
||
agora_aud_thread_hdl = NULL;
|
||
goto audio_tras_init_fail;
|
||
}
|
||
LOGI("create audio transfer driver task complete \r\n");
|
||
|
||
return BK_OK;
|
||
|
||
audio_tras_init_fail:
|
||
if (mic_data_buffer) {
|
||
ring_buffer_clear(&mic_data_rb);
|
||
psram_free(mic_data_buffer);
|
||
mic_data_buffer = NULL;
|
||
}
|
||
|
||
return BK_FAIL;
|
||
}
|
||
|
||
bk_err_t audio_tras_deinit(void)
|
||
{
|
||
bk_err_t ret;
|
||
aud_tras_msg_t msg;
|
||
|
||
msg.op = AUD_TRAS_EXIT;
|
||
if (agora_aud_msg_que) {
|
||
ret = rtos_push_to_queue_front(&agora_aud_msg_que, &msg, BEKEN_NO_WAIT);
|
||
if (kNoErr != ret) {
|
||
LOGE("audio send msg: AUD_TRAS_EXIT fail \r\n");
|
||
return kOverrunErr;
|
||
}
|
||
|
||
return ret;
|
||
}
|
||
return kNoResourcesErr;
|
||
}
|
||
|
||
|