18c2ecf20Sopenharmony_ci// SPDX-License-Identifier: GPL-2.0-or-later
28c2ecf20Sopenharmony_ci/*
38c2ecf20Sopenharmony_ci * Linux driver for TerraTec DMX 6Fire USB
48c2ecf20Sopenharmony_ci *
58c2ecf20Sopenharmony_ci * PCM driver
68c2ecf20Sopenharmony_ci *
78c2ecf20Sopenharmony_ci * Author:	Torsten Schenk <torsten.schenk@zoho.com>
88c2ecf20Sopenharmony_ci * Created:	Jan 01, 2011
98c2ecf20Sopenharmony_ci * Copyright:	(C) Torsten Schenk
108c2ecf20Sopenharmony_ci */
118c2ecf20Sopenharmony_ci
128c2ecf20Sopenharmony_ci#include "pcm.h"
138c2ecf20Sopenharmony_ci#include "chip.h"
148c2ecf20Sopenharmony_ci#include "comm.h"
158c2ecf20Sopenharmony_ci#include "control.h"
168c2ecf20Sopenharmony_ci
178c2ecf20Sopenharmony_cienum {
188c2ecf20Sopenharmony_ci	OUT_N_CHANNELS = 6, IN_N_CHANNELS = 4
198c2ecf20Sopenharmony_ci};
208c2ecf20Sopenharmony_ci
218c2ecf20Sopenharmony_ci/* keep next two synced with
228c2ecf20Sopenharmony_ci * FW_EP_W_MAX_PACKET_SIZE[] and RATES_MAX_PACKET_SIZE
238c2ecf20Sopenharmony_ci * and CONTROL_RATE_XXX in control.h */
248c2ecf20Sopenharmony_cistatic const int rates_in_packet_size[] = { 228, 228, 420, 420, 404, 404 };
258c2ecf20Sopenharmony_cistatic const int rates_out_packet_size[] = { 228, 228, 420, 420, 604, 604 };
268c2ecf20Sopenharmony_cistatic const int rates[] = { 44100, 48000, 88200, 96000, 176400, 192000 };
278c2ecf20Sopenharmony_cistatic const int rates_alsaid[] = {
288c2ecf20Sopenharmony_ci	SNDRV_PCM_RATE_44100, SNDRV_PCM_RATE_48000,
298c2ecf20Sopenharmony_ci	SNDRV_PCM_RATE_88200, SNDRV_PCM_RATE_96000,
308c2ecf20Sopenharmony_ci	SNDRV_PCM_RATE_176400, SNDRV_PCM_RATE_192000 };
318c2ecf20Sopenharmony_ci
328c2ecf20Sopenharmony_cienum { /* settings for pcm */
338c2ecf20Sopenharmony_ci	OUT_EP = 6, IN_EP = 2, MAX_BUFSIZE = 128 * 1024
348c2ecf20Sopenharmony_ci};
358c2ecf20Sopenharmony_ci
368c2ecf20Sopenharmony_cienum { /* pcm streaming states */
378c2ecf20Sopenharmony_ci	STREAM_DISABLED, /* no pcm streaming */
388c2ecf20Sopenharmony_ci	STREAM_STARTING, /* pcm streaming requested, waiting to become ready */
398c2ecf20Sopenharmony_ci	STREAM_RUNNING, /* pcm streaming running */
408c2ecf20Sopenharmony_ci	STREAM_STOPPING
418c2ecf20Sopenharmony_ci};
428c2ecf20Sopenharmony_ci
438c2ecf20Sopenharmony_cistatic const struct snd_pcm_hardware pcm_hw = {
448c2ecf20Sopenharmony_ci	.info = SNDRV_PCM_INFO_MMAP |
458c2ecf20Sopenharmony_ci		SNDRV_PCM_INFO_INTERLEAVED |
468c2ecf20Sopenharmony_ci		SNDRV_PCM_INFO_BLOCK_TRANSFER |
478c2ecf20Sopenharmony_ci		SNDRV_PCM_INFO_MMAP_VALID |
488c2ecf20Sopenharmony_ci		SNDRV_PCM_INFO_BATCH,
498c2ecf20Sopenharmony_ci
508c2ecf20Sopenharmony_ci	.formats = SNDRV_PCM_FMTBIT_S24_LE | SNDRV_PCM_FMTBIT_S32_LE,
518c2ecf20Sopenharmony_ci
528c2ecf20Sopenharmony_ci	.rates = SNDRV_PCM_RATE_44100 |
538c2ecf20Sopenharmony_ci		SNDRV_PCM_RATE_48000 |
548c2ecf20Sopenharmony_ci		SNDRV_PCM_RATE_88200 |
558c2ecf20Sopenharmony_ci		SNDRV_PCM_RATE_96000 |
568c2ecf20Sopenharmony_ci		SNDRV_PCM_RATE_176400 |
578c2ecf20Sopenharmony_ci		SNDRV_PCM_RATE_192000,
588c2ecf20Sopenharmony_ci
598c2ecf20Sopenharmony_ci	.rate_min = 44100,
608c2ecf20Sopenharmony_ci	.rate_max = 192000,
618c2ecf20Sopenharmony_ci	.channels_min = 1,
628c2ecf20Sopenharmony_ci	.channels_max = 0, /* set in pcm_open, depending on capture/playback */
638c2ecf20Sopenharmony_ci	.buffer_bytes_max = MAX_BUFSIZE,
648c2ecf20Sopenharmony_ci	.period_bytes_min = PCM_N_PACKETS_PER_URB * (PCM_MAX_PACKET_SIZE - 4),
658c2ecf20Sopenharmony_ci	.period_bytes_max = MAX_BUFSIZE,
668c2ecf20Sopenharmony_ci	.periods_min = 2,
678c2ecf20Sopenharmony_ci	.periods_max = 1024
688c2ecf20Sopenharmony_ci};
698c2ecf20Sopenharmony_ci
708c2ecf20Sopenharmony_cistatic int usb6fire_pcm_set_rate(struct pcm_runtime *rt)
718c2ecf20Sopenharmony_ci{
728c2ecf20Sopenharmony_ci	int ret;
738c2ecf20Sopenharmony_ci	struct control_runtime *ctrl_rt = rt->chip->control;
748c2ecf20Sopenharmony_ci
758c2ecf20Sopenharmony_ci	ctrl_rt->usb_streaming = false;
768c2ecf20Sopenharmony_ci	ret = ctrl_rt->update_streaming(ctrl_rt);
778c2ecf20Sopenharmony_ci	if (ret < 0) {
788c2ecf20Sopenharmony_ci		dev_err(&rt->chip->dev->dev,
798c2ecf20Sopenharmony_ci			"error stopping streaming while setting samplerate %d.\n",
808c2ecf20Sopenharmony_ci			rates[rt->rate]);
818c2ecf20Sopenharmony_ci		return ret;
828c2ecf20Sopenharmony_ci	}
838c2ecf20Sopenharmony_ci
848c2ecf20Sopenharmony_ci	ret = ctrl_rt->set_rate(ctrl_rt, rt->rate);
858c2ecf20Sopenharmony_ci	if (ret < 0) {
868c2ecf20Sopenharmony_ci		dev_err(&rt->chip->dev->dev,
878c2ecf20Sopenharmony_ci			"error setting samplerate %d.\n",
888c2ecf20Sopenharmony_ci			rates[rt->rate]);
898c2ecf20Sopenharmony_ci		return ret;
908c2ecf20Sopenharmony_ci	}
918c2ecf20Sopenharmony_ci
928c2ecf20Sopenharmony_ci	ret = ctrl_rt->set_channels(ctrl_rt, OUT_N_CHANNELS, IN_N_CHANNELS,
938c2ecf20Sopenharmony_ci			false, false);
948c2ecf20Sopenharmony_ci	if (ret < 0) {
958c2ecf20Sopenharmony_ci		dev_err(&rt->chip->dev->dev,
968c2ecf20Sopenharmony_ci			"error initializing channels while setting samplerate %d.\n",
978c2ecf20Sopenharmony_ci			rates[rt->rate]);
988c2ecf20Sopenharmony_ci		return ret;
998c2ecf20Sopenharmony_ci	}
1008c2ecf20Sopenharmony_ci
1018c2ecf20Sopenharmony_ci	ctrl_rt->usb_streaming = true;
1028c2ecf20Sopenharmony_ci	ret = ctrl_rt->update_streaming(ctrl_rt);
1038c2ecf20Sopenharmony_ci	if (ret < 0) {
1048c2ecf20Sopenharmony_ci		dev_err(&rt->chip->dev->dev,
1058c2ecf20Sopenharmony_ci			"error starting streaming while setting samplerate %d.\n",
1068c2ecf20Sopenharmony_ci			rates[rt->rate]);
1078c2ecf20Sopenharmony_ci		return ret;
1088c2ecf20Sopenharmony_ci	}
1098c2ecf20Sopenharmony_ci
1108c2ecf20Sopenharmony_ci	rt->in_n_analog = IN_N_CHANNELS;
1118c2ecf20Sopenharmony_ci	rt->out_n_analog = OUT_N_CHANNELS;
1128c2ecf20Sopenharmony_ci	rt->in_packet_size = rates_in_packet_size[rt->rate];
1138c2ecf20Sopenharmony_ci	rt->out_packet_size = rates_out_packet_size[rt->rate];
1148c2ecf20Sopenharmony_ci	return 0;
1158c2ecf20Sopenharmony_ci}
1168c2ecf20Sopenharmony_ci
1178c2ecf20Sopenharmony_cistatic struct pcm_substream *usb6fire_pcm_get_substream(
1188c2ecf20Sopenharmony_ci		struct snd_pcm_substream *alsa_sub)
1198c2ecf20Sopenharmony_ci{
1208c2ecf20Sopenharmony_ci	struct pcm_runtime *rt = snd_pcm_substream_chip(alsa_sub);
1218c2ecf20Sopenharmony_ci
1228c2ecf20Sopenharmony_ci	if (alsa_sub->stream == SNDRV_PCM_STREAM_PLAYBACK)
1238c2ecf20Sopenharmony_ci		return &rt->playback;
1248c2ecf20Sopenharmony_ci	else if (alsa_sub->stream == SNDRV_PCM_STREAM_CAPTURE)
1258c2ecf20Sopenharmony_ci		return &rt->capture;
1268c2ecf20Sopenharmony_ci	dev_err(&rt->chip->dev->dev, "error getting pcm substream slot.\n");
1278c2ecf20Sopenharmony_ci	return NULL;
1288c2ecf20Sopenharmony_ci}
1298c2ecf20Sopenharmony_ci
1308c2ecf20Sopenharmony_ci/* call with stream_mutex locked */
1318c2ecf20Sopenharmony_cistatic void usb6fire_pcm_stream_stop(struct pcm_runtime *rt)
1328c2ecf20Sopenharmony_ci{
1338c2ecf20Sopenharmony_ci	int i;
1348c2ecf20Sopenharmony_ci	struct control_runtime *ctrl_rt = rt->chip->control;
1358c2ecf20Sopenharmony_ci
1368c2ecf20Sopenharmony_ci	if (rt->stream_state != STREAM_DISABLED) {
1378c2ecf20Sopenharmony_ci
1388c2ecf20Sopenharmony_ci		rt->stream_state = STREAM_STOPPING;
1398c2ecf20Sopenharmony_ci
1408c2ecf20Sopenharmony_ci		for (i = 0; i < PCM_N_URBS; i++) {
1418c2ecf20Sopenharmony_ci			usb_kill_urb(&rt->in_urbs[i].instance);
1428c2ecf20Sopenharmony_ci			usb_kill_urb(&rt->out_urbs[i].instance);
1438c2ecf20Sopenharmony_ci		}
1448c2ecf20Sopenharmony_ci		ctrl_rt->usb_streaming = false;
1458c2ecf20Sopenharmony_ci		ctrl_rt->update_streaming(ctrl_rt);
1468c2ecf20Sopenharmony_ci		rt->stream_state = STREAM_DISABLED;
1478c2ecf20Sopenharmony_ci	}
1488c2ecf20Sopenharmony_ci}
1498c2ecf20Sopenharmony_ci
1508c2ecf20Sopenharmony_ci/* call with stream_mutex locked */
1518c2ecf20Sopenharmony_cistatic int usb6fire_pcm_stream_start(struct pcm_runtime *rt)
1528c2ecf20Sopenharmony_ci{
1538c2ecf20Sopenharmony_ci	int ret;
1548c2ecf20Sopenharmony_ci	int i;
1558c2ecf20Sopenharmony_ci	int k;
1568c2ecf20Sopenharmony_ci	struct usb_iso_packet_descriptor *packet;
1578c2ecf20Sopenharmony_ci
1588c2ecf20Sopenharmony_ci	if (rt->stream_state == STREAM_DISABLED) {
1598c2ecf20Sopenharmony_ci		/* submit our in urbs */
1608c2ecf20Sopenharmony_ci		rt->stream_wait_cond = false;
1618c2ecf20Sopenharmony_ci		rt->stream_state = STREAM_STARTING;
1628c2ecf20Sopenharmony_ci		for (i = 0; i < PCM_N_URBS; i++) {
1638c2ecf20Sopenharmony_ci			for (k = 0; k < PCM_N_PACKETS_PER_URB; k++) {
1648c2ecf20Sopenharmony_ci				packet = &rt->in_urbs[i].packets[k];
1658c2ecf20Sopenharmony_ci				packet->offset = k * rt->in_packet_size;
1668c2ecf20Sopenharmony_ci				packet->length = rt->in_packet_size;
1678c2ecf20Sopenharmony_ci				packet->actual_length = 0;
1688c2ecf20Sopenharmony_ci				packet->status = 0;
1698c2ecf20Sopenharmony_ci			}
1708c2ecf20Sopenharmony_ci			ret = usb_submit_urb(&rt->in_urbs[i].instance,
1718c2ecf20Sopenharmony_ci					GFP_ATOMIC);
1728c2ecf20Sopenharmony_ci			if (ret) {
1738c2ecf20Sopenharmony_ci				usb6fire_pcm_stream_stop(rt);
1748c2ecf20Sopenharmony_ci				return ret;
1758c2ecf20Sopenharmony_ci			}
1768c2ecf20Sopenharmony_ci		}
1778c2ecf20Sopenharmony_ci
1788c2ecf20Sopenharmony_ci		/* wait for first out urb to return (sent in in urb handler) */
1798c2ecf20Sopenharmony_ci		wait_event_timeout(rt->stream_wait_queue, rt->stream_wait_cond,
1808c2ecf20Sopenharmony_ci				HZ);
1818c2ecf20Sopenharmony_ci		if (rt->stream_wait_cond)
1828c2ecf20Sopenharmony_ci			rt->stream_state = STREAM_RUNNING;
1838c2ecf20Sopenharmony_ci		else {
1848c2ecf20Sopenharmony_ci			usb6fire_pcm_stream_stop(rt);
1858c2ecf20Sopenharmony_ci			return -EIO;
1868c2ecf20Sopenharmony_ci		}
1878c2ecf20Sopenharmony_ci	}
1888c2ecf20Sopenharmony_ci	return 0;
1898c2ecf20Sopenharmony_ci}
1908c2ecf20Sopenharmony_ci
1918c2ecf20Sopenharmony_ci/* call with substream locked */
1928c2ecf20Sopenharmony_cistatic void usb6fire_pcm_capture(struct pcm_substream *sub, struct pcm_urb *urb)
1938c2ecf20Sopenharmony_ci{
1948c2ecf20Sopenharmony_ci	int i;
1958c2ecf20Sopenharmony_ci	int frame;
1968c2ecf20Sopenharmony_ci	int frame_count;
1978c2ecf20Sopenharmony_ci	unsigned int total_length = 0;
1988c2ecf20Sopenharmony_ci	struct pcm_runtime *rt = snd_pcm_substream_chip(sub->instance);
1998c2ecf20Sopenharmony_ci	struct snd_pcm_runtime *alsa_rt = sub->instance->runtime;
2008c2ecf20Sopenharmony_ci	u32 *src = NULL;
2018c2ecf20Sopenharmony_ci	u32 *dest = (u32 *) (alsa_rt->dma_area + sub->dma_off
2028c2ecf20Sopenharmony_ci			* (alsa_rt->frame_bits >> 3));
2038c2ecf20Sopenharmony_ci	u32 *dest_end = (u32 *) (alsa_rt->dma_area + alsa_rt->buffer_size
2048c2ecf20Sopenharmony_ci			* (alsa_rt->frame_bits >> 3));
2058c2ecf20Sopenharmony_ci	int bytes_per_frame = alsa_rt->channels << 2;
2068c2ecf20Sopenharmony_ci
2078c2ecf20Sopenharmony_ci	for (i = 0; i < PCM_N_PACKETS_PER_URB; i++) {
2088c2ecf20Sopenharmony_ci		/* at least 4 header bytes for valid packet.
2098c2ecf20Sopenharmony_ci		 * after that: 32 bits per sample for analog channels */
2108c2ecf20Sopenharmony_ci		if (urb->packets[i].actual_length > 4)
2118c2ecf20Sopenharmony_ci			frame_count = (urb->packets[i].actual_length - 4)
2128c2ecf20Sopenharmony_ci					/ (rt->in_n_analog << 2);
2138c2ecf20Sopenharmony_ci		else
2148c2ecf20Sopenharmony_ci			frame_count = 0;
2158c2ecf20Sopenharmony_ci
2168c2ecf20Sopenharmony_ci		if (alsa_rt->format == SNDRV_PCM_FORMAT_S24_LE)
2178c2ecf20Sopenharmony_ci			src = (u32 *) (urb->buffer + total_length);
2188c2ecf20Sopenharmony_ci		else if (alsa_rt->format == SNDRV_PCM_FORMAT_S32_LE)
2198c2ecf20Sopenharmony_ci			src = (u32 *) (urb->buffer - 1 + total_length);
2208c2ecf20Sopenharmony_ci		else
2218c2ecf20Sopenharmony_ci			return;
2228c2ecf20Sopenharmony_ci		src++; /* skip leading 4 bytes of every packet */
2238c2ecf20Sopenharmony_ci		total_length += urb->packets[i].length;
2248c2ecf20Sopenharmony_ci		for (frame = 0; frame < frame_count; frame++) {
2258c2ecf20Sopenharmony_ci			memcpy(dest, src, bytes_per_frame);
2268c2ecf20Sopenharmony_ci			dest += alsa_rt->channels;
2278c2ecf20Sopenharmony_ci			src += rt->in_n_analog;
2288c2ecf20Sopenharmony_ci			sub->dma_off++;
2298c2ecf20Sopenharmony_ci			sub->period_off++;
2308c2ecf20Sopenharmony_ci			if (dest == dest_end) {
2318c2ecf20Sopenharmony_ci				sub->dma_off = 0;
2328c2ecf20Sopenharmony_ci				dest = (u32 *) alsa_rt->dma_area;
2338c2ecf20Sopenharmony_ci			}
2348c2ecf20Sopenharmony_ci		}
2358c2ecf20Sopenharmony_ci	}
2368c2ecf20Sopenharmony_ci}
2378c2ecf20Sopenharmony_ci
2388c2ecf20Sopenharmony_ci/* call with substream locked */
2398c2ecf20Sopenharmony_cistatic void usb6fire_pcm_playback(struct pcm_substream *sub,
2408c2ecf20Sopenharmony_ci		struct pcm_urb *urb)
2418c2ecf20Sopenharmony_ci{
2428c2ecf20Sopenharmony_ci	int i;
2438c2ecf20Sopenharmony_ci	int frame;
2448c2ecf20Sopenharmony_ci	int frame_count;
2458c2ecf20Sopenharmony_ci	struct pcm_runtime *rt = snd_pcm_substream_chip(sub->instance);
2468c2ecf20Sopenharmony_ci	struct snd_pcm_runtime *alsa_rt = sub->instance->runtime;
2478c2ecf20Sopenharmony_ci	u32 *src = (u32 *) (alsa_rt->dma_area + sub->dma_off
2488c2ecf20Sopenharmony_ci			* (alsa_rt->frame_bits >> 3));
2498c2ecf20Sopenharmony_ci	u32 *src_end = (u32 *) (alsa_rt->dma_area + alsa_rt->buffer_size
2508c2ecf20Sopenharmony_ci			* (alsa_rt->frame_bits >> 3));
2518c2ecf20Sopenharmony_ci	u32 *dest;
2528c2ecf20Sopenharmony_ci	int bytes_per_frame = alsa_rt->channels << 2;
2538c2ecf20Sopenharmony_ci
2548c2ecf20Sopenharmony_ci	if (alsa_rt->format == SNDRV_PCM_FORMAT_S32_LE)
2558c2ecf20Sopenharmony_ci		dest = (u32 *) (urb->buffer - 1);
2568c2ecf20Sopenharmony_ci	else if (alsa_rt->format == SNDRV_PCM_FORMAT_S24_LE)
2578c2ecf20Sopenharmony_ci		dest = (u32 *) (urb->buffer);
2588c2ecf20Sopenharmony_ci	else {
2598c2ecf20Sopenharmony_ci		dev_err(&rt->chip->dev->dev, "Unknown sample format.");
2608c2ecf20Sopenharmony_ci		return;
2618c2ecf20Sopenharmony_ci	}
2628c2ecf20Sopenharmony_ci
2638c2ecf20Sopenharmony_ci	for (i = 0; i < PCM_N_PACKETS_PER_URB; i++) {
2648c2ecf20Sopenharmony_ci		/* at least 4 header bytes for valid packet.
2658c2ecf20Sopenharmony_ci		 * after that: 32 bits per sample for analog channels */
2668c2ecf20Sopenharmony_ci		if (urb->packets[i].length > 4)
2678c2ecf20Sopenharmony_ci			frame_count = (urb->packets[i].length - 4)
2688c2ecf20Sopenharmony_ci					/ (rt->out_n_analog << 2);
2698c2ecf20Sopenharmony_ci		else
2708c2ecf20Sopenharmony_ci			frame_count = 0;
2718c2ecf20Sopenharmony_ci		dest++; /* skip leading 4 bytes of every frame */
2728c2ecf20Sopenharmony_ci		for (frame = 0; frame < frame_count; frame++) {
2738c2ecf20Sopenharmony_ci			memcpy(dest, src, bytes_per_frame);
2748c2ecf20Sopenharmony_ci			src += alsa_rt->channels;
2758c2ecf20Sopenharmony_ci			dest += rt->out_n_analog;
2768c2ecf20Sopenharmony_ci			sub->dma_off++;
2778c2ecf20Sopenharmony_ci			sub->period_off++;
2788c2ecf20Sopenharmony_ci			if (src == src_end) {
2798c2ecf20Sopenharmony_ci				src = (u32 *) alsa_rt->dma_area;
2808c2ecf20Sopenharmony_ci				sub->dma_off = 0;
2818c2ecf20Sopenharmony_ci			}
2828c2ecf20Sopenharmony_ci		}
2838c2ecf20Sopenharmony_ci	}
2848c2ecf20Sopenharmony_ci}
2858c2ecf20Sopenharmony_ci
2868c2ecf20Sopenharmony_cistatic void usb6fire_pcm_in_urb_handler(struct urb *usb_urb)
2878c2ecf20Sopenharmony_ci{
2888c2ecf20Sopenharmony_ci	struct pcm_urb *in_urb = usb_urb->context;
2898c2ecf20Sopenharmony_ci	struct pcm_urb *out_urb = in_urb->peer;
2908c2ecf20Sopenharmony_ci	struct pcm_runtime *rt = in_urb->chip->pcm;
2918c2ecf20Sopenharmony_ci	struct pcm_substream *sub;
2928c2ecf20Sopenharmony_ci	unsigned long flags;
2938c2ecf20Sopenharmony_ci	int total_length = 0;
2948c2ecf20Sopenharmony_ci	int frame_count;
2958c2ecf20Sopenharmony_ci	int frame;
2968c2ecf20Sopenharmony_ci	int channel;
2978c2ecf20Sopenharmony_ci	int i;
2988c2ecf20Sopenharmony_ci	u8 *dest;
2998c2ecf20Sopenharmony_ci
3008c2ecf20Sopenharmony_ci	if (usb_urb->status || rt->panic || rt->stream_state == STREAM_STOPPING)
3018c2ecf20Sopenharmony_ci		return;
3028c2ecf20Sopenharmony_ci	for (i = 0; i < PCM_N_PACKETS_PER_URB; i++)
3038c2ecf20Sopenharmony_ci		if (in_urb->packets[i].status) {
3048c2ecf20Sopenharmony_ci			rt->panic = true;
3058c2ecf20Sopenharmony_ci			return;
3068c2ecf20Sopenharmony_ci		}
3078c2ecf20Sopenharmony_ci
3088c2ecf20Sopenharmony_ci	if (rt->stream_state == STREAM_DISABLED) {
3098c2ecf20Sopenharmony_ci		dev_err(&rt->chip->dev->dev,
3108c2ecf20Sopenharmony_ci			"internal error: stream disabled in in-urb handler.\n");
3118c2ecf20Sopenharmony_ci		return;
3128c2ecf20Sopenharmony_ci	}
3138c2ecf20Sopenharmony_ci
3148c2ecf20Sopenharmony_ci	/* receive our capture data */
3158c2ecf20Sopenharmony_ci	sub = &rt->capture;
3168c2ecf20Sopenharmony_ci	spin_lock_irqsave(&sub->lock, flags);
3178c2ecf20Sopenharmony_ci	if (sub->active) {
3188c2ecf20Sopenharmony_ci		usb6fire_pcm_capture(sub, in_urb);
3198c2ecf20Sopenharmony_ci		if (sub->period_off >= sub->instance->runtime->period_size) {
3208c2ecf20Sopenharmony_ci			sub->period_off %= sub->instance->runtime->period_size;
3218c2ecf20Sopenharmony_ci			spin_unlock_irqrestore(&sub->lock, flags);
3228c2ecf20Sopenharmony_ci			snd_pcm_period_elapsed(sub->instance);
3238c2ecf20Sopenharmony_ci		} else
3248c2ecf20Sopenharmony_ci			spin_unlock_irqrestore(&sub->lock, flags);
3258c2ecf20Sopenharmony_ci	} else
3268c2ecf20Sopenharmony_ci		spin_unlock_irqrestore(&sub->lock, flags);
3278c2ecf20Sopenharmony_ci
3288c2ecf20Sopenharmony_ci	/* setup out urb structure */
3298c2ecf20Sopenharmony_ci	for (i = 0; i < PCM_N_PACKETS_PER_URB; i++) {
3308c2ecf20Sopenharmony_ci		out_urb->packets[i].offset = total_length;
3318c2ecf20Sopenharmony_ci		out_urb->packets[i].length = (in_urb->packets[i].actual_length
3328c2ecf20Sopenharmony_ci				- 4) / (rt->in_n_analog << 2)
3338c2ecf20Sopenharmony_ci				* (rt->out_n_analog << 2) + 4;
3348c2ecf20Sopenharmony_ci		out_urb->packets[i].status = 0;
3358c2ecf20Sopenharmony_ci		total_length += out_urb->packets[i].length;
3368c2ecf20Sopenharmony_ci	}
3378c2ecf20Sopenharmony_ci	memset(out_urb->buffer, 0, total_length);
3388c2ecf20Sopenharmony_ci
3398c2ecf20Sopenharmony_ci	/* now send our playback data (if a free out urb was found) */
3408c2ecf20Sopenharmony_ci	sub = &rt->playback;
3418c2ecf20Sopenharmony_ci	spin_lock_irqsave(&sub->lock, flags);
3428c2ecf20Sopenharmony_ci	if (sub->active) {
3438c2ecf20Sopenharmony_ci		usb6fire_pcm_playback(sub, out_urb);
3448c2ecf20Sopenharmony_ci		if (sub->period_off >= sub->instance->runtime->period_size) {
3458c2ecf20Sopenharmony_ci			sub->period_off %= sub->instance->runtime->period_size;
3468c2ecf20Sopenharmony_ci			spin_unlock_irqrestore(&sub->lock, flags);
3478c2ecf20Sopenharmony_ci			snd_pcm_period_elapsed(sub->instance);
3488c2ecf20Sopenharmony_ci		} else
3498c2ecf20Sopenharmony_ci			spin_unlock_irqrestore(&sub->lock, flags);
3508c2ecf20Sopenharmony_ci	} else
3518c2ecf20Sopenharmony_ci		spin_unlock_irqrestore(&sub->lock, flags);
3528c2ecf20Sopenharmony_ci
3538c2ecf20Sopenharmony_ci	/* setup the 4th byte of each sample (0x40 for analog channels) */
3548c2ecf20Sopenharmony_ci	dest = out_urb->buffer;
3558c2ecf20Sopenharmony_ci	for (i = 0; i < PCM_N_PACKETS_PER_URB; i++)
3568c2ecf20Sopenharmony_ci		if (out_urb->packets[i].length >= 4) {
3578c2ecf20Sopenharmony_ci			frame_count = (out_urb->packets[i].length - 4)
3588c2ecf20Sopenharmony_ci					/ (rt->out_n_analog << 2);
3598c2ecf20Sopenharmony_ci			*(dest++) = 0xaa;
3608c2ecf20Sopenharmony_ci			*(dest++) = 0xaa;
3618c2ecf20Sopenharmony_ci			*(dest++) = frame_count;
3628c2ecf20Sopenharmony_ci			*(dest++) = 0x00;
3638c2ecf20Sopenharmony_ci			for (frame = 0; frame < frame_count; frame++)
3648c2ecf20Sopenharmony_ci				for (channel = 0;
3658c2ecf20Sopenharmony_ci						channel < rt->out_n_analog;
3668c2ecf20Sopenharmony_ci						channel++) {
3678c2ecf20Sopenharmony_ci					dest += 3; /* skip sample data */
3688c2ecf20Sopenharmony_ci					*(dest++) = 0x40;
3698c2ecf20Sopenharmony_ci				}
3708c2ecf20Sopenharmony_ci		}
3718c2ecf20Sopenharmony_ci	usb_submit_urb(&out_urb->instance, GFP_ATOMIC);
3728c2ecf20Sopenharmony_ci	usb_submit_urb(&in_urb->instance, GFP_ATOMIC);
3738c2ecf20Sopenharmony_ci}
3748c2ecf20Sopenharmony_ci
3758c2ecf20Sopenharmony_cistatic void usb6fire_pcm_out_urb_handler(struct urb *usb_urb)
3768c2ecf20Sopenharmony_ci{
3778c2ecf20Sopenharmony_ci	struct pcm_urb *urb = usb_urb->context;
3788c2ecf20Sopenharmony_ci	struct pcm_runtime *rt = urb->chip->pcm;
3798c2ecf20Sopenharmony_ci
3808c2ecf20Sopenharmony_ci	if (rt->stream_state == STREAM_STARTING) {
3818c2ecf20Sopenharmony_ci		rt->stream_wait_cond = true;
3828c2ecf20Sopenharmony_ci		wake_up(&rt->stream_wait_queue);
3838c2ecf20Sopenharmony_ci	}
3848c2ecf20Sopenharmony_ci}
3858c2ecf20Sopenharmony_ci
3868c2ecf20Sopenharmony_cistatic int usb6fire_pcm_open(struct snd_pcm_substream *alsa_sub)
3878c2ecf20Sopenharmony_ci{
3888c2ecf20Sopenharmony_ci	struct pcm_runtime *rt = snd_pcm_substream_chip(alsa_sub);
3898c2ecf20Sopenharmony_ci	struct pcm_substream *sub = NULL;
3908c2ecf20Sopenharmony_ci	struct snd_pcm_runtime *alsa_rt = alsa_sub->runtime;
3918c2ecf20Sopenharmony_ci
3928c2ecf20Sopenharmony_ci	if (rt->panic)
3938c2ecf20Sopenharmony_ci		return -EPIPE;
3948c2ecf20Sopenharmony_ci
3958c2ecf20Sopenharmony_ci	mutex_lock(&rt->stream_mutex);
3968c2ecf20Sopenharmony_ci	alsa_rt->hw = pcm_hw;
3978c2ecf20Sopenharmony_ci
3988c2ecf20Sopenharmony_ci	if (alsa_sub->stream == SNDRV_PCM_STREAM_PLAYBACK) {
3998c2ecf20Sopenharmony_ci		if (rt->rate < ARRAY_SIZE(rates))
4008c2ecf20Sopenharmony_ci			alsa_rt->hw.rates = rates_alsaid[rt->rate];
4018c2ecf20Sopenharmony_ci		alsa_rt->hw.channels_max = OUT_N_CHANNELS;
4028c2ecf20Sopenharmony_ci		sub = &rt->playback;
4038c2ecf20Sopenharmony_ci	} else if (alsa_sub->stream == SNDRV_PCM_STREAM_CAPTURE) {
4048c2ecf20Sopenharmony_ci		if (rt->rate < ARRAY_SIZE(rates))
4058c2ecf20Sopenharmony_ci			alsa_rt->hw.rates = rates_alsaid[rt->rate];
4068c2ecf20Sopenharmony_ci		alsa_rt->hw.channels_max = IN_N_CHANNELS;
4078c2ecf20Sopenharmony_ci		sub = &rt->capture;
4088c2ecf20Sopenharmony_ci	}
4098c2ecf20Sopenharmony_ci
4108c2ecf20Sopenharmony_ci	if (!sub) {
4118c2ecf20Sopenharmony_ci		mutex_unlock(&rt->stream_mutex);
4128c2ecf20Sopenharmony_ci		dev_err(&rt->chip->dev->dev, "invalid stream type.\n");
4138c2ecf20Sopenharmony_ci		return -EINVAL;
4148c2ecf20Sopenharmony_ci	}
4158c2ecf20Sopenharmony_ci
4168c2ecf20Sopenharmony_ci	sub->instance = alsa_sub;
4178c2ecf20Sopenharmony_ci	sub->active = false;
4188c2ecf20Sopenharmony_ci	mutex_unlock(&rt->stream_mutex);
4198c2ecf20Sopenharmony_ci	return 0;
4208c2ecf20Sopenharmony_ci}
4218c2ecf20Sopenharmony_ci
4228c2ecf20Sopenharmony_cistatic int usb6fire_pcm_close(struct snd_pcm_substream *alsa_sub)
4238c2ecf20Sopenharmony_ci{
4248c2ecf20Sopenharmony_ci	struct pcm_runtime *rt = snd_pcm_substream_chip(alsa_sub);
4258c2ecf20Sopenharmony_ci	struct pcm_substream *sub = usb6fire_pcm_get_substream(alsa_sub);
4268c2ecf20Sopenharmony_ci	unsigned long flags;
4278c2ecf20Sopenharmony_ci
4288c2ecf20Sopenharmony_ci	if (rt->panic)
4298c2ecf20Sopenharmony_ci		return 0;
4308c2ecf20Sopenharmony_ci
4318c2ecf20Sopenharmony_ci	mutex_lock(&rt->stream_mutex);
4328c2ecf20Sopenharmony_ci	if (sub) {
4338c2ecf20Sopenharmony_ci		/* deactivate substream */
4348c2ecf20Sopenharmony_ci		spin_lock_irqsave(&sub->lock, flags);
4358c2ecf20Sopenharmony_ci		sub->instance = NULL;
4368c2ecf20Sopenharmony_ci		sub->active = false;
4378c2ecf20Sopenharmony_ci		spin_unlock_irqrestore(&sub->lock, flags);
4388c2ecf20Sopenharmony_ci
4398c2ecf20Sopenharmony_ci		/* all substreams closed? if so, stop streaming */
4408c2ecf20Sopenharmony_ci		if (!rt->playback.instance && !rt->capture.instance) {
4418c2ecf20Sopenharmony_ci			usb6fire_pcm_stream_stop(rt);
4428c2ecf20Sopenharmony_ci			rt->rate = ARRAY_SIZE(rates);
4438c2ecf20Sopenharmony_ci		}
4448c2ecf20Sopenharmony_ci	}
4458c2ecf20Sopenharmony_ci	mutex_unlock(&rt->stream_mutex);
4468c2ecf20Sopenharmony_ci	return 0;
4478c2ecf20Sopenharmony_ci}
4488c2ecf20Sopenharmony_ci
4498c2ecf20Sopenharmony_cistatic int usb6fire_pcm_prepare(struct snd_pcm_substream *alsa_sub)
4508c2ecf20Sopenharmony_ci{
4518c2ecf20Sopenharmony_ci	struct pcm_runtime *rt = snd_pcm_substream_chip(alsa_sub);
4528c2ecf20Sopenharmony_ci	struct pcm_substream *sub = usb6fire_pcm_get_substream(alsa_sub);
4538c2ecf20Sopenharmony_ci	struct snd_pcm_runtime *alsa_rt = alsa_sub->runtime;
4548c2ecf20Sopenharmony_ci	int ret;
4558c2ecf20Sopenharmony_ci
4568c2ecf20Sopenharmony_ci	if (rt->panic)
4578c2ecf20Sopenharmony_ci		return -EPIPE;
4588c2ecf20Sopenharmony_ci	if (!sub)
4598c2ecf20Sopenharmony_ci		return -ENODEV;
4608c2ecf20Sopenharmony_ci
4618c2ecf20Sopenharmony_ci	mutex_lock(&rt->stream_mutex);
4628c2ecf20Sopenharmony_ci	sub->dma_off = 0;
4638c2ecf20Sopenharmony_ci	sub->period_off = 0;
4648c2ecf20Sopenharmony_ci
4658c2ecf20Sopenharmony_ci	if (rt->stream_state == STREAM_DISABLED) {
4668c2ecf20Sopenharmony_ci		for (rt->rate = 0; rt->rate < ARRAY_SIZE(rates); rt->rate++)
4678c2ecf20Sopenharmony_ci			if (alsa_rt->rate == rates[rt->rate])
4688c2ecf20Sopenharmony_ci				break;
4698c2ecf20Sopenharmony_ci		if (rt->rate == ARRAY_SIZE(rates)) {
4708c2ecf20Sopenharmony_ci			mutex_unlock(&rt->stream_mutex);
4718c2ecf20Sopenharmony_ci			dev_err(&rt->chip->dev->dev,
4728c2ecf20Sopenharmony_ci				"invalid rate %d in prepare.\n",
4738c2ecf20Sopenharmony_ci				alsa_rt->rate);
4748c2ecf20Sopenharmony_ci			return -EINVAL;
4758c2ecf20Sopenharmony_ci		}
4768c2ecf20Sopenharmony_ci
4778c2ecf20Sopenharmony_ci		ret = usb6fire_pcm_set_rate(rt);
4788c2ecf20Sopenharmony_ci		if (ret) {
4798c2ecf20Sopenharmony_ci			mutex_unlock(&rt->stream_mutex);
4808c2ecf20Sopenharmony_ci			return ret;
4818c2ecf20Sopenharmony_ci		}
4828c2ecf20Sopenharmony_ci		ret = usb6fire_pcm_stream_start(rt);
4838c2ecf20Sopenharmony_ci		if (ret) {
4848c2ecf20Sopenharmony_ci			mutex_unlock(&rt->stream_mutex);
4858c2ecf20Sopenharmony_ci			dev_err(&rt->chip->dev->dev,
4868c2ecf20Sopenharmony_ci				"could not start pcm stream.\n");
4878c2ecf20Sopenharmony_ci			return ret;
4888c2ecf20Sopenharmony_ci		}
4898c2ecf20Sopenharmony_ci	}
4908c2ecf20Sopenharmony_ci	mutex_unlock(&rt->stream_mutex);
4918c2ecf20Sopenharmony_ci	return 0;
4928c2ecf20Sopenharmony_ci}
4938c2ecf20Sopenharmony_ci
4948c2ecf20Sopenharmony_cistatic int usb6fire_pcm_trigger(struct snd_pcm_substream *alsa_sub, int cmd)
4958c2ecf20Sopenharmony_ci{
4968c2ecf20Sopenharmony_ci	struct pcm_substream *sub = usb6fire_pcm_get_substream(alsa_sub);
4978c2ecf20Sopenharmony_ci	struct pcm_runtime *rt = snd_pcm_substream_chip(alsa_sub);
4988c2ecf20Sopenharmony_ci	unsigned long flags;
4998c2ecf20Sopenharmony_ci
5008c2ecf20Sopenharmony_ci	if (rt->panic)
5018c2ecf20Sopenharmony_ci		return -EPIPE;
5028c2ecf20Sopenharmony_ci	if (!sub)
5038c2ecf20Sopenharmony_ci		return -ENODEV;
5048c2ecf20Sopenharmony_ci
5058c2ecf20Sopenharmony_ci	switch (cmd) {
5068c2ecf20Sopenharmony_ci	case SNDRV_PCM_TRIGGER_START:
5078c2ecf20Sopenharmony_ci	case SNDRV_PCM_TRIGGER_PAUSE_RELEASE:
5088c2ecf20Sopenharmony_ci		spin_lock_irqsave(&sub->lock, flags);
5098c2ecf20Sopenharmony_ci		sub->active = true;
5108c2ecf20Sopenharmony_ci		spin_unlock_irqrestore(&sub->lock, flags);
5118c2ecf20Sopenharmony_ci		return 0;
5128c2ecf20Sopenharmony_ci
5138c2ecf20Sopenharmony_ci	case SNDRV_PCM_TRIGGER_STOP:
5148c2ecf20Sopenharmony_ci	case SNDRV_PCM_TRIGGER_PAUSE_PUSH:
5158c2ecf20Sopenharmony_ci		spin_lock_irqsave(&sub->lock, flags);
5168c2ecf20Sopenharmony_ci		sub->active = false;
5178c2ecf20Sopenharmony_ci		spin_unlock_irqrestore(&sub->lock, flags);
5188c2ecf20Sopenharmony_ci		return 0;
5198c2ecf20Sopenharmony_ci
5208c2ecf20Sopenharmony_ci	default:
5218c2ecf20Sopenharmony_ci		return -EINVAL;
5228c2ecf20Sopenharmony_ci	}
5238c2ecf20Sopenharmony_ci}
5248c2ecf20Sopenharmony_ci
5258c2ecf20Sopenharmony_cistatic snd_pcm_uframes_t usb6fire_pcm_pointer(
5268c2ecf20Sopenharmony_ci		struct snd_pcm_substream *alsa_sub)
5278c2ecf20Sopenharmony_ci{
5288c2ecf20Sopenharmony_ci	struct pcm_substream *sub = usb6fire_pcm_get_substream(alsa_sub);
5298c2ecf20Sopenharmony_ci	struct pcm_runtime *rt = snd_pcm_substream_chip(alsa_sub);
5308c2ecf20Sopenharmony_ci	unsigned long flags;
5318c2ecf20Sopenharmony_ci	snd_pcm_uframes_t ret;
5328c2ecf20Sopenharmony_ci
5338c2ecf20Sopenharmony_ci	if (rt->panic || !sub)
5348c2ecf20Sopenharmony_ci		return SNDRV_PCM_POS_XRUN;
5358c2ecf20Sopenharmony_ci
5368c2ecf20Sopenharmony_ci	spin_lock_irqsave(&sub->lock, flags);
5378c2ecf20Sopenharmony_ci	ret = sub->dma_off;
5388c2ecf20Sopenharmony_ci	spin_unlock_irqrestore(&sub->lock, flags);
5398c2ecf20Sopenharmony_ci	return ret;
5408c2ecf20Sopenharmony_ci}
5418c2ecf20Sopenharmony_ci
5428c2ecf20Sopenharmony_cistatic const struct snd_pcm_ops pcm_ops = {
5438c2ecf20Sopenharmony_ci	.open = usb6fire_pcm_open,
5448c2ecf20Sopenharmony_ci	.close = usb6fire_pcm_close,
5458c2ecf20Sopenharmony_ci	.prepare = usb6fire_pcm_prepare,
5468c2ecf20Sopenharmony_ci	.trigger = usb6fire_pcm_trigger,
5478c2ecf20Sopenharmony_ci	.pointer = usb6fire_pcm_pointer,
5488c2ecf20Sopenharmony_ci};
5498c2ecf20Sopenharmony_ci
5508c2ecf20Sopenharmony_cistatic void usb6fire_pcm_init_urb(struct pcm_urb *urb,
5518c2ecf20Sopenharmony_ci				  struct sfire_chip *chip, bool in, int ep,
5528c2ecf20Sopenharmony_ci				  void (*handler)(struct urb *))
5538c2ecf20Sopenharmony_ci{
5548c2ecf20Sopenharmony_ci	urb->chip = chip;
5558c2ecf20Sopenharmony_ci	usb_init_urb(&urb->instance);
5568c2ecf20Sopenharmony_ci	urb->instance.transfer_buffer = urb->buffer;
5578c2ecf20Sopenharmony_ci	urb->instance.transfer_buffer_length =
5588c2ecf20Sopenharmony_ci			PCM_N_PACKETS_PER_URB * PCM_MAX_PACKET_SIZE;
5598c2ecf20Sopenharmony_ci	urb->instance.dev = chip->dev;
5608c2ecf20Sopenharmony_ci	urb->instance.pipe = in ? usb_rcvisocpipe(chip->dev, ep)
5618c2ecf20Sopenharmony_ci			: usb_sndisocpipe(chip->dev, ep);
5628c2ecf20Sopenharmony_ci	urb->instance.interval = 1;
5638c2ecf20Sopenharmony_ci	urb->instance.complete = handler;
5648c2ecf20Sopenharmony_ci	urb->instance.context = urb;
5658c2ecf20Sopenharmony_ci	urb->instance.number_of_packets = PCM_N_PACKETS_PER_URB;
5668c2ecf20Sopenharmony_ci}
5678c2ecf20Sopenharmony_ci
5688c2ecf20Sopenharmony_cistatic int usb6fire_pcm_buffers_init(struct pcm_runtime *rt)
5698c2ecf20Sopenharmony_ci{
5708c2ecf20Sopenharmony_ci	int i;
5718c2ecf20Sopenharmony_ci
5728c2ecf20Sopenharmony_ci	for (i = 0; i < PCM_N_URBS; i++) {
5738c2ecf20Sopenharmony_ci		rt->out_urbs[i].buffer = kcalloc(PCM_MAX_PACKET_SIZE,
5748c2ecf20Sopenharmony_ci						 PCM_N_PACKETS_PER_URB,
5758c2ecf20Sopenharmony_ci						 GFP_KERNEL);
5768c2ecf20Sopenharmony_ci		if (!rt->out_urbs[i].buffer)
5778c2ecf20Sopenharmony_ci			return -ENOMEM;
5788c2ecf20Sopenharmony_ci		rt->in_urbs[i].buffer = kcalloc(PCM_MAX_PACKET_SIZE,
5798c2ecf20Sopenharmony_ci						PCM_N_PACKETS_PER_URB,
5808c2ecf20Sopenharmony_ci						GFP_KERNEL);
5818c2ecf20Sopenharmony_ci		if (!rt->in_urbs[i].buffer)
5828c2ecf20Sopenharmony_ci			return -ENOMEM;
5838c2ecf20Sopenharmony_ci	}
5848c2ecf20Sopenharmony_ci	return 0;
5858c2ecf20Sopenharmony_ci}
5868c2ecf20Sopenharmony_ci
5878c2ecf20Sopenharmony_cistatic void usb6fire_pcm_buffers_destroy(struct pcm_runtime *rt)
5888c2ecf20Sopenharmony_ci{
5898c2ecf20Sopenharmony_ci	int i;
5908c2ecf20Sopenharmony_ci
5918c2ecf20Sopenharmony_ci	for (i = 0; i < PCM_N_URBS; i++) {
5928c2ecf20Sopenharmony_ci		kfree(rt->out_urbs[i].buffer);
5938c2ecf20Sopenharmony_ci		kfree(rt->in_urbs[i].buffer);
5948c2ecf20Sopenharmony_ci	}
5958c2ecf20Sopenharmony_ci}
5968c2ecf20Sopenharmony_ci
5978c2ecf20Sopenharmony_ciint usb6fire_pcm_init(struct sfire_chip *chip)
5988c2ecf20Sopenharmony_ci{
5998c2ecf20Sopenharmony_ci	int i;
6008c2ecf20Sopenharmony_ci	int ret;
6018c2ecf20Sopenharmony_ci	struct snd_pcm *pcm;
6028c2ecf20Sopenharmony_ci	struct pcm_runtime *rt =
6038c2ecf20Sopenharmony_ci			kzalloc(sizeof(struct pcm_runtime), GFP_KERNEL);
6048c2ecf20Sopenharmony_ci
6058c2ecf20Sopenharmony_ci	if (!rt)
6068c2ecf20Sopenharmony_ci		return -ENOMEM;
6078c2ecf20Sopenharmony_ci
6088c2ecf20Sopenharmony_ci	ret = usb6fire_pcm_buffers_init(rt);
6098c2ecf20Sopenharmony_ci	if (ret) {
6108c2ecf20Sopenharmony_ci		usb6fire_pcm_buffers_destroy(rt);
6118c2ecf20Sopenharmony_ci		kfree(rt);
6128c2ecf20Sopenharmony_ci		return ret;
6138c2ecf20Sopenharmony_ci	}
6148c2ecf20Sopenharmony_ci
6158c2ecf20Sopenharmony_ci	rt->chip = chip;
6168c2ecf20Sopenharmony_ci	rt->stream_state = STREAM_DISABLED;
6178c2ecf20Sopenharmony_ci	rt->rate = ARRAY_SIZE(rates);
6188c2ecf20Sopenharmony_ci	init_waitqueue_head(&rt->stream_wait_queue);
6198c2ecf20Sopenharmony_ci	mutex_init(&rt->stream_mutex);
6208c2ecf20Sopenharmony_ci
6218c2ecf20Sopenharmony_ci	spin_lock_init(&rt->playback.lock);
6228c2ecf20Sopenharmony_ci	spin_lock_init(&rt->capture.lock);
6238c2ecf20Sopenharmony_ci
6248c2ecf20Sopenharmony_ci	for (i = 0; i < PCM_N_URBS; i++) {
6258c2ecf20Sopenharmony_ci		usb6fire_pcm_init_urb(&rt->in_urbs[i], chip, true, IN_EP,
6268c2ecf20Sopenharmony_ci				usb6fire_pcm_in_urb_handler);
6278c2ecf20Sopenharmony_ci		usb6fire_pcm_init_urb(&rt->out_urbs[i], chip, false, OUT_EP,
6288c2ecf20Sopenharmony_ci				usb6fire_pcm_out_urb_handler);
6298c2ecf20Sopenharmony_ci
6308c2ecf20Sopenharmony_ci		rt->in_urbs[i].peer = &rt->out_urbs[i];
6318c2ecf20Sopenharmony_ci		rt->out_urbs[i].peer = &rt->in_urbs[i];
6328c2ecf20Sopenharmony_ci	}
6338c2ecf20Sopenharmony_ci
6348c2ecf20Sopenharmony_ci	ret = snd_pcm_new(chip->card, "DMX6FireUSB", 0, 1, 1, &pcm);
6358c2ecf20Sopenharmony_ci	if (ret < 0) {
6368c2ecf20Sopenharmony_ci		usb6fire_pcm_buffers_destroy(rt);
6378c2ecf20Sopenharmony_ci		kfree(rt);
6388c2ecf20Sopenharmony_ci		dev_err(&chip->dev->dev, "cannot create pcm instance.\n");
6398c2ecf20Sopenharmony_ci		return ret;
6408c2ecf20Sopenharmony_ci	}
6418c2ecf20Sopenharmony_ci
6428c2ecf20Sopenharmony_ci	pcm->private_data = rt;
6438c2ecf20Sopenharmony_ci	strcpy(pcm->name, "DMX 6Fire USB");
6448c2ecf20Sopenharmony_ci	snd_pcm_set_ops(pcm, SNDRV_PCM_STREAM_PLAYBACK, &pcm_ops);
6458c2ecf20Sopenharmony_ci	snd_pcm_set_ops(pcm, SNDRV_PCM_STREAM_CAPTURE, &pcm_ops);
6468c2ecf20Sopenharmony_ci	snd_pcm_set_managed_buffer_all(pcm, SNDRV_DMA_TYPE_VMALLOC, NULL, 0, 0);
6478c2ecf20Sopenharmony_ci
6488c2ecf20Sopenharmony_ci	rt->instance = pcm;
6498c2ecf20Sopenharmony_ci
6508c2ecf20Sopenharmony_ci	chip->pcm = rt;
6518c2ecf20Sopenharmony_ci	return 0;
6528c2ecf20Sopenharmony_ci}
6538c2ecf20Sopenharmony_ci
6548c2ecf20Sopenharmony_civoid usb6fire_pcm_abort(struct sfire_chip *chip)
6558c2ecf20Sopenharmony_ci{
6568c2ecf20Sopenharmony_ci	struct pcm_runtime *rt = chip->pcm;
6578c2ecf20Sopenharmony_ci	int i;
6588c2ecf20Sopenharmony_ci
6598c2ecf20Sopenharmony_ci	if (rt) {
6608c2ecf20Sopenharmony_ci		rt->panic = true;
6618c2ecf20Sopenharmony_ci
6628c2ecf20Sopenharmony_ci		if (rt->playback.instance)
6638c2ecf20Sopenharmony_ci			snd_pcm_stop_xrun(rt->playback.instance);
6648c2ecf20Sopenharmony_ci
6658c2ecf20Sopenharmony_ci		if (rt->capture.instance)
6668c2ecf20Sopenharmony_ci			snd_pcm_stop_xrun(rt->capture.instance);
6678c2ecf20Sopenharmony_ci
6688c2ecf20Sopenharmony_ci		for (i = 0; i < PCM_N_URBS; i++) {
6698c2ecf20Sopenharmony_ci			usb_poison_urb(&rt->in_urbs[i].instance);
6708c2ecf20Sopenharmony_ci			usb_poison_urb(&rt->out_urbs[i].instance);
6718c2ecf20Sopenharmony_ci		}
6728c2ecf20Sopenharmony_ci
6738c2ecf20Sopenharmony_ci	}
6748c2ecf20Sopenharmony_ci}
6758c2ecf20Sopenharmony_ci
6768c2ecf20Sopenharmony_civoid usb6fire_pcm_destroy(struct sfire_chip *chip)
6778c2ecf20Sopenharmony_ci{
6788c2ecf20Sopenharmony_ci	struct pcm_runtime *rt = chip->pcm;
6798c2ecf20Sopenharmony_ci
6808c2ecf20Sopenharmony_ci	usb6fire_pcm_buffers_destroy(rt);
6818c2ecf20Sopenharmony_ci	kfree(rt);
6828c2ecf20Sopenharmony_ci	chip->pcm = NULL;
6838c2ecf20Sopenharmony_ci}
684