43 #define MAKE_CHECKBYTE(cdev,stream,i) \  argument
44 	(stream << 1) | (~(i / (cdev->n_streams * BYTES_PER_SAMPLE_USB)) & 1)
64 activate_substream(struct snd_usb_caiaqdev *cdev,  in activate_substream()  argument
67 	spin_lock(&cdev->spinlock);  in activate_substream()
70 		cdev->sub_playback[sub->number] = sub;  in activate_substream()
72 		cdev->sub_capture[sub->number] = sub;  in activate_substream()
74 	spin_unlock(&cdev->spinlock);  in activate_substream()
78 deactivate_substream(struct snd_usb_caiaqdev *cdev,  in deactivate_substream()  argument
82 	spin_lock_irqsave(&cdev->spinlock, flags);  in deactivate_substream()
85 		cdev->sub_playback[sub->number] = NULL;  in deactivate_substream()
87 		cdev->sub_capture[sub->number] = NULL;  in deactivate_substream()
89 	spin_unlock_irqrestore(&cdev->spinlock, flags);  in deactivate_substream()
102 static int stream_start(struct snd_usb_caiaqdev *cdev)  in stream_start()  argument
105 	struct device *dev = caiaqdev_to_dev(cdev);  in stream_start()
107 	dev_dbg(dev, "%s(%p)\n", __func__, cdev);  in stream_start()
109 	if (cdev->streaming)  in stream_start()
112 	memset(cdev->sub_playback, 0, sizeof(cdev->sub_playback));  in stream_start()
113 	memset(cdev->sub_capture, 0, sizeof(cdev->sub_capture));  in stream_start()
114 	cdev->input_panic = 0;  in stream_start()
115 	cdev->output_panic = 0;  in stream_start()
116 	cdev->first_packet = 4;  in stream_start()
117 	cdev->streaming = 1;  in stream_start()
118 	cdev->warned = 0;  in stream_start()
121 		ret = usb_submit_urb(cdev->data_urbs_in[i], GFP_ATOMIC);  in stream_start()
125 			cdev->streaming = 0;  in stream_start()
133 static void stream_stop(struct snd_usb_caiaqdev *cdev)  in stream_stop()  argument
136 	struct device *dev = caiaqdev_to_dev(cdev);  in stream_stop()
138 	dev_dbg(dev, "%s(%p)\n", __func__, cdev);  in stream_stop()
139 	if (!cdev->streaming)  in stream_stop()
142 	cdev->streaming = 0;  in stream_stop()
145 		usb_kill_urb(cdev->data_urbs_in[i]);  in stream_stop()
147 		if (test_bit(i, &cdev->outurb_active_mask))  in stream_stop()
148 			usb_kill_urb(cdev->data_urbs_out[i]);  in stream_stop()
151 	cdev->outurb_active_mask = 0;  in stream_stop()
156 	struct snd_usb_caiaqdev *cdev = snd_pcm_substream_chip(substream);  in snd_usb_caiaq_substream_open()  local
157 	struct device *dev = caiaqdev_to_dev(cdev);  in snd_usb_caiaq_substream_open()
160 	substream->runtime->hw = cdev->pcm_info;  in snd_usb_caiaq_substream_open()
168 	struct snd_usb_caiaqdev *cdev = snd_pcm_substream_chip(substream);  in snd_usb_caiaq_substream_close()  local
169 	struct device *dev = caiaqdev_to_dev(cdev);  in snd_usb_caiaq_substream_close()
172 	if (all_substreams_zero(cdev->sub_playback) &&  in snd_usb_caiaq_substream_close()
173 	    all_substreams_zero(cdev->sub_capture)) {  in snd_usb_caiaq_substream_close()
176 		stream_stop(cdev);  in snd_usb_caiaq_substream_close()
177 		cdev->pcm_info.rates = cdev->samplerates;  in snd_usb_caiaq_substream_close()
192 	struct snd_usb_caiaqdev *cdev = snd_pcm_substream_chip(sub);  in snd_usb_caiaq_pcm_hw_free()  local
193 	deactivate_substream(cdev, sub);  in snd_usb_caiaq_pcm_hw_free()
209 	struct snd_usb_caiaqdev *cdev = snd_pcm_substream_chip(substream);  in snd_usb_caiaq_pcm_prepare()  local
211 	struct device *dev = caiaqdev_to_dev(cdev);  in snd_usb_caiaq_pcm_prepare()
218 		switch (cdev->spec.data_alignment) {  in snd_usb_caiaq_pcm_prepare()
229 		cdev->period_out_count[index] = out_pos;  in snd_usb_caiaq_pcm_prepare()
230 		cdev->audio_out_buf_pos[index] = out_pos;  in snd_usb_caiaq_pcm_prepare()
234 		switch (cdev->spec.data_alignment) {  in snd_usb_caiaq_pcm_prepare()
247 		cdev->period_in_count[index] = in_pos;  in snd_usb_caiaq_pcm_prepare()
248 		cdev->audio_in_buf_pos[index] = in_pos;  in snd_usb_caiaq_pcm_prepare()
251 	if (cdev->streaming)  in snd_usb_caiaq_pcm_prepare()
258 			cdev->pcm_info.rates = 1 << i;  in snd_usb_caiaq_pcm_prepare()
263 	if (cdev->spec.data_alignment >= 2)  in snd_usb_caiaq_pcm_prepare()
267 		* bytes_per_sample * CHANNELS_PER_STREAM * cdev->n_streams;  in snd_usb_caiaq_pcm_prepare()
272 	ret = snd_usb_caiaq_set_audio_params(cdev, runtime->rate,  in snd_usb_caiaq_pcm_prepare()
277 	ret = stream_start(cdev);  in snd_usb_caiaq_pcm_prepare()
281 	cdev->output_running = 0;  in snd_usb_caiaq_pcm_prepare()
282 	wait_event_timeout(cdev->prepare_wait_queue, cdev->output_running, HZ);  in snd_usb_caiaq_pcm_prepare()
283 	if (!cdev->output_running) {  in snd_usb_caiaq_pcm_prepare()
284 		stream_stop(cdev);  in snd_usb_caiaq_pcm_prepare()
293 	struct snd_usb_caiaqdev *cdev = snd_pcm_substream_chip(sub);  in snd_usb_caiaq_pcm_trigger()  local
294 	struct device *dev = caiaqdev_to_dev(cdev);  in snd_usb_caiaq_pcm_trigger()
301 		activate_substream(cdev, sub);  in snd_usb_caiaq_pcm_trigger()
305 		deactivate_substream(cdev, sub);  in snd_usb_caiaq_pcm_trigger()
318 	struct snd_usb_caiaqdev *cdev = snd_pcm_substream_chip(sub);  in snd_usb_caiaq_pcm_pointer()  local
321 	spin_lock(&cdev->spinlock);  in snd_usb_caiaq_pcm_pointer()
323 	if (cdev->input_panic || cdev->output_panic) {  in snd_usb_caiaq_pcm_pointer()
330 					cdev->audio_out_buf_pos[index]);  in snd_usb_caiaq_pcm_pointer()
333 					cdev->audio_in_buf_pos[index]);  in snd_usb_caiaq_pcm_pointer()
336 	spin_unlock(&cdev->spinlock);  in snd_usb_caiaq_pcm_pointer()
353 static void check_for_elapsed_periods(struct snd_usb_caiaqdev *cdev,  in check_for_elapsed_periods()  argument
359 	for (stream = 0; stream < cdev->n_streams; stream++) {  in check_for_elapsed_periods()
366 					&cdev->period_out_count[stream] :  in check_for_elapsed_periods()
367 					&cdev->period_in_count[stream];  in check_for_elapsed_periods()
376 static void read_in_urb_mode0(struct snd_usb_caiaqdev *cdev,  in read_in_urb_mode0()  argument
384 	if (all_substreams_zero(cdev->sub_capture))  in read_in_urb_mode0()
388 		for (stream = 0; stream < cdev->n_streams; stream++, i++) {  in read_in_urb_mode0()
389 			sub = cdev->sub_capture[stream];  in read_in_urb_mode0()
394 				audio_buf[cdev->audio_in_buf_pos[stream]++]  in read_in_urb_mode0()
396 				cdev->period_in_count[stream]++;  in read_in_urb_mode0()
397 				if (cdev->audio_in_buf_pos[stream] == sz)  in read_in_urb_mode0()
398 					cdev->audio_in_buf_pos[stream] = 0;  in read_in_urb_mode0()
404 static void read_in_urb_mode2(struct snd_usb_caiaqdev *cdev,  in read_in_urb_mode2()  argument
414 		if (i % (cdev->n_streams * BYTES_PER_SAMPLE_USB) == 0) {  in read_in_urb_mode2()
416 			     stream < cdev->n_streams;  in read_in_urb_mode2()
418 				if (cdev->first_packet)  in read_in_urb_mode2()
421 				check_byte = MAKE_CHECKBYTE(cdev, stream, i);  in read_in_urb_mode2()
424 					cdev->input_panic = 1;  in read_in_urb_mode2()
427 					cdev->output_panic = 1;  in read_in_urb_mode2()
430 		cdev->first_packet = 0;  in read_in_urb_mode2()
432 		for (stream = 0; stream < cdev->n_streams; stream++, i++) {  in read_in_urb_mode2()
433 			sub = cdev->sub_capture[stream];  in read_in_urb_mode2()
434 			if (cdev->input_panic)  in read_in_urb_mode2()
441 				audio_buf[cdev->audio_in_buf_pos[stream]++] =  in read_in_urb_mode2()
443 				cdev->period_in_count[stream]++;  in read_in_urb_mode2()
444 				if (cdev->audio_in_buf_pos[stream] == sz)  in read_in_urb_mode2()
445 					cdev->audio_in_buf_pos[stream] = 0;  in read_in_urb_mode2()
451 static void read_in_urb_mode3(struct snd_usb_caiaqdev *cdev,  in read_in_urb_mode3()  argument
456 	struct device *dev = caiaqdev_to_dev(cdev);  in read_in_urb_mode3()
464 		for (stream = 0; stream < cdev->n_streams; stream++) {  in read_in_urb_mode3()
465 			struct snd_pcm_substream *sub = cdev->sub_capture[stream];  in read_in_urb_mode3()
469 			if (sub && !cdev->input_panic) {  in read_in_urb_mode3()
479 						audio_buf[cdev->audio_in_buf_pos[stream]++] = usb_buf[i+n];  in read_in_urb_mode3()
481 						if (cdev->audio_in_buf_pos[stream] == sz)  in read_in_urb_mode3()
482 							cdev->audio_in_buf_pos[stream] = 0;  in read_in_urb_mode3()
485 					cdev->period_in_count[stream] += BYTES_PER_SAMPLE;  in read_in_urb_mode3()
491 				    !cdev->first_packet) {  in read_in_urb_mode3()
492 					if (!cdev->input_panic)  in read_in_urb_mode3()
495 					cdev->input_panic = 1;  in read_in_urb_mode3()
503 	if (cdev->first_packet > 0)  in read_in_urb_mode3()
504 		cdev->first_packet--;  in read_in_urb_mode3()
507 static void read_in_urb(struct snd_usb_caiaqdev *cdev,  in read_in_urb()  argument
511 	struct device *dev = caiaqdev_to_dev(cdev);  in read_in_urb()
513 	if (!cdev->streaming)  in read_in_urb()
516 	if (iso->actual_length < cdev->bpp)  in read_in_urb()
519 	switch (cdev->spec.data_alignment) {  in read_in_urb()
521 		read_in_urb_mode0(cdev, urb, iso);  in read_in_urb()
524 		read_in_urb_mode2(cdev, urb, iso);  in read_in_urb()
527 		read_in_urb_mode3(cdev, urb, iso);  in read_in_urb()
531 	if ((cdev->input_panic || cdev->output_panic) && !cdev->warned) {  in read_in_urb()
533 				cdev->input_panic ? "(input)" : "",  in read_in_urb()
534 				cdev->output_panic ? "(output)" : "");  in read_in_urb()
535 		cdev->warned = 1;  in read_in_urb()
539 static void fill_out_urb_mode_0(struct snd_usb_caiaqdev *cdev,  in fill_out_urb_mode_0()  argument
548 		for (stream = 0; stream < cdev->n_streams; stream++, i++) {  in fill_out_urb_mode_0()
549 			sub = cdev->sub_playback[stream];  in fill_out_urb_mode_0()
555 					audio_buf[cdev->audio_out_buf_pos[stream]];  in fill_out_urb_mode_0()
556 				cdev->period_out_count[stream]++;  in fill_out_urb_mode_0()
557 				cdev->audio_out_buf_pos[stream]++;  in fill_out_urb_mode_0()
558 				if (cdev->audio_out_buf_pos[stream] == sz)  in fill_out_urb_mode_0()
559 					cdev->audio_out_buf_pos[stream] = 0;  in fill_out_urb_mode_0()
565 		if (cdev->spec.data_alignment == 2 &&  in fill_out_urb_mode_0()
566 		    i % (cdev->n_streams * BYTES_PER_SAMPLE_USB) ==  in fill_out_urb_mode_0()
567 		        (cdev->n_streams * CHANNELS_PER_STREAM))  in fill_out_urb_mode_0()
568 			for (stream = 0; stream < cdev->n_streams; stream++, i++)  in fill_out_urb_mode_0()
569 				usb_buf[i] = MAKE_CHECKBYTE(cdev, stream, i);  in fill_out_urb_mode_0()
573 static void fill_out_urb_mode_3(struct snd_usb_caiaqdev *cdev,  in fill_out_urb_mode_3()  argument
581 		for (stream = 0; stream < cdev->n_streams; stream++) {  in fill_out_urb_mode_3()
582 			struct snd_pcm_substream *sub = cdev->sub_playback[stream];  in fill_out_urb_mode_3()
595 						usb_buf[i+n] = audio_buf[cdev->audio_out_buf_pos[stream]++];  in fill_out_urb_mode_3()
597 						if (cdev->audio_out_buf_pos[stream] == sz)  in fill_out_urb_mode_3()
598 							cdev->audio_out_buf_pos[stream] = 0;  in fill_out_urb_mode_3()
605 					cdev->period_out_count[stream] += BYTES_PER_SAMPLE;  in fill_out_urb_mode_3()
616 static inline void fill_out_urb(struct snd_usb_caiaqdev *cdev,  in fill_out_urb()  argument
620 	switch (cdev->spec.data_alignment) {  in fill_out_urb()
623 		fill_out_urb_mode_0(cdev, urb, iso);  in fill_out_urb()
626 		fill_out_urb_mode_3(cdev, urb, iso);  in fill_out_urb()
634 	struct snd_usb_caiaqdev *cdev;  in read_completed()  local
644 	cdev = info->cdev;  in read_completed()
645 	dev = caiaqdev_to_dev(cdev);  in read_completed()
647 	if (!cdev->streaming)  in read_completed()
652 		if (test_and_set_bit(i, &cdev->outurb_active_mask) == 0) {  in read_completed()
653 			out = cdev->data_urbs_out[i];  in read_completed()
675 			spin_lock_irqsave(&cdev->spinlock, flags);  in read_completed()
676 			fill_out_urb(cdev, out, &out->iso_frame_desc[outframe]);  in read_completed()
677 			read_in_urb(cdev, urb, &urb->iso_frame_desc[frame]);  in read_completed()
678 			spin_unlock_irqrestore(&cdev->spinlock, flags);  in read_completed()
679 			check_for_elapsed_periods(cdev, cdev->sub_playback);  in read_completed()
680 			check_for_elapsed_periods(cdev, cdev->sub_capture);  in read_completed()
692 		clear_bit(oinfo->index, &cdev->outurb_active_mask);  in read_completed()
710 	struct snd_usb_caiaqdev *cdev = info->cdev;  in write_completed()  local
712 	if (!cdev->output_running) {  in write_completed()
713 		cdev->output_running = 1;  in write_completed()
714 		wake_up(&cdev->prepare_wait_queue);  in write_completed()
717 	clear_bit(info->index, &cdev->outurb_active_mask);  in write_completed()
720 static struct urb **alloc_urbs(struct snd_usb_caiaqdev *cdev, int dir, int *ret)  in alloc_urbs()  argument
724 	struct usb_device *usb_dev = cdev->chip.dev;  in alloc_urbs()
764 		urbs[i]->context = &cdev->data_cb_info[i];  in alloc_urbs()
794 int snd_usb_caiaq_audio_init(struct snd_usb_caiaqdev *cdev)  in snd_usb_caiaq_audio_init()  argument
797 	struct device *dev = caiaqdev_to_dev(cdev);  in snd_usb_caiaq_audio_init()
799 	cdev->n_audio_in  = max(cdev->spec.num_analog_audio_in,  in snd_usb_caiaq_audio_init()
800 			       cdev->spec.num_digital_audio_in) /  in snd_usb_caiaq_audio_init()
802 	cdev->n_audio_out = max(cdev->spec.num_analog_audio_out,  in snd_usb_caiaq_audio_init()
803 			       cdev->spec.num_digital_audio_out) /  in snd_usb_caiaq_audio_init()
805 	cdev->n_streams = max(cdev->n_audio_in, cdev->n_audio_out);  in snd_usb_caiaq_audio_init()
807 	dev_dbg(dev, "cdev->n_audio_in = %d\n", cdev->n_audio_in);  in snd_usb_caiaq_audio_init()
808 	dev_dbg(dev, "cdev->n_audio_out = %d\n", cdev->n_audio_out);  in snd_usb_caiaq_audio_init()
809 	dev_dbg(dev, "cdev->n_streams = %d\n", cdev->n_streams);  in snd_usb_caiaq_audio_init()
811 	if (cdev->n_streams > MAX_STREAMS) {  in snd_usb_caiaq_audio_init()
816 	if (cdev->n_streams < 1) {  in snd_usb_caiaq_audio_init()
817 		dev_err(dev, "bogus number of streams: %d\n", cdev->n_streams);  in snd_usb_caiaq_audio_init()
821 	ret = snd_pcm_new(cdev->chip.card, cdev->product_name, 0,  in snd_usb_caiaq_audio_init()
822 			cdev->n_audio_out, cdev->n_audio_in, &cdev->pcm);  in snd_usb_caiaq_audio_init()
829 	cdev->pcm->private_data = cdev;  in snd_usb_caiaq_audio_init()
830 	strlcpy(cdev->pcm->name, cdev->product_name, sizeof(cdev->pcm->name));  in snd_usb_caiaq_audio_init()
832 	memset(cdev->sub_playback, 0, sizeof(cdev->sub_playback));  in snd_usb_caiaq_audio_init()
833 	memset(cdev->sub_capture, 0, sizeof(cdev->sub_capture));  in snd_usb_caiaq_audio_init()
835 	memcpy(&cdev->pcm_info, &snd_usb_caiaq_pcm_hardware,  in snd_usb_caiaq_audio_init()
839 	cdev->samplerates = cdev->pcm_info.rates;  in snd_usb_caiaq_audio_init()
840 	switch (cdev->chip.usb_id) {  in snd_usb_caiaq_audio_init()
845 		cdev->samplerates |= SNDRV_PCM_RATE_192000;  in snd_usb_caiaq_audio_init()
851 		cdev->samplerates |= SNDRV_PCM_RATE_88200;  in snd_usb_caiaq_audio_init()
855 	snd_pcm_set_ops(cdev->pcm, SNDRV_PCM_STREAM_PLAYBACK,  in snd_usb_caiaq_audio_init()
857 	snd_pcm_set_ops(cdev->pcm, SNDRV_PCM_STREAM_CAPTURE,  in snd_usb_caiaq_audio_init()
860 	cdev->data_cb_info =  in snd_usb_caiaq_audio_init()
864 	if (!cdev->data_cb_info)  in snd_usb_caiaq_audio_init()
867 	cdev->outurb_active_mask = 0;  in snd_usb_caiaq_audio_init()
868 	BUILD_BUG_ON(N_URBS > (sizeof(cdev->outurb_active_mask) * 8));  in snd_usb_caiaq_audio_init()
871 		cdev->data_cb_info[i].cdev = cdev;  in snd_usb_caiaq_audio_init()
872 		cdev->data_cb_info[i].index = i;  in snd_usb_caiaq_audio_init()
875 	cdev->data_urbs_in = alloc_urbs(cdev, SNDRV_PCM_STREAM_CAPTURE, &ret);  in snd_usb_caiaq_audio_init()
877 		kfree(cdev->data_cb_info);  in snd_usb_caiaq_audio_init()
878 		free_urbs(cdev->data_urbs_in);  in snd_usb_caiaq_audio_init()
882 	cdev->data_urbs_out = alloc_urbs(cdev, SNDRV_PCM_STREAM_PLAYBACK, &ret);  in snd_usb_caiaq_audio_init()
884 		kfree(cdev->data_cb_info);  in snd_usb_caiaq_audio_init()
885 		free_urbs(cdev->data_urbs_in);  in snd_usb_caiaq_audio_init()
886 		free_urbs(cdev->data_urbs_out);  in snd_usb_caiaq_audio_init()
893 void snd_usb_caiaq_audio_free(struct snd_usb_caiaqdev *cdev)  in snd_usb_caiaq_audio_free()  argument
895 	struct device *dev = caiaqdev_to_dev(cdev);  in snd_usb_caiaq_audio_free()
897 	dev_dbg(dev, "%s(%p)\n", __func__, cdev);  in snd_usb_caiaq_audio_free()
898 	stream_stop(cdev);  in snd_usb_caiaq_audio_free()
899 	free_urbs(cdev->data_urbs_in);  in snd_usb_caiaq_audio_free()
900 	free_urbs(cdev->data_urbs_out);  in snd_usb_caiaq_audio_free()
901 	kfree(cdev->data_cb_info);  in snd_usb_caiaq_audio_free()