54d42ba9df
Use EOS V2 to avoid time out for EOS when afe port is closed before EOS Change-Id: I3be0aa33384d2015354b8f9a307f3e0cb200c040 Signed-off-by: Satish Babu Patakokila <sbpata@codeaurora.org>
233 lines
7.2 KiB
C
233 lines
7.2 KiB
C
// SPDX-License-Identifier: GPL-2.0-only
|
|
/* Copyright (c) 2012-2020, The Linux Foundation. All rights reserved.
|
|
*/
|
|
|
|
#include <linux/module.h>
|
|
#include <linux/fs.h>
|
|
#include <linux/miscdevice.h>
|
|
#include <linux/uaccess.h>
|
|
#include <linux/sched.h>
|
|
#include <linux/wait.h>
|
|
#include <linux/dma-mapping.h>
|
|
#include <linux/slab.h>
|
|
#include <linux/atomic.h>
|
|
#include <asm/ioctls.h>
|
|
#include "audio_utils_aio.h"
|
|
|
|
void q6_audio_cb(uint32_t opcode, uint32_t token,
|
|
uint32_t *payload, void *priv)
|
|
{
|
|
struct q6audio_aio *audio = (struct q6audio_aio *)priv;
|
|
|
|
pr_debug("%s:opcode = %x token = 0x%x\n", __func__, opcode, token);
|
|
switch (opcode) {
|
|
case ASM_DATA_EVENT_WRITE_DONE_V2:
|
|
case ASM_DATA_EVENT_READ_DONE_V2:
|
|
case ASM_DATA_EVENT_RENDERED_EOS:
|
|
case ASM_DATA_EVENT_RENDERED_EOS_V2:
|
|
case ASM_DATA_CMD_MEDIA_FMT_UPDATE_V2:
|
|
case ASM_STREAM_CMD_SET_ENCDEC_PARAM:
|
|
case ASM_DATA_EVENT_SR_CM_CHANGE_NOTIFY:
|
|
case ASM_DATA_EVENT_ENC_SR_CM_CHANGE_NOTIFY:
|
|
case RESET_EVENTS:
|
|
audio_aio_cb(opcode, token, payload, audio);
|
|
break;
|
|
default:
|
|
pr_debug("%s:Unhandled event = 0x%8x\n", __func__, opcode);
|
|
break;
|
|
}
|
|
}
|
|
|
|
void audio_aio_cb(uint32_t opcode, uint32_t token,
|
|
uint32_t *payload, void *priv/*struct q6audio_aio *audio*/)
|
|
{
|
|
struct q6audio_aio *audio = (struct q6audio_aio *)priv;
|
|
union msm_audio_event_payload e_payload;
|
|
|
|
spin_lock(&enc_dec_lock);
|
|
if (audio == NULL) {
|
|
pr_err("%s: failed to get q6audio value\n", __func__);
|
|
goto error;
|
|
}
|
|
switch (opcode) {
|
|
case ASM_DATA_EVENT_WRITE_DONE_V2:
|
|
pr_debug("%s[%pK]:ASM_DATA_EVENT_WRITE_DONE token = 0x%x\n",
|
|
__func__, audio, token);
|
|
audio_aio_async_write_ack(audio, token, payload);
|
|
break;
|
|
case ASM_DATA_EVENT_READ_DONE_V2:
|
|
pr_debug("%s[%pK]:ASM_DATA_EVENT_READ_DONE token = 0x%x\n",
|
|
__func__, audio, token);
|
|
audio_aio_async_read_ack(audio, token, payload);
|
|
break;
|
|
case ASM_DATA_EVENT_RENDERED_EOS:
|
|
case ASM_DATA_EVENT_RENDERED_EOS_V2:
|
|
/* EOS Handle */
|
|
pr_debug("%s[%pK]:ASM_DATA_CMDRSP_EOS\n", __func__, audio);
|
|
if (audio->feedback) { /* Non-Tunnel mode */
|
|
audio->eos_rsp = 1;
|
|
/* propagate input EOS i/p buffer,
|
|
* after receiving DSP acknowledgment
|
|
*/
|
|
if (audio->eos_flag &&
|
|
(audio->eos_write_payload.aio_buf.buf_addr)) {
|
|
audio_aio_post_event(audio,
|
|
AUDIO_EVENT_WRITE_DONE,
|
|
audio->eos_write_payload);
|
|
memset(&audio->eos_write_payload, 0,
|
|
sizeof(union msm_audio_event_payload));
|
|
audio->eos_flag = 0;
|
|
}
|
|
} else { /* Tunnel mode */
|
|
audio->eos_rsp = 1;
|
|
wake_up(&audio->write_wait);
|
|
wake_up(&audio->cmd_wait);
|
|
}
|
|
break;
|
|
case ASM_DATA_CMD_MEDIA_FMT_UPDATE_V2:
|
|
case ASM_STREAM_CMD_SET_ENCDEC_PARAM:
|
|
pr_debug("%s[%pK]:payload0[%x] payloa1d[%x]opcode= 0x%x\n",
|
|
__func__, audio, payload[0], payload[1], opcode);
|
|
break;
|
|
case ASM_DATA_EVENT_SR_CM_CHANGE_NOTIFY:
|
|
case ASM_DATA_EVENT_ENC_SR_CM_CHANGE_NOTIFY:
|
|
pr_debug("%s[%pK]: ASM_DATA_EVENT_SR_CM_CHANGE_NOTIFY, payload[0]-sr = %d, payload[1]-chl = %d, payload[2] = %d, payload[3] = %d\n",
|
|
__func__, audio, payload[0],
|
|
payload[1], payload[2], payload[3]);
|
|
|
|
pr_debug("%s[%pK]: ASM_DATA_EVENT_SR_CM_CHANGE_NOTIFY, sr(prev) = %d, chl(prev) = %d,",
|
|
__func__, audio, audio->pcm_cfg.sample_rate,
|
|
audio->pcm_cfg.channel_count);
|
|
|
|
audio->pcm_cfg.sample_rate = payload[0];
|
|
audio->pcm_cfg.channel_count = payload[1] & 0xFFFF;
|
|
e_payload.stream_info.chan_info = audio->pcm_cfg.channel_count;
|
|
e_payload.stream_info.sample_rate = audio->pcm_cfg.sample_rate;
|
|
audio_aio_post_event(audio, AUDIO_EVENT_STREAM_INFO, e_payload);
|
|
break;
|
|
case RESET_EVENTS:
|
|
pr_err("%s: Received opcode:0x%x\n", __func__, opcode);
|
|
audio->stopped = 1;
|
|
audio->reset_event = true;
|
|
wake_up(&audio->event_wait);
|
|
break;
|
|
default:
|
|
break;
|
|
}
|
|
error:
|
|
spin_unlock(&enc_dec_lock);
|
|
}
|
|
|
|
int extract_meta_out_info(struct q6audio_aio *audio,
|
|
struct audio_aio_buffer_node *buf_node, int dir)
|
|
{
|
|
struct dec_meta_out *meta_data = buf_node->kvaddr;
|
|
uint32_t temp;
|
|
|
|
if (dir) { /* input buffer - Write */
|
|
if (audio->buf_cfg.meta_info_enable) {
|
|
if (buf_node->buf.buf_len <
|
|
sizeof(struct dec_meta_in)) {
|
|
pr_debug("%s: invalid buf len %d\n",
|
|
__func__, buf_node->buf.buf_len);
|
|
return -EINVAL;
|
|
}
|
|
memcpy(&buf_node->meta_info.meta_in,
|
|
(char *)buf_node->kvaddr, sizeof(struct dec_meta_in));
|
|
} else {
|
|
memset(&buf_node->meta_info.meta_in,
|
|
0, sizeof(struct dec_meta_in));
|
|
}
|
|
pr_debug("%s[%pK]:i/p: msw_ts %d lsw_ts %d nflags 0x%8x\n",
|
|
__func__, audio,
|
|
buf_node->meta_info.meta_in.ntimestamp.highpart,
|
|
buf_node->meta_info.meta_in.ntimestamp.lowpart,
|
|
buf_node->meta_info.meta_in.nflags);
|
|
} else { /* output buffer - Read */
|
|
memcpy((char *)buf_node->kvaddr,
|
|
&buf_node->meta_info.meta_out,
|
|
sizeof(struct dec_meta_out));
|
|
meta_data->meta_out_dsp[0].nflags = 0x00000000;
|
|
temp = meta_data->meta_out_dsp[0].msw_ts;
|
|
meta_data->meta_out_dsp[0].msw_ts =
|
|
meta_data->meta_out_dsp[0].lsw_ts;
|
|
meta_data->meta_out_dsp[0].lsw_ts = temp;
|
|
|
|
pr_debug("%s[%pK]:o/p: msw_ts %d lsw_ts %d nflags 0x%8x, num_frames = %d\n",
|
|
__func__, audio,
|
|
((struct dec_meta_out *)buf_node->kvaddr)->
|
|
meta_out_dsp[0].msw_ts,
|
|
((struct dec_meta_out *)buf_node->kvaddr)->
|
|
meta_out_dsp[0].lsw_ts,
|
|
((struct dec_meta_out *)buf_node->kvaddr)->
|
|
meta_out_dsp[0].nflags,
|
|
((struct dec_meta_out *)buf_node->kvaddr)->num_of_frames);
|
|
}
|
|
return 0;
|
|
}
|
|
|
|
/* Read buffer from DSP / Handle Ack from DSP */
|
|
void audio_aio_async_read_ack(struct q6audio_aio *audio, uint32_t token,
|
|
uint32_t *payload)
|
|
{
|
|
unsigned long flags;
|
|
union msm_audio_event_payload event_payload;
|
|
struct audio_aio_buffer_node *filled_buf;
|
|
int ret;
|
|
|
|
pr_debug("%s\n", __func__);
|
|
|
|
/* No active flush in progress */
|
|
if (audio->rflush)
|
|
return;
|
|
|
|
/* Statistics of read */
|
|
atomic_add(payload[4], &audio->in_bytes);
|
|
atomic_add(payload[9], &audio->in_samples);
|
|
|
|
spin_lock_irqsave(&audio->dsp_lock, flags);
|
|
if (list_empty(&audio->in_queue)) {
|
|
spin_unlock_irqrestore(&audio->dsp_lock, flags);
|
|
pr_warn("%s unexpected ack from dsp\n", __func__);
|
|
return;
|
|
}
|
|
filled_buf = list_first_entry(&audio->in_queue,
|
|
struct audio_aio_buffer_node, list);
|
|
|
|
pr_debug("%s token: 0x[%x], filled_buf->token: 0x[%x]",
|
|
__func__, token, filled_buf->token);
|
|
if (token == (filled_buf->token)) {
|
|
list_del(&filled_buf->list);
|
|
spin_unlock_irqrestore(&audio->dsp_lock, flags);
|
|
event_payload.aio_buf = filled_buf->buf;
|
|
/* Read done Buffer due to flush/normal condition
|
|
* after EOS event, so append EOS buffer
|
|
*/
|
|
if (audio->eos_rsp == 0x1) {
|
|
event_payload.aio_buf.data_len =
|
|
insert_eos_buf(audio, filled_buf);
|
|
/* Reset flag back to indicate eos intimated */
|
|
audio->eos_rsp = 0;
|
|
} else {
|
|
filled_buf->meta_info.meta_out.num_of_frames
|
|
= payload[9];
|
|
event_payload.aio_buf.data_len = payload[4]
|
|
+ payload[5] + sizeof(struct dec_meta_out);
|
|
pr_debug("%s[%pK]:nr of frames 0x%8x len=%d\n",
|
|
__func__, audio,
|
|
filled_buf->meta_info.meta_out.num_of_frames,
|
|
event_payload.aio_buf.data_len);
|
|
ret = extract_meta_out_info(audio, filled_buf, 0);
|
|
audio->eos_rsp = 0;
|
|
}
|
|
pr_debug("%s, posting read done to the app here\n", __func__);
|
|
audio_aio_post_event(audio, AUDIO_EVENT_READ_DONE,
|
|
event_payload);
|
|
kfree(filled_buf);
|
|
} else {
|
|
pr_err("%s[%pK]:expected=%x ret=%x\n",
|
|
__func__, audio, filled_buf->token, token);
|
|
spin_unlock_irqrestore(&audio->dsp_lock, flags);
|
|
}
|
|
}
|