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