GNU Linux-libre 4.19.286-gnu1
[releases.git] / sound / firewire / motu / motu-pcm.c
1 /*
2  * motu-pcm.c - a part of driver for MOTU FireWire series
3  *
4  * Copyright (c) 2015-2017 Takashi Sakamoto <o-takashi@sakamocchi.jp>
5  *
6  * Licensed under the terms of the GNU General Public License, version 2.
7  */
8
9 #include <sound/pcm_params.h>
10 #include "motu.h"
11
12 static int motu_rate_constraint(struct snd_pcm_hw_params *params,
13                                 struct snd_pcm_hw_rule *rule)
14 {
15         struct snd_motu_packet_format *formats = rule->private;
16
17         const struct snd_interval *c =
18                 hw_param_interval_c(params, SNDRV_PCM_HW_PARAM_CHANNELS);
19         struct snd_interval *r =
20                 hw_param_interval(params, SNDRV_PCM_HW_PARAM_RATE);
21         struct snd_interval rates = {
22                 .min = UINT_MAX, .max = 0, .integer = 1
23         };
24         unsigned int i, pcm_channels, rate, mode;
25
26         for (i = 0; i < ARRAY_SIZE(snd_motu_clock_rates); ++i) {
27                 rate = snd_motu_clock_rates[i];
28                 mode = i / 2;
29
30                 pcm_channels = formats->fixed_part_pcm_chunks[mode] +
31                                formats->differed_part_pcm_chunks[mode];
32                 if (!snd_interval_test(c, pcm_channels))
33                         continue;
34
35                 rates.min = min(rates.min, rate);
36                 rates.max = max(rates.max, rate);
37         }
38
39         return snd_interval_refine(r, &rates);
40 }
41
42 static int motu_channels_constraint(struct snd_pcm_hw_params *params,
43                                     struct snd_pcm_hw_rule *rule)
44 {
45         struct snd_motu_packet_format *formats = rule->private;
46
47         const struct snd_interval *r =
48                 hw_param_interval_c(params, SNDRV_PCM_HW_PARAM_RATE);
49         struct snd_interval *c =
50                 hw_param_interval(params, SNDRV_PCM_HW_PARAM_CHANNELS);
51         struct snd_interval channels = {
52                 .min = UINT_MAX, .max = 0, .integer = 1
53         };
54         unsigned int i, pcm_channels, rate, mode;
55
56         for (i = 0; i < ARRAY_SIZE(snd_motu_clock_rates); ++i) {
57                 rate = snd_motu_clock_rates[i];
58                 mode = i / 2;
59
60                 if (!snd_interval_test(r, rate))
61                         continue;
62
63                 pcm_channels = formats->fixed_part_pcm_chunks[mode] +
64                                formats->differed_part_pcm_chunks[mode];
65                 channels.min = min(channels.min, pcm_channels);
66                 channels.max = max(channels.max, pcm_channels);
67         }
68
69         return snd_interval_refine(c, &channels);
70 }
71
72 static void limit_channels_and_rates(struct snd_motu *motu,
73                                      struct snd_pcm_runtime *runtime,
74                                      struct snd_motu_packet_format *formats)
75 {
76         struct snd_pcm_hardware *hw = &runtime->hw;
77         unsigned int i, pcm_channels, rate, mode;
78
79         hw->channels_min = UINT_MAX;
80         hw->channels_max = 0;
81
82         for (i = 0; i < ARRAY_SIZE(snd_motu_clock_rates); ++i) {
83                 rate = snd_motu_clock_rates[i];
84                 mode = i / 2;
85
86                 pcm_channels = formats->fixed_part_pcm_chunks[mode] +
87                                formats->differed_part_pcm_chunks[mode];
88                 if (pcm_channels == 0)
89                         continue;
90
91                 hw->rates |= snd_pcm_rate_to_rate_bit(rate);
92                 hw->channels_min = min(hw->channels_min, pcm_channels);
93                 hw->channels_max = max(hw->channels_max, pcm_channels);
94         }
95
96         snd_pcm_limit_hw_rates(runtime);
97 }
98
99 static int init_hw_info(struct snd_motu *motu,
100                         struct snd_pcm_substream *substream)
101 {
102         struct snd_pcm_runtime *runtime = substream->runtime;
103         struct snd_pcm_hardware *hw = &runtime->hw;
104         struct amdtp_stream *stream;
105         struct snd_motu_packet_format *formats;
106         int err;
107
108         if (substream->stream == SNDRV_PCM_STREAM_CAPTURE) {
109                 hw->formats = SNDRV_PCM_FMTBIT_S32;
110                 stream = &motu->tx_stream;
111                 formats = &motu->tx_packet_formats;
112         } else {
113                 hw->formats = SNDRV_PCM_FMTBIT_S32;
114                 stream = &motu->rx_stream;
115                 formats = &motu->rx_packet_formats;
116         }
117
118         limit_channels_and_rates(motu, runtime, formats);
119
120         err = snd_pcm_hw_rule_add(runtime, 0, SNDRV_PCM_HW_PARAM_RATE,
121                                   motu_rate_constraint, formats,
122                                   SNDRV_PCM_HW_PARAM_CHANNELS, -1);
123         if (err < 0)
124                 return err;
125         err = snd_pcm_hw_rule_add(runtime, 0, SNDRV_PCM_HW_PARAM_CHANNELS,
126                                   motu_channels_constraint, formats,
127                                   SNDRV_PCM_HW_PARAM_RATE, -1);
128         if (err < 0)
129                 return err;
130
131         return amdtp_motu_add_pcm_hw_constraints(stream, runtime);
132 }
133
134 static int pcm_open(struct snd_pcm_substream *substream)
135 {
136         struct snd_motu *motu = substream->private_data;
137         const struct snd_motu_protocol *const protocol = motu->spec->protocol;
138         enum snd_motu_clock_source src;
139         unsigned int rate;
140         int err;
141
142         err = snd_motu_stream_lock_try(motu);
143         if (err < 0)
144                 return err;
145
146         mutex_lock(&motu->mutex);
147
148         err = snd_motu_stream_cache_packet_formats(motu);
149         if (err < 0)
150                 goto err_locked;
151
152         err = init_hw_info(motu, substream);
153         if (err < 0)
154                 goto err_locked;
155
156         /*
157          * When source of clock is not internal or any PCM streams are running,
158          * available sampling rate is limited at current sampling rate.
159          */
160         err = protocol->get_clock_source(motu, &src);
161         if (err < 0)
162                 goto err_locked;
163         if (src != SND_MOTU_CLOCK_SOURCE_INTERNAL ||
164             amdtp_stream_pcm_running(&motu->tx_stream) ||
165             amdtp_stream_pcm_running(&motu->rx_stream)) {
166                 err = protocol->get_clock_rate(motu, &rate);
167                 if (err < 0)
168                         goto err_locked;
169                 substream->runtime->hw.rate_min = rate;
170                 substream->runtime->hw.rate_max = rate;
171         }
172
173         snd_pcm_set_sync(substream);
174
175         mutex_unlock(&motu->mutex);
176
177         return err;
178 err_locked:
179         mutex_unlock(&motu->mutex);
180         snd_motu_stream_lock_release(motu);
181         return err;
182 }
183
184 static int pcm_close(struct snd_pcm_substream *substream)
185 {
186         struct snd_motu *motu = substream->private_data;
187
188         snd_motu_stream_lock_release(motu);
189
190         return 0;
191 }
192
193 static int capture_hw_params(struct snd_pcm_substream *substream,
194                              struct snd_pcm_hw_params *hw_params)
195 {
196         struct snd_motu *motu = substream->private_data;
197         int err;
198
199         err = snd_pcm_lib_alloc_vmalloc_buffer(substream,
200                                                params_buffer_bytes(hw_params));
201         if (err < 0)
202                 return err;
203
204         if (substream->runtime->status->state == SNDRV_PCM_STATE_OPEN) {
205                 mutex_lock(&motu->mutex);
206                 motu->capture_substreams++;
207                 mutex_unlock(&motu->mutex);
208         }
209
210         return 0;
211 }
212 static int playback_hw_params(struct snd_pcm_substream *substream,
213                               struct snd_pcm_hw_params *hw_params)
214 {
215         struct snd_motu *motu = substream->private_data;
216         int err;
217
218         err = snd_pcm_lib_alloc_vmalloc_buffer(substream,
219                                                params_buffer_bytes(hw_params));
220         if (err < 0)
221                 return err;
222
223         if (substream->runtime->status->state == SNDRV_PCM_STATE_OPEN) {
224                 mutex_lock(&motu->mutex);
225                 motu->playback_substreams++;
226                 mutex_unlock(&motu->mutex);
227         }
228
229         return 0;
230 }
231
232 static int capture_hw_free(struct snd_pcm_substream *substream)
233 {
234         struct snd_motu *motu = substream->private_data;
235
236         mutex_lock(&motu->mutex);
237
238         if (substream->runtime->status->state != SNDRV_PCM_STATE_OPEN)
239                 motu->capture_substreams--;
240
241         snd_motu_stream_stop_duplex(motu);
242
243         mutex_unlock(&motu->mutex);
244
245         return snd_pcm_lib_free_vmalloc_buffer(substream);
246 }
247
248 static int playback_hw_free(struct snd_pcm_substream *substream)
249 {
250         struct snd_motu *motu = substream->private_data;
251
252         mutex_lock(&motu->mutex);
253
254         if (substream->runtime->status->state != SNDRV_PCM_STATE_OPEN)
255                 motu->playback_substreams--;
256
257         snd_motu_stream_stop_duplex(motu);
258
259         mutex_unlock(&motu->mutex);
260
261         return snd_pcm_lib_free_vmalloc_buffer(substream);
262 }
263
264 static int capture_prepare(struct snd_pcm_substream *substream)
265 {
266         struct snd_motu *motu = substream->private_data;
267         int err;
268
269         mutex_lock(&motu->mutex);
270         err = snd_motu_stream_start_duplex(motu, substream->runtime->rate);
271         mutex_unlock(&motu->mutex);
272         if (err >= 0)
273                 amdtp_stream_pcm_prepare(&motu->tx_stream);
274
275         return 0;
276 }
277 static int playback_prepare(struct snd_pcm_substream *substream)
278 {
279         struct snd_motu *motu = substream->private_data;
280         int err;
281
282         mutex_lock(&motu->mutex);
283         err = snd_motu_stream_start_duplex(motu, substream->runtime->rate);
284         mutex_unlock(&motu->mutex);
285         if (err >= 0)
286                 amdtp_stream_pcm_prepare(&motu->rx_stream);
287
288         return err;
289 }
290
291 static int capture_trigger(struct snd_pcm_substream *substream, int cmd)
292 {
293         struct snd_motu *motu = substream->private_data;
294
295         switch (cmd) {
296         case SNDRV_PCM_TRIGGER_START:
297                 amdtp_stream_pcm_trigger(&motu->tx_stream, substream);
298                 break;
299         case SNDRV_PCM_TRIGGER_STOP:
300                 amdtp_stream_pcm_trigger(&motu->tx_stream, NULL);
301                 break;
302         default:
303                 return -EINVAL;
304         }
305
306         return 0;
307 }
308 static int playback_trigger(struct snd_pcm_substream *substream, int cmd)
309 {
310         struct snd_motu *motu = substream->private_data;
311
312         switch (cmd) {
313         case SNDRV_PCM_TRIGGER_START:
314                 amdtp_stream_pcm_trigger(&motu->rx_stream, substream);
315                 break;
316         case SNDRV_PCM_TRIGGER_STOP:
317                 amdtp_stream_pcm_trigger(&motu->rx_stream, NULL);
318                 break;
319         default:
320                 return -EINVAL;
321         }
322
323         return 0;
324 }
325
326 static snd_pcm_uframes_t capture_pointer(struct snd_pcm_substream *substream)
327 {
328         struct snd_motu *motu = substream->private_data;
329
330         return amdtp_stream_pcm_pointer(&motu->tx_stream);
331 }
332 static snd_pcm_uframes_t playback_pointer(struct snd_pcm_substream *substream)
333 {
334         struct snd_motu *motu = substream->private_data;
335
336         return amdtp_stream_pcm_pointer(&motu->rx_stream);
337 }
338
339 static int capture_ack(struct snd_pcm_substream *substream)
340 {
341         struct snd_motu *motu = substream->private_data;
342
343         return amdtp_stream_pcm_ack(&motu->tx_stream);
344 }
345
346 static int playback_ack(struct snd_pcm_substream *substream)
347 {
348         struct snd_motu *motu = substream->private_data;
349
350         return amdtp_stream_pcm_ack(&motu->rx_stream);
351 }
352
353 int snd_motu_create_pcm_devices(struct snd_motu *motu)
354 {
355         static const struct snd_pcm_ops capture_ops = {
356                 .open      = pcm_open,
357                 .close     = pcm_close,
358                 .ioctl     = snd_pcm_lib_ioctl,
359                 .hw_params = capture_hw_params,
360                 .hw_free   = capture_hw_free,
361                 .prepare   = capture_prepare,
362                 .trigger   = capture_trigger,
363                 .pointer   = capture_pointer,
364                 .ack       = capture_ack,
365                 .page      = snd_pcm_lib_get_vmalloc_page,
366         };
367         static const struct snd_pcm_ops playback_ops = {
368                 .open      = pcm_open,
369                 .close     = pcm_close,
370                 .ioctl     = snd_pcm_lib_ioctl,
371                 .hw_params = playback_hw_params,
372                 .hw_free   = playback_hw_free,
373                 .prepare   = playback_prepare,
374                 .trigger   = playback_trigger,
375                 .pointer   = playback_pointer,
376                 .ack       = playback_ack,
377                 .page      = snd_pcm_lib_get_vmalloc_page,
378         };
379         struct snd_pcm *pcm;
380         int err;
381
382         err = snd_pcm_new(motu->card, motu->card->driver, 0, 1, 1, &pcm);
383         if (err < 0)
384                 return err;
385         pcm->private_data = motu;
386         strcpy(pcm->name, motu->card->shortname);
387
388         snd_pcm_set_ops(pcm, SNDRV_PCM_STREAM_CAPTURE, &capture_ops);
389         snd_pcm_set_ops(pcm, SNDRV_PCM_STREAM_PLAYBACK, &playback_ops);
390
391         return 0;
392 }