ADD YX audio
Change-Id: I35dd0c51998a9de3ef2d2aebad04a3d773a8494f
diff --git a/mbtk/include/mbtk/mbtk_audio.h b/mbtk/include/mbtk/mbtk_audio.h
index bdc54ee..72baf0f 100755
--- a/mbtk/include/mbtk/mbtk_audio.h
+++ b/mbtk/include/mbtk/mbtk_audio.h
@@ -203,6 +203,55 @@
void mbtk_audio_ubus_volume_get(mbtk_volume_cb cb);
int mbtk_audio_dsp_set(int type, int gain);
+/**
+ * @brief mbtk_audio_switch_pcm
+ *
+ * @details Turn on/off MSA PCM
+ *
+ * @param param
+ * "param0":UINT32 mode
+ * 0: Turn off MSA PCM
+ * 1: Turn on MSA PCM as NB PCM(i.e. 8KHz sample rate)
+ * 2: Turn on MSA PCM as WB PCM(i.e. 16KHz sample rate)
+ * @return return type
+ */
+void mbtk_audio_switch_pcm(int mode);
+
+/**
+ * @brief mbtk_audio_mode_set
+ *
+ * @details audio_mode_set
+ *
+ * @param param
+ * "param0": UINT32
+ * typedef enum {
+ * AUDIO_MODE_INVALID = -2,
+ * AUDIO_MODE_CURRENT = -1,
+ * AUDIO_MODE_NORMAL = 0,
+ * AUDIO_MODE_RINGTONE = 1,
+ * AUDIO_MODE_IN_CALL = 2,
+ * AUDIO_MODE_IN_COMMUNICATION=3,
+ * AUDIO_MODE_IN_VT_CALL= 4,
+ * AUDIO_MODE_CNT,
+ * AUDIO_MODE_MAX = AUDIO_MODE_CNT-1,
+ * } audio_mode_
+ * @return return type
+ */
+void mbtk_audio_mode_set(int mode);
+
+/**
+ * @brief mbtk_audio_path_enable
+ *
+ * @details first set the audio_mode_set ,then need set it
+ *
+ * @param param
+ * "param0": UINT32
+ * 1: enable
+ * 1: disable
+ * @return return type
+ */
+void mbtk_audio_path_enable(int mode);
+
int mbtk_audio_mp3_to_wav(const char *wavpath, char *mp3path);
int mbtk_audio_mp3_to_play(char *mp3path, int hdl, int sample_rate);
#endif /*__MBTK_AUDIO_ALSA_H__*/
diff --git a/mbtk/mbtk_lib/src/mbtk_audio.c b/mbtk/mbtk_lib/src/mbtk_audio.c
index 5d4af20..6e54fc9 100755
--- a/mbtk/mbtk_lib/src/mbtk_audio.c
+++ b/mbtk/mbtk_lib/src/mbtk_audio.c
@@ -37,6 +37,8 @@
#define AUDIO_UBUS_VOLUME_SET "volume_set"
#define AUDIO_UBUS_VOLUME_GET "volume_status"
#define AUDIO_UBUS_MODE_SET "audio_mode_set"
+#define AUDIO_UBUS_PATH_ENABLE "audio_path_enable"
+#define AUDIO_UBUS_SWITCH_PCM "switch_pcm"
#define AUDIO_UBUS_DSP_SET "config_dspgain"
#define AUDIO_UBUS_LOOPBACK_EN "loopback_enable"
#define AUDIO_UBUS_LOOPBACK_DIS "loopback_disable"
@@ -252,7 +254,7 @@
* } audio_mode_
* @return return type
*/
-static void mbtk_audio_mode_set(int mode)
+void mbtk_audio_mode_set(int mode)
{
int rc = 0;
struct ubus_request *req = NULL;
@@ -287,6 +289,93 @@
ubus_complete_request_async(mbtk_audio_ubus_db->ctx, req);
}
}
+
+
+void mbtk_audio_path_enable(int mode)
+{
+ int rc = 0;
+ struct ubus_request *req = NULL;
+
+ if(NULL == mbtk_audio_ubus_db)
+ {
+ printf("mbtk_dtmf_ubus not init!\n");
+ return;
+ }
+ req = (struct ubus_request *)malloc(sizeof(struct ubus_request));
+ if (req == NULL)
+ {
+ printf("leave %s: lack of memory\n", __FUNCTION__);
+ return;
+ }
+ memset(req, 0, sizeof(struct ubus_request));
+ blob_buf_init(&audio_cm_b, 0);
+ blobmsg_add_u32(&audio_cm_b, "param0", mode);
+ if ((rc = ubus_invoke_async(mbtk_audio_ubus_db->ctx,
+ mbtk_audio_ubus_db->audioif_request_id,
+ AUDIO_UBUS_PATH_ENABLE,
+ audio_cm_b.head, req)) != UBUS_STATUS_OK)
+ {
+ free(req);
+ printf("%s, ubus_invoke_async %s failed %s\n", __FUNCTION__, AUDIO_UBUS_PATH_ENABLE, ubus_strerror(rc));
+ }
+ else
+ {
+ printf("%s: ubus_invoke_async success\n", __FUNCTION__);
+ mbtk_audio_ubus_db->work_state++;
+ req->complete_cb = mbtk_ubus_complete_cb;
+ ubus_complete_request_async(mbtk_audio_ubus_db->ctx, req);
+ }
+}
+
+
+/**
+ * @brief mbtk_audio_switch_pcm
+ *
+ * @details detailed description
+ *
+ * @param param
+ * "param0":UINT32 mode
+ * 0: Turn off MSA PCM
+ * 1: Turn on MSA PCM as NB PCM(i.e. 8KHz sample rate)
+ * 2: Turn on MSA PCM as WB PCM(i.e. 16KHz sample rate)
+ * @return return type
+ */
+void mbtk_audio_switch_pcm(int mode)
+{
+ int rc = 0;
+ struct ubus_request *req = NULL;
+
+ if(NULL == mbtk_audio_ubus_db)
+ {
+ printf("mbtk_dtmf_ubus not init!\n");
+ return;
+ }
+ req = (struct ubus_request *)malloc(sizeof(struct ubus_request));
+ if (req == NULL)
+ {
+ printf("leave %s: lack of memory\n", __FUNCTION__);
+ return;
+ }
+ memset(req, 0, sizeof(struct ubus_request));
+ blob_buf_init(&audio_cm_b, 0);
+ blobmsg_add_u32(&audio_cm_b, "param0", mode);
+ if ((rc = ubus_invoke_async(mbtk_audio_ubus_db->ctx,
+ mbtk_audio_ubus_db->audioif_request_id,
+ AUDIO_UBUS_SWITCH_PCM,
+ audio_cm_b.head, req)) != UBUS_STATUS_OK)
+ {
+ free(req);
+ printf("%s, ubus_invoke_async %s failed %s\n", __FUNCTION__, AUDIO_UBUS_MODE_SET, ubus_strerror(rc));
+ }
+ else
+ {
+ printf("%s: ubus_invoke_async success\n", __FUNCTION__);
+ mbtk_audio_ubus_db->work_state++;
+ req->complete_cb = mbtk_ubus_complete_cb;
+ ubus_complete_request_async(mbtk_audio_ubus_db->ctx, req);
+ }
+}
+
int mbtk_audio_dsp_set(int type, int gain)
{
LOGE("1type:%d, gain:%d\n", type, gain);
diff --git a/mbtk/test/yx_audio_test.c b/mbtk/test/yx_audio_test.c
new file mode 100755
index 0000000..e01e9d9
--- /dev/null
+++ b/mbtk/test/yx_audio_test.c
@@ -0,0 +1,365 @@
+#include "mbtk_type.h"
+#include <fcntl.h>
+#include <stdint.h>
+#include <limits.h>
+#include <termios.h>
+#include <stdarg.h>
+// #include "ql_at.h"
+#include "ql/ql_audio.h"
+// #include "mopen_tts.h"
+
+#define MBTK_AUD_DEMO_WAV "/data/demo.wav"
+
+static int record_fd = 0;
+
+int Ql_cb_playback(int hdl, int result)
+{
+ printf("%s: hdl=%d, result=%d\n\r", __func__, hdl, result);
+ if (result == AUD_PLAYER_FINISHED || result == AUD_PLAYER_NODATA)
+ {
+ printf("%s: play finished\n\r", __func__);
+ }
+ return 0;
+}
+
+void record_cb_func(int cb_result, char* databuf, unsigned int len)
+{
+ int rc;
+
+ if(NULL != databuf && len > 0 && record_fd > 0)
+ {
+ //for debug:save into file
+ rc = write(record_fd, databuf, len);
+ if (rc < 0) {
+ printf("%s: error writing to file!\n", __FUNCTION__);
+ } else if (rc < len) {
+ printf("%s: wrote less the buffer size!\n", __FUNCTION__);
+ }
+ }
+}
+
+void dtmf_cb1(char dtmf)
+{
+ printf("%s:%c\n", __FUNCTION__, dtmf);
+}
+
+int MBTK_wav_pcm16Le_check(int fd)
+{
+ struct wav_header hdr;
+
+ if (fd <= 0)
+ return -1;
+
+ if (read(fd, &hdr, sizeof(hdr)) != sizeof(hdr))
+ {
+ printf("\n%s: cannot read header\n", __FUNCTION__);
+ return -1;
+ }
+
+ if ((hdr.riff_id != ID_RIFF)
+ || (hdr.riff_fmt != ID_WAVE)
+ || (hdr.fmt_id != ID_FMT))
+ {
+ printf("\n%s: is not a riff/wave file\n", __FUNCTION__);
+ return -1;
+ }
+
+ if ((hdr.audio_format != FORMAT_PCM) || (hdr.fmt_sz != 16)) {
+ printf("\n%s: is not pcm format\n", __FUNCTION__);
+ return -1;
+ }
+
+ if (hdr.bits_per_sample != 16) {
+ printf("\n%s: is not 16bit per sample\n", __FUNCTION__);
+ return -1;
+ }
+
+ return 0;
+}
+
+int MBTK_wav_pcm16Le_set(int fd)
+{
+ struct wav_header hdr;
+
+ if (fd <= 0)
+ return -1;
+
+ memset(&hdr, 0, sizeof(struct wav_header));
+
+ hdr.riff_id = ID_RIFF;
+ hdr.riff_fmt = ID_WAVE;
+ hdr.fmt_id = ID_FMT;
+ hdr.fmt_sz = 16;
+ hdr.audio_format = FORMAT_PCM;
+ hdr.num_channels = 1;
+ hdr.sample_rate = 8000;
+ hdr.bits_per_sample = 16;
+ hdr.byte_rate = (8000 * 1 * hdr.bits_per_sample) / 8;
+ hdr.block_align = (hdr.bits_per_sample * 1) / 8;
+ hdr.data_id = ID_DATA;
+ hdr.data_sz = 0;
+
+ hdr.riff_sz = hdr.data_sz + 44 - 8;
+ if (write(fd, &hdr, sizeof(hdr)) != sizeof(hdr)) {
+ return -1;
+ }
+
+ return 0;
+}
+void aplay(void)
+{
+ char operator[10];
+ char databuf[1024];
+ int opt = 0;
+ int fd = 0;
+ int size = 0;
+ int state;
+ int play_hdl = 0;
+ int handler = 0;
+
+ while(1)
+ {
+ printf("=========aplay========\n"
+ "\t 0 Open PCM\n"
+ "\t 1 Play Stream\n"
+ "\t 2 Play file\n"
+ "\t 3 Close\n"
+ "\t others exit\n\n"
+ "operator >> ");
+
+ fflush(stdin);
+ fgets(operator, sizeof(operator), stdin);
+ opt = atoi(operator);
+ switch (opt)
+ {
+ case 0:
+ mbtk_audio_ubus_client_init(&handler, dtmf_cb1);
+ mbtk_audio_switch_pcm(1);
+ mbtk_audio_mode_set(2);
+ play_hdl = Ql_AudPlayer_Open(NULL, Ql_cb_playback);
+ if(0 == play_hdl)
+ printf("Ql_AudPlayer_Open fail\n");
+ break;
+ case 1:
+ if(0 == play_hdl)
+ continue;
+
+ fd = open(MBTK_AUD_DEMO_WAV, O_RDWR);
+ if (fd <= 0)
+ continue;
+ mbtk_audio_path_enable(1);
+
+ if(0 == MBTK_wav_pcm16Le_check(fd))
+ {
+ memset(databuf, 0, sizeof(databuf));
+ while(0 < (size = read(fd, databuf, sizeof(databuf))))
+ {
+ if(-1 == Ql_AudPlayer_Play(play_hdl, databuf, size))
+ break;
+ }
+ printf("aplay Stream end \n");
+ }
+ mbtk_audio_path_enable(0);
+
+ close(fd);
+ break;
+ case 2:
+ if(0 == play_hdl)
+ continue;
+ fd = open(MBTK_AUD_DEMO_WAV, O_RDWR);
+ if (fd <= 0)
+ continue;
+
+ mbtk_audio_path_enable(1);
+ if(0 == MBTK_wav_pcm16Le_check(fd))
+ {
+ Ql_AudPlayer_PlayFrmFile(play_hdl, fd, 0);
+ }
+ else
+ {
+ printf("aplay file type error\n");
+ }
+ close(fd);
+ mbtk_audio_path_enable(0);
+ break;
+ case 3:
+ if(0 == play_hdl)
+ continue;
+ Ql_AudPlayer_Close(play_hdl);
+ mbtk_audio_mode_set(0);
+ mbtk_audio_switch_pcm(0);
+ break;
+ case 4:
+ // aplay_thread(MBTK_AUD_DEMO_WAV);
+ Ql_Mp3_To_Play("/data/mp3demo.mp3", play_hdl, 0);
+ break;
+ default:
+ return;
+ }
+
+ sleep(1);
+ }
+
+ printf("aplay exit\n");
+ return ;
+}
+void arec(void)
+{
+ int ret;
+ char operator[10];
+ int opt;
+ int hdl = 0;
+ int handler = 0;
+
+ while(1)
+ {
+ printf("=======arec======\n"
+ "\t 0 Open PCM\n"
+ "\t 1 Start Record\n"
+ "\t 2 Get state\n"
+ "\t 3 Pause\n"
+ "\t 4 Resume\n"
+ "\t 5 Stop\n"
+ "\t 6 Close\n"
+ "\t others exit\n\n"
+ "operator >> ");
+
+ fflush(stdin);
+ fgets(operator, sizeof(operator), stdin);
+ opt = atoi(operator);
+ switch (opt)
+ {
+ case 0:
+ mbtk_audio_ubus_client_init(&handler, dtmf_cb1);
+ mbtk_audio_switch_pcm(1);
+ mbtk_audio_mode_set(2);
+ hdl = Ql_AudRecorder_Open(NULL, record_cb_func);
+ if (hdl == 0)
+ return ;
+ break;
+ case 1:
+ if(0 == hdl)
+ {
+ printf("audio is not initialized yet.\n");
+ continue;
+ }
+
+ if(0 != record_fd)
+ {
+ printf("audio It's already being recorded.\n");
+ continue;
+ }
+
+ record_fd = open(MBTK_AUD_DEMO_WAV, O_RDWR|O_CREAT|O_TRUNC, 0644);
+ if (record_fd <= 0)
+ {
+ printf("file open error\n");
+ continue;
+ }
+
+ mbtk_audio_path_enable(1);
+
+ if(0 == MBTK_wav_pcm16Le_set(record_fd))
+ {
+ ret = Ql_AudRecorder_StartRecord();
+ if(0 != ret)
+ {
+ printf("audio record error: %d\n", ret);
+ close(record_fd);
+ record_fd = 0;
+ }
+ }
+ else
+ {
+ printf("arec set file header error\n");
+ close(record_fd);
+ record_fd = 0;
+ }
+ mbtk_audio_path_enable(0);
+ break;
+ case 2:
+ // printf("arec state : %d\n", state);
+ break;
+ case 3:
+ break;
+ case 4:
+ break;
+ case 5:
+ break;
+ case 6:
+ Ql_AudRecorder_Close();
+// mbtk_audio_mode_set(2);
+ if(record_fd > 0)
+ {
+ close(record_fd);
+ record_fd = 0;
+ }
+ mbtk_audio_mode_set(0);
+ mbtk_audio_switch_pcm(0);
+ break;
+ default:
+ return;
+ }
+
+ sleep(1);
+ }
+
+ printf("arec exit\n");
+ return ;
+}
+int main(void)
+{
+ char operator[10];
+ int opt;
+
+ while(1)
+ {
+ printf("=========audio main=========\n"
+ "\t0 exit\n"
+ "\t1 aplay\n"
+ "\t2 arec\n"
+ "\t3 set speaker Volume\n"
+ "\t4 get speaker Volume\n"
+ "\t5 set mic Volume\n"
+ "\t6 get mic Volume\n"
+ "\t7 tts\n"
+ "\t8 tone\n"
+ "operator: >> ");
+
+ fgets(operator, sizeof(operator), stdin);
+ fflush(stdin);
+ opt = atoi(operator);
+ switch (opt)
+ {
+ case 0:
+ printf("main exit\n");
+ return 0;
+ case 1:
+ aplay();
+ break;
+ case 2:
+ arec();
+ break;
+ case 3:
+ mbtk_at_rec(NULL);
+ break;
+ case 4:
+ mbtk_at_play(NULL);
+ break;
+ case 5:
+ break;
+ case 6:
+ break;
+ case 7:
+ break;
+ case 8:
+ break;
+ default:
+ break;
+ }
+
+ sleep(1);
+ }
+
+ return 0;
+}