projects / deliverable / linux.git / blame
? search:
summary | shortlog | log | commit | commitdiff | tree
blob | blame (incremental) | history | HEAD
ASoC: dapm: support user-defined stop condition in dai_get_connected_widgets
[deliverable/linux.git] / sound / soc / soc-pcm.c
CommitLineData
ddee627c
LG		 1/*
2 * soc-pcm.c -- ALSA SoC PCM
3 *
4 * Copyright 2005 Wolfson Microelectronics PLC.
5 * Copyright 2005 Openedhand Ltd.
6 * Copyright (C) 2010 Slimlogic Ltd.
7 * Copyright (C) 2010 Texas Instruments Inc.
8 *
9 * Authors: Liam Girdwood <lrg@ti.com>
c8dd1fec 10 * Mark Brown <broonie@opensource.wolfsonmicro.com>
ddee627c
LG		 11 *
12 * This program is free software; you can redistribute it and/or modify it
13 * under the terms of the GNU General Public License as published by the
14 * Free Software Foundation; either version 2 of the License, or (at your
15 * option) any later version.
16 *
17 */
18
19#include <linux/kernel.h>
20#include <linux/init.h>
21#include <linux/delay.h>
988e8cc4 22#include <linux/pinctrl/consumer.h>
d6652ef8 23#include <linux/pm_runtime.h>
ddee627c
LG		 24#include <linux/slab.h>
25#include <linux/workqueue.h>
01d7584c 26#include <linux/export.h>
f86dcef8 27#include <linux/debugfs.h>
ddee627c
LG		 28#include <sound/core.h>
29#include <sound/pcm.h>
30#include <sound/pcm_params.h>
31#include <sound/soc.h>
01d7584c 32#include <sound/soc-dpcm.h>
ddee627c
LG		 33#include <sound/initval.h>
34
01d7584c
LG		 35#define DPCM_MAX_BE_USERS 8
36
cde79035
RW		 37/*
38 * snd_soc_dai_stream_valid() - check if a DAI supports the given stream
39 *
40 * Returns true if the DAI supports the indicated stream type.
41 */
42static bool snd_soc_dai_stream_valid(struct snd_soc_dai *dai, int stream)
43{
44 struct snd_soc_pcm_stream *codec_stream;
45
46 if (stream == SNDRV_PCM_STREAM_PLAYBACK)
47 codec_stream = &dai->driver->playback;
48 else
49 codec_stream = &dai->driver->capture;
50
51 /* If the codec specifies any rate at all, it supports the stream. */
52 return codec_stream->rates;
53}
54
24894b76
LPC		 55/**
56 * snd_soc_runtime_activate() - Increment active count for PCM runtime components
57 * @rtd: ASoC PCM runtime that is activated
58 * @stream: Direction of the PCM stream
59 *
60 * Increments the active count for all the DAIs and components attached to a PCM
61 * runtime. Should typically be called when a stream is opened.
62 *
63 * Must be called with the rtd->pcm_mutex being held
64 */
65void snd_soc_runtime_activate(struct snd_soc_pcm_runtime *rtd, int stream)
66{
67 struct snd_soc_dai *cpu_dai = rtd->cpu_dai;
2e5894d7 68 int i;
24894b76
LPC		 69
70 lockdep_assert_held(&rtd->pcm_mutex);
71
72 if (stream == SNDRV_PCM_STREAM_PLAYBACK) {
73 cpu_dai->playback_active++;
2e5894d7
BC		 74 for (i = 0; i < rtd->num_codecs; i++)
75 rtd->codec_dais[i]->playback_active++;
24894b76
LPC		 76 } else {
77 cpu_dai->capture_active++;
2e5894d7
BC		 78 for (i = 0; i < rtd->num_codecs; i++)
79 rtd->codec_dais[i]->capture_active++;
24894b76
LPC		 80 }
81
82 cpu_dai->active++;
cdde4ccb 83 cpu_dai->component->active++;
2e5894d7
BC		 84 for (i = 0; i < rtd->num_codecs; i++) {
85 rtd->codec_dais[i]->active++;
86 rtd->codec_dais[i]->component->active++;
87 }
24894b76
LPC		 88}
89
90/**
91 * snd_soc_runtime_deactivate() - Decrement active count for PCM runtime components
92 * @rtd: ASoC PCM runtime that is deactivated
93 * @stream: Direction of the PCM stream
94 *
95 * Decrements the active count for all the DAIs and components attached to a PCM
96 * runtime. Should typically be called when a stream is closed.
97 *
98 * Must be called with the rtd->pcm_mutex being held
99 */
100void snd_soc_runtime_deactivate(struct snd_soc_pcm_runtime *rtd, int stream)
101{
102 struct snd_soc_dai *cpu_dai = rtd->cpu_dai;
2e5894d7 103 int i;
24894b76
LPC		 104
105 lockdep_assert_held(&rtd->pcm_mutex);
106
107 if (stream == SNDRV_PCM_STREAM_PLAYBACK) {
108 cpu_dai->playback_active--;
2e5894d7
BC		 109 for (i = 0; i < rtd->num_codecs; i++)
110 rtd->codec_dais[i]->playback_active--;
24894b76
LPC		 111 } else {
112 cpu_dai->capture_active--;
2e5894d7
BC		 113 for (i = 0; i < rtd->num_codecs; i++)
114 rtd->codec_dais[i]->capture_active--;
24894b76
LPC		 115 }
116
117 cpu_dai->active--;
cdde4ccb 118 cpu_dai->component->active--;
2e5894d7
BC		 119 for (i = 0; i < rtd->num_codecs; i++) {
120 rtd->codec_dais[i]->component->active--;
121 rtd->codec_dais[i]->active--;
122 }
24894b76
LPC		 123}
124
208a1589
LPC		 125/**
126 * snd_soc_runtime_ignore_pmdown_time() - Check whether to ignore the power down delay
127 * @rtd: The ASoC PCM runtime that should be checked.
128 *
129 * This function checks whether the power down delay should be ignored for a
130 * specific PCM runtime. Returns true if the delay is 0, if it the DAI link has
131 * been configured to ignore the delay, or if none of the components benefits
132 * from having the delay.
133 */
134bool snd_soc_runtime_ignore_pmdown_time(struct snd_soc_pcm_runtime *rtd)
135{
2e5894d7
BC		 136 int i;
137 bool ignore = true;
138
208a1589
LPC		 139 if (!rtd->pmdown_time || rtd->dai_link->ignore_pmdown_time)
140 return true;
141
2e5894d7
BC		 142 for (i = 0; i < rtd->num_codecs; i++)
143 ignore &= rtd->codec_dais[i]->component->ignore_pmdown_time;
144
145 return rtd->cpu_dai->component->ignore_pmdown_time && ignore;
208a1589
LPC		 146}
147
90996f43
LPC		 148/**
149 * snd_soc_set_runtime_hwparams - set the runtime hardware parameters
150 * @substream: the pcm substream
151 * @hw: the hardware parameters
152 *
153 * Sets the substream runtime hardware parameters.
154 */
155int snd_soc_set_runtime_hwparams(struct snd_pcm_substream *substream,
156 const struct snd_pcm_hardware *hw)
157{
158 struct snd_pcm_runtime *runtime = substream->runtime;
159 runtime->hw.info = hw->info;
160 runtime->hw.formats = hw->formats;
161 runtime->hw.period_bytes_min = hw->period_bytes_min;
162 runtime->hw.period_bytes_max = hw->period_bytes_max;
163 runtime->hw.periods_min = hw->periods_min;
164 runtime->hw.periods_max = hw->periods_max;
165 runtime->hw.buffer_bytes_max = hw->buffer_bytes_max;
166 runtime->hw.fifo_size = hw->fifo_size;
167 return 0;
168}
169EXPORT_SYMBOL_GPL(snd_soc_set_runtime_hwparams);
170
01d7584c 171/* DPCM stream event, send event to FE and all active BEs. */
23607025 172int dpcm_dapm_stream_event(struct snd_soc_pcm_runtime *fe, int dir,
01d7584c
LG		 173 int event)
174{
175 struct snd_soc_dpcm *dpcm;
176
177 list_for_each_entry(dpcm, &fe->dpcm[dir].be_clients, list_be) {
178
179 struct snd_soc_pcm_runtime *be = dpcm->be;
180
103d84a3 181 dev_dbg(be->dev, "ASoC: BE %s event %d dir %d\n",
01d7584c
LG		 182 be->dai_link->name, event, dir);
183
184 snd_soc_dapm_stream_event(be, dir, event);
185 }
186
187 snd_soc_dapm_stream_event(fe, dir, event);
188
189 return 0;
190}
191
17841020
DA		 192static int soc_pcm_apply_symmetry(struct snd_pcm_substream *substream,
193 struct snd_soc_dai *soc_dai)
ddee627c
LG		 194{
195 struct snd_soc_pcm_runtime *rtd = substream->private_data;
ddee627c
LG		 196 int ret;
197
3635bf09
NC		 198 if (soc_dai->rate && (soc_dai->driver->symmetric_rates ||
199 rtd->dai_link->symmetric_rates)) {
200 dev_dbg(soc_dai->dev, "ASoC: Symmetry forces %dHz rate\n",
201 soc_dai->rate);
202
4dcdd43b 203 ret = snd_pcm_hw_constraint_single(substream->runtime,
3635bf09 204 SNDRV_PCM_HW_PARAM_RATE,
4dcdd43b 205 soc_dai->rate);
3635bf09
NC		 206 if (ret < 0) {
207 dev_err(soc_dai->dev,
208 "ASoC: Unable to apply rate constraint: %d\n",
209 ret);
210 return ret;
211 }
212 }
ddee627c 213
3635bf09
NC		 214 if (soc_dai->channels && (soc_dai->driver->symmetric_channels ||
215 rtd->dai_link->symmetric_channels)) {
216 dev_dbg(soc_dai->dev, "ASoC: Symmetry forces %d channel(s)\n",
217 soc_dai->channels);
ddee627c 218
4dcdd43b 219 ret = snd_pcm_hw_constraint_single(substream->runtime,
3635bf09 220 SNDRV_PCM_HW_PARAM_CHANNELS,
3635bf09
NC		 221 soc_dai->channels);
222 if (ret < 0) {
223 dev_err(soc_dai->dev,
224 "ASoC: Unable to apply channel symmetry constraint: %d\n",
225 ret);
226 return ret;
227 }
ddee627c
LG		 228 }
229
3635bf09
NC		 230 if (soc_dai->sample_bits && (soc_dai->driver->symmetric_samplebits ||
231 rtd->dai_link->symmetric_samplebits)) {
232 dev_dbg(soc_dai->dev, "ASoC: Symmetry forces %d sample bits\n",
233 soc_dai->sample_bits);
ddee627c 234
4dcdd43b 235 ret = snd_pcm_hw_constraint_single(substream->runtime,
3635bf09 236 SNDRV_PCM_HW_PARAM_SAMPLE_BITS,
3635bf09
NC		 237 soc_dai->sample_bits);
238 if (ret < 0) {
239 dev_err(soc_dai->dev,
240 "ASoC: Unable to apply sample bits symmetry constraint: %d\n",
241 ret);
242 return ret;
243 }
ddee627c
LG		 244 }
245
246 return 0;
247}
248
3635bf09
NC		 249static int soc_pcm_params_symmetry(struct snd_pcm_substream *substream,
250 struct snd_pcm_hw_params *params)
251{
252 struct snd_soc_pcm_runtime *rtd = substream->private_data;
253 struct snd_soc_dai *cpu_dai = rtd->cpu_dai;
2e5894d7 254 unsigned int rate, channels, sample_bits, symmetry, i;
3635bf09
NC		 255
256 rate = params_rate(params);
257 channels = params_channels(params);
258 sample_bits = snd_pcm_format_physical_width(params_format(params));
259
260 /* reject unmatched parameters when applying symmetry */
261 symmetry = cpu_dai->driver->symmetric_rates ||
3635bf09 262 rtd->dai_link->symmetric_rates;
2e5894d7
BC		 263
264 for (i = 0; i < rtd->num_codecs; i++)
265 symmetry |= rtd->codec_dais[i]->driver->symmetric_rates;
266
3635bf09
NC		 267 if (symmetry && cpu_dai->rate && cpu_dai->rate != rate) {
268 dev_err(rtd->dev, "ASoC: unmatched rate symmetry: %d - %d\n",
269 cpu_dai->rate, rate);
270 return -EINVAL;
ddee627c
LG		 271 }
272
3635bf09 273 symmetry = cpu_dai->driver->symmetric_channels ||
3635bf09 274 rtd->dai_link->symmetric_channels;
2e5894d7
BC		 275
276 for (i = 0; i < rtd->num_codecs; i++)
277 symmetry |= rtd->codec_dais[i]->driver->symmetric_channels;
278
3635bf09
NC		 279 if (symmetry && cpu_dai->channels && cpu_dai->channels != channels) {
280 dev_err(rtd->dev, "ASoC: unmatched channel symmetry: %d - %d\n",
281 cpu_dai->channels, channels);
282 return -EINVAL;
283 }
ddee627c 284
3635bf09 285 symmetry = cpu_dai->driver->symmetric_samplebits ||
3635bf09 286 rtd->dai_link->symmetric_samplebits;
2e5894d7
BC		 287
288 for (i = 0; i < rtd->num_codecs; i++)
289 symmetry |= rtd->codec_dais[i]->driver->symmetric_samplebits;
290
3635bf09
NC		 291 if (symmetry && cpu_dai->sample_bits && cpu_dai->sample_bits != sample_bits) {
292 dev_err(rtd->dev, "ASoC: unmatched sample bits symmetry: %d - %d\n",
293 cpu_dai->sample_bits, sample_bits);
294 return -EINVAL;
ddee627c
LG		 295 }
296
297 return 0;
298}
299
62e5f676
LPC		 300static bool soc_pcm_has_symmetry(struct snd_pcm_substream *substream)
301{
302 struct snd_soc_pcm_runtime *rtd = substream->private_data;
303 struct snd_soc_dai_driver *cpu_driver = rtd->cpu_dai->driver;
62e5f676 304 struct snd_soc_dai_link *link = rtd->dai_link;
2e5894d7 305 unsigned int symmetry, i;
62e5f676 306
2e5894d7
BC		 307 symmetry = cpu_driver->symmetric_rates || link->symmetric_rates ||
308 cpu_driver->symmetric_channels || link->symmetric_channels ||
309 cpu_driver->symmetric_samplebits || link->symmetric_samplebits;
62e5f676 310
2e5894d7
BC		 311 for (i = 0; i < rtd->num_codecs; i++)
312 symmetry = symmetry ||
313 rtd->codec_dais[i]->driver->symmetric_rates ||
314 rtd->codec_dais[i]->driver->symmetric_channels ||
315 rtd->codec_dais[i]->driver->symmetric_samplebits;
316
317 return symmetry;
62e5f676
LPC		 318}
319
2e5894d7 320static void soc_pcm_set_msb(struct snd_pcm_substream *substream, int bits)
58ba9b25 321{
2e5894d7 322 struct snd_soc_pcm_runtime *rtd = substream->private_data;
c6068d3a 323 int ret;
58ba9b25
MB		 324
325 if (!bits)
326 return;
327
0e2a3751
LPC		 328 ret = snd_pcm_hw_constraint_msbits(substream->runtime, 0, 0, bits);
329 if (ret != 0)
330 dev_warn(rtd->dev, "ASoC: Failed to set MSB %d: %d\n",
331 bits, ret);
58ba9b25
MB		 332}
333
c8dd1fec
BC		 334static void soc_pcm_apply_msb(struct snd_pcm_substream *substream)
335{
336 struct snd_soc_pcm_runtime *rtd = substream->private_data;
337 struct snd_soc_dai *cpu_dai = rtd->cpu_dai;
2e5894d7
BC		 338 struct snd_soc_dai *codec_dai;
339 int i;
c8dd1fec
BC		 340 unsigned int bits = 0, cpu_bits;
341
342 if (substream->stream == SNDRV_PCM_STREAM_PLAYBACK) {
2e5894d7
BC		 343 for (i = 0; i < rtd->num_codecs; i++) {
344 codec_dai = rtd->codec_dais[i];
345 if (codec_dai->driver->playback.sig_bits == 0) {
346 bits = 0;
347 break;
348 }
349 bits = max(codec_dai->driver->playback.sig_bits, bits);
350 }
c8dd1fec
BC		 351 cpu_bits = cpu_dai->driver->playback.sig_bits;
352 } else {
2e5894d7
BC		 353 for (i = 0; i < rtd->num_codecs; i++) {
354 codec_dai = rtd->codec_dais[i];
5e63dfcc 355 if (codec_dai->driver->capture.sig_bits == 0) {
2e5894d7
BC		 356 bits = 0;
357 break;
358 }
359 bits = max(codec_dai->driver->capture.sig_bits, bits);
360 }
c8dd1fec
BC		 361 cpu_bits = cpu_dai->driver->capture.sig_bits;
362 }
363
2e5894d7
BC		 364 soc_pcm_set_msb(substream, bits);
365 soc_pcm_set_msb(substream, cpu_bits);
c8dd1fec
BC		 366}
367
2e5894d7 368static void soc_pcm_init_runtime_hw(struct snd_pcm_substream *substream)
bd477c31 369{
2e5894d7 370 struct snd_pcm_runtime *runtime = substream->runtime;
78e45c99 371 struct snd_pcm_hardware *hw = &runtime->hw;
2e5894d7
BC		 372 struct snd_soc_pcm_runtime *rtd = substream->private_data;
373 struct snd_soc_dai_driver *cpu_dai_drv = rtd->cpu_dai->driver;
374 struct snd_soc_dai_driver *codec_dai_drv;
375 struct snd_soc_pcm_stream *codec_stream;
376 struct snd_soc_pcm_stream *cpu_stream;
377 unsigned int chan_min = 0, chan_max = UINT_MAX;
378 unsigned int rate_min = 0, rate_max = UINT_MAX;
379 unsigned int rates = UINT_MAX;
380 u64 formats = ULLONG_MAX;
381 int i;
78e45c99 382
2e5894d7
BC		 383 if (substream->stream == SNDRV_PCM_STREAM_PLAYBACK)
384 cpu_stream = &cpu_dai_drv->playback;
16d7ea91 385 else
2e5894d7 386 cpu_stream = &cpu_dai_drv->capture;
78e45c99 387
2e5894d7
BC		 388 /* first calculate min/max only for CODECs in the DAI link */
389 for (i = 0; i < rtd->num_codecs; i++) {
cde79035
RW		 390
391 /*
392 * Skip CODECs which don't support the current stream type.
393 * Otherwise, since the rate, channel, and format values will
394 * zero in that case, we would have no usable settings left,
395 * causing the resulting setup to fail.
396 * At least one CODEC should match, otherwise we should have
397 * bailed out on a higher level, since there would be no
398 * CODEC to support the transfer direction in that case.
399 */
400 if (!snd_soc_dai_stream_valid(rtd->codec_dais[i],
401 substream->stream))
402 continue;
403
2e5894d7
BC		 404 codec_dai_drv = rtd->codec_dais[i]->driver;
405 if (substream->stream == SNDRV_PCM_STREAM_PLAYBACK)
406 codec_stream = &codec_dai_drv->playback;
407 else
408 codec_stream = &codec_dai_drv->capture;
409 chan_min = max(chan_min, codec_stream->channels_min);
410 chan_max = min(chan_max, codec_stream->channels_max);
411 rate_min = max(rate_min, codec_stream->rate_min);
412 rate_max = min_not_zero(rate_max, codec_stream->rate_max);
413 formats &= codec_stream->formats;
414 rates = snd_pcm_rate_mask_intersect(codec_stream->rates, rates);
415 }
416
417 /*
418 * chan min/max cannot be enforced if there are multiple CODEC DAIs
419 * connected to a single CPU DAI, use CPU DAI's directly and let
420 * channel allocation be fixed up later
421 */
422 if (rtd->num_codecs > 1) {
423 chan_min = cpu_stream->channels_min;
424 chan_max = cpu_stream->channels_max;
425 }
426
427 hw->channels_min = max(chan_min, cpu_stream->channels_min);
428 hw->channels_max = min(chan_max, cpu_stream->channels_max);
429 if (hw->formats)
430 hw->formats &= formats & cpu_stream->formats;
431 else
432 hw->formats = formats & cpu_stream->formats;
433 hw->rates = snd_pcm_rate_mask_intersect(rates, cpu_stream->rates);
78e45c99
LPC		 434
435 snd_pcm_limit_hw_rates(runtime);
436
437 hw->rate_min = max(hw->rate_min, cpu_stream->rate_min);
2e5894d7 438 hw->rate_min = max(hw->rate_min, rate_min);
78e45c99 439 hw->rate_max = min_not_zero(hw->rate_max, cpu_stream->rate_max);
2e5894d7 440 hw->rate_max = min_not_zero(hw->rate_max, rate_max);
bd477c31
LPC		 441}
442
ddee627c
LG		 443/*
444 * Called by ALSA when a PCM substream is opened, the runtime->hw record is
445 * then initialized and any private data can be allocated. This also calls
446 * startup for the cpu DAI, platform, machine and codec DAI.
447 */
448static int soc_pcm_open(struct snd_pcm_substream *substream)
449{
450 struct snd_soc_pcm_runtime *rtd = substream->private_data;
451 struct snd_pcm_runtime *runtime = substream->runtime;
452 struct snd_soc_platform *platform = rtd->platform;
453 struct snd_soc_dai *cpu_dai = rtd->cpu_dai;
2e5894d7
BC		 454 struct snd_soc_dai *codec_dai;
455 const char *codec_dai_name = "multicodec";
456 int i, ret = 0;
ddee627c 457
988e8cc4 458 pinctrl_pm_select_default_state(cpu_dai->dev);
2e5894d7
BC		 459 for (i = 0; i < rtd->num_codecs; i++)
460 pinctrl_pm_select_default_state(rtd->codec_dais[i]->dev);
d6652ef8 461 pm_runtime_get_sync(cpu_dai->dev);
2e5894d7
BC		 462 for (i = 0; i < rtd->num_codecs; i++)
463 pm_runtime_get_sync(rtd->codec_dais[i]->dev);
d6652ef8
MB		 464 pm_runtime_get_sync(platform->dev);
465
b8c0dab9 466 mutex_lock_nested(&rtd->pcm_mutex, rtd->pcm_subclass);
ddee627c
LG		 467
468 /* startup the audio subsystem */
c5914b0a 469 if (cpu_dai->driver->ops && cpu_dai->driver->ops->startup) {
ddee627c
LG		 470 ret = cpu_dai->driver->ops->startup(substream, cpu_dai);
471 if (ret < 0) {
103d84a3
LG		 472 dev_err(cpu_dai->dev, "ASoC: can't open interface"
473 " %s: %d\n", cpu_dai->name, ret);
ddee627c
LG		 474 goto out;
475 }
476 }
477
478 if (platform->driver->ops && platform->driver->ops->open) {
479 ret = platform->driver->ops->open(substream);
480 if (ret < 0) {
103d84a3 481 dev_err(platform->dev, "ASoC: can't open platform"
f4333203 482 " %s: %d\n", platform->component.name, ret);
ddee627c
LG		 483 goto platform_err;
484 }
485 }
486
2e5894d7
BC		 487 for (i = 0; i < rtd->num_codecs; i++) {
488 codec_dai = rtd->codec_dais[i];
489 if (codec_dai->driver->ops && codec_dai->driver->ops->startup) {
490 ret = codec_dai->driver->ops->startup(substream,
491 codec_dai);
492 if (ret < 0) {
493 dev_err(codec_dai->dev,
494 "ASoC: can't open codec %s: %d\n",
495 codec_dai->name, ret);
496 goto codec_dai_err;
497 }
ddee627c 498 }
2e5894d7
BC		 499
500 if (substream->stream == SNDRV_PCM_STREAM_PLAYBACK)
501 codec_dai->tx_mask = 0;
502 else
503 codec_dai->rx_mask = 0;
ddee627c
LG		 504 }
505
506 if (rtd->dai_link->ops && rtd->dai_link->ops->startup) {
507 ret = rtd->dai_link->ops->startup(substream);
508 if (ret < 0) {
103d84a3 509 pr_err("ASoC: %s startup failed: %d\n",
25bfe662 510 rtd->dai_link->name, ret);
ddee627c
LG		 511 goto machine_err;
512 }
513 }
514
01d7584c
LG		 515 /* Dynamic PCM DAI links compat checks use dynamic capabilities */
516 if (rtd->dai_link->dynamic || rtd->dai_link->no_pcm)
517 goto dynamic;
518
ddee627c 519 /* Check that the codec and cpu DAIs are compatible */
2e5894d7
BC		 520 soc_pcm_init_runtime_hw(substream);
521
522 if (rtd->num_codecs == 1)
523 codec_dai_name = rtd->codec_dai->name;
ddee627c 524
62e5f676
LPC		 525 if (soc_pcm_has_symmetry(substream))
526 runtime->hw.info |= SNDRV_PCM_INFO_JOINT_DUPLEX;
527
ddee627c 528 ret = -EINVAL;
ddee627c 529 if (!runtime->hw.rates) {
103d84a3 530 printk(KERN_ERR "ASoC: %s <-> %s No matching rates\n",
2e5894d7 531 codec_dai_name, cpu_dai->name);
ddee627c
LG		 532 goto config_err;
533 }
534 if (!runtime->hw.formats) {
103d84a3 535 printk(KERN_ERR "ASoC: %s <-> %s No matching formats\n",
2e5894d7 536 codec_dai_name, cpu_dai->name);
ddee627c
LG		 537 goto config_err;
538 }
539 if (!runtime->hw.channels_min || !runtime->hw.channels_max ||
540 runtime->hw.channels_min > runtime->hw.channels_max) {
103d84a3 541 printk(KERN_ERR "ASoC: %s <-> %s No matching channels\n",
2e5894d7 542 codec_dai_name, cpu_dai->name);
ddee627c
LG		 543 goto config_err;
544 }
545
c8dd1fec 546 soc_pcm_apply_msb(substream);
58ba9b25 547
ddee627c 548 /* Symmetry only applies if we've already got an active stream. */
17841020
DA		 549 if (cpu_dai->active) {
550 ret = soc_pcm_apply_symmetry(substream, cpu_dai);
551 if (ret != 0)
552 goto config_err;
553 }
554
2e5894d7
BC		 555 for (i = 0; i < rtd->num_codecs; i++) {
556 if (rtd->codec_dais[i]->active) {
557 ret = soc_pcm_apply_symmetry(substream,
558 rtd->codec_dais[i]);
559 if (ret != 0)
560 goto config_err;
561 }
ddee627c
LG		 562 }
563
103d84a3 564 pr_debug("ASoC: %s <-> %s info:\n",
2e5894d7 565 codec_dai_name, cpu_dai->name);
103d84a3
LG		 566 pr_debug("ASoC: rate mask 0x%x\n", runtime->hw.rates);
567 pr_debug("ASoC: min ch %d max ch %d\n", runtime->hw.channels_min,
ddee627c 568 runtime->hw.channels_max);
103d84a3 569 pr_debug("ASoC: min rate %d max rate %d\n", runtime->hw.rate_min,
ddee627c
LG		 570 runtime->hw.rate_max);
571
01d7584c 572dynamic:
24894b76
LPC		 573
574 snd_soc_runtime_activate(rtd, substream->stream);
575
b8c0dab9 576 mutex_unlock(&rtd->pcm_mutex);
ddee627c
LG		 577 return 0;
578
579config_err:
580 if (rtd->dai_link->ops && rtd->dai_link->ops->shutdown)
581 rtd->dai_link->ops->shutdown(substream);
582
583machine_err:
2e5894d7 584 i = rtd->num_codecs;
ddee627c
LG		 585
586codec_dai_err:
2e5894d7
BC		 587 while (--i >= 0) {
588 codec_dai = rtd->codec_dais[i];
589 if (codec_dai->driver->ops->shutdown)
590 codec_dai->driver->ops->shutdown(substream, codec_dai);
591 }
592
ddee627c
LG		 593 if (platform->driver->ops && platform->driver->ops->close)
594 platform->driver->ops->close(substream);
595
596platform_err:
597 if (cpu_dai->driver->ops->shutdown)
598 cpu_dai->driver->ops->shutdown(substream, cpu_dai);
599out:
b8c0dab9 600 mutex_unlock(&rtd->pcm_mutex);
d6652ef8 601
3f809783
SK		 602 pm_runtime_mark_last_busy(platform->dev);
603 pm_runtime_put_autosuspend(platform->dev);
604 for (i = 0; i < rtd->num_codecs; i++) {
605 pm_runtime_mark_last_busy(rtd->codec_dais[i]->dev);
606 pm_runtime_put_autosuspend(rtd->codec_dais[i]->dev);
607 }
608
609 pm_runtime_mark_last_busy(cpu_dai->dev);
610 pm_runtime_put_autosuspend(cpu_dai->dev);
2e5894d7
BC		 611 for (i = 0; i < rtd->num_codecs; i++) {
612 if (!rtd->codec_dais[i]->active)
613 pinctrl_pm_select_sleep_state(rtd->codec_dais[i]->dev);
614 }
988e8cc4
NC		 615 if (!cpu_dai->active)
616 pinctrl_pm_select_sleep_state(cpu_dai->dev);
d6652ef8 617
ddee627c
LG		 618 return ret;
619}
620
621/*
622 * Power down the audio subsystem pmdown_time msecs after close is called.
623 * This is to ensure there are no pops or clicks in between any music tracks
624 * due to DAPM power cycling.
625 */
626static void close_delayed_work(struct work_struct *work)
627{
628 struct snd_soc_pcm_runtime *rtd =
629 container_of(work, struct snd_soc_pcm_runtime, delayed_work.work);
2e5894d7 630 struct snd_soc_dai *codec_dai = rtd->codec_dais[0];
ddee627c 631
b8c0dab9 632 mutex_lock_nested(&rtd->pcm_mutex, rtd->pcm_subclass);
ddee627c 633
103d84a3 634 dev_dbg(rtd->dev, "ASoC: pop wq checking: %s status: %s waiting: %s\n",
ddee627c
LG		 635 codec_dai->driver->playback.stream_name,
636 codec_dai->playback_active ? "active" : "inactive",
9bffb1fb 637 rtd->pop_wait ? "yes" : "no");
ddee627c
LG		 638
639 /* are we waiting on this codec DAI stream */
9bffb1fb
MLC		 640 if (rtd->pop_wait == 1) {
641 rtd->pop_wait = 0;
7bd3a6f3 642 snd_soc_dapm_stream_event(rtd, SNDRV_PCM_STREAM_PLAYBACK,
d9b0951b 643 SND_SOC_DAPM_STREAM_STOP);
ddee627c
LG		 644 }
645
b8c0dab9 646 mutex_unlock(&rtd->pcm_mutex);
ddee627c
LG		 647}
648
649/*
650 * Called by ALSA when a PCM substream is closed. Private data can be
651 * freed here. The cpu DAI, codec DAI, machine and platform are also
652 * shutdown.
653 */
91d5e6b4 654static int soc_pcm_close(struct snd_pcm_substream *substream)
ddee627c
LG		 655{
656 struct snd_soc_pcm_runtime *rtd = substream->private_data;
657 struct snd_soc_platform *platform = rtd->platform;
658 struct snd_soc_dai *cpu_dai = rtd->cpu_dai;
2e5894d7
BC		 659 struct snd_soc_dai *codec_dai;
660 int i;
ddee627c 661
b8c0dab9 662 mutex_lock_nested(&rtd->pcm_mutex, rtd->pcm_subclass);
ddee627c 663
24894b76 664 snd_soc_runtime_deactivate(rtd, substream->stream);
ddee627c 665
17841020
DA		 666 /* clear the corresponding DAIs rate when inactive */
667 if (!cpu_dai->active)
668 cpu_dai->rate = 0;
669
2e5894d7
BC		 670 for (i = 0; i < rtd->num_codecs; i++) {
671 codec_dai = rtd->codec_dais[i];
672 if (!codec_dai->active)
673 codec_dai->rate = 0;
674 }
25b76791 675
ae11601b
RB		 676 snd_soc_dai_digital_mute(cpu_dai, 1, substream->stream);
677
ddee627c
LG		 678 if (cpu_dai->driver->ops->shutdown)
679 cpu_dai->driver->ops->shutdown(substream, cpu_dai);
680
2e5894d7
BC		 681 for (i = 0; i < rtd->num_codecs; i++) {
682 codec_dai = rtd->codec_dais[i];
683 if (codec_dai->driver->ops->shutdown)
684 codec_dai->driver->ops->shutdown(substream, codec_dai);
685 }
ddee627c
LG		 686
687 if (rtd->dai_link->ops && rtd->dai_link->ops->shutdown)
688 rtd->dai_link->ops->shutdown(substream);
689
690 if (platform->driver->ops && platform->driver->ops->close)
691 platform->driver->ops->close(substream);
ddee627c
LG		 692
693 if (substream->stream == SNDRV_PCM_STREAM_PLAYBACK) {
208a1589 694 if (snd_soc_runtime_ignore_pmdown_time(rtd)) {
1d69c5c5
PU		 695 /* powered down playback stream now */
696 snd_soc_dapm_stream_event(rtd,
7bd3a6f3 697 SNDRV_PCM_STREAM_PLAYBACK,
7bd3a6f3 698 SND_SOC_DAPM_STREAM_STOP);
1d69c5c5
PU		 699 } else {
700 /* start delayed pop wq here for playback streams */
9bffb1fb 701 rtd->pop_wait = 1;
d4e1a73a
MB		 702 queue_delayed_work(system_power_efficient_wq,
703 &rtd->delayed_work,
704 msecs_to_jiffies(rtd->pmdown_time));
1d69c5c5 705 }
ddee627c
LG		 706 } else {
707 /* capture streams can be powered down now */
7bd3a6f3 708 snd_soc_dapm_stream_event(rtd, SNDRV_PCM_STREAM_CAPTURE,
d9b0951b 709 SND_SOC_DAPM_STREAM_STOP);
ddee627c
LG		 710 }
711
b8c0dab9 712 mutex_unlock(&rtd->pcm_mutex);
d6652ef8 713
3f809783
SK		 714 pm_runtime_mark_last_busy(platform->dev);
715 pm_runtime_put_autosuspend(platform->dev);
716
717 for (i = 0; i < rtd->num_codecs; i++) {
718 pm_runtime_mark_last_busy(rtd->codec_dais[i]->dev);
719 pm_runtime_put_autosuspend(rtd->codec_dais[i]->dev);
720 }
721
722 pm_runtime_mark_last_busy(cpu_dai->dev);
723 pm_runtime_put_autosuspend(cpu_dai->dev);
724
2e5894d7
BC		 725 for (i = 0; i < rtd->num_codecs; i++) {
726 if (!rtd->codec_dais[i]->active)
727 pinctrl_pm_select_sleep_state(rtd->codec_dais[i]->dev);
728 }
988e8cc4
NC		 729 if (!cpu_dai->active)
730 pinctrl_pm_select_sleep_state(cpu_dai->dev);
d6652ef8 731
ddee627c
LG		 732 return 0;
733}
734
735/*
736 * Called by ALSA when the PCM substream is prepared, can set format, sample
737 * rate, etc. This function is non atomic and can be called multiple times,
738 * it can refer to the runtime info.
739 */
740static int soc_pcm_prepare(struct snd_pcm_substream *substream)
741{
742 struct snd_soc_pcm_runtime *rtd = substream->private_data;
743 struct snd_soc_platform *platform = rtd->platform;
744 struct snd_soc_dai *cpu_dai = rtd->cpu_dai;
2e5894d7
BC		 745 struct snd_soc_dai *codec_dai;
746 int i, ret = 0;
ddee627c 747
b8c0dab9 748 mutex_lock_nested(&rtd->pcm_mutex, rtd->pcm_subclass);
ddee627c
LG		 749
750 if (rtd->dai_link->ops && rtd->dai_link->ops->prepare) {
751 ret = rtd->dai_link->ops->prepare(substream);
752 if (ret < 0) {
103d84a3
LG		 753 dev_err(rtd->card->dev, "ASoC: machine prepare error:"
754 " %d\n", ret);
ddee627c
LG		 755 goto out;
756 }
757 }
758
759 if (platform->driver->ops && platform->driver->ops->prepare) {
760 ret = platform->driver->ops->prepare(substream);
761 if (ret < 0) {
103d84a3
LG		 762 dev_err(platform->dev, "ASoC: platform prepare error:"
763 " %d\n", ret);
ddee627c
LG		 764 goto out;
765 }
766 }
767
2e5894d7
BC		 768 for (i = 0; i < rtd->num_codecs; i++) {
769 codec_dai = rtd->codec_dais[i];
770 if (codec_dai->driver->ops && codec_dai->driver->ops->prepare) {
771 ret = codec_dai->driver->ops->prepare(substream,
772 codec_dai);
773 if (ret < 0) {
774 dev_err(codec_dai->dev,
90cc7f1c
JN		 775 "ASoC: codec DAI prepare error: %d\n",
776 ret);
2e5894d7
BC		 777 goto out;
778 }
ddee627c
LG		 779 }
780 }
781
c5914b0a 782 if (cpu_dai->driver->ops && cpu_dai->driver->ops->prepare) {
ddee627c
LG		 783 ret = cpu_dai->driver->ops->prepare(substream, cpu_dai);
784 if (ret < 0) {
90cc7f1c
JN		 785 dev_err(cpu_dai->dev,
786 "ASoC: cpu DAI prepare error: %d\n", ret);
ddee627c
LG		 787 goto out;
788 }
789 }
790
791 /* cancel any delayed stream shutdown that is pending */
792 if (substream->stream == SNDRV_PCM_STREAM_PLAYBACK &&
9bffb1fb
MLC		 793 rtd->pop_wait) {
794 rtd->pop_wait = 0;
ddee627c
LG		 795 cancel_delayed_work(&rtd->delayed_work);
796 }
797
d9b0951b
LG		 798 snd_soc_dapm_stream_event(rtd, substream->stream,
799 SND_SOC_DAPM_STREAM_START);
ddee627c 800
2e5894d7
BC		 801 for (i = 0; i < rtd->num_codecs; i++)
802 snd_soc_dai_digital_mute(rtd->codec_dais[i], 0,
803 substream->stream);
ae11601b 804 snd_soc_dai_digital_mute(cpu_dai, 0, substream->stream);
ddee627c
LG		 805
806out:
b8c0dab9 807 mutex_unlock(&rtd->pcm_mutex);
ddee627c
LG		 808 return ret;
809}
810
2e5894d7
BC		 811static void soc_pcm_codec_params_fixup(struct snd_pcm_hw_params *params,
812 unsigned int mask)
813{
814 struct snd_interval *interval;
815 int channels = hweight_long(mask);
816
817 interval = hw_param_interval(params, SNDRV_PCM_HW_PARAM_CHANNELS);
818 interval->min = channels;
819 interval->max = channels;
820}
821
93e6958a
BC		 822int soc_dai_hw_params(struct snd_pcm_substream *substream,
823 struct snd_pcm_hw_params *params,
824 struct snd_soc_dai *dai)
825{
826 int ret;
827
828 if (dai->driver->ops && dai->driver->ops->hw_params) {
829 ret = dai->driver->ops->hw_params(substream, params, dai);
830 if (ret < 0) {
831 dev_err(dai->dev, "ASoC: can't set %s hw params: %d\n",
832 dai->name, ret);
833 return ret;
834 }
835 }
836
837 return 0;
838}
839
ddee627c
LG		 840/*
841 * Called by ALSA when the hardware params are set by application. This
842 * function can also be called multiple times and can allocate buffers
843 * (using snd_pcm_lib_* ). It's non-atomic.
844 */
845static int soc_pcm_hw_params(struct snd_pcm_substream *substream,
846 struct snd_pcm_hw_params *params)
847{
848 struct snd_soc_pcm_runtime *rtd = substream->private_data;
849 struct snd_soc_platform *platform = rtd->platform;
850 struct snd_soc_dai *cpu_dai = rtd->cpu_dai;
2e5894d7 851 int i, ret = 0;
ddee627c 852
b8c0dab9 853 mutex_lock_nested(&rtd->pcm_mutex, rtd->pcm_subclass);
ddee627c 854
3635bf09
NC		 855 ret = soc_pcm_params_symmetry(substream, params);
856 if (ret)
857 goto out;
858
ddee627c
LG		 859 if (rtd->dai_link->ops && rtd->dai_link->ops->hw_params) {
860 ret = rtd->dai_link->ops->hw_params(substream, params);
861 if (ret < 0) {
103d84a3
LG		 862 dev_err(rtd->card->dev, "ASoC: machine hw_params"
863 " failed: %d\n", ret);
ddee627c
LG		 864 goto out;
865 }
866 }
867
2e5894d7
BC		 868 for (i = 0; i < rtd->num_codecs; i++) {
869 struct snd_soc_dai *codec_dai = rtd->codec_dais[i];
870 struct snd_pcm_hw_params codec_params;
871
cde79035
RW		 872 /*
873 * Skip CODECs which don't support the current stream type,
874 * the idea being that if a CODEC is not used for the currently
875 * set up transfer direction, it should not need to be
876 * configured, especially since the configuration used might
877 * not even be supported by that CODEC. There may be cases
878 * however where a CODEC needs to be set up although it is
879 * actually not being used for the transfer, e.g. if a
880 * capture-only CODEC is acting as an LRCLK and/or BCLK master
881 * for the DAI link including a playback-only CODEC.
882 * If this becomes necessary, we will have to augment the
883 * machine driver setup with information on how to act, so
884 * we can do the right thing here.
885 */
886 if (!snd_soc_dai_stream_valid(codec_dai, substream->stream))
887 continue;
888
2e5894d7
BC		 889 /* copy params for each codec */
890 codec_params = *params;
891
892 /* fixup params based on TDM slot masks */
893 if (codec_dai->tx_mask)
894 soc_pcm_codec_params_fixup(&codec_params,
895 codec_dai->tx_mask);
896 if (codec_dai->rx_mask)
897 soc_pcm_codec_params_fixup(&codec_params,
898 codec_dai->rx_mask);
899
93e6958a
BC		 900 ret = soc_dai_hw_params(substream, &codec_params, codec_dai);
901 if(ret < 0)
ddee627c 902 goto codec_err;
ddee627c 903
2e5894d7
BC		 904 codec_dai->rate = params_rate(&codec_params);
905 codec_dai->channels = params_channels(&codec_params);
906 codec_dai->sample_bits = snd_pcm_format_physical_width(
907 params_format(&codec_params));
ddee627c
LG		 908 }
909
93e6958a
BC		 910 ret = soc_dai_hw_params(substream, params, cpu_dai);
911 if (ret < 0)
912 goto interface_err;
ddee627c
LG		 913
914 if (platform->driver->ops && platform->driver->ops->hw_params) {
915 ret = platform->driver->ops->hw_params(substream, params);
916 if (ret < 0) {
103d84a3 917 dev_err(platform->dev, "ASoC: %s hw params failed: %d\n",
f4333203 918 platform->component.name, ret);
ddee627c
LG		 919 goto platform_err;
920 }
921 }
922
3635bf09 923 /* store the parameters for each DAIs */
17841020 924 cpu_dai->rate = params_rate(params);
3635bf09
NC		 925 cpu_dai->channels = params_channels(params);
926 cpu_dai->sample_bits =
927 snd_pcm_format_physical_width(params_format(params));
928
ddee627c 929out:
b8c0dab9 930 mutex_unlock(&rtd->pcm_mutex);
ddee627c
LG		 931 return ret;
932
933platform_err:
c5914b0a 934 if (cpu_dai->driver->ops && cpu_dai->driver->ops->hw_free)
ddee627c
LG		 935 cpu_dai->driver->ops->hw_free(substream, cpu_dai);
936
937interface_err:
2e5894d7 938 i = rtd->num_codecs;
ddee627c
LG		 939
940codec_err:
2e5894d7
BC		 941 while (--i >= 0) {
942 struct snd_soc_dai *codec_dai = rtd->codec_dais[i];
943 if (codec_dai->driver->ops && codec_dai->driver->ops->hw_free)
944 codec_dai->driver->ops->hw_free(substream, codec_dai);
945 codec_dai->rate = 0;
946 }
947
ddee627c
LG		 948 if (rtd->dai_link->ops && rtd->dai_link->ops->hw_free)
949 rtd->dai_link->ops->hw_free(substream);
950
b8c0dab9 951 mutex_unlock(&rtd->pcm_mutex);
ddee627c
LG		 952 return ret;
953}
954
955/*
956 * Frees resources allocated by hw_params, can be called multiple times
957 */
958static int soc_pcm_hw_free(struct snd_pcm_substream *substream)
959{
960 struct snd_soc_pcm_runtime *rtd = substream->private_data;
961 struct snd_soc_platform *platform = rtd->platform;
962 struct snd_soc_dai *cpu_dai = rtd->cpu_dai;
2e5894d7 963 struct snd_soc_dai *codec_dai;
7f62b6ee 964 bool playback = substream->stream == SNDRV_PCM_STREAM_PLAYBACK;
2e5894d7 965 int i;
ddee627c 966
b8c0dab9 967 mutex_lock_nested(&rtd->pcm_mutex, rtd->pcm_subclass);
ddee627c 968
d3383420
NC		 969 /* clear the corresponding DAIs parameters when going to be inactive */
970 if (cpu_dai->active == 1) {
971 cpu_dai->rate = 0;
972 cpu_dai->channels = 0;
973 cpu_dai->sample_bits = 0;
974 }
975
2e5894d7
BC		 976 for (i = 0; i < rtd->num_codecs; i++) {
977 codec_dai = rtd->codec_dais[i];
978 if (codec_dai->active == 1) {
979 codec_dai->rate = 0;
980 codec_dai->channels = 0;
981 codec_dai->sample_bits = 0;
982 }
d3383420
NC		 983 }
984
ddee627c 985 /* apply codec digital mute */
2e5894d7
BC		 986 for (i = 0; i < rtd->num_codecs; i++) {
987 if ((playback && rtd->codec_dais[i]->playback_active == 1) ||
988 (!playback && rtd->codec_dais[i]->capture_active == 1))
989 snd_soc_dai_digital_mute(rtd->codec_dais[i], 1,
990 substream->stream);
991 }
ddee627c
LG		 992
993 /* free any machine hw params */
994 if (rtd->dai_link->ops && rtd->dai_link->ops->hw_free)
995 rtd->dai_link->ops->hw_free(substream);
996
997 /* free any DMA resources */
998 if (platform->driver->ops && platform->driver->ops->hw_free)
999 platform->driver->ops->hw_free(substream);
1000
1001 /* now free hw params for the DAIs */
2e5894d7
BC		 1002 for (i = 0; i < rtd->num_codecs; i++) {
1003 codec_dai = rtd->codec_dais[i];
1004 if (codec_dai->driver->ops && codec_dai->driver->ops->hw_free)
1005 codec_dai->driver->ops->hw_free(substream, codec_dai);
1006 }
ddee627c 1007
c5914b0a 1008 if (cpu_dai->driver->ops && cpu_dai->driver->ops->hw_free)
ddee627c
LG		 1009 cpu_dai->driver->ops->hw_free(substream, cpu_dai);
1010
b8c0dab9 1011 mutex_unlock(&rtd->pcm_mutex);
ddee627c
LG		 1012 return 0;
1013}
1014
1015static int soc_pcm_trigger(struct snd_pcm_substream *substream, int cmd)
1016{
1017 struct snd_soc_pcm_runtime *rtd = substream->private_data;
1018 struct snd_soc_platform *platform = rtd->platform;
1019 struct snd_soc_dai *cpu_dai = rtd->cpu_dai;
2e5894d7
BC		 1020 struct snd_soc_dai *codec_dai;
1021 int i, ret;
1022
1023 for (i = 0; i < rtd->num_codecs; i++) {
1024 codec_dai = rtd->codec_dais[i];
1025 if (codec_dai->driver->ops && codec_dai->driver->ops->trigger) {
1026 ret = codec_dai->driver->ops->trigger(substream,
1027 cmd, codec_dai);
1028 if (ret < 0)
1029 return ret;
1030 }
ddee627c
LG		 1031 }
1032
1033 if (platform->driver->ops && platform->driver->ops->trigger) {
1034 ret = platform->driver->ops->trigger(substream, cmd);
1035 if (ret < 0)
1036 return ret;
1037 }
1038
c5914b0a 1039 if (cpu_dai->driver->ops && cpu_dai->driver->ops->trigger) {
ddee627c
LG		 1040 ret = cpu_dai->driver->ops->trigger(substream, cmd, cpu_dai);
1041 if (ret < 0)
1042 return ret;
1043 }
4792b0db
JN		 1044
1045 if (rtd->dai_link->ops && rtd->dai_link->ops->trigger) {
1046 ret = rtd->dai_link->ops->trigger(substream, cmd);
1047 if (ret < 0)
1048 return ret;
1049 }
1050
ddee627c
LG		 1051 return 0;
1052}
1053
45c0a188
MB		 1054static int soc_pcm_bespoke_trigger(struct snd_pcm_substream *substream,
1055 int cmd)
07bf84aa
LG		 1056{
1057 struct snd_soc_pcm_runtime *rtd = substream->private_data;
1058 struct snd_soc_platform *platform = rtd->platform;
1059 struct snd_soc_dai *cpu_dai = rtd->cpu_dai;
2e5894d7
BC		 1060 struct snd_soc_dai *codec_dai;
1061 int i, ret;
1062
1063 for (i = 0; i < rtd->num_codecs; i++) {
1064 codec_dai = rtd->codec_dais[i];
1065 if (codec_dai->driver->ops &&
1066 codec_dai->driver->ops->bespoke_trigger) {
1067 ret = codec_dai->driver->ops->bespoke_trigger(substream,
1068 cmd, codec_dai);
1069 if (ret < 0)
1070 return ret;
1071 }
07bf84aa
LG		 1072 }
1073
dcf0fa27 1074 if (platform->driver->bespoke_trigger) {
07bf84aa
LG		 1075 ret = platform->driver->bespoke_trigger(substream, cmd);
1076 if (ret < 0)
1077 return ret;
1078 }
1079
c5914b0a 1080 if (cpu_dai->driver->ops && cpu_dai->driver->ops->bespoke_trigger) {
07bf84aa
LG		 1081 ret = cpu_dai->driver->ops->bespoke_trigger(substream, cmd, cpu_dai);
1082 if (ret < 0)
1083 return ret;
1084 }
1085 return 0;
1086}
ddee627c
LG		 1087/*
1088 * soc level wrapper for pointer callback
1089 * If cpu_dai, codec_dai, platform driver has the delay callback, than
1090 * the runtime->delay will be updated accordingly.
1091 */
1092static snd_pcm_uframes_t soc_pcm_pointer(struct snd_pcm_substream *substream)
1093{
1094 struct snd_soc_pcm_runtime *rtd = substream->private_data;
1095 struct snd_soc_platform *platform = rtd->platform;
1096 struct snd_soc_dai *cpu_dai = rtd->cpu_dai;
2e5894d7 1097 struct snd_soc_dai *codec_dai;
ddee627c
LG		 1098 struct snd_pcm_runtime *runtime = substream->runtime;
1099 snd_pcm_uframes_t offset = 0;
1100 snd_pcm_sframes_t delay = 0;
2e5894d7
BC		 1101 snd_pcm_sframes_t codec_delay = 0;
1102 int i;
ddee627c
LG		 1103
1104 if (platform->driver->ops && platform->driver->ops->pointer)
1105 offset = platform->driver->ops->pointer(substream);
1106
c5914b0a 1107 if (cpu_dai->driver->ops && cpu_dai->driver->ops->delay)
ddee627c
LG		 1108 delay += cpu_dai->driver->ops->delay(substream, cpu_dai);
1109
2e5894d7
BC		 1110 for (i = 0; i < rtd->num_codecs; i++) {
1111 codec_dai = rtd->codec_dais[i];
1112 if (codec_dai->driver->ops && codec_dai->driver->ops->delay)
1113 codec_delay = max(codec_delay,
1114 codec_dai->driver->ops->delay(substream,
1115 codec_dai));
1116 }
1117 delay += codec_delay;
ddee627c 1118
2e5894d7
BC		 1119 /*
1120 * None of the existing platform drivers implement delay(), so
1121 * for now the codec_dai of first multicodec entry is used
1122 */
ddee627c 1123 if (platform->driver->delay)
2e5894d7 1124 delay += platform->driver->delay(substream, rtd->codec_dais[0]);
ddee627c
LG		 1125
1126 runtime->delay = delay;
1127
1128 return offset;
1129}
1130
01d7584c
LG		 1131/* connect a FE and BE */
1132static int dpcm_be_connect(struct snd_soc_pcm_runtime *fe,
1133 struct snd_soc_pcm_runtime *be, int stream)
1134{
1135 struct snd_soc_dpcm *dpcm;
1136
1137 /* only add new dpcms */
1138 list_for_each_entry(dpcm, &fe->dpcm[stream].be_clients, list_be) {
1139 if (dpcm->be == be && dpcm->fe == fe)
1140 return 0;
1141 }
1142
1143 dpcm = kzalloc(sizeof(struct snd_soc_dpcm), GFP_KERNEL);
1144 if (!dpcm)
1145 return -ENOMEM;
1146
1147 dpcm->be = be;
1148 dpcm->fe = fe;
1149 be->dpcm[stream].runtime = fe->dpcm[stream].runtime;
1150 dpcm->state = SND_SOC_DPCM_LINK_STATE_NEW;
1151 list_add(&dpcm->list_be, &fe->dpcm[stream].be_clients);
1152 list_add(&dpcm->list_fe, &be->dpcm[stream].fe_clients);
1153
7cc302d2 1154 dev_dbg(fe->dev, "connected new DPCM %s path %s %s %s\n",
01d7584c
LG		 1155 stream ? "capture" : "playback", fe->dai_link->name,
1156 stream ? "<-" : "->", be->dai_link->name);
1157
f86dcef8 1158#ifdef CONFIG_DEBUG_FS
6553bf06
LPC		 1159 if (fe->debugfs_dpcm_root)
1160 dpcm->debugfs_state = debugfs_create_u32(be->dai_link->name, 0644,
1161 fe->debugfs_dpcm_root, &dpcm->state);
f86dcef8 1162#endif
01d7584c
LG		 1163 return 1;
1164}
1165
1166/* reparent a BE onto another FE */
1167static void dpcm_be_reparent(struct snd_soc_pcm_runtime *fe,
1168 struct snd_soc_pcm_runtime *be, int stream)
1169{
1170 struct snd_soc_dpcm *dpcm;
1171 struct snd_pcm_substream *fe_substream, *be_substream;
1172
1173 /* reparent if BE is connected to other FEs */
1174 if (!be->dpcm[stream].users)
1175 return;
1176
1177 be_substream = snd_soc_dpcm_get_substream(be, stream);
1178
1179 list_for_each_entry(dpcm, &be->dpcm[stream].fe_clients, list_fe) {
1180 if (dpcm->fe == fe)
1181 continue;
1182
7cc302d2 1183 dev_dbg(fe->dev, "reparent %s path %s %s %s\n",
01d7584c
LG		 1184 stream ? "capture" : "playback",
1185 dpcm->fe->dai_link->name,
1186 stream ? "<-" : "->", dpcm->be->dai_link->name);
1187
1188 fe_substream = snd_soc_dpcm_get_substream(dpcm->fe, stream);
1189 be_substream->runtime = fe_substream->runtime;
1190 break;
1191 }
1192}
1193
1194/* disconnect a BE and FE */
23607025 1195void dpcm_be_disconnect(struct snd_soc_pcm_runtime *fe, int stream)
01d7584c
LG		 1196{
1197 struct snd_soc_dpcm *dpcm, *d;
1198
1199 list_for_each_entry_safe(dpcm, d, &fe->dpcm[stream].be_clients, list_be) {
103d84a3 1200 dev_dbg(fe->dev, "ASoC: BE %s disconnect check for %s\n",
01d7584c
LG		 1201 stream ? "capture" : "playback",
1202 dpcm->be->dai_link->name);
1203
1204 if (dpcm->state != SND_SOC_DPCM_LINK_STATE_FREE)
1205 continue;
1206
7cc302d2 1207 dev_dbg(fe->dev, "freed DSP %s path %s %s %s\n",
01d7584c
LG		 1208 stream ? "capture" : "playback", fe->dai_link->name,
1209 stream ? "<-" : "->", dpcm->be->dai_link->name);
1210
1211 /* BEs still alive need new FE */
1212 dpcm_be_reparent(fe, dpcm->be, stream);
1213
f86dcef8
LG		 1214#ifdef CONFIG_DEBUG_FS
1215 debugfs_remove(dpcm->debugfs_state);
1216#endif
01d7584c
LG		 1217 list_del(&dpcm->list_be);
1218 list_del(&dpcm->list_fe);
1219 kfree(dpcm);
1220 }
1221}
1222
1223/* get BE for DAI widget and stream */
1224static struct snd_soc_pcm_runtime *dpcm_get_be(struct snd_soc_card *card,
1225 struct snd_soc_dapm_widget *widget, int stream)
1226{
1227 struct snd_soc_pcm_runtime *be;
1a497983 1228 int i;
01d7584c
LG		 1229
1230 if (stream == SNDRV_PCM_STREAM_PLAYBACK) {
1a497983 1231 list_for_each_entry(be, &card->rtd_list, list) {
01d7584c 1232
35ea0655
LG		 1233 if (!be->dai_link->no_pcm)
1234 continue;
1235
2e5894d7 1236 if (be->cpu_dai->playback_widget == widget)
01d7584c 1237 return be;
2e5894d7 1238
1a497983
ML		 1239 for (i = 0; i < be->num_codecs; i++) {
1240 struct snd_soc_dai *dai = be->codec_dais[i];
2e5894d7
BC		 1241 if (dai->playback_widget == widget)
1242 return be;
1243 }
01d7584c
LG		 1244 }
1245 } else {
1246
1a497983 1247 list_for_each_entry(be, &card->rtd_list, list) {
01d7584c 1248
35ea0655
LG		 1249 if (!be->dai_link->no_pcm)
1250 continue;
1251
2e5894d7 1252 if (be->cpu_dai->capture_widget == widget)
01d7584c 1253 return be;
2e5894d7 1254
1a497983
ML		 1255 for (i = 0; i < be->num_codecs; i++) {
1256 struct snd_soc_dai *dai = be->codec_dais[i];
2e5894d7
BC		 1257 if (dai->capture_widget == widget)
1258 return be;
1259 }
01d7584c
LG		 1260 }
1261 }
1262
103d84a3 1263 dev_err(card->dev, "ASoC: can't get %s BE for %s\n",
01d7584c
LG		 1264 stream ? "capture" : "playback", widget->name);
1265 return NULL;
1266}
1267
1268static inline struct snd_soc_dapm_widget *
37018610 1269 dai_get_widget(struct snd_soc_dai *dai, int stream)
01d7584c
LG		 1270{
1271 if (stream == SNDRV_PCM_STREAM_PLAYBACK)
37018610 1272 return dai->playback_widget;
01d7584c 1273 else
37018610 1274 return dai->capture_widget;
01d7584c
LG		 1275}
1276
1277static int widget_in_list(struct snd_soc_dapm_widget_list *list,
1278 struct snd_soc_dapm_widget *widget)
1279{
1280 int i;
1281
1282 for (i = 0; i < list->num_widgets; i++) {
1283 if (widget == list->widgets[i])
1284 return 1;
1285 }
1286
1287 return 0;
1288}
1289
23607025 1290int dpcm_path_get(struct snd_soc_pcm_runtime *fe,
1ce43acf 1291 int stream, struct snd_soc_dapm_widget_list **list)
01d7584c
LG		 1292{
1293 struct snd_soc_dai *cpu_dai = fe->cpu_dai;
01d7584c
LG		 1294 int paths;
1295
01d7584c 1296 /* get number of valid DAI paths and their widgets */
6742064a
PS		 1297 paths = snd_soc_dapm_dai_get_connected_widgets(cpu_dai, stream, list,
1298 NULL);
01d7584c 1299
103d84a3 1300 dev_dbg(fe->dev, "ASoC: found %d audio %s paths\n", paths,
01d7584c
LG		 1301 stream ? "capture" : "playback");
1302
01d7584c
LG		 1303 return paths;
1304}
1305
01d7584c
LG		 1306static int dpcm_prune_paths(struct snd_soc_pcm_runtime *fe, int stream,
1307 struct snd_soc_dapm_widget_list **list_)
1308{
1309 struct snd_soc_dpcm *dpcm;
1310 struct snd_soc_dapm_widget_list *list = *list_;
1311 struct snd_soc_dapm_widget *widget;
1312 int prune = 0;
1313
1314 /* Destroy any old FE <--> BE connections */
1315 list_for_each_entry(dpcm, &fe->dpcm[stream].be_clients, list_be) {
2e5894d7 1316 unsigned int i;
01d7584c
LG		 1317
1318 /* is there a valid CPU DAI widget for this BE */
37018610 1319 widget = dai_get_widget(dpcm->be->cpu_dai, stream);
01d7584c
LG		 1320
1321 /* prune the BE if it's no longer in our active list */
1322 if (widget && widget_in_list(list, widget))
1323 continue;
1324
1325 /* is there a valid CODEC DAI widget for this BE */
2e5894d7
BC		 1326 for (i = 0; i < dpcm->be->num_codecs; i++) {
1327 struct snd_soc_dai *dai = dpcm->be->codec_dais[i];
1328 widget = dai_get_widget(dai, stream);
01d7584c 1329
2e5894d7
BC		 1330 /* prune the BE if it's no longer in our active list */
1331 if (widget && widget_in_list(list, widget))
1332 continue;
1333 }
01d7584c 1334
103d84a3 1335 dev_dbg(fe->dev, "ASoC: pruning %s BE %s for %s\n",
01d7584c
LG		 1336 stream ? "capture" : "playback",
1337 dpcm->be->dai_link->name, fe->dai_link->name);
1338 dpcm->state = SND_SOC_DPCM_LINK_STATE_FREE;
1339 dpcm->be->dpcm[stream].runtime_update = SND_SOC_DPCM_UPDATE_BE;
1340 prune++;
1341 }
1342
103d84a3 1343 dev_dbg(fe->dev, "ASoC: found %d old BE paths for pruning\n", prune);
01d7584c
LG		 1344 return prune;
1345}
1346
1347static int dpcm_add_paths(struct snd_soc_pcm_runtime *fe, int stream,
1348 struct snd_soc_dapm_widget_list **list_)
1349{
1350 struct snd_soc_card *card = fe->card;
1351 struct snd_soc_dapm_widget_list *list = *list_;
1352 struct snd_soc_pcm_runtime *be;
1353 int i, new = 0, err;
1354
1355 /* Create any new FE <--> BE connections */
1356 for (i = 0; i < list->num_widgets; i++) {
1357
4616274d
MB		 1358 switch (list->widgets[i]->id) {
1359 case snd_soc_dapm_dai_in:
c5b8540d
KC		 1360 if (stream != SNDRV_PCM_STREAM_PLAYBACK)
1361 continue;
1362 break;
4616274d 1363 case snd_soc_dapm_dai_out:
c5b8540d
KC		 1364 if (stream != SNDRV_PCM_STREAM_CAPTURE)
1365 continue;
4616274d
MB		 1366 break;
1367 default:
01d7584c 1368 continue;
4616274d 1369 }
01d7584c
LG		 1370
1371 /* is there a valid BE rtd for this widget */
1372 be = dpcm_get_be(card, list->widgets[i], stream);
1373 if (!be) {
103d84a3 1374 dev_err(fe->dev, "ASoC: no BE found for %s\n",
01d7584c
LG		 1375 list->widgets[i]->name);
1376 continue;
1377 }
1378
1379 /* make sure BE is a real BE */
1380 if (!be->dai_link->no_pcm)
1381 continue;
1382
1383 /* don't connect if FE is not running */
23607025 1384 if (!fe->dpcm[stream].runtime && !fe->fe_compr)
01d7584c
LG		 1385 continue;
1386
1387 /* newly connected FE and BE */
1388 err = dpcm_be_connect(fe, be, stream);
1389 if (err < 0) {
103d84a3 1390 dev_err(fe->dev, "ASoC: can't connect %s\n",
01d7584c
LG		 1391 list->widgets[i]->name);
1392 break;
1393 } else if (err == 0) /* already connected */
1394 continue;
1395
1396 /* new */
1397 be->dpcm[stream].runtime_update = SND_SOC_DPCM_UPDATE_BE;
1398 new++;
1399 }
1400
103d84a3 1401 dev_dbg(fe->dev, "ASoC: found %d new BE paths\n", new);
01d7584c
LG		 1402 return new;
1403}
1404
1405/*
1406 * Find the corresponding BE DAIs that source or sink audio to this
1407 * FE substream.
1408 */
23607025 1409int dpcm_process_paths(struct snd_soc_pcm_runtime *fe,
01d7584c
LG		 1410 int stream, struct snd_soc_dapm_widget_list **list, int new)
1411{
1412 if (new)
1413 return dpcm_add_paths(fe, stream, list);
1414 else
1415 return dpcm_prune_paths(fe, stream, list);
1416}
1417
23607025 1418void dpcm_clear_pending_state(struct snd_soc_pcm_runtime *fe, int stream)
01d7584c
LG		 1419{
1420 struct snd_soc_dpcm *dpcm;
1421
1422 list_for_each_entry(dpcm, &fe->dpcm[stream].be_clients, list_be)
1423 dpcm->be->dpcm[stream].runtime_update =
1424 SND_SOC_DPCM_UPDATE_NO;
1425}
1426
1427static void dpcm_be_dai_startup_unwind(struct snd_soc_pcm_runtime *fe,
1428 int stream)
1429{
1430 struct snd_soc_dpcm *dpcm;
1431
1432 /* disable any enabled and non active backends */
1433 list_for_each_entry(dpcm, &fe->dpcm[stream].be_clients, list_be) {
1434
1435 struct snd_soc_pcm_runtime *be = dpcm->be;
1436 struct snd_pcm_substream *be_substream =
1437 snd_soc_dpcm_get_substream(be, stream);
1438
1439 if (be->dpcm[stream].users == 0)
103d84a3 1440 dev_err(be->dev, "ASoC: no users %s at close - state %d\n",
01d7584c
LG		 1441 stream ? "capture" : "playback",
1442 be->dpcm[stream].state);
1443
1444 if (--be->dpcm[stream].users != 0)
1445 continue;
1446
1447 if (be->dpcm[stream].state != SND_SOC_DPCM_STATE_OPEN)
1448 continue;
1449
1450 soc_pcm_close(be_substream);
1451 be_substream->runtime = NULL;
1452 be->dpcm[stream].state = SND_SOC_DPCM_STATE_CLOSE;
1453 }
1454}
1455
23607025 1456int dpcm_be_dai_startup(struct snd_soc_pcm_runtime *fe, int stream)
01d7584c
LG		 1457{
1458 struct snd_soc_dpcm *dpcm;
1459 int err, count = 0;
1460
1461 /* only startup BE DAIs that are either sinks or sources to this FE DAI */
1462 list_for_each_entry(dpcm, &fe->dpcm[stream].be_clients, list_be) {
1463
1464 struct snd_soc_pcm_runtime *be = dpcm->be;
1465 struct snd_pcm_substream *be_substream =
1466 snd_soc_dpcm_get_substream(be, stream);
1467
2062b4c5
RKAL		 1468 if (!be_substream) {
1469 dev_err(be->dev, "ASoC: no backend %s stream\n",
1470 stream ? "capture" : "playback");
1471 continue;
1472 }
1473
01d7584c
LG		 1474 /* is this op for this BE ? */
1475 if (!snd_soc_dpcm_be_can_update(fe, be, stream))
1476 continue;
1477
1478 /* first time the dpcm is open ? */
1479 if (be->dpcm[stream].users == DPCM_MAX_BE_USERS)
103d84a3 1480 dev_err(be->dev, "ASoC: too many users %s at open %d\n",
01d7584c
LG		 1481 stream ? "capture" : "playback",
1482 be->dpcm[stream].state);
1483
1484 if (be->dpcm[stream].users++ != 0)
1485 continue;
1486
1487 if ((be->dpcm[stream].state != SND_SOC_DPCM_STATE_NEW) &&
1488 (be->dpcm[stream].state != SND_SOC_DPCM_STATE_CLOSE))
1489 continue;
1490
2062b4c5
RKAL		 1491 dev_dbg(be->dev, "ASoC: open %s BE %s\n",
1492 stream ? "capture" : "playback", be->dai_link->name);
01d7584c
LG		 1493
1494 be_substream->runtime = be->dpcm[stream].runtime;
1495 err = soc_pcm_open(be_substream);
1496 if (err < 0) {
103d84a3 1497 dev_err(be->dev, "ASoC: BE open failed %d\n", err);
01d7584c
LG		 1498 be->dpcm[stream].users--;
1499 if (be->dpcm[stream].users < 0)
103d84a3 1500 dev_err(be->dev, "ASoC: no users %s at unwind %d\n",
01d7584c
LG		 1501 stream ? "capture" : "playback",
1502 be->dpcm[stream].state);
1503
1504 be->dpcm[stream].state = SND_SOC_DPCM_STATE_CLOSE;
1505 goto unwind;
1506 }
1507
1508 be->dpcm[stream].state = SND_SOC_DPCM_STATE_OPEN;
1509 count++;
1510 }
1511
1512 return count;
1513
1514unwind:
1515 /* disable any enabled and non active backends */
1516 list_for_each_entry_continue_reverse(dpcm, &fe->dpcm[stream].be_clients, list_be) {
1517 struct snd_soc_pcm_runtime *be = dpcm->be;
1518 struct snd_pcm_substream *be_substream =
1519 snd_soc_dpcm_get_substream(be, stream);
1520
1521 if (!snd_soc_dpcm_be_can_update(fe, be, stream))
1522 continue;
1523
1524 if (be->dpcm[stream].users == 0)
103d84a3 1525 dev_err(be->dev, "ASoC: no users %s at close %d\n",
01d7584c
LG		 1526 stream ? "capture" : "playback",
1527 be->dpcm[stream].state);
1528
1529 if (--be->dpcm[stream].users != 0)
1530 continue;
1531
1532 if (be->dpcm[stream].state != SND_SOC_DPCM_STATE_OPEN)
1533 continue;
1534
1535 soc_pcm_close(be_substream);
1536 be_substream->runtime = NULL;
1537 be->dpcm[stream].state = SND_SOC_DPCM_STATE_CLOSE;
1538 }
1539
1540 return err;
1541}
1542
08ae9b45 1543static void dpcm_init_runtime_hw(struct snd_pcm_runtime *runtime,
b073ed4e
KM		 1544 struct snd_soc_pcm_stream *stream,
1545 u64 formats)
08ae9b45
LPC		 1546{
1547 runtime->hw.rate_min = stream->rate_min;
1548 runtime->hw.rate_max = stream->rate_max;
1549 runtime->hw.channels_min = stream->channels_min;
1550 runtime->hw.channels_max = stream->channels_max;
002220a9 1551 if (runtime->hw.formats)
b073ed4e 1552 runtime->hw.formats &= formats & stream->formats;
002220a9 1553 else
b073ed4e 1554 runtime->hw.formats = formats & stream->formats;
08ae9b45
LPC		 1555 runtime->hw.rates = stream->rates;
1556}
1557
b073ed4e
KM		 1558static u64 dpcm_runtime_base_format(struct snd_pcm_substream *substream)
1559{
1560 struct snd_soc_pcm_runtime *fe = substream->private_data;
1561 struct snd_soc_dpcm *dpcm;
1562 u64 formats = ULLONG_MAX;
1563 int stream = substream->stream;
1564
1565 if (!fe->dai_link->dpcm_merged_format)
1566 return formats;
1567
1568 /*
1569 * It returns merged BE codec format
1570 * if FE want to use it (= dpcm_merged_format)
1571 */
1572
1573 list_for_each_entry(dpcm, &fe->dpcm[stream].be_clients, list_be) {
1574 struct snd_soc_pcm_runtime *be = dpcm->be;
1575 struct snd_soc_dai_driver *codec_dai_drv;
1576 struct snd_soc_pcm_stream *codec_stream;
1577 int i;
1578
1579 for (i = 0; i < be->num_codecs; i++) {
1580 codec_dai_drv = be->codec_dais[i]->driver;
1581 if (stream == SNDRV_PCM_STREAM_PLAYBACK)
1582 codec_stream = &codec_dai_drv->playback;
1583 else
1584 codec_stream = &codec_dai_drv->capture;
1585
1586 formats &= codec_stream->formats;
1587 }
1588 }
1589
1590 return formats;
1591}
1592
45c0a188 1593static void dpcm_set_fe_runtime(struct snd_pcm_substream *substream)
01d7584c
LG		 1594{
1595 struct snd_pcm_runtime *runtime = substream->runtime;
1596 struct snd_soc_pcm_runtime *rtd = substream->private_data;
1597 struct snd_soc_dai *cpu_dai = rtd->cpu_dai;
1598 struct snd_soc_dai_driver *cpu_dai_drv = cpu_dai->driver;
b073ed4e 1599 u64 format = dpcm_runtime_base_format(substream);
01d7584c 1600
08ae9b45 1601 if (substream->stream == SNDRV_PCM_STREAM_PLAYBACK)
b073ed4e 1602 dpcm_init_runtime_hw(runtime, &cpu_dai_drv->playback, format);
08ae9b45 1603 else
b073ed4e 1604 dpcm_init_runtime_hw(runtime, &cpu_dai_drv->capture, format);
01d7584c
LG		 1605}
1606
ea9d0d77
TI		 1607static int dpcm_fe_dai_do_trigger(struct snd_pcm_substream *substream, int cmd);
1608
1609/* Set FE's runtime_update state; the state is protected via PCM stream lock
1610 * for avoiding the race with trigger callback.
1611 * If the state is unset and a trigger is pending while the previous operation,
1612 * process the pending trigger action here.
1613 */
1614static void dpcm_set_fe_update_state(struct snd_soc_pcm_runtime *fe,
1615 int stream, enum snd_soc_dpcm_update state)
1616{
1617 struct snd_pcm_substream *substream =
1618 snd_soc_dpcm_get_substream(fe, stream);
1619
1620 snd_pcm_stream_lock_irq(substream);
1621 if (state == SND_SOC_DPCM_UPDATE_NO && fe->dpcm[stream].trigger_pending) {
1622 dpcm_fe_dai_do_trigger(substream,
1623 fe->dpcm[stream].trigger_pending - 1);
1624 fe->dpcm[stream].trigger_pending = 0;
1625 }
1626 fe->dpcm[stream].runtime_update = state;
1627 snd_pcm_stream_unlock_irq(substream);
1628}
1629
906c7d69
PL		 1630static int dpcm_apply_symmetry(struct snd_pcm_substream *fe_substream,
1631 int stream)
1632{
1633 struct snd_soc_dpcm *dpcm;
1634 struct snd_soc_pcm_runtime *fe = fe_substream->private_data;
1635 struct snd_soc_dai *fe_cpu_dai = fe->cpu_dai;
1636 int err;
1637
1638 /* apply symmetry for FE */
1639 if (soc_pcm_has_symmetry(fe_substream))
1640 fe_substream->runtime->hw.info |= SNDRV_PCM_INFO_JOINT_DUPLEX;
1641
1642 /* Symmetry only applies if we've got an active stream. */
1643 if (fe_cpu_dai->active) {
1644 err = soc_pcm_apply_symmetry(fe_substream, fe_cpu_dai);
1645 if (err < 0)
1646 return err;
1647 }
1648
1649 /* apply symmetry for BE */
1650 list_for_each_entry(dpcm, &fe->dpcm[stream].be_clients, list_be) {
1651 struct snd_soc_pcm_runtime *be = dpcm->be;
1652 struct snd_pcm_substream *be_substream =
1653 snd_soc_dpcm_get_substream(be, stream);
1654 struct snd_soc_pcm_runtime *rtd = be_substream->private_data;
1655 int i;
1656
1657 if (soc_pcm_has_symmetry(be_substream))
1658 be_substream->runtime->hw.info |= SNDRV_PCM_INFO_JOINT_DUPLEX;
1659
1660 /* Symmetry only applies if we've got an active stream. */
1661 if (rtd->cpu_dai->active) {
1662 err = soc_pcm_apply_symmetry(be_substream, rtd->cpu_dai);
1663 if (err < 0)
1664 return err;
1665 }
1666
1667 for (i = 0; i < rtd->num_codecs; i++) {
1668 if (rtd->codec_dais[i]->active) {
1669 err = soc_pcm_apply_symmetry(be_substream,
1670 rtd->codec_dais[i]);
1671 if (err < 0)
1672 return err;
1673 }
1674 }
1675 }
1676
1677 return 0;
1678}
1679
01d7584c
LG		 1680static int dpcm_fe_dai_startup(struct snd_pcm_substream *fe_substream)
1681{
1682 struct snd_soc_pcm_runtime *fe = fe_substream->private_data;
1683 struct snd_pcm_runtime *runtime = fe_substream->runtime;
1684 int stream = fe_substream->stream, ret = 0;
1685
ea9d0d77 1686 dpcm_set_fe_update_state(fe, stream, SND_SOC_DPCM_UPDATE_FE);
01d7584c
LG		 1687
1688 ret = dpcm_be_dai_startup(fe, fe_substream->stream);
1689 if (ret < 0) {
103d84a3 1690 dev_err(fe->dev,"ASoC: failed to start some BEs %d\n", ret);
01d7584c
LG		 1691 goto be_err;
1692 }
1693
103d84a3 1694 dev_dbg(fe->dev, "ASoC: open FE %s\n", fe->dai_link->name);
01d7584c
LG		 1695
1696 /* start the DAI frontend */
1697 ret = soc_pcm_open(fe_substream);
1698 if (ret < 0) {
103d84a3 1699 dev_err(fe->dev,"ASoC: failed to start FE %d\n", ret);
01d7584c
LG		 1700 goto unwind;
1701 }
1702
1703 fe->dpcm[stream].state = SND_SOC_DPCM_STATE_OPEN;
1704
1705 dpcm_set_fe_runtime(fe_substream);
1706 snd_pcm_limit_hw_rates(runtime);
1707
906c7d69
PL		 1708 ret = dpcm_apply_symmetry(fe_substream, stream);
1709 if (ret < 0) {
1710 dev_err(fe->dev, "ASoC: failed to apply dpcm symmetry %d\n",
1711 ret);
1712 goto unwind;
1713 }
1714
ea9d0d77 1715 dpcm_set_fe_update_state(fe, stream, SND_SOC_DPCM_UPDATE_NO);
01d7584c
LG		 1716 return 0;
1717
1718unwind:
1719 dpcm_be_dai_startup_unwind(fe, fe_substream->stream);
1720be_err:
ea9d0d77 1721 dpcm_set_fe_update_state(fe, stream, SND_SOC_DPCM_UPDATE_NO);
01d7584c
LG		 1722 return ret;
1723}
1724
23607025 1725int dpcm_be_dai_shutdown(struct snd_soc_pcm_runtime *fe, int stream)
01d7584c
LG		 1726{
1727 struct snd_soc_dpcm *dpcm;
1728
1729 /* only shutdown BEs that are either sinks or sources to this FE DAI */
1730 list_for_each_entry(dpcm, &fe->dpcm[stream].be_clients, list_be) {
1731
1732 struct snd_soc_pcm_runtime *be = dpcm->be;
1733 struct snd_pcm_substream *be_substream =
1734 snd_soc_dpcm_get_substream(be, stream);
1735
1736 /* is this op for this BE ? */
1737 if (!snd_soc_dpcm_be_can_update(fe, be, stream))
1738 continue;
1739
1740 if (be->dpcm[stream].users == 0)
103d84a3 1741 dev_err(be->dev, "ASoC: no users %s at close - state %d\n",
01d7584c
LG		 1742 stream ? "capture" : "playback",
1743 be->dpcm[stream].state);
1744
1745 if (--be->dpcm[stream].users != 0)
1746 continue;
1747
1748 if ((be->dpcm[stream].state != SND_SOC_DPCM_STATE_HW_FREE) &&
1749 (be->dpcm[stream].state != SND_SOC_DPCM_STATE_OPEN))
1750 continue;
1751
103d84a3 1752 dev_dbg(be->dev, "ASoC: close BE %s\n",
01d7584c
LG		 1753 dpcm->fe->dai_link->name);
1754
1755 soc_pcm_close(be_substream);
1756 be_substream->runtime = NULL;
1757
1758 be->dpcm[stream].state = SND_SOC_DPCM_STATE_CLOSE;
1759 }
1760 return 0;
1761}
1762
1763static int dpcm_fe_dai_shutdown(struct snd_pcm_substream *substream)
1764{
1765 struct snd_soc_pcm_runtime *fe = substream->private_data;
1766 int stream = substream->stream;
1767
ea9d0d77 1768 dpcm_set_fe_update_state(fe, stream, SND_SOC_DPCM_UPDATE_FE);
01d7584c
LG		 1769
1770 /* shutdown the BEs */
1771 dpcm_be_dai_shutdown(fe, substream->stream);
1772
103d84a3 1773 dev_dbg(fe->dev, "ASoC: close FE %s\n", fe->dai_link->name);
01d7584c
LG		 1774
1775 /* now shutdown the frontend */
1776 soc_pcm_close(substream);
1777
1778 /* run the stream event for each BE */
1779 dpcm_dapm_stream_event(fe, stream, SND_SOC_DAPM_STREAM_STOP);
1780
1781 fe->dpcm[stream].state = SND_SOC_DPCM_STATE_CLOSE;
ea9d0d77 1782 dpcm_set_fe_update_state(fe, stream, SND_SOC_DPCM_UPDATE_NO);
01d7584c
LG		 1783 return 0;
1784}
1785
23607025 1786int dpcm_be_dai_hw_free(struct snd_soc_pcm_runtime *fe, int stream)
01d7584c
LG		 1787{
1788 struct snd_soc_dpcm *dpcm;
1789
1790 /* only hw_params backends that are either sinks or sources
1791 * to this frontend DAI */
1792 list_for_each_entry(dpcm, &fe->dpcm[stream].be_clients, list_be) {
1793
1794 struct snd_soc_pcm_runtime *be = dpcm->be;
1795 struct snd_pcm_substream *be_substream =
1796 snd_soc_dpcm_get_substream(be, stream);
1797
1798 /* is this op for this BE ? */
1799 if (!snd_soc_dpcm_be_can_update(fe, be, stream))
1800 continue;
1801
1802 /* only free hw when no longer used - check all FEs */
1803 if (!snd_soc_dpcm_can_be_free_stop(fe, be, stream))
1804 continue;
1805
36fba62c
QZ		 1806 /* do not free hw if this BE is used by other FE */
1807 if (be->dpcm[stream].users > 1)
1808 continue;
1809
01d7584c
LG		 1810 if ((be->dpcm[stream].state != SND_SOC_DPCM_STATE_HW_PARAMS) &&
1811 (be->dpcm[stream].state != SND_SOC_DPCM_STATE_PREPARE) &&
1812 (be->dpcm[stream].state != SND_SOC_DPCM_STATE_HW_FREE) &&
08b27848 1813 (be->dpcm[stream].state != SND_SOC_DPCM_STATE_PAUSED) &&
5e82d2be
VK		 1814 (be->dpcm[stream].state != SND_SOC_DPCM_STATE_STOP) &&
1815 (be->dpcm[stream].state != SND_SOC_DPCM_STATE_SUSPEND))
01d7584c
LG		 1816 continue;
1817
103d84a3 1818 dev_dbg(be->dev, "ASoC: hw_free BE %s\n",
01d7584c
LG		 1819 dpcm->fe->dai_link->name);
1820
1821 soc_pcm_hw_free(be_substream);
1822
1823 be->dpcm[stream].state = SND_SOC_DPCM_STATE_HW_FREE;
1824 }
1825
1826 return 0;
1827}
1828
45c0a188 1829static int dpcm_fe_dai_hw_free(struct snd_pcm_substream *substream)
01d7584c
LG		 1830{
1831 struct snd_soc_pcm_runtime *fe = substream->private_data;
1832 int err, stream = substream->stream;
1833
1834 mutex_lock_nested(&fe->card->mutex, SND_SOC_CARD_CLASS_RUNTIME);
ea9d0d77 1835 dpcm_set_fe_update_state(fe, stream, SND_SOC_DPCM_UPDATE_FE);
01d7584c 1836
103d84a3 1837 dev_dbg(fe->dev, "ASoC: hw_free FE %s\n", fe->dai_link->name);
01d7584c
LG		 1838
1839 /* call hw_free on the frontend */
1840 err = soc_pcm_hw_free(substream);
1841 if (err < 0)
103d84a3 1842 dev_err(fe->dev,"ASoC: hw_free FE %s failed\n",
01d7584c
LG		 1843 fe->dai_link->name);
1844
1845 /* only hw_params backends that are either sinks or sources
1846 * to this frontend DAI */
1847 err = dpcm_be_dai_hw_free(fe, stream);
1848
1849 fe->dpcm[stream].state = SND_SOC_DPCM_STATE_HW_FREE;
ea9d0d77 1850 dpcm_set_fe_update_state(fe, stream, SND_SOC_DPCM_UPDATE_NO);
01d7584c
LG		 1851
1852 mutex_unlock(&fe->card->mutex);
1853 return 0;
1854}
1855
23607025 1856int dpcm_be_dai_hw_params(struct snd_soc_pcm_runtime *fe, int stream)
01d7584c
LG		 1857{
1858 struct snd_soc_dpcm *dpcm;
1859 int ret;
1860
1861 list_for_each_entry(dpcm, &fe->dpcm[stream].be_clients, list_be) {
1862
1863 struct snd_soc_pcm_runtime *be = dpcm->be;
1864 struct snd_pcm_substream *be_substream =
1865 snd_soc_dpcm_get_substream(be, stream);
1866
1867 /* is this op for this BE ? */
1868 if (!snd_soc_dpcm_be_can_update(fe, be, stream))
1869 continue;
1870
01d7584c
LG		 1871 /* copy params for each dpcm */
1872 memcpy(&dpcm->hw_params, &fe->dpcm[stream].hw_params,
1873 sizeof(struct snd_pcm_hw_params));
1874
1875 /* perform any hw_params fixups */
1876 if (be->dai_link->be_hw_params_fixup) {
1877 ret = be->dai_link->be_hw_params_fixup(be,
1878 &dpcm->hw_params);
1879 if (ret < 0) {
1880 dev_err(be->dev,
103d84a3 1881 "ASoC: hw_params BE fixup failed %d\n",
01d7584c
LG		 1882 ret);
1883 goto unwind;
1884 }
1885 }
1886
b0639bd2
KM		 1887 /* only allow hw_params() if no connected FEs are running */
1888 if (!snd_soc_dpcm_can_be_params(fe, be, stream))
1889 continue;
1890
1891 if ((be->dpcm[stream].state != SND_SOC_DPCM_STATE_OPEN) &&
1892 (be->dpcm[stream].state != SND_SOC_DPCM_STATE_HW_PARAMS) &&
1893 (be->dpcm[stream].state != SND_SOC_DPCM_STATE_HW_FREE))
1894 continue;
1895
1896 dev_dbg(be->dev, "ASoC: hw_params BE %s\n",
1897 dpcm->fe->dai_link->name);
1898
01d7584c
LG		 1899 ret = soc_pcm_hw_params(be_substream, &dpcm->hw_params);
1900 if (ret < 0) {
1901 dev_err(dpcm->be->dev,
103d84a3 1902 "ASoC: hw_params BE failed %d\n", ret);
01d7584c
LG		 1903 goto unwind;
1904 }
1905
1906 be->dpcm[stream].state = SND_SOC_DPCM_STATE_HW_PARAMS;
1907 }
1908 return 0;
1909
1910unwind:
1911 /* disable any enabled and non active backends */
1912 list_for_each_entry_continue_reverse(dpcm, &fe->dpcm[stream].be_clients, list_be) {
1913 struct snd_soc_pcm_runtime *be = dpcm->be;
1914 struct snd_pcm_substream *be_substream =
1915 snd_soc_dpcm_get_substream(be, stream);
1916
1917 if (!snd_soc_dpcm_be_can_update(fe, be, stream))
1918 continue;
1919
1920 /* only allow hw_free() if no connected FEs are running */
1921 if (!snd_soc_dpcm_can_be_free_stop(fe, be, stream))
1922 continue;
1923
1924 if ((be->dpcm[stream].state != SND_SOC_DPCM_STATE_OPEN) &&
1925 (be->dpcm[stream].state != SND_SOC_DPCM_STATE_HW_PARAMS) &&
1926 (be->dpcm[stream].state != SND_SOC_DPCM_STATE_HW_FREE) &&
1927 (be->dpcm[stream].state != SND_SOC_DPCM_STATE_STOP))
1928 continue;
1929
1930 soc_pcm_hw_free(be_substream);
1931 }
1932
1933 return ret;
1934}
1935
45c0a188
MB		 1936static int dpcm_fe_dai_hw_params(struct snd_pcm_substream *substream,
1937 struct snd_pcm_hw_params *params)
01d7584c
LG		 1938{
1939 struct snd_soc_pcm_runtime *fe = substream->private_data;
1940 int ret, stream = substream->stream;
1941
1942 mutex_lock_nested(&fe->card->mutex, SND_SOC_CARD_CLASS_RUNTIME);
ea9d0d77 1943 dpcm_set_fe_update_state(fe, stream, SND_SOC_DPCM_UPDATE_FE);
01d7584c
LG		 1944
1945 memcpy(&fe->dpcm[substream->stream].hw_params, params,
1946 sizeof(struct snd_pcm_hw_params));
1947 ret = dpcm_be_dai_hw_params(fe, substream->stream);
1948 if (ret < 0) {
103d84a3 1949 dev_err(fe->dev,"ASoC: hw_params BE failed %d\n", ret);
01d7584c
LG		 1950 goto out;
1951 }
1952
103d84a3 1953 dev_dbg(fe->dev, "ASoC: hw_params FE %s rate %d chan %x fmt %d\n",
01d7584c
LG		 1954 fe->dai_link->name, params_rate(params),
1955 params_channels(params), params_format(params));
1956
1957 /* call hw_params on the frontend */
1958 ret = soc_pcm_hw_params(substream, params);
1959 if (ret < 0) {
103d84a3 1960 dev_err(fe->dev,"ASoC: hw_params FE failed %d\n", ret);
01d7584c
LG		 1961 dpcm_be_dai_hw_free(fe, stream);
1962 } else
1963 fe->dpcm[stream].state = SND_SOC_DPCM_STATE_HW_PARAMS;
1964
1965out:
ea9d0d77 1966 dpcm_set_fe_update_state(fe, stream, SND_SOC_DPCM_UPDATE_NO);
01d7584c
LG		 1967 mutex_unlock(&fe->card->mutex);
1968 return ret;
1969}
1970
1971static int dpcm_do_trigger(struct snd_soc_dpcm *dpcm,
1972 struct snd_pcm_substream *substream, int cmd)
1973{
1974 int ret;
1975
103d84a3 1976 dev_dbg(dpcm->be->dev, "ASoC: trigger BE %s cmd %d\n",
01d7584c
LG		 1977 dpcm->fe->dai_link->name, cmd);
1978
1979 ret = soc_pcm_trigger(substream, cmd);
1980 if (ret < 0)
103d84a3 1981 dev_err(dpcm->be->dev,"ASoC: trigger BE failed %d\n", ret);
01d7584c
LG		 1982
1983 return ret;
1984}
1985
23607025 1986int dpcm_be_dai_trigger(struct snd_soc_pcm_runtime *fe, int stream,
45c0a188 1987 int cmd)
01d7584c
LG		 1988{
1989 struct snd_soc_dpcm *dpcm;
1990 int ret = 0;
1991
1992 list_for_each_entry(dpcm, &fe->dpcm[stream].be_clients, list_be) {
1993
1994 struct snd_soc_pcm_runtime *be = dpcm->be;
1995 struct snd_pcm_substream *be_substream =
1996 snd_soc_dpcm_get_substream(be, stream);
1997
1998 /* is this op for this BE ? */
1999 if (!snd_soc_dpcm_be_can_update(fe, be, stream))
2000 continue;
2001
2002 switch (cmd) {
2003 case SNDRV_PCM_TRIGGER_START:
2004 if ((be->dpcm[stream].state != SND_SOC_DPCM_STATE_PREPARE) &&
2005 (be->dpcm[stream].state != SND_SOC_DPCM_STATE_STOP))
2006 continue;
2007
2008 ret = dpcm_do_trigger(dpcm, be_substream, cmd);
2009 if (ret)
2010 return ret;
2011
2012 be->dpcm[stream].state = SND_SOC_DPCM_STATE_START;
2013 break;
2014 case SNDRV_PCM_TRIGGER_RESUME:
2015 if ((be->dpcm[stream].state != SND_SOC_DPCM_STATE_SUSPEND))
2016 continue;
2017
2018 ret = dpcm_do_trigger(dpcm, be_substream, cmd);
2019 if (ret)
2020 return ret;
2021
2022 be->dpcm[stream].state = SND_SOC_DPCM_STATE_START;
2023 break;
2024 case SNDRV_PCM_TRIGGER_PAUSE_RELEASE:
2025 if ((be->dpcm[stream].state != SND_SOC_DPCM_STATE_PAUSED))
2026 continue;
2027
2028 ret = dpcm_do_trigger(dpcm, be_substream, cmd);
2029 if (ret)
2030 return ret;
2031
2032 be->dpcm[stream].state = SND_SOC_DPCM_STATE_START;
2033 break;
2034 case SNDRV_PCM_TRIGGER_STOP:
2035 if (be->dpcm[stream].state != SND_SOC_DPCM_STATE_START)
2036 continue;
2037
2038 if (!snd_soc_dpcm_can_be_free_stop(fe, be, stream))
2039 continue;
2040
2041 ret = dpcm_do_trigger(dpcm, be_substream, cmd);
2042 if (ret)
2043 return ret;
2044
2045 be->dpcm[stream].state = SND_SOC_DPCM_STATE_STOP;
2046 break;
2047 case SNDRV_PCM_TRIGGER_SUSPEND:
868a6ca8 2048 if (be->dpcm[stream].state != SND_SOC_DPCM_STATE_START)
01d7584c
LG		 2049 continue;
2050
2051 if (!snd_soc_dpcm_can_be_free_stop(fe, be, stream))
2052 continue;
2053
2054 ret = dpcm_do_trigger(dpcm, be_substream, cmd);
2055 if (ret)
2056 return ret;
2057
2058 be->dpcm[stream].state = SND_SOC_DPCM_STATE_SUSPEND;
2059 break;
2060 case SNDRV_PCM_TRIGGER_PAUSE_PUSH:
2061 if (be->dpcm[stream].state != SND_SOC_DPCM_STATE_START)
2062 continue;
2063
2064 if (!snd_soc_dpcm_can_be_free_stop(fe, be, stream))
2065 continue;
2066
2067 ret = dpcm_do_trigger(dpcm, be_substream, cmd);
2068 if (ret)
2069 return ret;
2070
2071 be->dpcm[stream].state = SND_SOC_DPCM_STATE_PAUSED;
2072 break;
2073 }
2074 }
2075
2076 return ret;
2077}
2078EXPORT_SYMBOL_GPL(dpcm_be_dai_trigger);
2079
ea9d0d77 2080static int dpcm_fe_dai_do_trigger(struct snd_pcm_substream *substream, int cmd)
01d7584c
LG		 2081{
2082 struct snd_soc_pcm_runtime *fe = substream->private_data;
2083 int stream = substream->stream, ret;
2084 enum snd_soc_dpcm_trigger trigger = fe->dai_link->trigger[stream];
2085
2086 fe->dpcm[stream].runtime_update = SND_SOC_DPCM_UPDATE_FE;
2087
2088 switch (trigger) {
2089 case SND_SOC_DPCM_TRIGGER_PRE:
2090 /* call trigger on the frontend before the backend. */
2091
103d84a3 2092 dev_dbg(fe->dev, "ASoC: pre trigger FE %s cmd %d\n",
01d7584c
LG		 2093 fe->dai_link->name, cmd);
2094
2095 ret = soc_pcm_trigger(substream, cmd);
2096 if (ret < 0) {
103d84a3 2097 dev_err(fe->dev,"ASoC: trigger FE failed %d\n", ret);
01d7584c
LG		 2098 goto out;
2099 }
2100
2101 ret = dpcm_be_dai_trigger(fe, substream->stream, cmd);
2102 break;
2103 case SND_SOC_DPCM_TRIGGER_POST:
2104 /* call trigger on the frontend after the backend. */
2105
2106 ret = dpcm_be_dai_trigger(fe, substream->stream, cmd);
2107 if (ret < 0) {
103d84a3 2108 dev_err(fe->dev,"ASoC: trigger FE failed %d\n", ret);
01d7584c
LG		 2109 goto out;
2110 }
2111
103d84a3 2112 dev_dbg(fe->dev, "ASoC: post trigger FE %s cmd %d\n",
01d7584c
LG		 2113 fe->dai_link->name, cmd);
2114
2115 ret = soc_pcm_trigger(substream, cmd);
2116 break;
07bf84aa
LG		 2117 case SND_SOC_DPCM_TRIGGER_BESPOKE:
2118 /* bespoke trigger() - handles both FE and BEs */
2119
103d84a3 2120 dev_dbg(fe->dev, "ASoC: bespoke trigger FE %s cmd %d\n",
07bf84aa
LG		 2121 fe->dai_link->name, cmd);
2122
2123 ret = soc_pcm_bespoke_trigger(substream, cmd);
2124 if (ret < 0) {
103d84a3 2125 dev_err(fe->dev,"ASoC: trigger FE failed %d\n", ret);
07bf84aa
LG		 2126 goto out;
2127 }
2128 break;
01d7584c 2129 default:
103d84a3 2130 dev_err(fe->dev, "ASoC: invalid trigger cmd %d for %s\n", cmd,
01d7584c
LG		 2131 fe->dai_link->name);
2132 ret = -EINVAL;
2133 goto out;
2134 }
2135
2136 switch (cmd) {
2137 case SNDRV_PCM_TRIGGER_START:
2138 case SNDRV_PCM_TRIGGER_RESUME:
2139 case SNDRV_PCM_TRIGGER_PAUSE_RELEASE:
2140 fe->dpcm[stream].state = SND_SOC_DPCM_STATE_START;
2141 break;
2142 case SNDRV_PCM_TRIGGER_STOP:
2143 case SNDRV_PCM_TRIGGER_SUSPEND:
2144 case SNDRV_PCM_TRIGGER_PAUSE_PUSH:
2145 fe->dpcm[stream].state = SND_SOC_DPCM_STATE_STOP;
2146 break;
2147 }
2148
2149out:
2150 fe->dpcm[stream].runtime_update = SND_SOC_DPCM_UPDATE_NO;
2151 return ret;
2152}
2153
ea9d0d77
TI		 2154static int dpcm_fe_dai_trigger(struct snd_pcm_substream *substream, int cmd)
2155{
2156 struct snd_soc_pcm_runtime *fe = substream->private_data;
2157 int stream = substream->stream;
2158
2159 /* if FE's runtime_update is already set, we're in race;
2160 * process this trigger later at exit
2161 */
2162 if (fe->dpcm[stream].runtime_update != SND_SOC_DPCM_UPDATE_NO) {
2163 fe->dpcm[stream].trigger_pending = cmd + 1;
2164 return 0; /* delayed, assuming it's successful */
2165 }
2166
2167 /* we're alone, let's trigger */
2168 return dpcm_fe_dai_do_trigger(substream, cmd);
2169}
2170
23607025 2171int dpcm_be_dai_prepare(struct snd_soc_pcm_runtime *fe, int stream)
01d7584c
LG		 2172{
2173 struct snd_soc_dpcm *dpcm;
2174 int ret = 0;
2175
2176 list_for_each_entry(dpcm, &fe->dpcm[stream].be_clients, list_be) {
2177
2178 struct snd_soc_pcm_runtime *be = dpcm->be;
2179 struct snd_pcm_substream *be_substream =
2180 snd_soc_dpcm_get_substream(be, stream);
2181
2182 /* is this op for this BE ? */
2183 if (!snd_soc_dpcm_be_can_update(fe, be, stream))
2184 continue;
2185
2186 if ((be->dpcm[stream].state != SND_SOC_DPCM_STATE_HW_PARAMS) &&
95f444dc
KC		 2187 (be->dpcm[stream].state != SND_SOC_DPCM_STATE_STOP) &&
2188 (be->dpcm[stream].state != SND_SOC_DPCM_STATE_SUSPEND))
01d7584c
LG		 2189 continue;
2190
103d84a3 2191 dev_dbg(be->dev, "ASoC: prepare BE %s\n",
01d7584c
LG		 2192 dpcm->fe->dai_link->name);
2193
2194 ret = soc_pcm_prepare(be_substream);
2195 if (ret < 0) {
103d84a3 2196 dev_err(be->dev, "ASoC: backend prepare failed %d\n",
01d7584c
LG		 2197 ret);
2198 break;
2199 }
2200
2201 be->dpcm[stream].state = SND_SOC_DPCM_STATE_PREPARE;
2202 }
2203 return ret;
2204}
2205
45c0a188 2206static int dpcm_fe_dai_prepare(struct snd_pcm_substream *substream)
01d7584c
LG		 2207{
2208 struct snd_soc_pcm_runtime *fe = substream->private_data;
2209 int stream = substream->stream, ret = 0;
2210
2211 mutex_lock_nested(&fe->card->mutex, SND_SOC_CARD_CLASS_RUNTIME);
2212
103d84a3 2213 dev_dbg(fe->dev, "ASoC: prepare FE %s\n", fe->dai_link->name);
01d7584c 2214
ea9d0d77 2215 dpcm_set_fe_update_state(fe, stream, SND_SOC_DPCM_UPDATE_FE);
01d7584c
LG		 2216
2217 /* there is no point preparing this FE if there are no BEs */
2218 if (list_empty(&fe->dpcm[stream].be_clients)) {
103d84a3 2219 dev_err(fe->dev, "ASoC: no backend DAIs enabled for %s\n",
01d7584c
LG		 2220 fe->dai_link->name);
2221 ret = -EINVAL;
2222 goto out;
2223 }
2224
2225 ret = dpcm_be_dai_prepare(fe, substream->stream);
2226 if (ret < 0)
2227 goto out;
2228
2229 /* call prepare on the frontend */
2230 ret = soc_pcm_prepare(substream);
2231 if (ret < 0) {
103d84a3 2232 dev_err(fe->dev,"ASoC: prepare FE %s failed\n",
01d7584c
LG		 2233 fe->dai_link->name);
2234 goto out;
2235 }
2236
2237 /* run the stream event for each BE */
2238 dpcm_dapm_stream_event(fe, stream, SND_SOC_DAPM_STREAM_START);
2239 fe->dpcm[stream].state = SND_SOC_DPCM_STATE_PREPARE;
2240
2241out:
ea9d0d77 2242 dpcm_set_fe_update_state(fe, stream, SND_SOC_DPCM_UPDATE_NO);
01d7584c
LG		 2243 mutex_unlock(&fe->card->mutex);
2244
2245 return ret;
2246}
2247
be3f3f2c
LG		 2248static int soc_pcm_ioctl(struct snd_pcm_substream *substream,
2249 unsigned int cmd, void *arg)
2250{
2251 struct snd_soc_pcm_runtime *rtd = substream->private_data;
2252 struct snd_soc_platform *platform = rtd->platform;
2253
c5914b0a 2254 if (platform->driver->ops && platform->driver->ops->ioctl)
be3f3f2c
LG		 2255 return platform->driver->ops->ioctl(substream, cmd, arg);
2256 return snd_pcm_lib_ioctl(substream, cmd, arg);
2257}
2258
618dae11
LG		 2259static int dpcm_run_update_shutdown(struct snd_soc_pcm_runtime *fe, int stream)
2260{
07bf84aa
LG		 2261 struct snd_pcm_substream *substream =
2262 snd_soc_dpcm_get_substream(fe, stream);
2263 enum snd_soc_dpcm_trigger trigger = fe->dai_link->trigger[stream];
618dae11
LG		 2264 int err;
2265
103d84a3 2266 dev_dbg(fe->dev, "ASoC: runtime %s close on FE %s\n",
618dae11
LG		 2267 stream ? "capture" : "playback", fe->dai_link->name);
2268
07bf84aa
LG		 2269 if (trigger == SND_SOC_DPCM_TRIGGER_BESPOKE) {
2270 /* call bespoke trigger - FE takes care of all BE triggers */
103d84a3 2271 dev_dbg(fe->dev, "ASoC: bespoke trigger FE %s cmd stop\n",
07bf84aa
LG		 2272 fe->dai_link->name);
2273
2274 err = soc_pcm_bespoke_trigger(substream, SNDRV_PCM_TRIGGER_STOP);
2275 if (err < 0)
103d84a3 2276 dev_err(fe->dev,"ASoC: trigger FE failed %d\n", err);
07bf84aa 2277 } else {
103d84a3 2278 dev_dbg(fe->dev, "ASoC: trigger FE %s cmd stop\n",
07bf84aa
LG		 2279 fe->dai_link->name);
2280
2281 err = dpcm_be_dai_trigger(fe, stream, SNDRV_PCM_TRIGGER_STOP);
2282 if (err < 0)
103d84a3 2283 dev_err(fe->dev,"ASoC: trigger FE failed %d\n", err);
07bf84aa 2284 }
618dae11
LG		 2285
2286 err = dpcm_be_dai_hw_free(fe, stream);
2287 if (err < 0)
103d84a3 2288 dev_err(fe->dev,"ASoC: hw_free FE failed %d\n", err);
618dae11
LG		 2289
2290 err = dpcm_be_dai_shutdown(fe, stream);
2291 if (err < 0)
103d84a3 2292 dev_err(fe->dev,"ASoC: shutdown FE failed %d\n", err);
618dae11
LG		 2293
2294 /* run the stream event for each BE */
2295 dpcm_dapm_stream_event(fe, stream, SND_SOC_DAPM_STREAM_NOP);
2296
2297 return 0;
2298}
2299
2300static int dpcm_run_update_startup(struct snd_soc_pcm_runtime *fe, int stream)
2301{
07bf84aa
LG		 2302 struct snd_pcm_substream *substream =
2303 snd_soc_dpcm_get_substream(fe, stream);
618dae11 2304 struct snd_soc_dpcm *dpcm;
07bf84aa 2305 enum snd_soc_dpcm_trigger trigger = fe->dai_link->trigger[stream];
618dae11
LG		 2306 int ret;
2307
103d84a3 2308 dev_dbg(fe->dev, "ASoC: runtime %s open on FE %s\n",
618dae11
LG		 2309 stream ? "capture" : "playback", fe->dai_link->name);
2310
2311 /* Only start the BE if the FE is ready */
2312 if (fe->dpcm[stream].state == SND_SOC_DPCM_STATE_HW_FREE ||
2313 fe->dpcm[stream].state == SND_SOC_DPCM_STATE_CLOSE)
2314 return -EINVAL;
2315
2316 /* startup must always be called for new BEs */
2317 ret = dpcm_be_dai_startup(fe, stream);
fffc0ca2 2318 if (ret < 0)
618dae11 2319 goto disconnect;
618dae11
LG		 2320
2321 /* keep going if FE state is > open */
2322 if (fe->dpcm[stream].state == SND_SOC_DPCM_STATE_OPEN)
2323 return 0;
01d7584c 2324
618dae11 2325 ret = dpcm_be_dai_hw_params(fe, stream);
fffc0ca2 2326 if (ret < 0)
618dae11 2327 goto close;
618dae11
LG		 2328
2329 /* keep going if FE state is > hw_params */
2330 if (fe->dpcm[stream].state == SND_SOC_DPCM_STATE_HW_PARAMS)
2331 return 0;
2332
2333
2334 ret = dpcm_be_dai_prepare(fe, stream);
fffc0ca2 2335 if (ret < 0)
618dae11 2336 goto hw_free;
618dae11
LG		 2337
2338 /* run the stream event for each BE */
2339 dpcm_dapm_stream_event(fe, stream, SND_SOC_DAPM_STREAM_NOP);
2340
2341 /* keep going if FE state is > prepare */
2342 if (fe->dpcm[stream].state == SND_SOC_DPCM_STATE_PREPARE ||
2343 fe->dpcm[stream].state == SND_SOC_DPCM_STATE_STOP)
2344 return 0;
2345
07bf84aa
LG		 2346 if (trigger == SND_SOC_DPCM_TRIGGER_BESPOKE) {
2347 /* call trigger on the frontend - FE takes care of all BE triggers */
103d84a3 2348 dev_dbg(fe->dev, "ASoC: bespoke trigger FE %s cmd start\n",
07bf84aa 2349 fe->dai_link->name);
618dae11 2350
07bf84aa
LG		 2351 ret = soc_pcm_bespoke_trigger(substream, SNDRV_PCM_TRIGGER_START);
2352 if (ret < 0) {
103d84a3 2353 dev_err(fe->dev,"ASoC: bespoke trigger FE failed %d\n", ret);
07bf84aa
LG		 2354 goto hw_free;
2355 }
2356 } else {
103d84a3 2357 dev_dbg(fe->dev, "ASoC: trigger FE %s cmd start\n",
07bf84aa
LG		 2358 fe->dai_link->name);
2359
2360 ret = dpcm_be_dai_trigger(fe, stream,
2361 SNDRV_PCM_TRIGGER_START);
2362 if (ret < 0) {
103d84a3 2363 dev_err(fe->dev,"ASoC: trigger FE failed %d\n", ret);
07bf84aa
LG		 2364 goto hw_free;
2365 }
618dae11
LG		 2366 }
2367
2368 return 0;
2369
2370hw_free:
2371 dpcm_be_dai_hw_free(fe, stream);
2372close:
2373 dpcm_be_dai_shutdown(fe, stream);
2374disconnect:
2375 /* disconnect any non started BEs */
2376 list_for_each_entry(dpcm, &fe->dpcm[stream].be_clients, list_be) {
2377 struct snd_soc_pcm_runtime *be = dpcm->be;
2378 if (be->dpcm[stream].state != SND_SOC_DPCM_STATE_START)
2379 dpcm->state = SND_SOC_DPCM_LINK_STATE_FREE;
2380 }
2381
2382 return ret;
2383}
2384
2385static int dpcm_run_new_update(struct snd_soc_pcm_runtime *fe, int stream)
2386{
2387 int ret;
2388
ea9d0d77 2389 dpcm_set_fe_update_state(fe, stream, SND_SOC_DPCM_UPDATE_BE);
618dae11
LG		 2390 ret = dpcm_run_update_startup(fe, stream);
2391 if (ret < 0)
103d84a3 2392 dev_err(fe->dev, "ASoC: failed to startup some BEs\n");
ea9d0d77 2393 dpcm_set_fe_update_state(fe, stream, SND_SOC_DPCM_UPDATE_NO);
618dae11
LG		 2394
2395 return ret;
2396}
2397
2398static int dpcm_run_old_update(struct snd_soc_pcm_runtime *fe, int stream)
2399{
2400 int ret;
2401
ea9d0d77 2402 dpcm_set_fe_update_state(fe, stream, SND_SOC_DPCM_UPDATE_BE);
618dae11
LG		 2403 ret = dpcm_run_update_shutdown(fe, stream);
2404 if (ret < 0)
103d84a3 2405 dev_err(fe->dev, "ASoC: failed to shutdown some BEs\n");
ea9d0d77 2406 dpcm_set_fe_update_state(fe, stream, SND_SOC_DPCM_UPDATE_NO);
618dae11
LG		 2407
2408 return ret;
2409}
2410
2411/* Called by DAPM mixer/mux changes to update audio routing between PCMs and
2412 * any DAI links.
2413 */
c3f48ae6 2414int soc_dpcm_runtime_update(struct snd_soc_card *card)
618dae11 2415{
1a497983
ML		 2416 struct snd_soc_pcm_runtime *fe;
2417 int old, new, paths;
618dae11 2418
618dae11 2419 mutex_lock_nested(&card->mutex, SND_SOC_CARD_CLASS_RUNTIME);
1a497983 2420 list_for_each_entry(fe, &card->rtd_list, list) {
618dae11 2421 struct snd_soc_dapm_widget_list *list;
618dae11
LG		 2422
2423 /* make sure link is FE */
2424 if (!fe->dai_link->dynamic)
2425 continue;
2426
2427 /* only check active links */
2428 if (!fe->cpu_dai->active)
2429 continue;
2430
2431 /* DAPM sync will call this to update DSP paths */
103d84a3 2432 dev_dbg(fe->dev, "ASoC: DPCM runtime update for FE %s\n",
618dae11
LG		 2433 fe->dai_link->name);
2434
2435 /* skip if FE doesn't have playback capability */
075207d2
QZ		 2436 if (!fe->cpu_dai->driver->playback.channels_min
2437 || !fe->codec_dai->driver->playback.channels_min)
2438 goto capture;
2439
2440 /* skip if FE isn't currently playing */
2441 if (!fe->cpu_dai->playback_active
2442 || !fe->codec_dai->playback_active)
618dae11
LG		 2443 goto capture;
2444
2445 paths = dpcm_path_get(fe, SNDRV_PCM_STREAM_PLAYBACK, &list);
2446 if (paths < 0) {
103d84a3 2447 dev_warn(fe->dev, "ASoC: %s no valid %s path\n",
618dae11
LG		 2448 fe->dai_link->name, "playback");
2449 mutex_unlock(&card->mutex);
2450 return paths;
2451 }
2452
2453 /* update any new playback paths */
2454 new = dpcm_process_paths(fe, SNDRV_PCM_STREAM_PLAYBACK, &list, 1);
2455 if (new) {
2456 dpcm_run_new_update(fe, SNDRV_PCM_STREAM_PLAYBACK);
2457 dpcm_clear_pending_state(fe, SNDRV_PCM_STREAM_PLAYBACK);
2458 dpcm_be_disconnect(fe, SNDRV_PCM_STREAM_PLAYBACK);
2459 }
2460
2461 /* update any old playback paths */
2462 old = dpcm_process_paths(fe, SNDRV_PCM_STREAM_PLAYBACK, &list, 0);
2463 if (old) {
2464 dpcm_run_old_update(fe, SNDRV_PCM_STREAM_PLAYBACK);
2465 dpcm_clear_pending_state(fe, SNDRV_PCM_STREAM_PLAYBACK);
2466 dpcm_be_disconnect(fe, SNDRV_PCM_STREAM_PLAYBACK);
2467 }
2468
7ed9de76 2469 dpcm_path_put(&list);
618dae11
LG		 2470capture:
2471 /* skip if FE doesn't have capture capability */
075207d2
QZ		 2472 if (!fe->cpu_dai->driver->capture.channels_min
2473 || !fe->codec_dai->driver->capture.channels_min)
2474 continue;
2475
2476 /* skip if FE isn't currently capturing */
2477 if (!fe->cpu_dai->capture_active
2478 || !fe->codec_dai->capture_active)
618dae11
LG		 2479 continue;
2480
2481 paths = dpcm_path_get(fe, SNDRV_PCM_STREAM_CAPTURE, &list);
2482 if (paths < 0) {
103d84a3 2483 dev_warn(fe->dev, "ASoC: %s no valid %s path\n",
618dae11
LG		 2484 fe->dai_link->name, "capture");
2485 mutex_unlock(&card->mutex);
2486 return paths;
2487 }
2488
2489 /* update any new capture paths */
2490 new = dpcm_process_paths(fe, SNDRV_PCM_STREAM_CAPTURE, &list, 1);
2491 if (new) {
2492 dpcm_run_new_update(fe, SNDRV_PCM_STREAM_CAPTURE);
2493 dpcm_clear_pending_state(fe, SNDRV_PCM_STREAM_CAPTURE);
2494 dpcm_be_disconnect(fe, SNDRV_PCM_STREAM_CAPTURE);
2495 }
2496
2497 /* update any old capture paths */
2498 old = dpcm_process_paths(fe, SNDRV_PCM_STREAM_CAPTURE, &list, 0);
2499 if (old) {
2500 dpcm_run_old_update(fe, SNDRV_PCM_STREAM_CAPTURE);
2501 dpcm_clear_pending_state(fe, SNDRV_PCM_STREAM_CAPTURE);
2502 dpcm_be_disconnect(fe, SNDRV_PCM_STREAM_CAPTURE);
2503 }
2504
2505 dpcm_path_put(&list);
2506 }
2507
2508 mutex_unlock(&card->mutex);
2509 return 0;
2510}
01d7584c
LG		 2511int soc_dpcm_be_digital_mute(struct snd_soc_pcm_runtime *fe, int mute)
2512{
2513 struct snd_soc_dpcm *dpcm;
2514 struct list_head *clients =
2515 &fe->dpcm[SNDRV_PCM_STREAM_PLAYBACK].be_clients;
2516
2517 list_for_each_entry(dpcm, clients, list_be) {
2518
2519 struct snd_soc_pcm_runtime *be = dpcm->be;
2e5894d7 2520 int i;
01d7584c
LG		 2521
2522 if (be->dai_link->ignore_suspend)
2523 continue;
2524
2e5894d7
BC		 2525 for (i = 0; i < be->num_codecs; i++) {
2526 struct snd_soc_dai *dai = be->codec_dais[i];
2527 struct snd_soc_dai_driver *drv = dai->driver;
2528
2529 dev_dbg(be->dev, "ASoC: BE digital mute %s\n",
2530 be->dai_link->name);
01d7584c 2531
2e5894d7
BC		 2532 if (drv->ops && drv->ops->digital_mute &&
2533 dai->playback_active)
2534 drv->ops->digital_mute(dai, mute);
2535 }
01d7584c
LG		 2536 }
2537
2538 return 0;
2539}
2540
45c0a188 2541static int dpcm_fe_dai_open(struct snd_pcm_substream *fe_substream)
01d7584c
LG		 2542{
2543 struct snd_soc_pcm_runtime *fe = fe_substream->private_data;
2544 struct snd_soc_dpcm *dpcm;
2545 struct snd_soc_dapm_widget_list *list;
2546 int ret;
2547 int stream = fe_substream->stream;
2548
2549 mutex_lock_nested(&fe->card->mutex, SND_SOC_CARD_CLASS_RUNTIME);
2550 fe->dpcm[stream].runtime = fe_substream->runtime;
2551
8f70e515
QZ		 2552 ret = dpcm_path_get(fe, stream, &list);
2553 if (ret < 0) {
2554 mutex_unlock(&fe->card->mutex);
2555 return ret;
2556 } else if (ret == 0) {
103d84a3 2557 dev_dbg(fe->dev, "ASoC: %s no valid %s route\n",
01d7584c 2558 fe->dai_link->name, stream ? "capture" : "playback");
01d7584c
LG		 2559 }
2560
2561 /* calculate valid and active FE <-> BE dpcms */
2562 dpcm_process_paths(fe, stream, &list, 1);
2563
2564 ret = dpcm_fe_dai_startup(fe_substream);
2565 if (ret < 0) {
2566 /* clean up all links */
2567 list_for_each_entry(dpcm, &fe->dpcm[stream].be_clients, list_be)
2568 dpcm->state = SND_SOC_DPCM_LINK_STATE_FREE;
2569
2570 dpcm_be_disconnect(fe, stream);
2571 fe->dpcm[stream].runtime = NULL;
2572 }
2573
2574 dpcm_clear_pending_state(fe, stream);
2575 dpcm_path_put(&list);
2576 mutex_unlock(&fe->card->mutex);
2577 return ret;
2578}
2579
45c0a188 2580static int dpcm_fe_dai_close(struct snd_pcm_substream *fe_substream)
01d7584c
LG		 2581{
2582 struct snd_soc_pcm_runtime *fe = fe_substream->private_data;
2583 struct snd_soc_dpcm *dpcm;
2584 int stream = fe_substream->stream, ret;
2585
2586 mutex_lock_nested(&fe->card->mutex, SND_SOC_CARD_CLASS_RUNTIME);
2587 ret = dpcm_fe_dai_shutdown(fe_substream);
2588
2589 /* mark FE's links ready to prune */
2590 list_for_each_entry(dpcm, &fe->dpcm[stream].be_clients, list_be)
2591 dpcm->state = SND_SOC_DPCM_LINK_STATE_FREE;
2592
2593 dpcm_be_disconnect(fe, stream);
2594
2595 fe->dpcm[stream].runtime = NULL;
2596 mutex_unlock(&fe->card->mutex);
2597 return ret;
2598}
2599
ddee627c
LG		 2600/* create a new pcm */
2601int soc_new_pcm(struct snd_soc_pcm_runtime *rtd, int num)
2602{
ddee627c 2603 struct snd_soc_platform *platform = rtd->platform;
2e5894d7 2604 struct snd_soc_dai *codec_dai;
ddee627c
LG		 2605 struct snd_soc_dai *cpu_dai = rtd->cpu_dai;
2606 struct snd_pcm *pcm;
2607 char new_name[64];
2608 int ret = 0, playback = 0, capture = 0;
2e5894d7 2609 int i;
ddee627c 2610
01d7584c 2611 if (rtd->dai_link->dynamic || rtd->dai_link->no_pcm) {
1e9de42f
LG		 2612 playback = rtd->dai_link->dpcm_playback;
2613 capture = rtd->dai_link->dpcm_capture;
01d7584c 2614 } else {
2e5894d7
BC		 2615 for (i = 0; i < rtd->num_codecs; i++) {
2616 codec_dai = rtd->codec_dais[i];
2617 if (codec_dai->driver->playback.channels_min)
2618 playback = 1;
2619 if (codec_dai->driver->capture.channels_min)
2620 capture = 1;
2621 }
2622
2623 capture = capture && cpu_dai->driver->capture.channels_min;
2624 playback = playback && cpu_dai->driver->playback.channels_min;
01d7584c
LG		 2625 }
2626
d6bead02
FE		 2627 if (rtd->dai_link->playback_only) {
2628 playback = 1;
2629 capture = 0;
2630 }
2631
2632 if (rtd->dai_link->capture_only) {
2633 playback = 0;
2634 capture = 1;
2635 }
2636
01d7584c
LG		 2637 /* create the PCM */
2638 if (rtd->dai_link->no_pcm) {
2639 snprintf(new_name, sizeof(new_name), "(%s)",
2640 rtd->dai_link->stream_name);
2641
2642 ret = snd_pcm_new_internal(rtd->card->snd_card, new_name, num,
2643 playback, capture, &pcm);
2644 } else {
2645 if (rtd->dai_link->dynamic)
2646 snprintf(new_name, sizeof(new_name), "%s (*)",
2647 rtd->dai_link->stream_name);
2648 else
2649 snprintf(new_name, sizeof(new_name), "%s %s-%d",
2e5894d7
BC		 2650 rtd->dai_link->stream_name,
2651 (rtd->num_codecs > 1) ?
2652 "multicodec" : rtd->codec_dai->name, num);
01d7584c
LG		 2653
2654 ret = snd_pcm_new(rtd->card->snd_card, new_name, num, playback,
2655 capture, &pcm);
2656 }
ddee627c 2657 if (ret < 0) {
103d84a3 2658 dev_err(rtd->card->dev, "ASoC: can't create pcm for %s\n",
5cb9b748 2659 rtd->dai_link->name);
ddee627c
LG		 2660 return ret;
2661 }
103d84a3 2662 dev_dbg(rtd->card->dev, "ASoC: registered pcm #%d %s\n",num, new_name);
ddee627c
LG		 2663
2664 /* DAPM dai link stream work */
2665 INIT_DELAYED_WORK(&rtd->delayed_work, close_delayed_work);
2666
48c7699f 2667 pcm->nonatomic = rtd->dai_link->nonatomic;
ddee627c
LG		 2668 rtd->pcm = pcm;
2669 pcm->private_data = rtd;
01d7584c
LG		 2670
2671 if (rtd->dai_link->no_pcm) {
2672 if (playback)
2673 pcm->streams[SNDRV_PCM_STREAM_PLAYBACK].substream->private_data = rtd;
2674 if (capture)
2675 pcm->streams[SNDRV_PCM_STREAM_CAPTURE].substream->private_data = rtd;
2676 goto out;
2677 }
2678
2679 /* ASoC PCM operations */
2680 if (rtd->dai_link->dynamic) {
2681 rtd->ops.open = dpcm_fe_dai_open;
2682 rtd->ops.hw_params = dpcm_fe_dai_hw_params;
2683 rtd->ops.prepare = dpcm_fe_dai_prepare;
2684 rtd->ops.trigger = dpcm_fe_dai_trigger;
2685 rtd->ops.hw_free = dpcm_fe_dai_hw_free;
2686 rtd->ops.close = dpcm_fe_dai_close;
2687 rtd->ops.pointer = soc_pcm_pointer;
be3f3f2c 2688 rtd->ops.ioctl = soc_pcm_ioctl;
01d7584c
LG		 2689 } else {
2690 rtd->ops.open = soc_pcm_open;
2691 rtd->ops.hw_params = soc_pcm_hw_params;
2692 rtd->ops.prepare = soc_pcm_prepare;
2693 rtd->ops.trigger = soc_pcm_trigger;
2694 rtd->ops.hw_free = soc_pcm_hw_free;
2695 rtd->ops.close = soc_pcm_close;
2696 rtd->ops.pointer = soc_pcm_pointer;
be3f3f2c 2697 rtd->ops.ioctl = soc_pcm_ioctl;
01d7584c
LG		 2698 }
2699
ddee627c 2700 if (platform->driver->ops) {
01d7584c
LG		 2701 rtd->ops.ack = platform->driver->ops->ack;
2702 rtd->ops.copy = platform->driver->ops->copy;
2703 rtd->ops.silence = platform->driver->ops->silence;
2704 rtd->ops.page = platform->driver->ops->page;
2705 rtd->ops.mmap = platform->driver->ops->mmap;
ddee627c
LG		 2706 }
2707
2708 if (playback)
01d7584c 2709 snd_pcm_set_ops(pcm, SNDRV_PCM_STREAM_PLAYBACK, &rtd->ops);
ddee627c
LG		 2710
2711 if (capture)
01d7584c 2712 snd_pcm_set_ops(pcm, SNDRV_PCM_STREAM_CAPTURE, &rtd->ops);
ddee627c
LG		 2713
2714 if (platform->driver->pcm_new) {
2715 ret = platform->driver->pcm_new(rtd);
2716 if (ret < 0) {
b1bc7b3c
MB		 2717 dev_err(platform->dev,
2718 "ASoC: pcm constructor failed: %d\n",
2719 ret);
ddee627c
LG		 2720 return ret;
2721 }
2722 }
2723
2724 pcm->private_free = platform->driver->pcm_free;
01d7584c 2725out:
2e5894d7
BC		 2726 dev_info(rtd->card->dev, "%s <-> %s mapping ok\n",
2727 (rtd->num_codecs > 1) ? "multicodec" : rtd->codec_dai->name,
2728 cpu_dai->name);
ddee627c
LG		 2729 return ret;
2730}
01d7584c
LG		 2731
2732/* is the current PCM operation for this FE ? */
2733int snd_soc_dpcm_fe_can_update(struct snd_soc_pcm_runtime *fe, int stream)
2734{
2735 if (fe->dpcm[stream].runtime_update == SND_SOC_DPCM_UPDATE_FE)
2736 return 1;
2737 return 0;
2738}
2739EXPORT_SYMBOL_GPL(snd_soc_dpcm_fe_can_update);
2740
2741/* is the current PCM operation for this BE ? */
2742int snd_soc_dpcm_be_can_update(struct snd_soc_pcm_runtime *fe,
2743 struct snd_soc_pcm_runtime *be, int stream)
2744{
2745 if ((fe->dpcm[stream].runtime_update == SND_SOC_DPCM_UPDATE_FE) ||
2746 ((fe->dpcm[stream].runtime_update == SND_SOC_DPCM_UPDATE_BE) &&
2747 be->dpcm[stream].runtime_update))
2748 return 1;
2749 return 0;
2750}
2751EXPORT_SYMBOL_GPL(snd_soc_dpcm_be_can_update);
2752
2753/* get the substream for this BE */
2754struct snd_pcm_substream *
2755 snd_soc_dpcm_get_substream(struct snd_soc_pcm_runtime *be, int stream)
2756{
2757 return be->pcm->streams[stream].substream;
2758}
2759EXPORT_SYMBOL_GPL(snd_soc_dpcm_get_substream);
2760
2761/* get the BE runtime state */
2762enum snd_soc_dpcm_state
2763 snd_soc_dpcm_be_get_state(struct snd_soc_pcm_runtime *be, int stream)
2764{
2765 return be->dpcm[stream].state;
2766}
2767EXPORT_SYMBOL_GPL(snd_soc_dpcm_be_get_state);
2768
2769/* set the BE runtime state */
2770void snd_soc_dpcm_be_set_state(struct snd_soc_pcm_runtime *be,
2771 int stream, enum snd_soc_dpcm_state state)
2772{
2773 be->dpcm[stream].state = state;
2774}
2775EXPORT_SYMBOL_GPL(snd_soc_dpcm_be_set_state);
2776
2777/*
2778 * We can only hw_free, stop, pause or suspend a BE DAI if any of it's FE
2779 * are not running, paused or suspended for the specified stream direction.
2780 */
2781int snd_soc_dpcm_can_be_free_stop(struct snd_soc_pcm_runtime *fe,
2782 struct snd_soc_pcm_runtime *be, int stream)
2783{
2784 struct snd_soc_dpcm *dpcm;
2785 int state;
2786
2787 list_for_each_entry(dpcm, &be->dpcm[stream].fe_clients, list_fe) {
2788
2789 if (dpcm->fe == fe)
2790 continue;
2791
2792 state = dpcm->fe->dpcm[stream].state;
2793 if (state == SND_SOC_DPCM_STATE_START ||
2794 state == SND_SOC_DPCM_STATE_PAUSED ||
2795 state == SND_SOC_DPCM_STATE_SUSPEND)
2796 return 0;
2797 }
2798
2799 /* it's safe to free/stop this BE DAI */
2800 return 1;
2801}
2802EXPORT_SYMBOL_GPL(snd_soc_dpcm_can_be_free_stop);
2803
2804/*
2805 * We can only change hw params a BE DAI if any of it's FE are not prepared,
2806 * running, paused or suspended for the specified stream direction.
2807 */
2808int snd_soc_dpcm_can_be_params(struct snd_soc_pcm_runtime *fe,
2809 struct snd_soc_pcm_runtime *be, int stream)
2810{
2811 struct snd_soc_dpcm *dpcm;
2812 int state;
2813
2814 list_for_each_entry(dpcm, &be->dpcm[stream].fe_clients, list_fe) {
2815
2816 if (dpcm->fe == fe)
2817 continue;
2818
2819 state = dpcm->fe->dpcm[stream].state;
2820 if (state == SND_SOC_DPCM_STATE_START ||
2821 state == SND_SOC_DPCM_STATE_PAUSED ||
2822 state == SND_SOC_DPCM_STATE_SUSPEND ||
2823 state == SND_SOC_DPCM_STATE_PREPARE)
2824 return 0;
2825 }
2826
2827 /* it's safe to change hw_params */
2828 return 1;
2829}
2830EXPORT_SYMBOL_GPL(snd_soc_dpcm_can_be_params);
f86dcef8 2831
07bf84aa
LG		 2832int snd_soc_platform_trigger(struct snd_pcm_substream *substream,
2833 int cmd, struct snd_soc_platform *platform)
2834{
c5914b0a 2835 if (platform->driver->ops && platform->driver->ops->trigger)
07bf84aa
LG		 2836 return platform->driver->ops->trigger(substream, cmd);
2837 return 0;
2838}
2839EXPORT_SYMBOL_GPL(snd_soc_platform_trigger);
2840
f86dcef8
LG		 2841#ifdef CONFIG_DEBUG_FS
2842static char *dpcm_state_string(enum snd_soc_dpcm_state state)
2843{
2844 switch (state) {
2845 case SND_SOC_DPCM_STATE_NEW:
2846 return "new";
2847 case SND_SOC_DPCM_STATE_OPEN:
2848 return "open";
2849 case SND_SOC_DPCM_STATE_HW_PARAMS:
2850 return "hw_params";
2851 case SND_SOC_DPCM_STATE_PREPARE:
2852 return "prepare";
2853 case SND_SOC_DPCM_STATE_START:
2854 return "start";
2855 case SND_SOC_DPCM_STATE_STOP:
2856 return "stop";
2857 case SND_SOC_DPCM_STATE_SUSPEND:
2858 return "suspend";
2859 case SND_SOC_DPCM_STATE_PAUSED:
2860 return "paused";
2861 case SND_SOC_DPCM_STATE_HW_FREE:
2862 return "hw_free";
2863 case SND_SOC_DPCM_STATE_CLOSE:
2864 return "close";
2865 }
2866
2867 return "unknown";
2868}
2869
f86dcef8
LG		 2870static ssize_t dpcm_show_state(struct snd_soc_pcm_runtime *fe,
2871 int stream, char *buf, size_t size)
2872{
2873 struct snd_pcm_hw_params *params = &fe->dpcm[stream].hw_params;
2874 struct snd_soc_dpcm *dpcm;
2875 ssize_t offset = 0;
2876
2877 /* FE state */
2878 offset += snprintf(buf + offset, size - offset,
2879 "[%s - %s]\n", fe->dai_link->name,
2880 stream ? "Capture" : "Playback");
2881
2882 offset += snprintf(buf + offset, size - offset, "State: %s\n",
2883 dpcm_state_string(fe->dpcm[stream].state));
2884
2885 if ((fe->dpcm[stream].state >= SND_SOC_DPCM_STATE_HW_PARAMS) &&
2886 (fe->dpcm[stream].state <= SND_SOC_DPCM_STATE_STOP))
2887 offset += snprintf(buf + offset, size - offset,
2888 "Hardware Params: "
2889 "Format = %s, Channels = %d, Rate = %d\n",
2890 snd_pcm_format_name(params_format(params)),
2891 params_channels(params),
2892 params_rate(params));
2893
2894 /* BEs state */
2895 offset += snprintf(buf + offset, size - offset, "Backends:\n");
2896
2897 if (list_empty(&fe->dpcm[stream].be_clients)) {
2898 offset += snprintf(buf + offset, size - offset,
2899 " No active DSP links\n");
2900 goto out;
2901 }
2902
2903 list_for_each_entry(dpcm, &fe->dpcm[stream].be_clients, list_be) {
2904 struct snd_soc_pcm_runtime *be = dpcm->be;
2905 params = &dpcm->hw_params;
2906
2907 offset += snprintf(buf + offset, size - offset,
2908 "- %s\n", be->dai_link->name);
2909
2910 offset += snprintf(buf + offset, size - offset,
2911 " State: %s\n",
2912 dpcm_state_string(be->dpcm[stream].state));
2913
2914 if ((be->dpcm[stream].state >= SND_SOC_DPCM_STATE_HW_PARAMS) &&
2915 (be->dpcm[stream].state <= SND_SOC_DPCM_STATE_STOP))
2916 offset += snprintf(buf + offset, size - offset,
2917 " Hardware Params: "
2918 "Format = %s, Channels = %d, Rate = %d\n",
2919 snd_pcm_format_name(params_format(params)),
2920 params_channels(params),
2921 params_rate(params));
2922 }
2923
2924out:
2925 return offset;
2926}
2927
2928static ssize_t dpcm_state_read_file(struct file *file, char __user *user_buf,
2929 size_t count, loff_t *ppos)
2930{
2931 struct snd_soc_pcm_runtime *fe = file->private_data;
2932 ssize_t out_count = PAGE_SIZE, offset = 0, ret = 0;
2933 char *buf;
2934
2935 buf = kmalloc(out_count, GFP_KERNEL);
2936 if (!buf)
2937 return -ENOMEM;
2938
2939 if (fe->cpu_dai->driver->playback.channels_min)
2940 offset += dpcm_show_state(fe, SNDRV_PCM_STREAM_PLAYBACK,
2941 buf + offset, out_count - offset);
2942
2943 if (fe->cpu_dai->driver->capture.channels_min)
2944 offset += dpcm_show_state(fe, SNDRV_PCM_STREAM_CAPTURE,
2945 buf + offset, out_count - offset);
2946
f57b8488 2947 ret = simple_read_from_buffer(user_buf, count, ppos, buf, offset);
f86dcef8 2948
f57b8488
LG		 2949 kfree(buf);
2950 return ret;
f86dcef8
LG		 2951}
2952
2953static const struct file_operations dpcm_state_fops = {
f57b8488 2954 .open = simple_open,
f86dcef8
LG		 2955 .read = dpcm_state_read_file,
2956 .llseek = default_llseek,
2957};
2958
2e55b90a 2959void soc_dpcm_debugfs_add(struct snd_soc_pcm_runtime *rtd)
f86dcef8 2960{
b3bba9a1 2961 if (!rtd->dai_link)
2e55b90a 2962 return;
b3bba9a1 2963
6553bf06
LPC		 2964 if (!rtd->card->debugfs_card_root)
2965 return;
b3bba9a1 2966
f86dcef8
LG		 2967 rtd->debugfs_dpcm_root = debugfs_create_dir(rtd->dai_link->name,
2968 rtd->card->debugfs_card_root);
2969 if (!rtd->debugfs_dpcm_root) {
2970 dev_dbg(rtd->dev,
2971 "ASoC: Failed to create dpcm debugfs directory %s\n",
2972 rtd->dai_link->name);
2e55b90a 2973 return;
f86dcef8
LG		 2974 }
2975
f57b8488 2976 rtd->debugfs_dpcm_state = debugfs_create_file("state", 0444,
f86dcef8
LG		 2977 rtd->debugfs_dpcm_root,
2978 rtd, &dpcm_state_fops);
f86dcef8
LG		 2979}
2980#endif
Linux kernel - Deliverables
This page took 0.412219 seconds and 5 git commands to generate.