xref: /openbmc/linux/sound/usb/usx2y/usb_stream.c (revision 80b2b03b)
1 // SPDX-License-Identifier: GPL-2.0-or-later
2 /*
3  * Copyright (C) 2007, 2008 Karsten Wiese <fzu@wemgehoertderstaat.de>
4  */
5 
6 #include <linux/usb.h>
7 #include <linux/gfp.h>
8 
9 #include "usb_stream.h"
10 
11 /*                             setup                                  */
12 
usb_stream_next_packet_size(struct usb_stream_kernel * sk)13 static unsigned int usb_stream_next_packet_size(struct usb_stream_kernel *sk)
14 {
15 	struct usb_stream *s = sk->s;
16 
17 	sk->out_phase_peeked = (sk->out_phase & 0xffff) + sk->freqn;
18 	return (sk->out_phase_peeked >> 16) * s->cfg.frame_size;
19 }
20 
playback_prep_freqn(struct usb_stream_kernel * sk,struct urb * urb)21 static void playback_prep_freqn(struct usb_stream_kernel *sk, struct urb *urb)
22 {
23 	struct usb_stream *s = sk->s;
24 	int pack, lb = 0;
25 
26 	for (pack = 0; pack < sk->n_o_ps; pack++) {
27 		int l = usb_stream_next_packet_size(sk);
28 
29 		if (s->idle_outsize + lb + l > s->period_size)
30 			goto check;
31 
32 		sk->out_phase = sk->out_phase_peeked;
33 		urb->iso_frame_desc[pack].offset = lb;
34 		urb->iso_frame_desc[pack].length = l;
35 		lb += l;
36 	}
37 	snd_printdd(KERN_DEBUG "%i\n", lb);
38 
39 check:
40 	urb->number_of_packets = pack;
41 	urb->transfer_buffer_length = lb;
42 	s->idle_outsize += lb - s->period_size;
43 	snd_printdd(KERN_DEBUG "idle=%i ul=%i ps=%i\n", s->idle_outsize,
44 		    lb, s->period_size);
45 }
46 
init_pipe_urbs(struct usb_stream_kernel * sk,unsigned int use_packsize,struct urb ** urbs,char * transfer,struct usb_device * dev,int pipe)47 static int init_pipe_urbs(struct usb_stream_kernel *sk,
48 			  unsigned int use_packsize,
49 			  struct urb **urbs, char *transfer,
50 			  struct usb_device *dev, int pipe)
51 {
52 	int u, p;
53 	int maxpacket = use_packsize ?
54 		use_packsize : usb_maxpacket(dev, pipe);
55 	int transfer_length = maxpacket * sk->n_o_ps;
56 
57 	for (u = 0; u < USB_STREAM_NURBS;
58 	     ++u, transfer += transfer_length) {
59 		struct urb *urb = urbs[u];
60 		struct usb_iso_packet_descriptor *desc;
61 
62 		urb->transfer_buffer = transfer;
63 		urb->dev = dev;
64 		urb->pipe = pipe;
65 		urb->number_of_packets = sk->n_o_ps;
66 		urb->context = sk;
67 		urb->interval = 1;
68 		if (usb_pipeout(pipe))
69 			continue;
70 		if (usb_urb_ep_type_check(urb))
71 			return -EINVAL;
72 
73 		urb->transfer_buffer_length = transfer_length;
74 		desc = urb->iso_frame_desc;
75 		desc->offset = 0;
76 		desc->length = maxpacket;
77 		for (p = 1; p < sk->n_o_ps; ++p) {
78 			desc[p].offset = desc[p - 1].offset + maxpacket;
79 			desc[p].length = maxpacket;
80 		}
81 	}
82 
83 	return 0;
84 }
85 
init_urbs(struct usb_stream_kernel * sk,unsigned int use_packsize,struct usb_device * dev,int in_pipe,int out_pipe)86 static int init_urbs(struct usb_stream_kernel *sk, unsigned int use_packsize,
87 		     struct usb_device *dev, int in_pipe, int out_pipe)
88 {
89 	struct usb_stream	*s = sk->s;
90 	char			*indata =
91 		(char *)s + sizeof(*s) + sizeof(struct usb_stream_packet) * s->inpackets;
92 	int			u;
93 
94 	for (u = 0; u < USB_STREAM_NURBS; ++u) {
95 		sk->inurb[u] = usb_alloc_urb(sk->n_o_ps, GFP_KERNEL);
96 		if (!sk->inurb[u])
97 			return -ENOMEM;
98 
99 		sk->outurb[u] = usb_alloc_urb(sk->n_o_ps, GFP_KERNEL);
100 		if (!sk->outurb[u])
101 			return -ENOMEM;
102 	}
103 
104 	if (init_pipe_urbs(sk, use_packsize, sk->inurb, indata, dev, in_pipe) ||
105 	    init_pipe_urbs(sk, use_packsize, sk->outurb, sk->write_page, dev,
106 			   out_pipe))
107 		return -EINVAL;
108 
109 	return 0;
110 }
111 
112 /*
113  * convert a sampling rate into our full speed format (fs/1000 in Q16.16)
114  * this will overflow at approx 524 kHz
115  */
get_usb_full_speed_rate(unsigned int rate)116 static inline unsigned int get_usb_full_speed_rate(unsigned int rate)
117 {
118 	return ((rate << 13) + 62) / 125;
119 }
120 
121 /*
122  * convert a sampling rate into USB high speed format (fs/8000 in Q16.16)
123  * this will overflow at approx 4 MHz
124  */
get_usb_high_speed_rate(unsigned int rate)125 static inline unsigned int get_usb_high_speed_rate(unsigned int rate)
126 {
127 	return ((rate << 10) + 62) / 125;
128 }
129 
usb_stream_free(struct usb_stream_kernel * sk)130 void usb_stream_free(struct usb_stream_kernel *sk)
131 {
132 	struct usb_stream *s;
133 	unsigned int u;
134 
135 	for (u = 0; u < USB_STREAM_NURBS; ++u) {
136 		usb_free_urb(sk->inurb[u]);
137 		sk->inurb[u] = NULL;
138 		usb_free_urb(sk->outurb[u]);
139 		sk->outurb[u] = NULL;
140 	}
141 
142 	s = sk->s;
143 	if (!s)
144 		return;
145 
146 	if (sk->write_page) {
147 		free_pages_exact(sk->write_page, s->write_size);
148 		sk->write_page = NULL;
149 	}
150 
151 	free_pages_exact(s, s->read_size);
152 	sk->s = NULL;
153 }
154 
usb_stream_new(struct usb_stream_kernel * sk,struct usb_device * dev,unsigned int in_endpoint,unsigned int out_endpoint,unsigned int sample_rate,unsigned int use_packsize,unsigned int period_frames,unsigned int frame_size)155 struct usb_stream *usb_stream_new(struct usb_stream_kernel *sk,
156 				  struct usb_device *dev,
157 				  unsigned int in_endpoint,
158 				  unsigned int out_endpoint,
159 				  unsigned int sample_rate,
160 				  unsigned int use_packsize,
161 				  unsigned int period_frames,
162 				  unsigned int frame_size)
163 {
164 	int packets, max_packsize;
165 	int in_pipe, out_pipe;
166 	int read_size = sizeof(struct usb_stream);
167 	int write_size;
168 	int usb_frames = dev->speed == USB_SPEED_HIGH ? 8000 : 1000;
169 
170 	in_pipe = usb_rcvisocpipe(dev, in_endpoint);
171 	out_pipe = usb_sndisocpipe(dev, out_endpoint);
172 
173 	max_packsize = use_packsize ?
174 		use_packsize : usb_maxpacket(dev, in_pipe);
175 
176 	/*
177 		t_period = period_frames / sample_rate
178 		iso_packs = t_period / t_iso_frame
179 			= (period_frames / sample_rate) * (1 / t_iso_frame)
180 	*/
181 
182 	packets = period_frames * usb_frames / sample_rate + 1;
183 
184 	if (dev->speed == USB_SPEED_HIGH)
185 		packets = (packets + 7) & ~7;
186 
187 	read_size += packets * USB_STREAM_URBDEPTH *
188 		(max_packsize + sizeof(struct usb_stream_packet));
189 
190 	max_packsize = usb_maxpacket(dev, out_pipe);
191 	write_size = max_packsize * packets * USB_STREAM_URBDEPTH;
192 
193 	if (read_size >= 256*PAGE_SIZE || write_size >= 256*PAGE_SIZE) {
194 		snd_printk(KERN_WARNING "a size exceeds 128*PAGE_SIZE\n");
195 		goto out;
196 	}
197 
198 	sk->s = alloc_pages_exact(read_size,
199 				  GFP_KERNEL | __GFP_ZERO | __GFP_NOWARN);
200 	if (!sk->s) {
201 		pr_warn("us122l: couldn't allocate read buffer\n");
202 		goto out;
203 	}
204 	sk->s->cfg.version = USB_STREAM_INTERFACE_VERSION;
205 
206 	sk->s->read_size = read_size;
207 
208 	sk->s->cfg.sample_rate = sample_rate;
209 	sk->s->cfg.frame_size = frame_size;
210 	sk->n_o_ps = packets;
211 	sk->s->inpackets = packets * USB_STREAM_URBDEPTH;
212 	sk->s->cfg.period_frames = period_frames;
213 	sk->s->period_size = frame_size * period_frames;
214 
215 	sk->s->write_size = write_size;
216 
217 	sk->write_page = alloc_pages_exact(write_size,
218 					   GFP_KERNEL | __GFP_ZERO | __GFP_NOWARN);
219 	if (!sk->write_page) {
220 		pr_warn("us122l: couldn't allocate write buffer\n");
221 		usb_stream_free(sk);
222 		return NULL;
223 	}
224 
225 	/* calculate the frequency in 16.16 format */
226 	if (dev->speed == USB_SPEED_FULL)
227 		sk->freqn = get_usb_full_speed_rate(sample_rate);
228 	else
229 		sk->freqn = get_usb_high_speed_rate(sample_rate);
230 
231 	if (init_urbs(sk, use_packsize, dev, in_pipe, out_pipe) < 0) {
232 		usb_stream_free(sk);
233 		return NULL;
234 	}
235 
236 	sk->s->state = usb_stream_stopped;
237 out:
238 	return sk->s;
239 }
240 
241 /*                             start                                  */
242 
balance_check(struct usb_stream_kernel * sk,struct urb * urb)243 static bool balance_check(struct usb_stream_kernel *sk, struct urb *urb)
244 {
245 	bool r;
246 
247 	if (unlikely(urb->status)) {
248 		if (urb->status != -ESHUTDOWN && urb->status != -ENOENT)
249 			snd_printk(KERN_WARNING "status=%i\n", urb->status);
250 		sk->iso_frame_balance = 0x7FFFFFFF;
251 		return false;
252 	}
253 	r = sk->iso_frame_balance == 0;
254 	if (!r)
255 		sk->i_urb = urb;
256 	return r;
257 }
258 
balance_playback(struct usb_stream_kernel * sk,struct urb * urb)259 static bool balance_playback(struct usb_stream_kernel *sk, struct urb *urb)
260 {
261 	sk->iso_frame_balance += urb->number_of_packets;
262 	return balance_check(sk, urb);
263 }
264 
balance_capture(struct usb_stream_kernel * sk,struct urb * urb)265 static bool balance_capture(struct usb_stream_kernel *sk, struct urb *urb)
266 {
267 	sk->iso_frame_balance -= urb->number_of_packets;
268 	return balance_check(sk, urb);
269 }
270 
subs_set_complete(struct urb ** urbs,void (* complete)(struct urb *))271 static void subs_set_complete(struct urb **urbs, void (*complete)(struct urb *))
272 {
273 	int u;
274 
275 	for (u = 0; u < USB_STREAM_NURBS; u++) {
276 		struct urb *urb = urbs[u];
277 
278 		urb->complete = complete;
279 	}
280 }
281 
usb_stream_prepare_playback(struct usb_stream_kernel * sk,struct urb * inurb)282 static int usb_stream_prepare_playback(struct usb_stream_kernel *sk,
283 		struct urb *inurb)
284 {
285 	struct usb_stream *s = sk->s;
286 	struct urb *io;
287 	struct usb_iso_packet_descriptor *id, *od;
288 	int p = 0, lb = 0, l = 0;
289 
290 	io = sk->idle_outurb;
291 	od = io->iso_frame_desc;
292 
293 	for (; s->sync_packet < 0; ++p, ++s->sync_packet) {
294 		struct urb *ii = sk->completed_inurb;
295 
296 		id = ii->iso_frame_desc +
297 			ii->number_of_packets + s->sync_packet;
298 		l = id->actual_length;
299 
300 		od[p].length = l;
301 		od[p].offset = lb;
302 		lb += l;
303 	}
304 
305 	for (;
306 	     s->sync_packet < inurb->number_of_packets && p < sk->n_o_ps;
307 	     ++p, ++s->sync_packet) {
308 		l = inurb->iso_frame_desc[s->sync_packet].actual_length;
309 
310 		if (s->idle_outsize + lb + l > s->period_size)
311 			goto check_ok;
312 
313 		od[p].length = l;
314 		od[p].offset = lb;
315 		lb += l;
316 	}
317 
318 check_ok:
319 	s->sync_packet -= inurb->number_of_packets;
320 	if (unlikely(s->sync_packet < -2 || s->sync_packet > 0)) {
321 		snd_printk(KERN_WARNING "invalid sync_packet = %i;"
322 			   " p=%i nop=%i %i %x %x %x > %x\n",
323 			   s->sync_packet, p, inurb->number_of_packets,
324 			   s->idle_outsize + lb + l,
325 			   s->idle_outsize, lb,  l,
326 			   s->period_size);
327 		return -1;
328 	}
329 	if (unlikely(lb % s->cfg.frame_size)) {
330 		snd_printk(KERN_WARNING"invalid outsize = %i\n",
331 			   lb);
332 		return -1;
333 	}
334 	s->idle_outsize += lb - s->period_size;
335 	io->number_of_packets = p;
336 	io->transfer_buffer_length = lb;
337 	if (s->idle_outsize <= 0)
338 		return 0;
339 
340 	snd_printk(KERN_WARNING "idle=%i\n", s->idle_outsize);
341 	return -1;
342 }
343 
prepare_inurb(int number_of_packets,struct urb * iu)344 static void prepare_inurb(int number_of_packets, struct urb *iu)
345 {
346 	struct usb_iso_packet_descriptor *id;
347 	int p;
348 
349 	iu->number_of_packets = number_of_packets;
350 	id = iu->iso_frame_desc;
351 	id->offset = 0;
352 	for (p = 0; p < iu->number_of_packets - 1; ++p)
353 		id[p + 1].offset = id[p].offset + id[p].length;
354 
355 	iu->transfer_buffer_length =
356 		id[0].length * iu->number_of_packets;
357 }
358 
submit_urbs(struct usb_stream_kernel * sk,struct urb * inurb,struct urb * outurb)359 static int submit_urbs(struct usb_stream_kernel *sk,
360 		       struct urb *inurb, struct urb *outurb)
361 {
362 	int err;
363 
364 	prepare_inurb(sk->idle_outurb->number_of_packets, sk->idle_inurb);
365 	err = usb_submit_urb(sk->idle_inurb, GFP_ATOMIC);
366 	if (err < 0)
367 		goto report_failure;
368 
369 	sk->idle_inurb = sk->completed_inurb;
370 	sk->completed_inurb = inurb;
371 	err = usb_submit_urb(sk->idle_outurb, GFP_ATOMIC);
372 	if (err < 0)
373 		goto report_failure;
374 
375 	sk->idle_outurb = sk->completed_outurb;
376 	sk->completed_outurb = outurb;
377 	return 0;
378 
379 report_failure:
380 	snd_printk(KERN_ERR "%i\n", err);
381 	return err;
382 }
383 
384 #ifdef DEBUG_LOOP_BACK
385 /*
386   This loop_back() shows how to read/write the period data.
387  */
loop_back(struct usb_stream * s)388 static void loop_back(struct usb_stream *s)
389 {
390 	char *i, *o;
391 	int il, ol, l, p;
392 	struct urb *iu;
393 	struct usb_iso_packet_descriptor *id;
394 
395 	o = s->playback1st_to;
396 	ol = s->playback1st_size;
397 	l = 0;
398 
399 	if (s->insplit_pack >= 0) {
400 		iu = sk->idle_inurb;
401 		id = iu->iso_frame_desc;
402 		p = s->insplit_pack;
403 	} else
404 		goto second;
405 loop:
406 	for (; p < iu->number_of_packets && l < s->period_size; ++p) {
407 		i = iu->transfer_buffer + id[p].offset;
408 		il = id[p].actual_length;
409 		if (l + il > s->period_size)
410 			il = s->period_size - l;
411 		if (il <= ol) {
412 			memcpy(o, i, il);
413 			o += il;
414 			ol -= il;
415 		} else {
416 			memcpy(o, i, ol);
417 			singen_6pack(o, ol);
418 			o = s->playback_to;
419 			memcpy(o, i + ol, il - ol);
420 			o += il - ol;
421 			ol = s->period_size - s->playback1st_size;
422 		}
423 		l += il;
424 	}
425 	if (iu == sk->completed_inurb) {
426 		if (l != s->period_size)
427 			printk(KERN_DEBUG"%s:%i %i\n", __func__, __LINE__,
428 			       l/(int)s->cfg.frame_size);
429 
430 		return;
431 	}
432 second:
433 	iu = sk->completed_inurb;
434 	id = iu->iso_frame_desc;
435 	p = 0;
436 	goto loop;
437 
438 }
439 #else
loop_back(struct usb_stream * s)440 static void loop_back(struct usb_stream *s)
441 {
442 }
443 #endif
444 
stream_idle(struct usb_stream_kernel * sk,struct urb * inurb,struct urb * outurb)445 static void stream_idle(struct usb_stream_kernel *sk,
446 			struct urb *inurb, struct urb *outurb)
447 {
448 	struct usb_stream *s = sk->s;
449 	int l, p;
450 	int insize = s->idle_insize;
451 	int urb_size = 0;
452 
453 	s->inpacket_split = s->next_inpacket_split;
454 	s->inpacket_split_at = s->next_inpacket_split_at;
455 	s->next_inpacket_split = -1;
456 	s->next_inpacket_split_at = 0;
457 
458 	for (p = 0; p < inurb->number_of_packets; ++p) {
459 		struct usb_iso_packet_descriptor *id = inurb->iso_frame_desc;
460 
461 		l = id[p].actual_length;
462 		if (unlikely(l == 0 || id[p].status)) {
463 			snd_printk(KERN_WARNING "underrun, status=%u\n",
464 				   id[p].status);
465 			goto err_out;
466 		}
467 		s->inpacket_head++;
468 		s->inpacket_head %= s->inpackets;
469 		if (s->inpacket_split == -1)
470 			s->inpacket_split = s->inpacket_head;
471 
472 		s->inpacket[s->inpacket_head].offset =
473 			id[p].offset + (inurb->transfer_buffer - (void *)s);
474 		s->inpacket[s->inpacket_head].length = l;
475 		if (insize + l > s->period_size &&
476 		    s->next_inpacket_split == -1) {
477 			s->next_inpacket_split = s->inpacket_head;
478 			s->next_inpacket_split_at = s->period_size - insize;
479 		}
480 		insize += l;
481 		urb_size += l;
482 	}
483 	s->idle_insize += urb_size - s->period_size;
484 	if (s->idle_insize < 0) {
485 		snd_printk(KERN_WARNING "%i\n",
486 			   (s->idle_insize)/(int)s->cfg.frame_size);
487 		goto err_out;
488 	}
489 	s->insize_done += urb_size;
490 
491 	l = s->idle_outsize;
492 	s->outpacket[0].offset = (sk->idle_outurb->transfer_buffer -
493 				  sk->write_page) - l;
494 
495 	if (usb_stream_prepare_playback(sk, inurb) < 0)
496 		goto err_out;
497 
498 	s->outpacket[0].length = sk->idle_outurb->transfer_buffer_length + l;
499 	s->outpacket[1].offset = sk->completed_outurb->transfer_buffer -
500 		sk->write_page;
501 
502 	if (submit_urbs(sk, inurb, outurb) < 0)
503 		goto err_out;
504 
505 	loop_back(s);
506 	s->periods_done++;
507 	wake_up_all(&sk->sleep);
508 	return;
509 err_out:
510 	s->state = usb_stream_xrun;
511 	wake_up_all(&sk->sleep);
512 }
513 
i_capture_idle(struct urb * urb)514 static void i_capture_idle(struct urb *urb)
515 {
516 	struct usb_stream_kernel *sk = urb->context;
517 
518 	if (balance_capture(sk, urb))
519 		stream_idle(sk, urb, sk->i_urb);
520 }
521 
i_playback_idle(struct urb * urb)522 static void i_playback_idle(struct urb *urb)
523 {
524 	struct usb_stream_kernel *sk = urb->context;
525 
526 	if (balance_playback(sk, urb))
527 		stream_idle(sk, sk->i_urb, urb);
528 }
529 
stream_start(struct usb_stream_kernel * sk,struct urb * inurb,struct urb * outurb)530 static void stream_start(struct usb_stream_kernel *sk,
531 			 struct urb *inurb, struct urb *outurb)
532 {
533 	struct usb_stream *s = sk->s;
534 
535 	if (s->state >= usb_stream_sync1) {
536 		int l, p, max_diff, max_diff_0;
537 		int urb_size = 0;
538 		unsigned int frames_per_packet, min_frames = 0;
539 
540 		frames_per_packet = (s->period_size - s->idle_insize);
541 		frames_per_packet <<= 8;
542 		frames_per_packet /=
543 			s->cfg.frame_size * inurb->number_of_packets;
544 		frames_per_packet++;
545 
546 		max_diff_0 = s->cfg.frame_size;
547 		if (s->cfg.period_frames >= 256)
548 			max_diff_0 <<= 1;
549 		if (s->cfg.period_frames >= 1024)
550 			max_diff_0 <<= 1;
551 		max_diff = max_diff_0;
552 		for (p = 0; p < inurb->number_of_packets; ++p) {
553 			int diff;
554 
555 			l = inurb->iso_frame_desc[p].actual_length;
556 			urb_size += l;
557 
558 			min_frames += frames_per_packet;
559 			diff = urb_size -
560 				(min_frames >> 8) * s->cfg.frame_size;
561 			if (diff < max_diff) {
562 				snd_printdd(KERN_DEBUG "%i %i %i %i\n",
563 					    s->insize_done,
564 					    urb_size / (int)s->cfg.frame_size,
565 					    inurb->number_of_packets, diff);
566 				max_diff = diff;
567 			}
568 		}
569 		s->idle_insize -= max_diff - max_diff_0;
570 		s->idle_insize += urb_size - s->period_size;
571 		if (s->idle_insize < 0) {
572 			snd_printk(KERN_WARNING "%i %i %i\n",
573 				   s->idle_insize, urb_size, s->period_size);
574 			return;
575 		} else if (s->idle_insize == 0) {
576 			s->next_inpacket_split =
577 				(s->inpacket_head + 1) % s->inpackets;
578 			s->next_inpacket_split_at = 0;
579 		} else {
580 			unsigned int split = s->inpacket_head;
581 
582 			l = s->idle_insize;
583 			while (l > s->inpacket[split].length) {
584 				l -= s->inpacket[split].length;
585 				if (split == 0)
586 					split = s->inpackets - 1;
587 				else
588 					split--;
589 			}
590 			s->next_inpacket_split = split;
591 			s->next_inpacket_split_at =
592 				s->inpacket[split].length - l;
593 		}
594 
595 		s->insize_done += urb_size;
596 
597 		if (usb_stream_prepare_playback(sk, inurb) < 0)
598 			return;
599 
600 	} else
601 		playback_prep_freqn(sk, sk->idle_outurb);
602 
603 	if (submit_urbs(sk, inurb, outurb) < 0)
604 		return;
605 
606 	if (s->state == usb_stream_sync1 && s->insize_done > 360000) {
607 		/* just guesswork                            ^^^^^^ */
608 		s->state = usb_stream_ready;
609 		subs_set_complete(sk->inurb, i_capture_idle);
610 		subs_set_complete(sk->outurb, i_playback_idle);
611 	}
612 }
613 
i_capture_start(struct urb * urb)614 static void i_capture_start(struct urb *urb)
615 {
616 	struct usb_iso_packet_descriptor *id = urb->iso_frame_desc;
617 	struct usb_stream_kernel *sk = urb->context;
618 	struct usb_stream *s = sk->s;
619 	int p;
620 	int empty = 0;
621 
622 	if (urb->status) {
623 		snd_printk(KERN_WARNING "status=%i\n", urb->status);
624 		return;
625 	}
626 
627 	for (p = 0; p < urb->number_of_packets; ++p) {
628 		int l = id[p].actual_length;
629 
630 		if (l < s->cfg.frame_size) {
631 			++empty;
632 			if (s->state >= usb_stream_sync0) {
633 				snd_printk(KERN_WARNING "%i\n", l);
634 				return;
635 			}
636 		}
637 		s->inpacket_head++;
638 		s->inpacket_head %= s->inpackets;
639 		s->inpacket[s->inpacket_head].offset =
640 			id[p].offset + (urb->transfer_buffer - (void *)s);
641 		s->inpacket[s->inpacket_head].length = l;
642 	}
643 #ifdef SHOW_EMPTY
644 	if (empty) {
645 		printk(KERN_DEBUG"%s:%i: %i", __func__, __LINE__,
646 		       urb->iso_frame_desc[0].actual_length);
647 		for (pack = 1; pack < urb->number_of_packets; ++pack) {
648 			int l = urb->iso_frame_desc[pack].actual_length;
649 
650 			printk(KERN_CONT " %i", l);
651 		}
652 		printk(KERN_CONT "\n");
653 	}
654 #endif
655 	if (!empty && s->state < usb_stream_sync1)
656 		++s->state;
657 
658 	if (balance_capture(sk, urb))
659 		stream_start(sk, urb, sk->i_urb);
660 }
661 
i_playback_start(struct urb * urb)662 static void i_playback_start(struct urb *urb)
663 {
664 	struct usb_stream_kernel *sk = urb->context;
665 
666 	if (balance_playback(sk, urb))
667 		stream_start(sk, sk->i_urb, urb);
668 }
669 
usb_stream_start(struct usb_stream_kernel * sk)670 int usb_stream_start(struct usb_stream_kernel *sk)
671 {
672 	struct usb_stream *s = sk->s;
673 	int frame = 0, iters = 0;
674 	int u, err;
675 	int try = 0;
676 
677 	if (s->state != usb_stream_stopped)
678 		return -EAGAIN;
679 
680 	subs_set_complete(sk->inurb, i_capture_start);
681 	subs_set_complete(sk->outurb, i_playback_start);
682 	memset(sk->write_page, 0, s->write_size);
683 dotry:
684 	s->insize_done = 0;
685 	s->idle_insize = 0;
686 	s->idle_outsize = 0;
687 	s->sync_packet = -1;
688 	s->inpacket_head = -1;
689 	sk->iso_frame_balance = 0;
690 	++try;
691 	for (u = 0; u < 2; u++) {
692 		struct urb *inurb = sk->inurb[u];
693 		struct urb *outurb = sk->outurb[u];
694 
695 		playback_prep_freqn(sk, outurb);
696 		inurb->number_of_packets = outurb->number_of_packets;
697 		inurb->transfer_buffer_length =
698 			inurb->number_of_packets *
699 			inurb->iso_frame_desc[0].length;
700 
701 		if (u == 0) {
702 			int now;
703 			struct usb_device *dev = inurb->dev;
704 
705 			frame = usb_get_current_frame_number(dev);
706 			do {
707 				now = usb_get_current_frame_number(dev);
708 				++iters;
709 			} while (now > -1 && now == frame);
710 		}
711 		err = usb_submit_urb(inurb, GFP_ATOMIC);
712 		if (err < 0) {
713 			snd_printk(KERN_ERR
714 				   "usb_submit_urb(sk->inurb[%i]) returned %i\n",
715 				   u, err);
716 			return err;
717 		}
718 		err = usb_submit_urb(outurb, GFP_ATOMIC);
719 		if (err < 0) {
720 			snd_printk(KERN_ERR
721 				   "usb_submit_urb(sk->outurb[%i]) returned %i\n",
722 				   u, err);
723 			return err;
724 		}
725 
726 		if (inurb->start_frame != outurb->start_frame) {
727 			snd_printd(KERN_DEBUG
728 				   "u[%i] start_frames differ in:%u out:%u\n",
729 				   u, inurb->start_frame, outurb->start_frame);
730 			goto check_retry;
731 		}
732 	}
733 	snd_printdd(KERN_DEBUG "%i %i\n", frame, iters);
734 	try = 0;
735 check_retry:
736 	if (try) {
737 		usb_stream_stop(sk);
738 		if (try < 5) {
739 			msleep(1500);
740 			snd_printd(KERN_DEBUG "goto dotry;\n");
741 			goto dotry;
742 		}
743 		snd_printk(KERN_WARNING
744 			   "couldn't start all urbs on the same start_frame.\n");
745 		return -EFAULT;
746 	}
747 
748 	sk->idle_inurb = sk->inurb[USB_STREAM_NURBS - 2];
749 	sk->idle_outurb = sk->outurb[USB_STREAM_NURBS - 2];
750 	sk->completed_inurb = sk->inurb[USB_STREAM_NURBS - 1];
751 	sk->completed_outurb = sk->outurb[USB_STREAM_NURBS - 1];
752 
753 /* wait, check */
754 	{
755 		int wait_ms = 3000;
756 
757 		while (s->state != usb_stream_ready && wait_ms > 0) {
758 			snd_printdd(KERN_DEBUG "%i\n", s->state);
759 			msleep(200);
760 			wait_ms -= 200;
761 		}
762 	}
763 
764 	return s->state == usb_stream_ready ? 0 : -EFAULT;
765 }
766 
767 
768 /*                             stop                                   */
769 
usb_stream_stop(struct usb_stream_kernel * sk)770 void usb_stream_stop(struct usb_stream_kernel *sk)
771 {
772 	int u;
773 
774 	if (!sk->s)
775 		return;
776 	for (u = 0; u < USB_STREAM_NURBS; ++u) {
777 		usb_kill_urb(sk->inurb[u]);
778 		usb_kill_urb(sk->outurb[u]);
779 	}
780 	sk->s->state = usb_stream_stopped;
781 	msleep(400);
782 }
783