Lines Matching +full:sub +full:- +full:device
1 // SPDX-License-Identifier: GPL-2.0-or-later
3 * Copyright (c) 2006-2008 Daniel Mack, Karsten Wiese
6 #include <linux/device.h>
14 #include "device.h"
31 (stream << 1) | (~(i / (cdev->n_streams * BYTES_PER_SAMPLE_USB)) & 1)
52 struct snd_pcm_substream *sub)
54 guard(spinlock)(&cdev->spinlock);
56 if (sub->stream == SNDRV_PCM_STREAM_PLAYBACK)
57 cdev->sub_playback[sub->number] = sub;
59 cdev->sub_capture[sub->number] = sub;
64 struct snd_pcm_substream *sub)
66 guard(spinlock_irqsave)(&cdev->spinlock);
68 if (sub->stream == SNDRV_PCM_STREAM_PLAYBACK)
69 cdev->sub_playback[sub->number] = NULL;
71 cdev->sub_capture[sub->number] = NULL;
87 struct device *dev = caiaqdev_to_dev(cdev);
91 if (cdev->streaming)
92 return -EINVAL;
94 memset(cdev->sub_playback, 0, sizeof(cdev->sub_playback));
95 memset(cdev->sub_capture, 0, sizeof(cdev->sub_capture));
96 cdev->input_panic = 0;
97 cdev->output_panic = 0;
98 cdev->first_packet = 4;
99 cdev->streaming = 1;
100 cdev->warned = 0;
103 ret = usb_submit_urb(cdev->data_urbs_in[i], GFP_ATOMIC);
107 cdev->streaming = 0;
108 return -EPIPE;
118 struct device *dev = caiaqdev_to_dev(cdev);
121 if (!cdev->streaming)
124 cdev->streaming = 0;
127 usb_kill_urb(cdev->data_urbs_in[i]);
129 if (test_bit(i, &cdev->outurb_active_mask))
130 usb_kill_urb(cdev->data_urbs_out[i]);
133 cdev->outurb_active_mask = 0;
139 struct device *dev = caiaqdev_to_dev(cdev);
142 substream->runtime->hw = cdev->pcm_info;
143 snd_pcm_limit_hw_rates(substream->runtime);
151 struct device *dev = caiaqdev_to_dev(cdev);
154 if (all_substreams_zero(cdev->sub_playback) &&
155 all_substreams_zero(cdev->sub_capture)) {
159 cdev->pcm_info.rates = cdev->samplerates;
165 static int snd_usb_caiaq_pcm_hw_free(struct snd_pcm_substream *sub)
167 struct snd_usb_caiaqdev *cdev = snd_pcm_substream_chip(sub);
168 deactivate_substream(cdev, sub);
175 int index = substream->number;
177 struct snd_pcm_runtime *runtime = substream->runtime;
178 struct device *dev = caiaqdev_to_dev(cdev);
182 if (substream->stream == SNDRV_PCM_STREAM_PLAYBACK) {
185 switch (cdev->spec.data_alignment) {
196 cdev->period_out_count[index] = out_pos;
197 cdev->audio_out_buf_pos[index] = out_pos;
201 switch (cdev->spec.data_alignment) {
214 cdev->period_in_count[index] = in_pos;
215 cdev->audio_in_buf_pos[index] = in_pos;
218 if (cdev->streaming)
223 cdev->pcm_info.rates = snd_pcm_rate_to_rate_bit(runtime->rate);
227 if (cdev->spec.data_alignment >= 2)
230 bpp = ((runtime->rate / 8000) + CLOCK_DRIFT_TOLERANCE)
231 * bytes_per_sample * CHANNELS_PER_STREAM * cdev->n_streams;
236 ret = snd_usb_caiaq_set_audio_params(cdev, runtime->rate,
237 runtime->sample_bits, bpp);
245 cdev->output_running = 0;
246 wait_event_timeout(cdev->prepare_wait_queue, cdev->output_running, HZ);
247 if (!cdev->output_running) {
249 return -EPIPE;
255 static int snd_usb_caiaq_pcm_trigger(struct snd_pcm_substream *sub, int cmd)
257 struct snd_usb_caiaqdev *cdev = snd_pcm_substream_chip(sub);
258 struct device *dev = caiaqdev_to_dev(cdev);
260 dev_dbg(dev, "%s(%p) cmd %d\n", __func__, sub, cmd);
265 activate_substream(cdev, sub);
269 deactivate_substream(cdev, sub);
272 return -EINVAL;
279 snd_usb_caiaq_pcm_pointer(struct snd_pcm_substream *sub)
281 int index = sub->number;
282 struct snd_usb_caiaqdev *cdev = snd_pcm_substream_chip(sub);
284 guard(spinlock)(&cdev->spinlock);
286 if (cdev->input_panic || cdev->output_panic)
289 if (sub->stream == SNDRV_PCM_STREAM_PLAYBACK)
290 return bytes_to_frames(sub->runtime,
291 cdev->audio_out_buf_pos[index]);
293 return bytes_to_frames(sub->runtime,
294 cdev->audio_in_buf_pos[index]);
311 struct snd_pcm_substream *sub;
313 for (stream = 0; stream < cdev->n_streams; stream++) {
314 sub = subs[stream];
315 if (!sub)
318 pb = snd_pcm_lib_period_bytes(sub);
319 cnt = (sub->stream == SNDRV_PCM_STREAM_PLAYBACK) ?
320 &cdev->period_out_count[stream] :
321 &cdev->period_in_count[stream];
324 snd_pcm_period_elapsed(sub);
334 unsigned char *usb_buf = urb->transfer_buffer + iso->offset;
335 struct snd_pcm_substream *sub;
338 if (all_substreams_zero(cdev->sub_capture))
341 for (i = 0; i < iso->actual_length;) {
342 for (stream = 0; stream < cdev->n_streams; stream++, i++) {
343 sub = cdev->sub_capture[stream];
344 if (sub) {
345 struct snd_pcm_runtime *rt = sub->runtime;
346 char *audio_buf = rt->dma_area;
347 int sz = frames_to_bytes(rt, rt->buffer_size);
348 audio_buf[cdev->audio_in_buf_pos[stream]++]
350 cdev->period_in_count[stream]++;
351 if (cdev->audio_in_buf_pos[stream] == sz)
352 cdev->audio_in_buf_pos[stream] = 0;
362 unsigned char *usb_buf = urb->transfer_buffer + iso->offset;
364 struct snd_pcm_substream *sub;
367 for (i = 0; i < iso->actual_length;) {
368 if (i % (cdev->n_streams * BYTES_PER_SAMPLE_USB) == 0) {
370 stream < cdev->n_streams;
372 if (cdev->first_packet)
378 cdev->input_panic = 1;
381 cdev->output_panic = 1;
384 cdev->first_packet = 0;
386 for (stream = 0; stream < cdev->n_streams; stream++, i++) {
387 sub = cdev->sub_capture[stream];
388 if (cdev->input_panic)
391 if (sub) {
392 struct snd_pcm_runtime *rt = sub->runtime;
393 char *audio_buf = rt->dma_area;
394 int sz = frames_to_bytes(rt, rt->buffer_size);
395 audio_buf[cdev->audio_in_buf_pos[stream]++] =
397 cdev->period_in_count[stream]++;
398 if (cdev->audio_in_buf_pos[stream] == sz)
399 cdev->audio_in_buf_pos[stream] = 0;
409 unsigned char *usb_buf = urb->transfer_buffer + iso->offset;
410 struct device *dev = caiaqdev_to_dev(cdev);
414 if (iso->actual_length % (BYTES_PER_SAMPLE_USB * CHANNELS_PER_STREAM))
417 for (i = 0; i < iso->actual_length;) {
418 for (stream = 0; stream < cdev->n_streams; stream++) {
419 struct snd_pcm_substream *sub = cdev->sub_capture[stream];
423 if (sub && !cdev->input_panic) {
424 struct snd_pcm_runtime *rt = sub->runtime;
425 audio_buf = rt->dma_area;
426 sz = frames_to_bytes(rt, rt->buffer_size);
433 audio_buf[cdev->audio_in_buf_pos[stream]++] = usb_buf[i+n];
435 if (cdev->audio_in_buf_pos[stream] == sz)
436 cdev->audio_in_buf_pos[stream] = 0;
439 cdev->period_in_count[stream] += BYTES_PER_SAMPLE;
445 !cdev->first_packet) {
446 if (!cdev->input_panic)
449 cdev->input_panic = 1;
457 if (cdev->first_packet > 0)
458 cdev->first_packet--;
465 struct device *dev = caiaqdev_to_dev(cdev);
467 if (!cdev->streaming)
470 if (iso->actual_length < cdev->bpp)
473 switch (cdev->spec.data_alignment) {
485 if ((cdev->input_panic || cdev->output_panic) && !cdev->warned) {
487 cdev->input_panic ? "(input)" : "",
488 cdev->output_panic ? "(output)" : "");
489 cdev->warned = 1;
497 unsigned char *usb_buf = urb->transfer_buffer + iso->offset;
498 struct snd_pcm_substream *sub;
501 for (i = 0; i < iso->length;) {
502 for (stream = 0; stream < cdev->n_streams; stream++, i++) {
503 sub = cdev->sub_playback[stream];
504 if (sub) {
505 struct snd_pcm_runtime *rt = sub->runtime;
506 char *audio_buf = rt->dma_area;
507 int sz = frames_to_bytes(rt, rt->buffer_size);
509 audio_buf[cdev->audio_out_buf_pos[stream]];
510 cdev->period_out_count[stream]++;
511 cdev->audio_out_buf_pos[stream]++;
512 if (cdev->audio_out_buf_pos[stream] == sz)
513 cdev->audio_out_buf_pos[stream] = 0;
519 if (cdev->spec.data_alignment == 2 &&
520 i % (cdev->n_streams * BYTES_PER_SAMPLE_USB) ==
521 (cdev->n_streams * CHANNELS_PER_STREAM))
522 for (stream = 0; stream < cdev->n_streams; stream++, i++)
531 unsigned char *usb_buf = urb->transfer_buffer + iso->offset;
534 for (i = 0; i < iso->length;) {
535 for (stream = 0; stream < cdev->n_streams; stream++) {
536 struct snd_pcm_substream *sub = cdev->sub_playback[stream];
540 if (sub) {
541 struct snd_pcm_runtime *rt = sub->runtime;
542 audio_buf = rt->dma_area;
543 sz = frames_to_bytes(rt, rt->buffer_size);
549 usb_buf[i+n] = audio_buf[cdev->audio_out_buf_pos[stream]++];
551 if (cdev->audio_out_buf_pos[stream] == sz)
552 cdev->audio_out_buf_pos[stream] = 0;
559 cdev->period_out_count[stream] += BYTES_PER_SAMPLE;
574 switch (cdev->spec.data_alignment) {
587 struct snd_usb_caiaq_cb_info *info = urb->context;
589 struct device *dev;
594 if (urb->status || !info)
597 cdev = info->cdev;
600 if (!cdev->streaming)
605 if (test_and_set_bit(i, &cdev->outurb_active_mask) == 0) {
606 out = cdev->data_urbs_out[i];
618 if (urb->iso_frame_desc[frame].status)
621 len = urb->iso_frame_desc[outframe].actual_length;
622 out->iso_frame_desc[outframe].length = len;
623 out->iso_frame_desc[outframe].actual_length = 0;
624 out->iso_frame_desc[outframe].offset = offset;
628 scoped_guard(spinlock_irqsave, &cdev->spinlock) {
629 fill_out_urb(cdev, out, &out->iso_frame_desc[outframe]);
630 read_in_urb(cdev, urb, &urb->iso_frame_desc[frame]);
632 check_for_elapsed_periods(cdev, cdev->sub_playback);
633 check_for_elapsed_periods(cdev, cdev->sub_capture);
641 out->number_of_packets = outframe;
644 struct snd_usb_caiaq_cb_info *oinfo = out->context;
645 clear_bit(oinfo->index, &cdev->outurb_active_mask);
649 /* re-submit inbound urb */
651 urb->iso_frame_desc[frame].offset = BYTES_PER_FRAME * frame;
652 urb->iso_frame_desc[frame].length = BYTES_PER_FRAME;
653 urb->iso_frame_desc[frame].actual_length = 0;
656 urb->number_of_packets = FRAMES_PER_URB;
662 struct snd_usb_caiaq_cb_info *info = urb->context;
663 struct snd_usb_caiaqdev *cdev = info->cdev;
665 if (!cdev->output_running) {
666 cdev->output_running = 1;
667 wake_up(&cdev->prepare_wait_queue);
670 clear_bit(info->index, &cdev->outurb_active_mask);
677 struct usb_device *usb_dev = cdev->chip.dev;
686 *ret = -ENOMEM;
693 *ret = -ENOMEM;
697 urbs[i]->transfer_buffer =
700 if (!urbs[i]->transfer_buffer) {
701 *ret = -ENOMEM;
707 &urbs[i]->iso_frame_desc[frame];
709 iso->offset = BYTES_PER_FRAME * frame;
710 iso->length = BYTES_PER_FRAME;
713 urbs[i]->dev = usb_dev;
714 urbs[i]->pipe = pipe;
715 urbs[i]->transfer_buffer_length = FRAMES_PER_URB
717 urbs[i]->context = &cdev->data_cb_info[i];
718 urbs[i]->interval = 1;
719 urbs[i]->number_of_packets = FRAMES_PER_URB;
720 urbs[i]->complete = (dir == SNDRV_PCM_STREAM_CAPTURE) ?
740 kfree(urbs[i]->transfer_buffer);
750 struct device *dev = caiaqdev_to_dev(cdev);
752 cdev->n_audio_in = max(cdev->spec.num_analog_audio_in,
753 cdev->spec.num_digital_audio_in) /
755 cdev->n_audio_out = max(cdev->spec.num_analog_audio_out,
756 cdev->spec.num_digital_audio_out) /
758 cdev->n_streams = max(cdev->n_audio_in, cdev->n_audio_out);
760 dev_dbg(dev, "cdev->n_audio_in = %d\n", cdev->n_audio_in);
761 dev_dbg(dev, "cdev->n_audio_out = %d\n", cdev->n_audio_out);
762 dev_dbg(dev, "cdev->n_streams = %d\n", cdev->n_streams);
764 if (cdev->n_streams > MAX_STREAMS) {
765 dev_err(dev, "unable to initialize device, too many streams.\n");
766 return -EINVAL;
769 if (cdev->n_streams < 1) {
770 dev_err(dev, "bogus number of streams: %d\n", cdev->n_streams);
771 return -EINVAL;
774 ret = snd_pcm_new(cdev->chip.card, cdev->product_name, 0,
775 cdev->n_audio_out, cdev->n_audio_in, &cdev->pcm);
782 cdev->pcm->private_data = cdev;
783 strscpy(cdev->pcm->name, cdev->product_name, sizeof(cdev->pcm->name));
785 memset(cdev->sub_playback, 0, sizeof(cdev->sub_playback));
786 memset(cdev->sub_capture, 0, sizeof(cdev->sub_capture));
788 memcpy(&cdev->pcm_info, &snd_usb_caiaq_pcm_hardware,
792 cdev->samplerates = cdev->pcm_info.rates;
793 switch (cdev->chip.usb_id) {
798 cdev->samplerates |= SNDRV_PCM_RATE_192000;
804 cdev->samplerates |= SNDRV_PCM_RATE_88200;
808 snd_pcm_set_ops(cdev->pcm, SNDRV_PCM_STREAM_PLAYBACK,
810 snd_pcm_set_ops(cdev->pcm, SNDRV_PCM_STREAM_CAPTURE,
812 snd_pcm_set_managed_buffer_all(cdev->pcm, SNDRV_DMA_TYPE_VMALLOC,
815 cdev->data_cb_info =
819 if (!cdev->data_cb_info)
820 return -ENOMEM;
822 cdev->outurb_active_mask = 0;
823 BUILD_BUG_ON(N_URBS > (sizeof(cdev->outurb_active_mask) * 8));
826 cdev->data_cb_info[i].cdev = cdev;
827 cdev->data_cb_info[i].index = i;
830 cdev->data_urbs_in = alloc_urbs(cdev, SNDRV_PCM_STREAM_CAPTURE, &ret);
832 kfree(cdev->data_cb_info);
833 free_urbs(cdev->data_urbs_in);
837 cdev->data_urbs_out = alloc_urbs(cdev, SNDRV_PCM_STREAM_PLAYBACK, &ret);
839 kfree(cdev->data_cb_info);
840 free_urbs(cdev->data_urbs_in);
841 free_urbs(cdev->data_urbs_out);
850 struct device *dev = caiaqdev_to_dev(cdev);
858 struct device *dev = caiaqdev_to_dev(cdev);
861 free_urbs(cdev->data_urbs_in);
862 free_urbs(cdev->data_urbs_out);
863 kfree(cdev->data_cb_info);