2 * Line6 Linux USB driver - 0.8.0
4 * Copyright (C) 2004-2009 Markus Grabner (grabner@icg.tugraz.at)
6 * This program is free software; you can redistribute it and/or
7 * modify it under the terms of the GNU General Public License as
8 * published by the Free Software Foundation, version 2.
14 #include <sound/core.h>
15 #include <sound/pcm.h>
16 #include <sound/pcm_params.h>
24 Find a free URB and submit it.
26 static int submit_audio_in_urb(struct snd_pcm_substream
*substream
)
30 struct snd_line6_pcm
*line6pcm
= snd_pcm_substream_chip(substream
);
34 spin_lock_irqsave(&line6pcm
->lock_audio_in
, flags
);
36 find_first_zero_bit(&line6pcm
->active_urb_in
, LINE6_ISO_BUFFERS
);
38 if (index
>= LINE6_ISO_BUFFERS
) {
39 spin_unlock_irqrestore(&line6pcm
->lock_audio_in
, flags
);
40 dev_err(s2m(substream
), "no free URB found\n");
44 urb_in
= line6pcm
->urb_audio_in
[index
];
47 for (i
= 0; i
< LINE6_ISO_PACKETS
; ++i
) {
48 struct usb_iso_packet_descriptor
*fin
=
49 &urb_in
->iso_frame_desc
[i
];
50 fin
->offset
= urb_size
;
51 fin
->length
= line6pcm
->max_packet_size
;
52 urb_size
+= line6pcm
->max_packet_size
;
55 urb_in
->transfer_buffer
=
57 index
* LINE6_ISO_PACKETS
* line6pcm
->max_packet_size
;
58 urb_in
->transfer_buffer_length
= urb_size
;
59 urb_in
->context
= substream
;
61 if (usb_submit_urb(urb_in
, GFP_ATOMIC
) == 0)
62 set_bit(index
, &line6pcm
->active_urb_in
);
64 dev_err(s2m(substream
), "URB in #%d submission failed\n",
67 spin_unlock_irqrestore(&line6pcm
->lock_audio_in
, flags
);
72 Submit all currently available capture URBs.
74 static int submit_audio_in_all_urbs(struct snd_pcm_substream
*substream
)
78 for (i
= 0; i
< LINE6_ISO_BUFFERS
; ++i
) {
79 ret
= submit_audio_in_urb(substream
);
88 Unlink all currently active capture URBs.
90 static void unlink_audio_in_urbs(struct snd_line6_pcm
*line6pcm
)
94 for (i
= LINE6_ISO_BUFFERS
; i
--;) {
95 if (test_bit(i
, &line6pcm
->active_urb_in
)) {
96 if (!test_and_set_bit(i
, &line6pcm
->unlink_urb_in
)) {
97 struct urb
*u
= line6pcm
->urb_audio_in
[i
];
105 Wait until unlinking of all currently active capture URBs has been
108 static void wait_clear_audio_in_urbs(struct snd_line6_pcm
*line6pcm
)
116 for (i
= LINE6_ISO_BUFFERS
; i
--;) {
117 if (test_bit(i
, &line6pcm
->active_urb_in
))
122 set_current_state(TASK_UNINTERRUPTIBLE
);
124 } while (--timeout
> 0);
126 snd_printk(KERN_ERR
"timeout: still %d active urbs..\n", alive
);
128 line6pcm
->active_urb_in
= 0;
129 line6pcm
->unlink_urb_in
= 0;
133 Unlink all currently active capture URBs, and wait for finishing.
135 void unlink_wait_clear_audio_in_urbs(struct snd_line6_pcm
*line6pcm
)
137 unlink_audio_in_urbs(line6pcm
);
138 wait_clear_audio_in_urbs(line6pcm
);
142 Callback for completed capture URB.
144 static void audio_in_callback(struct urb
*urb
)
146 int i
, index
, length
= 0, shutdown
= 0;
150 struct snd_pcm_substream
*substream
=
151 (struct snd_pcm_substream
*)urb
->context
;
152 struct snd_line6_pcm
*line6pcm
= snd_pcm_substream_chip(substream
);
153 const int bytes_per_frame
= line6pcm
->properties
->bytes_per_frame
;
154 struct snd_pcm_runtime
*runtime
= substream
->runtime
;
156 /* find index of URB */
157 for (index
= 0; index
< LINE6_ISO_BUFFERS
; ++index
)
158 if (urb
== line6pcm
->urb_audio_in
[index
])
161 #if DO_DUMP_PCM_RECEIVE
162 for (i
= 0; i
< LINE6_ISO_PACKETS
; ++i
) {
163 struct usb_iso_packet_descriptor
*fout
=
164 &urb
->iso_frame_desc
[i
];
165 line6_write_hexdump(line6pcm
->line6
, 'C',
166 urb
->transfer_buffer
+ fout
->offset
,
171 spin_lock_irqsave(&line6pcm
->lock_audio_in
, flags
);
173 for (i
= 0; i
< LINE6_ISO_PACKETS
; ++i
) {
176 struct usb_iso_packet_descriptor
*fin
= &urb
->iso_frame_desc
[i
];
178 if (fin
->status
== -18) {
183 fbuf
= urb
->transfer_buffer
+ fin
->offset
;
184 fsize
= fin
->actual_length
;
188 frames
= fsize
/ bytes_per_frame
;
190 if (line6pcm
->pos_in_done
+ frames
>
191 runtime
->buffer_size
) {
193 The transferred area goes over buffer
194 boundary, copy two separate chunks.
198 runtime
->buffer_size
-
199 line6pcm
->pos_in_done
;
202 memcpy(runtime
->dma_area
+
203 line6pcm
->pos_in_done
*
204 bytes_per_frame
, fbuf
,
205 len
* bytes_per_frame
);
206 memcpy(runtime
->dma_area
,
207 fbuf
+ len
* bytes_per_frame
,
209 len
) * bytes_per_frame
);
211 /* this is somewhat paranoid */
212 dev_err(s2m(substream
),
213 "driver bug: len = %d\n", len
);
216 /* copy single chunk */
217 memcpy(runtime
->dma_area
+
218 line6pcm
->pos_in_done
* bytes_per_frame
,
219 fbuf
, fsize
* bytes_per_frame
);
222 line6pcm
->pos_in_done
+= frames
;
223 if (line6pcm
->pos_in_done
>= runtime
->buffer_size
)
224 line6pcm
->pos_in_done
-= runtime
->buffer_size
;
228 clear_bit(index
, &line6pcm
->active_urb_in
);
230 if (test_bit(index
, &line6pcm
->unlink_urb_in
))
233 spin_unlock_irqrestore(&line6pcm
->lock_audio_in
, flags
);
236 submit_audio_in_urb(substream
);
238 line6pcm
->bytes_in
+= length
;
239 if (line6pcm
->bytes_in
>= line6pcm
->period_in
) {
240 line6pcm
->bytes_in
-= line6pcm
->period_in
;
241 snd_pcm_period_elapsed(substream
);
246 /* open capture callback */
247 static int snd_line6_capture_open(struct snd_pcm_substream
*substream
)
250 struct snd_pcm_runtime
*runtime
= substream
->runtime
;
251 struct snd_line6_pcm
*line6pcm
= snd_pcm_substream_chip(substream
);
253 err
= snd_pcm_hw_constraint_ratdens(runtime
, 0,
254 SNDRV_PCM_HW_PARAM_RATE
,
255 (&line6pcm
->properties
->
260 runtime
->hw
= line6pcm
->properties
->snd_line6_capture_hw
;
264 /* close capture callback */
265 static int snd_line6_capture_close(struct snd_pcm_substream
*substream
)
270 /* hw_params capture callback */
271 static int snd_line6_capture_hw_params(struct snd_pcm_substream
*substream
,
272 struct snd_pcm_hw_params
*hw_params
)
275 struct snd_line6_pcm
*line6pcm
= snd_pcm_substream_chip(substream
);
277 /* -- Florian Demski [FD] */
278 /* don't ask me why, but this fixes the bug on my machine */
279 if (line6pcm
== NULL
) {
280 if (substream
->pcm
== NULL
)
282 if (substream
->pcm
->private_data
== NULL
)
284 substream
->private_data
= substream
->pcm
->private_data
;
285 line6pcm
= snd_pcm_substream_chip(substream
);
289 ret
= snd_pcm_lib_malloc_pages(substream
,
290 params_buffer_bytes(hw_params
));
294 line6pcm
->period_in
= params_period_bytes(hw_params
);
295 line6pcm
->buffer_in
=
296 kmalloc(LINE6_ISO_BUFFERS
* LINE6_ISO_PACKETS
*
297 LINE6_ISO_PACKET_SIZE_MAX
, GFP_KERNEL
);
299 if (!line6pcm
->buffer_in
) {
300 dev_err(s2m(substream
), "cannot malloc buffer_in\n");
307 /* hw_free capture callback */
308 static int snd_line6_capture_hw_free(struct snd_pcm_substream
*substream
)
310 struct snd_line6_pcm
*line6pcm
= snd_pcm_substream_chip(substream
);
311 unlink_wait_clear_audio_in_urbs(line6pcm
);
313 kfree(line6pcm
->buffer_in
);
314 line6pcm
->buffer_in
= NULL
;
316 return snd_pcm_lib_free_pages(substream
);
319 /* trigger callback */
320 int snd_line6_capture_trigger(struct snd_pcm_substream
*substream
, int cmd
)
322 struct snd_line6_pcm
*line6pcm
= snd_pcm_substream_chip(substream
);
324 line6pcm
->count_in
= 0;
327 case SNDRV_PCM_TRIGGER_START
:
328 if (!test_and_set_bit(BIT_RUNNING_CAPTURE
, &line6pcm
->flags
)) {
329 err
= submit_audio_in_all_urbs(substream
);
332 clear_bit(BIT_RUNNING_CAPTURE
,
340 case SNDRV_PCM_TRIGGER_STOP
:
341 if (test_and_clear_bit(BIT_RUNNING_CAPTURE
, &line6pcm
->flags
))
342 unlink_audio_in_urbs(line6pcm
);
353 /* capture pointer callback */
354 static snd_pcm_uframes_t
355 snd_line6_capture_pointer(struct snd_pcm_substream
*substream
)
357 struct snd_line6_pcm
*line6pcm
= snd_pcm_substream_chip(substream
);
358 return line6pcm
->pos_in_done
;
361 /* capture operators */
362 struct snd_pcm_ops snd_line6_capture_ops
= {
363 .open
= snd_line6_capture_open
,
364 .close
= snd_line6_capture_close
,
365 .ioctl
= snd_pcm_lib_ioctl
,
366 .hw_params
= snd_line6_capture_hw_params
,
367 .hw_free
= snd_line6_capture_hw_free
,
368 .prepare
= snd_line6_prepare
,
369 .trigger
= snd_line6_trigger
,
370 .pointer
= snd_line6_capture_pointer
,
373 int create_audio_in_urbs(struct snd_line6_pcm
*line6pcm
)
377 /* create audio URBs and fill in constant values: */
378 for (i
= 0; i
< LINE6_ISO_BUFFERS
; ++i
) {
381 /* URB for audio in: */
382 urb
= line6pcm
->urb_audio_in
[i
] =
383 usb_alloc_urb(LINE6_ISO_PACKETS
, GFP_KERNEL
);
386 dev_err(line6pcm
->line6
->ifcdev
, "Out of memory\n");
390 urb
->dev
= line6pcm
->line6
->usbdev
;
392 usb_rcvisocpipe(line6pcm
->line6
->usbdev
,
394 ep_audio_read
& USB_ENDPOINT_NUMBER_MASK
);
395 urb
->transfer_flags
= URB_ISO_ASAP
;
396 urb
->start_frame
= -1;
397 urb
->number_of_packets
= LINE6_ISO_PACKETS
;
398 urb
->interval
= LINE6_ISO_INTERVAL
;
399 urb
->error_count
= 0;
400 urb
->complete
= audio_in_callback
;