// SPDX-License-Identifier: GPL-2.0-only /* Copyright (c) 2012-2019, The Linux Foundation. All rights reserved. */ #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include "msm-pcm-afe-v2.h" #define DRV_NAME "msm-pcm-afe-v2" #define TIMEOUT_MS 1000 #define MIN_PLAYBACK_PERIOD_SIZE (128 * 2) #define MAX_PLAYBACK_PERIOD_SIZE (128 * 2 * 2 * 6) #define MIN_PLAYBACK_NUM_PERIODS (4) #define MAX_PLAYBACK_NUM_PERIODS (384) #define MIN_CAPTURE_PERIOD_SIZE (128 * 2) #define MAX_CAPTURE_PERIOD_SIZE (192 * 2 * 2 * 8 * 4) #define MIN_CAPTURE_NUM_PERIODS (4) #define MAX_CAPTURE_NUM_PERIODS (384) static struct snd_pcm_hardware msm_afe_hardware_playback = { .info = (SNDRV_PCM_INFO_MMAP | SNDRV_PCM_INFO_BLOCK_TRANSFER | SNDRV_PCM_INFO_MMAP_VALID | SNDRV_PCM_INFO_INTERLEAVED), .formats = SNDRV_PCM_FMTBIT_S16_LE| SNDRV_PCM_FMTBIT_S24_LE, .rates = (SNDRV_PCM_RATE_8000 | SNDRV_PCM_RATE_16000 | SNDRV_PCM_RATE_48000), .rate_min = 8000, .rate_max = 48000, .channels_min = 1, .channels_max = 6, .buffer_bytes_max = MAX_PLAYBACK_PERIOD_SIZE * MAX_PLAYBACK_NUM_PERIODS, .period_bytes_min = MIN_PLAYBACK_PERIOD_SIZE, .period_bytes_max = MAX_PLAYBACK_PERIOD_SIZE, .periods_min = MIN_PLAYBACK_NUM_PERIODS, .periods_max = MAX_PLAYBACK_NUM_PERIODS, .fifo_size = 0, }; static struct snd_pcm_hardware msm_afe_hardware_capture = { .info = (SNDRV_PCM_INFO_MMAP | SNDRV_PCM_INFO_BLOCK_TRANSFER | SNDRV_PCM_INFO_MMAP_VALID | SNDRV_PCM_INFO_INTERLEAVED), .formats = SNDRV_PCM_FMTBIT_S16_LE| SNDRV_PCM_FMTBIT_S24_LE, .rates = (SNDRV_PCM_RATE_8000 | SNDRV_PCM_RATE_16000 | SNDRV_PCM_RATE_48000), .rate_min = 8000, .rate_max = 48000, .channels_min = 1, .channels_max = 6, .buffer_bytes_max = MAX_CAPTURE_PERIOD_SIZE * MAX_CAPTURE_NUM_PERIODS, .period_bytes_min = MIN_CAPTURE_PERIOD_SIZE, .period_bytes_max = MAX_CAPTURE_PERIOD_SIZE, .periods_min = MIN_CAPTURE_NUM_PERIODS, .periods_max = MAX_CAPTURE_NUM_PERIODS, .fifo_size = 0, }; static enum hrtimer_restart afe_hrtimer_callback(struct hrtimer *hrt); static enum hrtimer_restart afe_hrtimer_rec_callback(struct hrtimer *hrt); static enum hrtimer_restart afe_hrtimer_callback(struct hrtimer *hrt) { struct pcm_afe_info *prtd = container_of(hrt, struct pcm_afe_info, hrt); struct snd_pcm_substream *substream = prtd->substream; struct snd_pcm_runtime *runtime = substream->runtime; u32 mem_map_handle = 0; mem_map_handle = afe_req_mmap_handle(prtd->audio_client); if (!mem_map_handle) pr_err("%s: mem_map_handle is NULL\n", __func__); if (prtd->start) { pr_debug("sending frame to DSP: poll_time: %d\n", prtd->poll_time); if (prtd->dsp_cnt == runtime->periods) prtd->dsp_cnt = 0; pr_debug("%s: mem_map_handle 0x%x\n", __func__, mem_map_handle); afe_rt_proxy_port_write( (prtd->dma_addr + (prtd->dsp_cnt * snd_pcm_lib_period_bytes(prtd->substream))), mem_map_handle, snd_pcm_lib_period_bytes(prtd->substream)); prtd->dsp_cnt++; hrtimer_forward_now(hrt, ns_to_ktime(prtd->poll_time * 1000)); return HRTIMER_RESTART; } else return HRTIMER_NORESTART; } static enum hrtimer_restart afe_hrtimer_rec_callback(struct hrtimer *hrt) { struct pcm_afe_info *prtd = container_of(hrt, struct pcm_afe_info, hrt); struct snd_pcm_substream *substream = prtd->substream; struct snd_pcm_runtime *runtime = substream->runtime; u32 mem_map_handle = 0; int ret; mem_map_handle = afe_req_mmap_handle(prtd->audio_client); if (!mem_map_handle) pr_err("%s: mem_map_handle is NULL\n", __func__); if (prtd->start) { if (prtd->dsp_cnt == runtime->periods) prtd->dsp_cnt = 0; pr_debug("%s: mem_map_handle 0x%x\n", __func__, mem_map_handle); ret = afe_rt_proxy_port_read( (prtd->dma_addr + (prtd->dsp_cnt * snd_pcm_lib_period_bytes(prtd->substream))), mem_map_handle, snd_pcm_lib_period_bytes(prtd->substream)); if (ret < 0) { pr_err("%s: AFE port read fails: %d\n", __func__, ret); prtd->start = 0; return HRTIMER_NORESTART; } prtd->dsp_cnt++; pr_debug("sending frame rec to DSP: poll_time: %d\n", prtd->poll_time); hrtimer_forward_now(hrt, ns_to_ktime(prtd->poll_time * 1000)); return HRTIMER_RESTART; } else return HRTIMER_NORESTART; } static void pcm_afe_process_tx_pkt(uint32_t opcode, uint32_t token, uint32_t *payload, void *priv) { struct pcm_afe_info *prtd = priv; unsigned long dsp_flags; struct snd_pcm_substream *substream = NULL; struct snd_pcm_runtime *runtime = NULL; uint16_t event; uint64_t period_bytes; uint64_t bytes_one_sec; if (prtd == NULL) return; substream = prtd->substream; runtime = substream->runtime; pr_debug("%s\n", __func__); spin_lock_irqsave(&prtd->dsp_lock, dsp_flags); switch (opcode) { case AFE_EVENT_RT_PROXY_PORT_STATUS: { event = (uint16_t)((0xFFFF0000 & payload[0]) >> 0x10); switch (event) { case AFE_EVENT_RTPORT_START: { prtd->dsp_cnt = 0; /* Calculate poll time. * Split steps to avoid overflow. * Poll time-time corresponding to one period * in bytes. * (Samplerate * channelcount * format) = * bytes in 1 sec. * Poll time = * (period bytes / bytes in one sec) * * 1000000 micro seconds. * Multiplication by 1000000 is done in two * steps to keep the accuracy of poll time. */ if (prtd->mmap_flag) { period_bytes = ((uint64_t)( (snd_pcm_lib_period_bytes( prtd->substream)) * 1000)); bytes_one_sec = (runtime->rate * runtime->channels * 2); bytes_one_sec = div_u64(bytes_one_sec, 1000); prtd->poll_time = div_u64(period_bytes, bytes_one_sec); pr_debug("prtd->poll_time: %d", prtd->poll_time); } break; } case AFE_EVENT_RTPORT_STOP: pr_debug("%s: event!=0\n", __func__); prtd->start = 0; snd_pcm_stop(substream, SNDRV_PCM_STATE_SETUP); break; case AFE_EVENT_RTPORT_LOW_WM: pr_debug("%s: Underrun\n", __func__); break; case AFE_EVENT_RTPORT_HI_WM: pr_debug("%s: Overrun\n", __func__); break; default: break; } break; } case APR_BASIC_RSP_RESULT: { switch (payload[0]) { case AFE_PORT_DATA_CMD_RT_PROXY_PORT_WRITE_V2: pr_debug("write done\n"); prtd->pcm_irq_pos += snd_pcm_lib_period_bytes (prtd->substream); snd_pcm_period_elapsed(prtd->substream); break; default: break; } break; } case RESET_EVENTS: prtd->pcm_irq_pos += snd_pcm_lib_period_bytes (prtd->substream); prtd->reset_event = true; snd_pcm_period_elapsed(prtd->substream); break; default: break; } spin_unlock_irqrestore(&prtd->dsp_lock, dsp_flags); } static void pcm_afe_process_rx_pkt(uint32_t opcode, uint32_t token, uint32_t *payload, void *priv) { struct pcm_afe_info *prtd = priv; unsigned long dsp_flags; struct snd_pcm_substream *substream = NULL; struct snd_pcm_runtime *runtime = NULL; uint16_t event; uint64_t period_bytes; uint64_t bytes_one_sec; uint32_t mem_map_handle = 0; if (prtd == NULL) return; substream = prtd->substream; runtime = substream->runtime; pr_debug("%s\n", __func__); spin_lock_irqsave(&prtd->dsp_lock, dsp_flags); switch (opcode) { case AFE_EVENT_RT_PROXY_PORT_STATUS: { event = (uint16_t)((0xFFFF0000 & payload[0]) >> 0x10); switch (event) { case AFE_EVENT_RTPORT_START: { prtd->dsp_cnt = 0; /* Calculate poll time. Split steps to avoid overflow. * Poll time-time corresponding to one period in bytes. * (Samplerate * channelcount * format)=bytes in 1 sec. * Poll time = (period bytes / bytes in one sec) * * 1000000 micro seconds. * Multiplication by 1000000 is done in two steps to * keep the accuracy of poll time. */ if (prtd->mmap_flag) { period_bytes = ((uint64_t)( (snd_pcm_lib_period_bytes( prtd->substream)) * 1000)); bytes_one_sec = (runtime->rate * runtime->channels * 2); bytes_one_sec = div_u64(bytes_one_sec, 1000); prtd->poll_time = div_u64(period_bytes, bytes_one_sec); pr_debug("prtd->poll_time : %d\n", prtd->poll_time); } else { mem_map_handle = afe_req_mmap_handle(prtd->audio_client); if (!mem_map_handle) pr_err("%s:mem_map_handle is NULL\n", __func__); /* Do initial read to start transfer */ afe_rt_proxy_port_read((prtd->dma_addr + (prtd->dsp_cnt * snd_pcm_lib_period_bytes( prtd->substream))), mem_map_handle, snd_pcm_lib_period_bytes( prtd->substream)); prtd->dsp_cnt++; } break; } case AFE_EVENT_RTPORT_STOP: pr_debug("%s: event!=0\n", __func__); prtd->start = 0; snd_pcm_stop(substream, SNDRV_PCM_STATE_SETUP); break; case AFE_EVENT_RTPORT_LOW_WM: pr_debug("%s: Underrun\n", __func__); break; case AFE_EVENT_RTPORT_HI_WM: pr_debug("%s: Overrun\n", __func__); break; default: break; } break; } case APR_BASIC_RSP_RESULT: { switch (payload[0]) { case AFE_PORT_DATA_CMD_RT_PROXY_PORT_READ_V2: pr_debug("%s :Read done\n", __func__); prtd->pcm_irq_pos += snd_pcm_lib_period_bytes (prtd->substream); if (!prtd->mmap_flag) { atomic_set(&prtd->rec_bytes_avail, 1); wake_up(&prtd->read_wait); } snd_pcm_period_elapsed(prtd->substream); break; default: break; } break; } case RESET_EVENTS: prtd->pcm_irq_pos += snd_pcm_lib_period_bytes (prtd->substream); prtd->reset_event = true; if (!prtd->mmap_flag) { atomic_set(&prtd->rec_bytes_avail, 1); wake_up(&prtd->read_wait); } snd_pcm_period_elapsed(prtd->substream); break; default: break; } spin_unlock_irqrestore(&prtd->dsp_lock, dsp_flags); } static int msm_afe_playback_prepare(struct snd_pcm_substream *substream) { struct snd_pcm_runtime *runtime = substream->runtime; struct pcm_afe_info *prtd = runtime->private_data; struct snd_soc_pcm_runtime *rtd = substream->private_data; struct snd_soc_dai *dai = rtd->cpu_dai; int ret = 0; pr_debug("%s: sample_rate=%d\n", __func__, runtime->rate); pr_debug("%s: dai->id =%x\n", __func__, dai->id); ret = afe_register_get_events(dai->id, pcm_afe_process_tx_pkt, prtd); if (ret < 0) { pr_err("afe-pcm:register for events failed\n"); return ret; } pr_debug("%s:success\n", __func__); prtd->prepared++; return ret; } static int msm_afe_capture_prepare(struct snd_pcm_substream *substream) { struct snd_pcm_runtime *runtime = substream->runtime; struct pcm_afe_info *prtd = runtime->private_data; struct snd_soc_pcm_runtime *rtd = substream->private_data; struct snd_soc_dai *dai = rtd->cpu_dai; int ret = 0; pr_debug("%s\n", __func__); pr_debug("%s: dai->id =%x\n", __func__, dai->id); ret = afe_register_get_events(dai->id, pcm_afe_process_rx_pkt, prtd); if (ret < 0) { pr_err("afe-pcm:register for events failed\n"); return ret; } pr_debug("%s:success\n", __func__); prtd->prepared++; return 0; } /* Conventional and unconventional sample rate supported */ static unsigned int supported_sample_rates[] = { 8000, 16000, 48000 }; static struct snd_pcm_hw_constraint_list constraints_sample_rates = { .count = ARRAY_SIZE(supported_sample_rates), .list = supported_sample_rates, .mask = 0, }; static int msm_afe_open(struct snd_pcm_substream *substream) { struct snd_pcm_runtime *runtime = substream->runtime; struct pcm_afe_info *prtd = NULL; int ret = 0; prtd = kzalloc(sizeof(struct pcm_afe_info), GFP_KERNEL); if (prtd == NULL) return -ENOMEM; pr_debug("prtd %pK\n", prtd); mutex_init(&prtd->lock); spin_lock_init(&prtd->dsp_lock); prtd->dsp_cnt = 0; mutex_lock(&prtd->lock); if (substream->stream == SNDRV_PCM_STREAM_PLAYBACK) runtime->hw = msm_afe_hardware_playback; else runtime->hw = msm_afe_hardware_capture; prtd->substream = substream; runtime->private_data = prtd; prtd->audio_client = q6afe_audio_client_alloc(prtd); if (!prtd->audio_client) { pr_debug("%s: Could not allocate memory\n", __func__); mutex_unlock(&prtd->lock); kfree(prtd); return -ENOMEM; } atomic_set(&prtd->rec_bytes_avail, 0); init_waitqueue_head(&prtd->read_wait); hrtimer_init(&prtd->hrt, CLOCK_MONOTONIC, HRTIMER_MODE_REL); if (substream->stream == SNDRV_PCM_STREAM_PLAYBACK) prtd->hrt.function = afe_hrtimer_callback; else if (substream->stream == SNDRV_PCM_STREAM_CAPTURE) prtd->hrt.function = afe_hrtimer_rec_callback; mutex_unlock(&prtd->lock); ret = snd_pcm_hw_constraint_list(runtime, 0, SNDRV_PCM_HW_PARAM_RATE, &constraints_sample_rates); if (ret < 0) pr_err("snd_pcm_hw_constraint_list failed\n"); /* Ensure that buffer size is a multiple of period size */ ret = snd_pcm_hw_constraint_integer(runtime, SNDRV_PCM_HW_PARAM_PERIODS); if (ret < 0) pr_err("snd_pcm_hw_constraint_integer failed\n"); if (substream->stream == SNDRV_PCM_STREAM_CAPTURE) { ret = snd_pcm_hw_constraint_minmax(runtime, SNDRV_PCM_HW_PARAM_BUFFER_BYTES, MIN_CAPTURE_NUM_PERIODS * MIN_CAPTURE_PERIOD_SIZE, MAX_CAPTURE_NUM_PERIODS * MAX_CAPTURE_PERIOD_SIZE); if (ret < 0) { pr_err("constraint for buffer bytes min max ret = %d\n", ret); } } prtd->reset_event = false; return 0; } static int msm_afe_playback_copy(struct snd_pcm_substream *substream, int channel, unsigned long hwoff, void __user *buf, unsigned long fbytes) { int ret = 0; struct snd_pcm_runtime *runtime = substream->runtime; struct pcm_afe_info *prtd = runtime->private_data; char *hwbuf = runtime->dma_area + hwoff; u32 mem_map_handle = 0; pr_debug("%s : appl_ptr 0x%lx hw_ptr 0x%lx dest_to_copy 0x%pK\n", __func__, runtime->control->appl_ptr, runtime->status->hw_ptr, hwbuf); if (copy_from_user(hwbuf, buf, fbytes)) { pr_err("%s :Failed to copy audio from user buffer\n", __func__); ret = -EFAULT; goto fail; } if (!prtd->mmap_flag) { mem_map_handle = afe_req_mmap_handle(prtd->audio_client); if (!mem_map_handle) { pr_err("%s: mem_map_handle is NULL\n", __func__); ret = -EFAULT; goto fail; } pr_debug("%s : prtd-> dma_addr 0x%lx dsp_cnt %d\n", __func__, prtd->dma_addr, prtd->dsp_cnt); if (prtd->dsp_cnt == runtime->periods) prtd->dsp_cnt = 0; ret = afe_rt_proxy_port_write( (prtd->dma_addr + (prtd->dsp_cnt * snd_pcm_lib_period_bytes(prtd->substream))), mem_map_handle, snd_pcm_lib_period_bytes(prtd->substream)); if (ret) { pr_err("%s: AFE proxy port write failed %d\n", __func__, ret); goto fail; } prtd->dsp_cnt++; } fail: return ret; } static int msm_afe_capture_copy(struct snd_pcm_substream *substream, int channel, unsigned long hwoff, void __user *buf, unsigned long fbytes) { int ret = 0; struct snd_pcm_runtime *runtime = substream->runtime; struct pcm_afe_info *prtd = runtime->private_data; char *hwbuf = runtime->dma_area + hwoff; u32 mem_map_handle = 0; if (!prtd->mmap_flag) { mem_map_handle = afe_req_mmap_handle(prtd->audio_client); if (!mem_map_handle) { pr_err("%s: mem_map_handle is NULL\n", __func__); ret = -EFAULT; goto fail; } if (prtd->dsp_cnt == runtime->periods) prtd->dsp_cnt = 0; ret = afe_rt_proxy_port_read((prtd->dma_addr + (prtd->dsp_cnt * snd_pcm_lib_period_bytes(prtd->substream))), mem_map_handle, snd_pcm_lib_period_bytes(prtd->substream)); if (ret) { pr_err("%s: AFE proxy port read failed %d\n", __func__, ret); goto fail; } prtd->dsp_cnt++; ret = wait_event_timeout(prtd->read_wait, atomic_read(&prtd->rec_bytes_avail), msecs_to_jiffies(TIMEOUT_MS)); if (ret < 0) { pr_err("%s: wait_event_timeout failed\n", __func__); ret = -ETIMEDOUT; goto fail; } atomic_set(&prtd->rec_bytes_avail, 0); } pr_debug("%s:appl_ptr 0x%lx hw_ptr 0x%lx src_to_copy 0x%pK\n", __func__, runtime->control->appl_ptr, runtime->status->hw_ptr, hwbuf); if (copy_to_user(buf, hwbuf, fbytes)) { pr_err("%s: copy to user failed\n", __func__); goto fail; ret = -EFAULT; } fail: return ret; } static int msm_afe_copy(struct snd_pcm_substream *substream, int channel, unsigned long hwoff, void __user *buf, unsigned long fbytes) { struct snd_pcm_runtime *runtime = substream->runtime; struct pcm_afe_info *prtd = runtime->private_data; int ret = 0; if (prtd->reset_event) { pr_debug("%s: reset events received from ADSP, return error\n", __func__); return -ENETRESET; } if (substream->stream == SNDRV_PCM_STREAM_PLAYBACK) ret = msm_afe_playback_copy(substream, channel, hwoff, buf, fbytes); else if (substream->stream == SNDRV_PCM_STREAM_CAPTURE) ret = msm_afe_capture_copy(substream, channel, hwoff, buf, fbytes); return ret; } static int msm_afe_close(struct snd_pcm_substream *substream) { int rc = 0; struct snd_dma_buffer *dma_buf; struct snd_pcm_runtime *runtime; struct pcm_afe_info *prtd; struct snd_soc_pcm_runtime *rtd = NULL; struct snd_soc_dai *dai = NULL; int dir = IN; int ret = 0; pr_debug("%s\n", __func__); if (substream == NULL) { pr_err("substream is NULL\n"); return -EINVAL; } rtd = substream->private_data; dai = rtd->cpu_dai; runtime = substream->runtime; prtd = runtime->private_data; mutex_lock(&prtd->lock); if (substream->stream == SNDRV_PCM_STREAM_PLAYBACK) { dir = IN; ret = afe_unregister_get_events(dai->id); if (ret < 0) pr_err("AFE unregister for events failed\n"); } else if (substream->stream == SNDRV_PCM_STREAM_CAPTURE) { dir = OUT; ret = afe_unregister_get_events(dai->id); if (ret < 0) pr_err("AFE unregister for events failed\n"); } if (prtd->mmap_flag) hrtimer_cancel(&prtd->hrt); rc = afe_cmd_memory_unmap(afe_req_mmap_handle(prtd->audio_client)); if (rc < 0) pr_err("AFE memory unmap failed\n"); pr_debug("release all buffer\n"); dma_buf = &substream->dma_buffer; if (dma_buf == NULL) { pr_debug("dma_buf is NULL\n"); goto done; } if (dma_buf->area) dma_buf->area = NULL; q6afe_audio_client_buf_free_contiguous(dir, prtd->audio_client); done: pr_debug("%s: dai->id =%x\n", __func__, dai->id); q6afe_audio_client_free(prtd->audio_client); mutex_unlock(&prtd->lock); prtd->prepared--; kfree(prtd); runtime->private_data = NULL; return 0; } static int msm_afe_prepare(struct snd_pcm_substream *substream) { int ret = 0; struct snd_pcm_runtime *runtime = substream->runtime; struct pcm_afe_info *prtd = runtime->private_data; prtd->pcm_irq_pos = 0; if (prtd->prepared) return 0; mutex_lock(&prtd->lock); if (substream->stream == SNDRV_PCM_STREAM_PLAYBACK) ret = msm_afe_playback_prepare(substream); else if (substream->stream == SNDRV_PCM_STREAM_CAPTURE) ret = msm_afe_capture_prepare(substream); mutex_unlock(&prtd->lock); return ret; } static int msm_afe_mmap(struct snd_pcm_substream *substream, struct vm_area_struct *vma) { struct snd_pcm_runtime *runtime = substream->runtime; struct pcm_afe_info *prtd = runtime->private_data; struct afe_audio_client *ac = prtd->audio_client; struct afe_audio_port_data *apd = ac->port; struct afe_audio_buffer *ab; int dir = -1; pr_debug("%s\n", __func__); prtd->mmap_flag = 1; if (substream->stream == SNDRV_PCM_STREAM_PLAYBACK) dir = IN; else dir = OUT; ab = &(apd[dir].buf[0]); return msm_audio_ion_mmap((struct audio_buffer *)ab, vma); } static int msm_afe_trigger(struct snd_pcm_substream *substream, int cmd) { int ret = 0; struct snd_pcm_runtime *runtime = substream->runtime; struct pcm_afe_info *prtd = runtime->private_data; switch (cmd) { case SNDRV_PCM_TRIGGER_START: case SNDRV_PCM_TRIGGER_RESUME: case SNDRV_PCM_TRIGGER_PAUSE_RELEASE: pr_debug("%s: SNDRV_PCM_TRIGGER_START\n", __func__); prtd->start = 1; if (prtd->mmap_flag) hrtimer_start(&prtd->hrt, ns_to_ktime(0), HRTIMER_MODE_REL); break; case SNDRV_PCM_TRIGGER_STOP: case SNDRV_PCM_TRIGGER_SUSPEND: case SNDRV_PCM_TRIGGER_PAUSE_PUSH: pr_debug("%s: SNDRV_PCM_TRIGGER_STOP\n", __func__); prtd->start = 0; break; default: ret = -EINVAL; break; } return ret; } static int msm_afe_hw_params(struct snd_pcm_substream *substream, struct snd_pcm_hw_params *params) { struct snd_pcm_runtime *runtime = substream->runtime; struct snd_dma_buffer *dma_buf = &substream->dma_buffer; struct pcm_afe_info *prtd = runtime->private_data; struct afe_audio_buffer *buf; int dir, rc; pr_debug("%s:\n", __func__); mutex_lock(&prtd->lock); if (substream->stream == SNDRV_PCM_STREAM_PLAYBACK) dir = IN; else dir = OUT; rc = q6afe_audio_client_buf_alloc_contiguous(dir, prtd->audio_client, (params_buffer_bytes(params) / params_periods(params)), params_periods(params)); pr_debug("params_buffer_bytes(params) = %d\n", (params_buffer_bytes(params))); pr_debug("params_periods(params) = %d\n", (params_periods(params))); pr_debug("params_periodsize(params) = %d\n", (params_buffer_bytes(params) / params_periods(params))); if (rc < 0) { pr_err("Audio Start: Buffer Allocation failed rc = %d\n", rc); mutex_unlock(&prtd->lock); return -ENOMEM; } buf = prtd->audio_client->port[dir].buf; if (buf == NULL || buf[0].data == NULL) { mutex_unlock(&prtd->lock); return -ENOMEM; } pr_debug("%s:buf = %pK\n", __func__, buf); dma_buf->dev.type = SNDRV_DMA_TYPE_DEV; dma_buf->dev.dev = substream->pcm->card->dev; dma_buf->private_data = NULL; dma_buf->area = buf[0].data; dma_buf->addr = buf[0].phys; dma_buf->bytes = params_buffer_bytes(params); if (!dma_buf->area) { pr_err("%s:MSM AFE physical memory allocation failed\n", __func__); mutex_unlock(&prtd->lock); return -ENOMEM; } memset(dma_buf->area, 0, params_buffer_bytes(params)); prtd->dma_addr = (phys_addr_t) dma_buf->addr; mutex_unlock(&prtd->lock); snd_pcm_set_runtime_buffer(substream, &substream->dma_buffer); rc = afe_memory_map(dma_buf->addr, dma_buf->bytes, prtd->audio_client); if (rc < 0) pr_err("fail to map memory to DSP\n"); return rc; } static snd_pcm_uframes_t msm_afe_pointer(struct snd_pcm_substream *substream) { struct snd_pcm_runtime *runtime = substream->runtime; struct pcm_afe_info *prtd = runtime->private_data; if (prtd->pcm_irq_pos >= snd_pcm_lib_buffer_bytes(substream)) prtd->pcm_irq_pos = 0; if (prtd->reset_event) { pr_debug("%s: reset events received from ADSP, return XRUN\n", __func__); return SNDRV_PCM_POS_XRUN; } pr_debug("pcm_irq_pos = %d\n", prtd->pcm_irq_pos); return bytes_to_frames(runtime, (prtd->pcm_irq_pos)); } static const struct snd_pcm_ops msm_afe_ops = { .open = msm_afe_open, .copy_user = msm_afe_copy, .hw_params = msm_afe_hw_params, .trigger = msm_afe_trigger, .close = msm_afe_close, .prepare = msm_afe_prepare, .mmap = msm_afe_mmap, .pointer = msm_afe_pointer, }; static int msm_asoc_pcm_new(struct snd_soc_pcm_runtime *rtd) { struct snd_card *card = rtd->card->snd_card; int ret = 0; pr_debug("%s\n", __func__); if (!card->dev->coherent_dma_mask) card->dev->coherent_dma_mask = DMA_BIT_MASK(32); return ret; } static int msm_afe_afe_probe(struct snd_soc_component *component) { pr_debug("%s\n", __func__); return 0; } static struct snd_soc_component_driver msm_soc_component = { .name = DRV_NAME, .ops = &msm_afe_ops, .pcm_new = msm_asoc_pcm_new, .probe = msm_afe_afe_probe, }; static int msm_afe_probe(struct platform_device *pdev) { pr_debug("%s: dev name %s\n", __func__, dev_name(&pdev->dev)); return snd_soc_register_component(&pdev->dev, &msm_soc_component, NULL, 0); } static int msm_afe_remove(struct platform_device *pdev) { pr_debug("%s\n", __func__); snd_soc_unregister_component(&pdev->dev); return 0; } static const struct of_device_id msm_pcm_afe_dt_match[] = { {.compatible = "qcom,msm-pcm-afe"}, {} }; MODULE_DEVICE_TABLE(of, msm_pcm_afe_dt_match); static struct platform_driver msm_afe_driver = { .driver = { .name = "msm-pcm-afe", .owner = THIS_MODULE, .of_match_table = msm_pcm_afe_dt_match, .suppress_bind_attrs = true, }, .probe = msm_afe_probe, .remove = msm_afe_remove, }; int __init msm_pcm_afe_init(void) { pr_debug("%s\n", __func__); return platform_driver_register(&msm_afe_driver); } void msm_pcm_afe_exit(void) { pr_debug("%s\n", __func__); platform_driver_unregister(&msm_afe_driver); } MODULE_DESCRIPTION("AFE PCM module platform driver"); MODULE_LICENSE("GPL v2");