uhci-q.c 39.9 KB
Newer Older
L
Linus Torvalds 已提交
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15
/*
 * Universal Host Controller Interface driver for USB.
 *
 * Maintainer: Alan Stern <stern@rowland.harvard.edu>
 *
 * (C) Copyright 1999 Linus Torvalds
 * (C) Copyright 1999-2002 Johannes Erdfelt, johannes@erdfelt.com
 * (C) Copyright 1999 Randy Dunlap
 * (C) Copyright 1999 Georg Acher, acher@in.tum.de
 * (C) Copyright 1999 Deti Fliegl, deti@fliegl.de
 * (C) Copyright 1999 Thomas Sailer, sailer@ife.ee.ethz.ch
 * (C) Copyright 1999 Roman Weissgaerber, weissg@vienna.at
 * (C) Copyright 2000 Yggdrasil Computing, Inc. (port of new PCI interface
 *               support from usb-ohci.c by Adam Richter, adam@yggdrasil.com).
 * (C) Copyright 1999 Gregory P. Smith (from usb-ohci.c)
16
 * (C) Copyright 2004-2006 Alan Stern, stern@rowland.harvard.edu
L
Linus Torvalds 已提交
17 18 19 20 21 22 23 24 25 26 27
 */


/*
 * Technically, updating td->status here is a race, but it's not really a
 * problem. The worst that can happen is that we set the IOC bit again
 * generating a spurious interrupt. We could fix this by creating another
 * QH and leaving the IOC bit always set, but then we would have to play
 * games with the FSBR code to make sure we get the correct order in all
 * the cases. I don't think it's worth the effort
 */
28
static void uhci_set_next_interrupt(struct uhci_hcd *uhci)
L
Linus Torvalds 已提交
29
{
30
	if (uhci->is_stopped)
31
		mod_timer(&uhci_to_hcd(uhci)->rh_timer, jiffies);
L
Linus Torvalds 已提交
32 33 34 35 36 37 38 39
	uhci->term_td->status |= cpu_to_le32(TD_CTRL_IOC); 
}

static inline void uhci_clear_next_interrupt(struct uhci_hcd *uhci)
{
	uhci->term_td->status &= ~cpu_to_le32(TD_CTRL_IOC);
}

A
Alan Stern 已提交
40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66

/*
 * Full-Speed Bandwidth Reclamation (FSBR).
 * We turn on FSBR whenever a queue that wants it is advancing,
 * and leave it on for a short time thereafter.
 */
static void uhci_fsbr_on(struct uhci_hcd *uhci)
{
	uhci->fsbr_is_on = 1;
	uhci->skel_term_qh->link = cpu_to_le32(
			uhci->skel_fs_control_qh->dma_handle) | UHCI_PTR_QH;
}

static void uhci_fsbr_off(struct uhci_hcd *uhci)
{
	uhci->fsbr_is_on = 0;
	uhci->skel_term_qh->link = UHCI_PTR_TERM;
}

static void uhci_add_fsbr(struct uhci_hcd *uhci, struct urb *urb)
{
	struct urb_priv *urbp = urb->hcpriv;

	if (!(urb->transfer_flags & URB_NO_FSBR))
		urbp->fsbr = 1;
}

67
static void uhci_urbp_wants_fsbr(struct uhci_hcd *uhci, struct urb_priv *urbp)
A
Alan Stern 已提交
68 69
{
	if (urbp->fsbr) {
70
		uhci->fsbr_is_wanted = 1;
A
Alan Stern 已提交
71 72
		if (!uhci->fsbr_is_on)
			uhci_fsbr_on(uhci);
73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88
		else if (uhci->fsbr_expiring) {
			uhci->fsbr_expiring = 0;
			del_timer(&uhci->fsbr_timer);
		}
	}
}

static void uhci_fsbr_timeout(unsigned long _uhci)
{
	struct uhci_hcd *uhci = (struct uhci_hcd *) _uhci;
	unsigned long flags;

	spin_lock_irqsave(&uhci->lock, flags);
	if (uhci->fsbr_expiring) {
		uhci->fsbr_expiring = 0;
		uhci_fsbr_off(uhci);
A
Alan Stern 已提交
89
	}
90
	spin_unlock_irqrestore(&uhci->lock, flags);
A
Alan Stern 已提交
91 92 93
}


94
static struct uhci_td *uhci_alloc_td(struct uhci_hcd *uhci)
L
Linus Torvalds 已提交
95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111
{
	dma_addr_t dma_handle;
	struct uhci_td *td;

	td = dma_pool_alloc(uhci->td_pool, GFP_ATOMIC, &dma_handle);
	if (!td)
		return NULL;

	td->dma_handle = dma_handle;
	td->frame = -1;

	INIT_LIST_HEAD(&td->list);
	INIT_LIST_HEAD(&td->fl_list);

	return td;
}

112 113 114 115 116 117 118 119 120 121
static void uhci_free_td(struct uhci_hcd *uhci, struct uhci_td *td)
{
	if (!list_empty(&td->list))
		dev_warn(uhci_dev(uhci), "td %p still in list!\n", td);
	if (!list_empty(&td->fl_list))
		dev_warn(uhci_dev(uhci), "td %p still in fl_list!\n", td);

	dma_pool_free(uhci->td_pool, td, td->dma_handle);
}

L
Linus Torvalds 已提交
122 123 124 125 126 127 128 129
static inline void uhci_fill_td(struct uhci_td *td, u32 status,
		u32 token, u32 buffer)
{
	td->status = cpu_to_le32(status);
	td->token = cpu_to_le32(token);
	td->buffer = cpu_to_le32(buffer);
}

130 131 132 133 134 135 136 137 138 139
static void uhci_add_td_to_urbp(struct uhci_td *td, struct urb_priv *urbp)
{
	list_add_tail(&td->list, &urbp->td_list);
}

static void uhci_remove_td_from_urbp(struct uhci_td *td)
{
	list_del_init(&td->list);
}

L
Linus Torvalds 已提交
140
/*
141
 * We insert Isochronous URBs directly into the frame list at the beginning
L
Linus Torvalds 已提交
142
 */
143 144
static inline void uhci_insert_td_in_frame_list(struct uhci_hcd *uhci,
		struct uhci_td *td, unsigned framenum)
L
Linus Torvalds 已提交
145 146 147 148 149 150
{
	framenum &= (UHCI_NUMFRAMES - 1);

	td->frame = framenum;

	/* Is there a TD already mapped there? */
151
	if (uhci->frame_cpu[framenum]) {
L
Linus Torvalds 已提交
152 153
		struct uhci_td *ftd, *ltd;

154
		ftd = uhci->frame_cpu[framenum];
L
Linus Torvalds 已提交
155 156 157 158 159 160 161 162
		ltd = list_entry(ftd->fl_list.prev, struct uhci_td, fl_list);

		list_add_tail(&td->fl_list, &ftd->fl_list);

		td->link = ltd->link;
		wmb();
		ltd->link = cpu_to_le32(td->dma_handle);
	} else {
163
		td->link = uhci->frame[framenum];
L
Linus Torvalds 已提交
164
		wmb();
165 166
		uhci->frame[framenum] = cpu_to_le32(td->dma_handle);
		uhci->frame_cpu[framenum] = td;
L
Linus Torvalds 已提交
167 168 169
	}
}

170
static inline void uhci_remove_td_from_frame_list(struct uhci_hcd *uhci,
171
		struct uhci_td *td)
L
Linus Torvalds 已提交
172 173
{
	/* If it's not inserted, don't remove it */
174 175
	if (td->frame == -1) {
		WARN_ON(!list_empty(&td->fl_list));
L
Linus Torvalds 已提交
176
		return;
177
	}
L
Linus Torvalds 已提交
178

179
	if (uhci->frame_cpu[td->frame] == td) {
L
Linus Torvalds 已提交
180
		if (list_empty(&td->fl_list)) {
181 182
			uhci->frame[td->frame] = td->link;
			uhci->frame_cpu[td->frame] = NULL;
L
Linus Torvalds 已提交
183 184 185 186
		} else {
			struct uhci_td *ntd;

			ntd = list_entry(td->fl_list.next, struct uhci_td, fl_list);
187 188
			uhci->frame[td->frame] = cpu_to_le32(ntd->dma_handle);
			uhci->frame_cpu[td->frame] = ntd;
L
Linus Torvalds 已提交
189 190 191 192 193 194 195 196 197 198 199 200
		}
	} else {
		struct uhci_td *ptd;

		ptd = list_entry(td->fl_list.prev, struct uhci_td, fl_list);
		ptd->link = td->link;
	}

	list_del_init(&td->fl_list);
	td->frame = -1;
}

201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 218
static inline void uhci_remove_tds_from_frame(struct uhci_hcd *uhci,
		unsigned int framenum)
{
	struct uhci_td *ftd, *ltd;

	framenum &= (UHCI_NUMFRAMES - 1);

	ftd = uhci->frame_cpu[framenum];
	if (ftd) {
		ltd = list_entry(ftd->fl_list.prev, struct uhci_td, fl_list);
		uhci->frame[framenum] = ltd->link;
		uhci->frame_cpu[framenum] = NULL;

		while (!list_empty(&ftd->fl_list))
			list_del_init(ftd->fl_list.prev);
	}
}

219 220 221 222
/*
 * Remove all the TDs for an Isochronous URB from the frame list
 */
static void uhci_unlink_isochronous_tds(struct uhci_hcd *uhci, struct urb *urb)
223 224 225 226 227
{
	struct urb_priv *urbp = (struct urb_priv *) urb->hcpriv;
	struct uhci_td *td;

	list_for_each_entry(td, &urbp->td_list, list)
228
		uhci_remove_td_from_frame_list(uhci, td);
229 230
}

231 232
static struct uhci_qh *uhci_alloc_qh(struct uhci_hcd *uhci,
		struct usb_device *udev, struct usb_host_endpoint *hep)
L
Linus Torvalds 已提交
233 234 235 236 237 238 239 240
{
	dma_addr_t dma_handle;
	struct uhci_qh *qh;

	qh = dma_pool_alloc(uhci->qh_pool, GFP_ATOMIC, &dma_handle);
	if (!qh)
		return NULL;

241
	memset(qh, 0, sizeof(*qh));
L
Linus Torvalds 已提交
242 243 244 245 246
	qh->dma_handle = dma_handle;

	qh->element = UHCI_PTR_TERM;
	qh->link = UHCI_PTR_TERM;

247 248
	INIT_LIST_HEAD(&qh->queue);
	INIT_LIST_HEAD(&qh->node);
L
Linus Torvalds 已提交
249

250
	if (udev) {		/* Normal QH */
A
Alan Stern 已提交
251 252 253 254 255
		qh->dummy_td = uhci_alloc_td(uhci);
		if (!qh->dummy_td) {
			dma_pool_free(uhci->qh_pool, qh, dma_handle);
			return NULL;
		}
256 257 258 259
		qh->state = QH_STATE_IDLE;
		qh->hep = hep;
		qh->udev = udev;
		hep->hcpriv = qh;
260
		qh->type = hep->desc.bmAttributes & USB_ENDPOINT_XFERTYPE_MASK;
L
Linus Torvalds 已提交
261

262 263
	} else {		/* Skeleton QH */
		qh->state = QH_STATE_ACTIVE;
264
		qh->type = -1;
265
	}
L
Linus Torvalds 已提交
266 267 268 269 270
	return qh;
}

static void uhci_free_qh(struct uhci_hcd *uhci, struct uhci_qh *qh)
{
271 272
	WARN_ON(qh->state != QH_STATE_IDLE && qh->udev);
	if (!list_empty(&qh->queue))
L
Linus Torvalds 已提交
273 274
		dev_warn(uhci_dev(uhci), "qh %p list not empty!\n", qh);

275 276 277
	list_del(&qh->node);
	if (qh->udev) {
		qh->hep->hcpriv = NULL;
A
Alan Stern 已提交
278
		uhci_free_td(uhci, qh->dummy_td);
279
	}
L
Linus Torvalds 已提交
280 281 282
	dma_pool_free(uhci->qh_pool, qh, qh->dma_handle);
}

283
/*
284 285 286
 * When a queue is stopped and a dequeued URB is given back, adjust
 * the previous TD link (if the URB isn't first on the queue) or
 * save its toggle value (if it is first and is currently executing).
287 288
 *
 * Returns 0 if the URB should not yet be given back, 1 otherwise.
289
 */
290
static int uhci_cleanup_queue(struct uhci_hcd *uhci, struct uhci_qh *qh,
291
		struct urb *urb)
292
{
293
	struct urb_priv *urbp = urb->hcpriv;
294
	struct uhci_td *td;
295
	int ret = 1;
296

297
	/* Isochronous pipes don't use toggles and their TD link pointers
298 299 300 301 302 303
	 * get adjusted during uhci_urb_dequeue().  But since their queues
	 * cannot truly be stopped, we have to watch out for dequeues
	 * occurring after the nominal unlink frame. */
	if (qh->type == USB_ENDPOINT_XFER_ISOC) {
		ret = (uhci->frame_number + uhci->is_stopped !=
				qh->unlink_frame);
304
		goto done;
305
	}
306 307 308 309 310 311 312 313 314 315 316 317 318 319 320

	/* If the URB isn't first on its queue, adjust the link pointer
	 * of the last TD in the previous URB.  The toggle doesn't need
	 * to be saved since this URB can't be executing yet. */
	if (qh->queue.next != &urbp->node) {
		struct urb_priv *purbp;
		struct uhci_td *ptd;

		purbp = list_entry(urbp->node.prev, struct urb_priv, node);
		WARN_ON(list_empty(&purbp->td_list));
		ptd = list_entry(purbp->td_list.prev, struct uhci_td,
				list);
		td = list_entry(urbp->td_list.prev, struct uhci_td,
				list);
		ptd->link = td->link;
321
		goto done;
322 323
	}

324 325
	/* If the QH element pointer is UHCI_PTR_TERM then then currently
	 * executing URB has already been unlinked, so this one isn't it. */
326
	if (qh_element(qh) == UHCI_PTR_TERM)
327
		goto done;
328 329
	qh->element = UHCI_PTR_TERM;

330 331
	/* Control pipes have to worry about toggles */
	if (qh->type == USB_ENDPOINT_XFER_CONTROL)
332
		goto done;
333

334
	/* Save the next toggle value */
335 336 337 338
	WARN_ON(list_empty(&urbp->td_list));
	td = list_entry(urbp->td_list.next, struct uhci_td, list);
	qh->needs_fixup = 1;
	qh->initial_toggle = uhci_toggle(td_token(td));
339 340

done:
341
	return ret;
342 343 344 345 346 347 348 349 350 351 352 353 354 355 356 357 358 359 360 361 362 363 364 365 366 367
}

/*
 * Fix up the data toggles for URBs in a queue, when one of them
 * terminates early (short transfer, error, or dequeued).
 */
static void uhci_fixup_toggles(struct uhci_qh *qh, int skip_first)
{
	struct urb_priv *urbp = NULL;
	struct uhci_td *td;
	unsigned int toggle = qh->initial_toggle;
	unsigned int pipe;

	/* Fixups for a short transfer start with the second URB in the
	 * queue (the short URB is the first). */
	if (skip_first)
		urbp = list_entry(qh->queue.next, struct urb_priv, node);

	/* When starting with the first URB, if the QH element pointer is
	 * still valid then we know the URB's toggles are okay. */
	else if (qh_element(qh) != UHCI_PTR_TERM)
		toggle = 2;

	/* Fix up the toggle for the URBs in the queue.  Normally this
	 * loop won't run more than once: When an error or short transfer
	 * occurs, the queue usually gets emptied. */
368
	urbp = list_prepare_entry(urbp, &qh->queue, node);
369 370 371 372 373 374 375 376 377 378 379 380 381 382 383 384 385 386 387 388 389 390 391 392 393 394 395
	list_for_each_entry_continue(urbp, &qh->queue, node) {

		/* If the first TD has the right toggle value, we don't
		 * need to change any toggles in this URB */
		td = list_entry(urbp->td_list.next, struct uhci_td, list);
		if (toggle > 1 || uhci_toggle(td_token(td)) == toggle) {
			td = list_entry(urbp->td_list.next, struct uhci_td,
					list);
			toggle = uhci_toggle(td_token(td)) ^ 1;

		/* Otherwise all the toggles in the URB have to be switched */
		} else {
			list_for_each_entry(td, &urbp->td_list, list) {
				td->token ^= __constant_cpu_to_le32(
							TD_TOKEN_TOGGLE);
				toggle ^= 1;
			}
		}
	}

	wmb();
	pipe = list_entry(qh->queue.next, struct urb_priv, node)->urb->pipe;
	usb_settoggle(qh->udev, usb_pipeendpoint(pipe),
			usb_pipeout(pipe), toggle);
	qh->needs_fixup = 0;
}

L
Linus Torvalds 已提交
396
/*
397
 * Put a QH on the schedule in both hardware and software
L
Linus Torvalds 已提交
398
 */
399
static void uhci_activate_qh(struct uhci_hcd *uhci, struct uhci_qh *qh)
L
Linus Torvalds 已提交
400
{
401
	struct uhci_qh *pqh;
L
Linus Torvalds 已提交
402

403
	WARN_ON(list_empty(&qh->queue));
L
Linus Torvalds 已提交
404

405 406 407 408 409 410 411
	/* Set the element pointer if it isn't set already.
	 * This isn't needed for Isochronous queues, but it doesn't hurt. */
	if (qh_element(qh) == UHCI_PTR_TERM) {
		struct urb_priv *urbp = list_entry(qh->queue.next,
				struct urb_priv, node);
		struct uhci_td *td = list_entry(urbp->td_list.next,
				struct uhci_td, list);
L
Linus Torvalds 已提交
412

413
		qh->element = cpu_to_le32(td->dma_handle);
L
Linus Torvalds 已提交
414 415
	}

A
Alan Stern 已提交
416 417 418 419
	/* Treat the queue as if it has just advanced */
	qh->wait_expired = 0;
	qh->advance_jiffies = jiffies;

420 421 422 423 424 425
	if (qh->state == QH_STATE_ACTIVE)
		return;
	qh->state = QH_STATE_ACTIVE;

	/* Move the QH from its old list to the end of the appropriate
	 * skeleton's list */
426 427 428
	if (qh == uhci->next_qh)
		uhci->next_qh = list_entry(qh->node.next, struct uhci_qh,
				node);
429 430 431 432 433 434 435
	list_move_tail(&qh->node, &qh->skel->node);

	/* Link it into the schedule */
	pqh = list_entry(qh->node.prev, struct uhci_qh, node);
	qh->link = pqh->link;
	wmb();
	pqh->link = UHCI_PTR_QH | cpu_to_le32(qh->dma_handle);
L
Linus Torvalds 已提交
436 437 438
}

/*
439
 * Take a QH off the hardware schedule
L
Linus Torvalds 已提交
440
 */
441
static void uhci_unlink_qh(struct uhci_hcd *uhci, struct uhci_qh *qh)
L
Linus Torvalds 已提交
442 443 444
{
	struct uhci_qh *pqh;

445
	if (qh->state == QH_STATE_UNLINKING)
L
Linus Torvalds 已提交
446
		return;
447 448
	WARN_ON(qh->state != QH_STATE_ACTIVE || !qh->udev);
	qh->state = QH_STATE_UNLINKING;
L
Linus Torvalds 已提交
449

450 451 452 453
	/* Unlink the QH from the schedule and record when we did it */
	pqh = list_entry(qh->node.prev, struct uhci_qh, node);
	pqh->link = qh->link;
	mb();
L
Linus Torvalds 已提交
454 455

	uhci_get_current_frame_number(uhci);
456
	qh->unlink_frame = uhci->frame_number;
L
Linus Torvalds 已提交
457

458 459
	/* Force an interrupt so we know when the QH is fully unlinked */
	if (list_empty(&uhci->skel_unlink_qh->node))
L
Linus Torvalds 已提交
460 461
		uhci_set_next_interrupt(uhci);

462
	/* Move the QH from its old list to the end of the unlinking list */
463 464 465
	if (qh == uhci->next_qh)
		uhci->next_qh = list_entry(qh->node.next, struct uhci_qh,
				node);
466
	list_move_tail(&qh->node, &uhci->skel_unlink_qh->node);
L
Linus Torvalds 已提交
467 468
}

469 470 471 472 473 474 475
/*
 * When we and the controller are through with a QH, it becomes IDLE.
 * This happens when a QH has been off the schedule (on the unlinking
 * list) for more than one frame, or when an error occurs while adding
 * the first URB onto a new QH.
 */
static void uhci_make_qh_idle(struct uhci_hcd *uhci, struct uhci_qh *qh)
L
Linus Torvalds 已提交
476
{
477
	WARN_ON(qh->state == QH_STATE_ACTIVE);
L
Linus Torvalds 已提交
478

479 480 481
	if (qh == uhci->next_qh)
		uhci->next_qh = list_entry(qh->node.next, struct uhci_qh,
				node);
482 483
	list_move(&qh->node, &uhci->idle_qh_list);
	qh->state = QH_STATE_IDLE;
L
Linus Torvalds 已提交
484

485 486 487 488 489 490
	/* Now that the QH is idle, its post_td isn't being used */
	if (qh->post_td) {
		uhci_free_td(uhci, qh->post_td);
		qh->post_td = NULL;
	}

491 492 493
	/* If anyone is waiting for a QH to become idle, wake them up */
	if (uhci->num_waiting)
		wake_up_all(&uhci->waitqh);
L
Linus Torvalds 已提交
494 495
}

496 497
static inline struct urb_priv *uhci_alloc_urb_priv(struct uhci_hcd *uhci,
		struct urb *urb)
L
Linus Torvalds 已提交
498 499 500 501 502 503 504 505 506 507
{
	struct urb_priv *urbp;

	urbp = kmem_cache_alloc(uhci_up_cachep, SLAB_ATOMIC);
	if (!urbp)
		return NULL;

	memset((void *)urbp, 0, sizeof(*urbp));

	urbp->urb = urb;
508
	urb->hcpriv = urbp;
L
Linus Torvalds 已提交
509
	
510
	INIT_LIST_HEAD(&urbp->node);
L
Linus Torvalds 已提交
511 512 513 514 515
	INIT_LIST_HEAD(&urbp->td_list);

	return urbp;
}

516 517
static void uhci_free_urb_priv(struct uhci_hcd *uhci,
		struct urb_priv *urbp)
L
Linus Torvalds 已提交
518 519 520
{
	struct uhci_td *td, *tmp;

521 522 523
	if (!list_empty(&urbp->node))
		dev_warn(uhci_dev(uhci), "urb %p still on QH's list!\n",
				urbp->urb);
L
Linus Torvalds 已提交
524 525

	list_for_each_entry_safe(td, tmp, &urbp->td_list, list) {
526 527
		uhci_remove_td_from_urbp(td);
		uhci_free_td(uhci, td);
L
Linus Torvalds 已提交
528 529
	}

530
	urbp->urb->hcpriv = NULL;
L
Linus Torvalds 已提交
531 532 533 534 535 536 537 538 539 540 541 542 543 544 545 546 547 548 549 550 551 552 553 554 555 556 557 558 559 560 561 562 563 564 565
	kmem_cache_free(uhci_up_cachep, urbp);
}

/*
 * Map status to standard result codes
 *
 * <status> is (td_status(td) & 0xF60000), a.k.a.
 * uhci_status_bits(td_status(td)).
 * Note: <status> does not include the TD_CTRL_NAK bit.
 * <dir_out> is True for output TDs and False for input TDs.
 */
static int uhci_map_status(int status, int dir_out)
{
	if (!status)
		return 0;
	if (status & TD_CTRL_BITSTUFF)			/* Bitstuff error */
		return -EPROTO;
	if (status & TD_CTRL_CRCTIMEO) {		/* CRC/Timeout */
		if (dir_out)
			return -EPROTO;
		else
			return -EILSEQ;
	}
	if (status & TD_CTRL_BABBLE)			/* Babble */
		return -EOVERFLOW;
	if (status & TD_CTRL_DBUFERR)			/* Buffer error */
		return -ENOSR;
	if (status & TD_CTRL_STALLED)			/* Stalled */
		return -EPIPE;
	return 0;
}

/*
 * Control transfers
 */
566 567
static int uhci_submit_control(struct uhci_hcd *uhci, struct urb *urb,
		struct uhci_qh *qh)
L
Linus Torvalds 已提交
568 569 570
{
	struct uhci_td *td;
	unsigned long destination, status;
571
	int maxsze = le16_to_cpu(qh->hep->desc.wMaxPacketSize);
L
Linus Torvalds 已提交
572 573
	int len = urb->transfer_buffer_length;
	dma_addr_t data = urb->transfer_dma;
574
	__le32 *plink;
575
	struct urb_priv *urbp = urb->hcpriv;
L
Linus Torvalds 已提交
576 577 578 579

	/* The "pipe" thing contains the destination in bits 8--18 */
	destination = (urb->pipe & PIPE_DEVEP_MASK) | USB_PID_SETUP;

A
Alan Stern 已提交
580 581
	/* 3 errors, dummy TD remains inactive */
	status = uhci_maxerr(3);
L
Linus Torvalds 已提交
582 583 584 585 586 587
	if (urb->dev->speed == USB_SPEED_LOW)
		status |= TD_CTRL_LS;

	/*
	 * Build the TD for the control request setup packet
	 */
A
Alan Stern 已提交
588
	td = qh->dummy_td;
589
	uhci_add_td_to_urbp(td, urbp);
590
	uhci_fill_td(td, status, destination | uhci_explen(8),
591 592
			urb->setup_dma);
	plink = &td->link;
A
Alan Stern 已提交
593
	status |= TD_CTRL_ACTIVE;
L
Linus Torvalds 已提交
594 595 596 597 598 599 600 601 602 603 604 605 606 607

	/*
	 * If direction is "send", change the packet ID from SETUP (0x2D)
	 * to OUT (0xE1).  Else change it from SETUP to IN (0x69) and
	 * set Short Packet Detect (SPD) for all data packets.
	 */
	if (usb_pipeout(urb->pipe))
		destination ^= (USB_PID_SETUP ^ USB_PID_OUT);
	else {
		destination ^= (USB_PID_SETUP ^ USB_PID_IN);
		status |= TD_CTRL_SPD;
	}

	/*
608
	 * Build the DATA TDs
L
Linus Torvalds 已提交
609 610
	 */
	while (len > 0) {
611
		int pktsze = min(len, maxsze);
L
Linus Torvalds 已提交
612

613
		td = uhci_alloc_td(uhci);
L
Linus Torvalds 已提交
614
		if (!td)
A
Alan Stern 已提交
615
			goto nomem;
616
		*plink = cpu_to_le32(td->dma_handle);
L
Linus Torvalds 已提交
617 618 619 620

		/* Alternate Data0/1 (start with Data1) */
		destination ^= TD_TOKEN_TOGGLE;
	
621
		uhci_add_td_to_urbp(td, urbp);
622
		uhci_fill_td(td, status, destination | uhci_explen(pktsze),
623 624
				data);
		plink = &td->link;
L
Linus Torvalds 已提交
625 626 627 628 629 630 631 632

		data += pktsze;
		len -= pktsze;
	}

	/*
	 * Build the final TD for control status 
	 */
633
	td = uhci_alloc_td(uhci);
L
Linus Torvalds 已提交
634
	if (!td)
A
Alan Stern 已提交
635
		goto nomem;
636
	*plink = cpu_to_le32(td->dma_handle);
L
Linus Torvalds 已提交
637 638 639 640 641 642 643 644 645 646 647 648 649 650 651

	/*
	 * It's IN if the pipe is an output pipe or we're not expecting
	 * data back.
	 */
	destination &= ~TD_TOKEN_PID_MASK;
	if (usb_pipeout(urb->pipe) || !urb->transfer_buffer_length)
		destination |= USB_PID_IN;
	else
		destination |= USB_PID_OUT;

	destination |= TD_TOKEN_TOGGLE;		/* End in Data1 */

	status &= ~TD_CTRL_SPD;

652
	uhci_add_td_to_urbp(td, urbp);
L
Linus Torvalds 已提交
653
	uhci_fill_td(td, status | TD_CTRL_IOC,
654
			destination | uhci_explen(0), 0);
A
Alan Stern 已提交
655 656 657 658 659 660 661 662 663 664 665 666 667 668
	plink = &td->link;

	/*
	 * Build the new dummy TD and activate the old one
	 */
	td = uhci_alloc_td(uhci);
	if (!td)
		goto nomem;
	*plink = cpu_to_le32(td->dma_handle);

	uhci_fill_td(td, 0, USB_PID_OUT | uhci_explen(0), 0);
	wmb();
	qh->dummy_td->status |= __constant_cpu_to_le32(TD_CTRL_ACTIVE);
	qh->dummy_td = td;
L
Linus Torvalds 已提交
669 670 671 672

	/* Low-speed transfers get a different queue, and won't hog the bus.
	 * Also, some devices enumerate better without FSBR; the easiest way
	 * to do that is to put URBs on the low-speed queue while the device
673
	 * isn't in the CONFIGURED state. */
L
Linus Torvalds 已提交
674
	if (urb->dev->speed == USB_SPEED_LOW ||
675
			urb->dev->state != USB_STATE_CONFIGURED)
676
		qh->skel = uhci->skel_ls_control_qh;
L
Linus Torvalds 已提交
677
	else {
678
		qh->skel = uhci->skel_fs_control_qh;
A
Alan Stern 已提交
679
		uhci_add_fsbr(uhci, urb);
L
Linus Torvalds 已提交
680
	}
681 682

	urb->actual_length = -8;	/* Account for the SETUP packet */
683
	return 0;
A
Alan Stern 已提交
684 685 686

nomem:
	/* Remove the dummy TD from the td_list so it doesn't get freed */
687
	uhci_remove_td_from_urbp(qh->dummy_td);
A
Alan Stern 已提交
688
	return -ENOMEM;
L
Linus Torvalds 已提交
689 690 691 692 693
}

/*
 * Common submit for bulk and interrupt
 */
694 695
static int uhci_submit_common(struct uhci_hcd *uhci, struct urb *urb,
		struct uhci_qh *qh)
L
Linus Torvalds 已提交
696 697 698
{
	struct uhci_td *td;
	unsigned long destination, status;
699
	int maxsze = le16_to_cpu(qh->hep->desc.wMaxPacketSize);
L
Linus Torvalds 已提交
700 701
	int len = urb->transfer_buffer_length;
	dma_addr_t data = urb->transfer_dma;
A
Alan Stern 已提交
702
	__le32 *plink;
703
	struct urb_priv *urbp = urb->hcpriv;
A
Alan Stern 已提交
704
	unsigned int toggle;
L
Linus Torvalds 已提交
705 706 707 708 709 710

	if (len < 0)
		return -EINVAL;

	/* The "pipe" thing contains the destination in bits 8--18 */
	destination = (urb->pipe & PIPE_DEVEP_MASK) | usb_packetid(urb->pipe);
A
Alan Stern 已提交
711 712
	toggle = usb_gettoggle(urb->dev, usb_pipeendpoint(urb->pipe),
			 usb_pipeout(urb->pipe));
L
Linus Torvalds 已提交
713

A
Alan Stern 已提交
714 715
	/* 3 errors, dummy TD remains inactive */
	status = uhci_maxerr(3);
L
Linus Torvalds 已提交
716 717 718 719 720 721
	if (urb->dev->speed == USB_SPEED_LOW)
		status |= TD_CTRL_LS;
	if (usb_pipein(urb->pipe))
		status |= TD_CTRL_SPD;

	/*
722
	 * Build the DATA TDs
L
Linus Torvalds 已提交
723
	 */
A
Alan Stern 已提交
724 725
	plink = NULL;
	td = qh->dummy_td;
L
Linus Torvalds 已提交
726 727 728
	do {	/* Allow zero length packets */
		int pktsze = maxsze;

729
		if (len <= pktsze) {		/* The last packet */
L
Linus Torvalds 已提交
730 731 732 733 734
			pktsze = len;
			if (!(urb->transfer_flags & URB_SHORT_NOT_OK))
				status &= ~TD_CTRL_SPD;
		}

A
Alan Stern 已提交
735 736 737 738 739 740
		if (plink) {
			td = uhci_alloc_td(uhci);
			if (!td)
				goto nomem;
			*plink = cpu_to_le32(td->dma_handle);
		}
741
		uhci_add_td_to_urbp(td, urbp);
742
		uhci_fill_td(td, status,
A
Alan Stern 已提交
743 744 745
				destination | uhci_explen(pktsze) |
					(toggle << TD_TOKEN_TOGGLE_SHIFT),
				data);
746
		plink = &td->link;
A
Alan Stern 已提交
747
		status |= TD_CTRL_ACTIVE;
L
Linus Torvalds 已提交
748 749 750

		data += pktsze;
		len -= maxsze;
A
Alan Stern 已提交
751
		toggle ^= 1;
L
Linus Torvalds 已提交
752 753 754 755 756 757 758 759 760
	} while (len > 0);

	/*
	 * URB_ZERO_PACKET means adding a 0-length packet, if direction
	 * is OUT and the transfer_length was an exact multiple of maxsze,
	 * hence (len = transfer_length - N * maxsze) == 0
	 * however, if transfer_length == 0, the zero packet was already
	 * prepared above.
	 */
761 762 763
	if ((urb->transfer_flags & URB_ZERO_PACKET) &&
			usb_pipeout(urb->pipe) && len == 0 &&
			urb->transfer_buffer_length > 0) {
764
		td = uhci_alloc_td(uhci);
L
Linus Torvalds 已提交
765
		if (!td)
A
Alan Stern 已提交
766
			goto nomem;
767
		*plink = cpu_to_le32(td->dma_handle);
L
Linus Torvalds 已提交
768

769
		uhci_add_td_to_urbp(td, urbp);
A
Alan Stern 已提交
770 771 772 773 774
		uhci_fill_td(td, status,
				destination | uhci_explen(0) |
					(toggle << TD_TOKEN_TOGGLE_SHIFT),
				data);
		plink = &td->link;
L
Linus Torvalds 已提交
775

A
Alan Stern 已提交
776
		toggle ^= 1;
L
Linus Torvalds 已提交
777 778 779 780 781 782 783 784
	}

	/* Set the interrupt-on-completion flag on the last packet.
	 * A more-or-less typical 4 KB URB (= size of one memory page)
	 * will require about 3 ms to transfer; that's a little on the
	 * fast side but not enough to justify delaying an interrupt
	 * more than 2 or 3 URBs, so we will ignore the URB_NO_INTERRUPT
	 * flag setting. */
785
	td->status |= __constant_cpu_to_le32(TD_CTRL_IOC);
L
Linus Torvalds 已提交
786

A
Alan Stern 已提交
787 788 789 790 791 792 793 794 795 796 797 798
	/*
	 * Build the new dummy TD and activate the old one
	 */
	td = uhci_alloc_td(uhci);
	if (!td)
		goto nomem;
	*plink = cpu_to_le32(td->dma_handle);

	uhci_fill_td(td, 0, USB_PID_OUT | uhci_explen(0), 0);
	wmb();
	qh->dummy_td->status |= __constant_cpu_to_le32(TD_CTRL_ACTIVE);
	qh->dummy_td = td;
799
	qh->period = urb->interval;
A
Alan Stern 已提交
800 801 802

	usb_settoggle(urb->dev, usb_pipeendpoint(urb->pipe),
			usb_pipeout(urb->pipe), toggle);
803
	return 0;
A
Alan Stern 已提交
804 805 806

nomem:
	/* Remove the dummy TD from the td_list so it doesn't get freed */
807
	uhci_remove_td_from_urbp(qh->dummy_td);
A
Alan Stern 已提交
808
	return -ENOMEM;
L
Linus Torvalds 已提交
809 810
}

811 812
static inline int uhci_submit_bulk(struct uhci_hcd *uhci, struct urb *urb,
		struct uhci_qh *qh)
L
Linus Torvalds 已提交
813 814 815 816 817 818 819
{
	int ret;

	/* Can't have low-speed bulk transfers */
	if (urb->dev->speed == USB_SPEED_LOW)
		return -EINVAL;

820 821 822
	qh->skel = uhci->skel_bulk_qh;
	ret = uhci_submit_common(uhci, urb, qh);
	if (ret == 0)
A
Alan Stern 已提交
823
		uhci_add_fsbr(uhci, urb);
L
Linus Torvalds 已提交
824 825 826
	return ret;
}

827
static int uhci_submit_interrupt(struct uhci_hcd *uhci, struct urb *urb,
828
		struct uhci_qh *qh)
L
Linus Torvalds 已提交
829
{
830 831
	int exponent;

832 833 834
	/* USB 1.1 interrupt transfers only involve one packet per interval.
	 * Drivers can submit URBs of any length, but longer ones will need
	 * multiple intervals to complete.
L
Linus Torvalds 已提交
835
	 */
836 837 838 839 840 841 842 843 844 845 846 847 848 849 850

	/* Figure out which power-of-two queue to use */
	for (exponent = 7; exponent >= 0; --exponent) {
		if ((1 << exponent) <= urb->interval)
			break;
	}
	if (exponent < 0)
		return -EINVAL;
	urb->interval = 1 << exponent;

	if (qh->period == 0)
		qh->skel = uhci->skelqh[UHCI_SKEL_INDEX(exponent)];
	else if (qh->period != urb->interval)
		return -EINVAL;		/* Can't change the period */

851
	return uhci_submit_common(uhci, urb, qh);
L
Linus Torvalds 已提交
852 853
}

854 855 856 857
/*
 * Fix up the data structures following a short transfer
 */
static int uhci_fixup_short_transfer(struct uhci_hcd *uhci,
858
		struct uhci_qh *qh, struct urb_priv *urbp)
859 860
{
	struct uhci_td *td;
861 862
	struct list_head *tmp;
	int ret;
863 864 865 866 867 868 869

	td = list_entry(urbp->td_list.prev, struct uhci_td, list);
	if (qh->type == USB_ENDPOINT_XFER_CONTROL) {

		/* When a control transfer is short, we have to restart
		 * the queue at the status stage transaction, which is
		 * the last TD. */
870
		WARN_ON(list_empty(&urbp->td_list));
871
		qh->element = cpu_to_le32(td->dma_handle);
872
		tmp = td->list.prev;
873 874
		ret = -EINPROGRESS;

875
	} else {
876 877 878 879

		/* When a bulk/interrupt transfer is short, we have to
		 * fix up the toggles of the following URBs on the queue
		 * before restarting the queue at the next URB. */
880
		qh->initial_toggle = uhci_toggle(td_token(qh->post_td)) ^ 1;
881 882
		uhci_fixup_toggles(qh, 1);

883 884
		if (list_empty(&urbp->td_list))
			td = qh->post_td;
885
		qh->element = td->link;
886 887
		tmp = urbp->td_list.prev;
		ret = 0;
888 889
	}

890 891 892 893 894
	/* Remove all the TDs we skipped over, from tmp back to the start */
	while (tmp != &urbp->td_list) {
		td = list_entry(tmp, struct uhci_td, list);
		tmp = tmp->prev;

895 896
		uhci_remove_td_from_urbp(td);
		uhci_free_td(uhci, td);
897
	}
898 899 900 901 902 903 904 905 906 907
	return ret;
}

/*
 * Common result for control, bulk, and interrupt
 */
static int uhci_result_common(struct uhci_hcd *uhci, struct urb *urb)
{
	struct urb_priv *urbp = urb->hcpriv;
	struct uhci_qh *qh = urbp->qh;
908
	struct uhci_td *td, *tmp;
909 910 911
	unsigned status;
	int ret = 0;

912
	list_for_each_entry_safe(td, tmp, &urbp->td_list, list) {
913 914 915 916 917 918 919 920 921 922 923 924 925 926 927 928
		unsigned int ctrlstat;
		int len;

		ctrlstat = td_status(td);
		status = uhci_status_bits(ctrlstat);
		if (status & TD_CTRL_ACTIVE)
			return -EINPROGRESS;

		len = uhci_actual_length(ctrlstat);
		urb->actual_length += len;

		if (status) {
			ret = uhci_map_status(status,
					uhci_packetout(td_token(td)));
			if ((debug == 1 && ret != -EPIPE) || debug > 1) {
				/* Some debugging code */
D
David Brownell 已提交
929
				dev_dbg(&urb->dev->dev,
930 931 932 933 934 935 936 937 938 939 940 941 942 943 944 945
						"%s: failed with status %x\n",
						__FUNCTION__, status);

				if (debug > 1 && errbuf) {
					/* Print the chain for debugging */
					uhci_show_qh(urbp->qh, errbuf,
							ERRBUF_LEN, 0);
					lprintk(errbuf);
				}
			}

		} else if (len < uhci_expected_length(td_token(td))) {

			/* We received a short packet */
			if (urb->transfer_flags & URB_SHORT_NOT_OK)
				ret = -EREMOTEIO;
946 947 948

			/* Fixup needed only if this isn't the URB's last TD */
			else if (&td->list != urbp->td_list.prev)
949 950 951
				ret = 1;
		}

952
		uhci_remove_td_from_urbp(td);
953
		if (qh->post_td)
954
			uhci_free_td(uhci, qh->post_td);
955 956
		qh->post_td = td;

957 958 959 960 961 962 963 964 965 966 967 968 969 970 971 972 973 974 975 976
		if (ret != 0)
			goto err;
	}
	return ret;

err:
	if (ret < 0) {
		/* In case a control transfer gets an error
		 * during the setup stage */
		urb->actual_length = max(urb->actual_length, 0);

		/* Note that the queue has stopped and save
		 * the next toggle value */
		qh->element = UHCI_PTR_TERM;
		qh->is_stopped = 1;
		qh->needs_fixup = (qh->type != USB_ENDPOINT_XFER_CONTROL);
		qh->initial_toggle = uhci_toggle(td_token(td)) ^
				(ret == -EREMOTEIO);

	} else		/* Short packet received */
977
		ret = uhci_fixup_short_transfer(uhci, qh, urbp);
978 979 980
	return ret;
}

L
Linus Torvalds 已提交
981 982 983
/*
 * Isochronous transfers
 */
984 985
static int uhci_submit_isochronous(struct uhci_hcd *uhci, struct urb *urb,
		struct uhci_qh *qh)
L
Linus Torvalds 已提交
986
{
987 988 989 990
	struct uhci_td *td = NULL;	/* Since urb->number_of_packets > 0 */
	int i, frame;
	unsigned long destination, status;
	struct urb_priv *urbp = (struct urb_priv *) urb->hcpriv;
L
Linus Torvalds 已提交
991

992 993 994
	/* Values must not be too big (could overflow below) */
	if (urb->interval >= UHCI_NUMFRAMES ||
			urb->number_of_packets >= UHCI_NUMFRAMES)
L
Linus Torvalds 已提交
995 996
		return -EFBIG;

997 998 999
	/* Check the period and figure out the starting frame number */
	if (qh->period == 0) {
		if (urb->transfer_flags & URB_ISO_ASAP) {
1000
			uhci_get_current_frame_number(uhci);
1001 1002
			urb->start_frame = uhci->frame_number + 10;
		} else {
1003
			i = urb->start_frame - uhci->last_iso_frame;
1004 1005 1006 1007 1008
			if (i <= 0 || i >= UHCI_NUMFRAMES)
				return -EINVAL;
		}
	} else if (qh->period != urb->interval) {
		return -EINVAL;		/* Can't change the period */
L
Linus Torvalds 已提交
1009

1010
	} else {	/* Pick up where the last URB leaves off */
1011
		if (list_empty(&qh->queue)) {
1012
			frame = qh->iso_frame;
1013 1014
		} else {
			struct urb *lurb;
1015

1016
			lurb = list_entry(qh->queue.prev,
1017
					struct urb_priv, node)->urb;
1018 1019 1020
			frame = lurb->start_frame +
					lurb->number_of_packets *
					lurb->interval;
1021
		}
1022 1023
		if (urb->transfer_flags & URB_ISO_ASAP)
			urb->start_frame = frame;
1024 1025
		else if (urb->start_frame != frame)
			return -EINVAL;
L
Linus Torvalds 已提交
1026 1027
	}

1028
	/* Make sure we won't have to go too far into the future */
1029
	if (uhci_frame_before_eq(uhci->last_iso_frame + UHCI_NUMFRAMES,
1030 1031 1032 1033 1034 1035 1036
			urb->start_frame + urb->number_of_packets *
				urb->interval))
		return -EFBIG;

	status = TD_CTRL_ACTIVE | TD_CTRL_IOS;
	destination = (urb->pipe & PIPE_DEVEP_MASK) | usb_packetid(urb->pipe);

1037
	for (i = 0; i < urb->number_of_packets; i++) {
1038
		td = uhci_alloc_td(uhci);
L
Linus Torvalds 已提交
1039 1040 1041
		if (!td)
			return -ENOMEM;

1042
		uhci_add_td_to_urbp(td, urbp);
1043 1044 1045 1046
		uhci_fill_td(td, status, destination |
				uhci_explen(urb->iso_frame_desc[i].length),
				urb->transfer_dma +
					urb->iso_frame_desc[i].offset);
1047
	}
L
Linus Torvalds 已提交
1048

1049 1050 1051 1052
	/* Set the interrupt-on-completion flag on the last packet. */
	td->status |= __constant_cpu_to_le32(TD_CTRL_IOC);

	qh->skel = uhci->skel_iso_qh;
1053
	qh->period = urb->interval;
1054 1055

	/* Add the TDs to the frame list */
1056 1057
	frame = urb->start_frame;
	list_for_each_entry(td, &urbp->td_list, list) {
1058
		uhci_insert_td_in_frame_list(uhci, td, frame);
1059 1060 1061 1062 1063 1064 1065
		frame += qh->period;
	}

	if (list_empty(&qh->queue)) {
		qh->iso_packet_desc = &urb->iso_frame_desc[0];
		qh->iso_frame = urb->start_frame;
		qh->iso_status = 0;
L
Linus Torvalds 已提交
1066 1067
	}

1068
	return 0;
L
Linus Torvalds 已提交
1069 1070 1071 1072
}

static int uhci_result_isochronous(struct uhci_hcd *uhci, struct urb *urb)
{
1073 1074 1075
	struct uhci_td *td, *tmp;
	struct urb_priv *urbp = urb->hcpriv;
	struct uhci_qh *qh = urbp->qh;
L
Linus Torvalds 已提交
1076

1077 1078 1079
	list_for_each_entry_safe(td, tmp, &urbp->td_list, list) {
		unsigned int ctrlstat;
		int status;
L
Linus Torvalds 已提交
1080 1081
		int actlength;

1082
		if (uhci_frame_before_eq(uhci->cur_iso_frame, qh->iso_frame))
L
Linus Torvalds 已提交
1083 1084
			return -EINPROGRESS;

1085 1086 1087 1088 1089 1090 1091 1092 1093 1094 1095 1096 1097 1098
		uhci_remove_tds_from_frame(uhci, qh->iso_frame);

		ctrlstat = td_status(td);
		if (ctrlstat & TD_CTRL_ACTIVE) {
			status = -EXDEV;	/* TD was added too late? */
		} else {
			status = uhci_map_status(uhci_status_bits(ctrlstat),
					usb_pipeout(urb->pipe));
			actlength = uhci_actual_length(ctrlstat);

			urb->actual_length += actlength;
			qh->iso_packet_desc->actual_length = actlength;
			qh->iso_packet_desc->status = status;
		}
L
Linus Torvalds 已提交
1099 1100 1101

		if (status) {
			urb->error_count++;
1102
			qh->iso_status = status;
L
Linus Torvalds 已提交
1103 1104
		}

1105 1106 1107 1108
		uhci_remove_td_from_urbp(td);
		uhci_free_td(uhci, td);
		qh->iso_frame += qh->period;
		++qh->iso_packet_desc;
L
Linus Torvalds 已提交
1109
	}
1110
	return qh->iso_status;
L
Linus Torvalds 已提交
1111 1112 1113
}

static int uhci_urb_enqueue(struct usb_hcd *hcd,
1114
		struct usb_host_endpoint *hep,
A
Al Viro 已提交
1115
		struct urb *urb, gfp_t mem_flags)
L
Linus Torvalds 已提交
1116 1117 1118 1119
{
	int ret;
	struct uhci_hcd *uhci = hcd_to_uhci(hcd);
	unsigned long flags;
1120 1121
	struct urb_priv *urbp;
	struct uhci_qh *qh;
L
Linus Torvalds 已提交
1122 1123 1124 1125 1126 1127
	int bustime;

	spin_lock_irqsave(&uhci->lock, flags);

	ret = urb->status;
	if (ret != -EINPROGRESS)		/* URB already unlinked! */
1128
		goto done;
L
Linus Torvalds 已提交
1129

1130 1131 1132 1133
	ret = -ENOMEM;
	urbp = uhci_alloc_urb_priv(uhci, urb);
	if (!urbp)
		goto done;
L
Linus Torvalds 已提交
1134

1135 1136 1137 1138 1139 1140
	if (hep->hcpriv)
		qh = (struct uhci_qh *) hep->hcpriv;
	else {
		qh = uhci_alloc_qh(uhci, urb->dev, hep);
		if (!qh)
			goto err_no_qh;
L
Linus Torvalds 已提交
1141
	}
1142
	urbp->qh = qh;
L
Linus Torvalds 已提交
1143

1144 1145
	switch (qh->type) {
	case USB_ENDPOINT_XFER_CONTROL:
1146 1147
		ret = uhci_submit_control(uhci, urb, qh);
		break;
1148
	case USB_ENDPOINT_XFER_BULK:
1149
		ret = uhci_submit_bulk(uhci, urb, qh);
L
Linus Torvalds 已提交
1150
		break;
1151
	case USB_ENDPOINT_XFER_INT:
1152
		if (list_empty(&qh->queue)) {
L
Linus Torvalds 已提交
1153 1154 1155 1156
			bustime = usb_check_bandwidth(urb->dev, urb);
			if (bustime < 0)
				ret = bustime;
			else {
1157 1158
				ret = uhci_submit_interrupt(uhci, urb, qh);
				if (ret == 0)
L
Linus Torvalds 已提交
1159 1160 1161
					usb_claim_bandwidth(urb->dev, urb, bustime, 0);
			}
		} else {	/* inherit from parent */
1162 1163 1164 1165 1166 1167
			struct urb_priv *eurbp;

			eurbp = list_entry(qh->queue.prev, struct urb_priv,
					node);
			urb->bandwidth = eurbp->urb->bandwidth;
			ret = uhci_submit_interrupt(uhci, urb, qh);
L
Linus Torvalds 已提交
1168 1169
		}
		break;
1170
	case USB_ENDPOINT_XFER_ISOC:
1171
		urb->error_count = 0;
L
Linus Torvalds 已提交
1172 1173 1174 1175 1176 1177
		bustime = usb_check_bandwidth(urb->dev, urb);
		if (bustime < 0) {
			ret = bustime;
			break;
		}

1178 1179
		ret = uhci_submit_isochronous(uhci, urb, qh);
		if (ret == 0)
L
Linus Torvalds 已提交
1180 1181 1182
			usb_claim_bandwidth(urb->dev, urb, bustime, 1);
		break;
	}
1183 1184
	if (ret != 0)
		goto err_submit_failed;
L
Linus Torvalds 已提交
1185

1186 1187 1188
	/* Add this URB to the QH */
	urbp->qh = qh;
	list_add_tail(&urbp->node, &qh->queue);
L
Linus Torvalds 已提交
1189

1190 1191
	/* If the new URB is the first and only one on this QH then either
	 * the QH is new and idle or else it's unlinked and waiting to
1192 1193
	 * become idle, so we can activate it right away.  But only if the
	 * queue isn't stopped. */
A
Alan Stern 已提交
1194
	if (qh->queue.next == &urbp->node && !qh->is_stopped) {
1195
		uhci_activate_qh(uhci, qh);
1196
		uhci_urbp_wants_fsbr(uhci, urbp);
A
Alan Stern 已提交
1197
	}
1198 1199 1200 1201 1202
	goto done;

err_submit_failed:
	if (qh->state == QH_STATE_IDLE)
		uhci_make_qh_idle(uhci, qh);	/* Reclaim unused QH */
L
Linus Torvalds 已提交
1203

1204 1205 1206 1207
err_no_qh:
	uhci_free_urb_priv(uhci, urbp);

done:
L
Linus Torvalds 已提交
1208 1209 1210 1211
	spin_unlock_irqrestore(&uhci->lock, flags);
	return ret;
}

1212 1213 1214 1215 1216
static int uhci_urb_dequeue(struct usb_hcd *hcd, struct urb *urb)
{
	struct uhci_hcd *uhci = hcd_to_uhci(hcd);
	unsigned long flags;
	struct urb_priv *urbp;
1217
	struct uhci_qh *qh;
1218 1219 1220 1221 1222

	spin_lock_irqsave(&uhci->lock, flags);
	urbp = urb->hcpriv;
	if (!urbp)			/* URB was never linked! */
		goto done;
1223
	qh = urbp->qh;
1224 1225

	/* Remove Isochronous TDs from the frame list ASAP */
1226
	if (qh->type == USB_ENDPOINT_XFER_ISOC) {
1227
		uhci_unlink_isochronous_tds(uhci, urb);
1228 1229 1230 1231 1232 1233 1234 1235 1236
		mb();

		/* If the URB has already started, update the QH unlink time */
		uhci_get_current_frame_number(uhci);
		if (uhci_frame_before_eq(urb->start_frame, uhci->frame_number))
			qh->unlink_frame = uhci->frame_number;
	}

	uhci_unlink_qh(uhci, qh);
1237 1238 1239 1240 1241 1242

done:
	spin_unlock_irqrestore(&uhci->lock, flags);
	return 0;
}

L
Linus Torvalds 已提交
1243
/*
1244
 * Finish unlinking an URB and give it back
L
Linus Torvalds 已提交
1245
 */
1246 1247 1248 1249
static void uhci_giveback_urb(struct uhci_hcd *uhci, struct uhci_qh *qh,
		struct urb *urb, struct pt_regs *regs)
__releases(uhci->lock)
__acquires(uhci->lock)
L
Linus Torvalds 已提交
1250
{
1251
	struct urb_priv *urbp = (struct urb_priv *) urb->hcpriv;
L
Linus Torvalds 已提交
1252

1253 1254 1255 1256 1257 1258 1259 1260 1261 1262 1263 1264
	/* When giving back the first URB in an Isochronous queue,
	 * reinitialize the QH's iso-related members for the next URB. */
	if (qh->type == USB_ENDPOINT_XFER_ISOC &&
			urbp->node.prev == &qh->queue &&
			urbp->node.next != &qh->queue) {
		struct urb *nurb = list_entry(urbp->node.next,
				struct urb_priv, node)->urb;

		qh->iso_packet_desc = &nurb->iso_frame_desc[0];
		qh->iso_frame = nurb->start_frame;
		qh->iso_status = 0;
	}
L
Linus Torvalds 已提交
1265

1266 1267 1268 1269 1270 1271 1272 1273 1274 1275
	/* Take the URB off the QH's queue.  If the queue is now empty,
	 * this is a perfect time for a toggle fixup. */
	list_del_init(&urbp->node);
	if (list_empty(&qh->queue) && qh->needs_fixup) {
		usb_settoggle(urb->dev, usb_pipeendpoint(urb->pipe),
				usb_pipeout(urb->pipe), qh->initial_toggle);
		qh->needs_fixup = 0;
	}

	uhci_free_urb_priv(uhci, urbp);
L
Linus Torvalds 已提交
1276

1277 1278
	switch (qh->type) {
	case USB_ENDPOINT_XFER_ISOC:
L
Linus Torvalds 已提交
1279 1280 1281 1282
		/* Release bandwidth for Interrupt or Isoc. transfers */
		if (urb->bandwidth)
			usb_release_bandwidth(urb->dev, urb, 1);
		break;
1283
	case USB_ENDPOINT_XFER_INT:
L
Linus Torvalds 已提交
1284 1285
		/* Release bandwidth for Interrupt or Isoc. transfers */
		/* Make sure we don't release if we have a queued URB */
1286
		if (list_empty(&qh->queue) && urb->bandwidth)
L
Linus Torvalds 已提交
1287 1288 1289 1290 1291 1292 1293 1294
			usb_release_bandwidth(urb->dev, urb, 0);
		else
			/* bandwidth was passed on to queued URB, */
			/* so don't let usb_unlink_urb() release it */
			urb->bandwidth = 0;
		break;
	}

1295 1296 1297
	spin_unlock(&uhci->lock);
	usb_hcd_giveback_urb(uhci_to_hcd(uhci), urb, regs);
	spin_lock(&uhci->lock);
L
Linus Torvalds 已提交
1298

1299 1300 1301 1302
	/* If the queue is now empty, we can unlink the QH and give up its
	 * reserved bandwidth. */
	if (list_empty(&qh->queue)) {
		uhci_unlink_qh(uhci, qh);
L
Linus Torvalds 已提交
1303

1304
		/* Bandwidth stuff not yet implemented */
1305
		qh->period = 0;
1306
	}
1307
}
L
Linus Torvalds 已提交
1308

1309
/*
1310
 * Scan the URBs in a QH's queue
1311
 */
1312 1313 1314
#define QH_FINISHED_UNLINKING(qh)			\
		(qh->state == QH_STATE_UNLINKING &&	\
		uhci->frame_number + uhci->is_stopped != qh->unlink_frame)
L
Linus Torvalds 已提交
1315

1316 1317
static void uhci_scan_qh(struct uhci_hcd *uhci, struct uhci_qh *qh,
		struct pt_regs *regs)
L
Linus Torvalds 已提交
1318 1319
{
	struct urb_priv *urbp;
1320 1321
	struct urb *urb;
	int status;
L
Linus Torvalds 已提交
1322

1323 1324 1325
	while (!list_empty(&qh->queue)) {
		urbp = list_entry(qh->queue.next, struct urb_priv, node);
		urb = urbp->urb;
L
Linus Torvalds 已提交
1326

1327
		if (qh->type == USB_ENDPOINT_XFER_ISOC)
1328
			status = uhci_result_isochronous(uhci, urb);
1329
		else
1330 1331 1332
			status = uhci_result_common(uhci, urb);
		if (status == -EINPROGRESS)
			break;
L
Linus Torvalds 已提交
1333

1334 1335 1336 1337
		spin_lock(&urb->lock);
		if (urb->status == -EINPROGRESS)	/* Not dequeued */
			urb->status = status;
		else
1338
			status = ECONNRESET;		/* Not -ECONNRESET */
1339
		spin_unlock(&urb->lock);
L
Linus Torvalds 已提交
1340

1341 1342
		/* Dequeued but completed URBs can't be given back unless
		 * the QH is stopped or has finished unlinking. */
1343 1344 1345 1346 1347 1348
		if (status == ECONNRESET) {
			if (QH_FINISHED_UNLINKING(qh))
				qh->is_stopped = 1;
			else if (!qh->is_stopped)
				return;
		}
L
Linus Torvalds 已提交
1349

1350
		uhci_giveback_urb(uhci, qh, urb, regs);
A
Alan Stern 已提交
1351
		if (status < 0 && qh->type != USB_ENDPOINT_XFER_ISOC)
1352 1353
			break;
	}
L
Linus Torvalds 已提交
1354

1355 1356
	/* If the QH is neither stopped nor finished unlinking (normal case),
	 * our work here is done. */
1357 1358 1359
	if (QH_FINISHED_UNLINKING(qh))
		qh->is_stopped = 1;
	else if (!qh->is_stopped)
1360
		return;
L
Linus Torvalds 已提交
1361

1362
	/* Otherwise give back each of the dequeued URBs */
1363
restart:
1364 1365 1366
	list_for_each_entry(urbp, &qh->queue, node) {
		urb = urbp->urb;
		if (urb->status != -EINPROGRESS) {
1367 1368 1369 1370 1371 1372 1373 1374

			/* Fix up the TD links and save the toggles for
			 * non-Isochronous queues.  For Isochronous queues,
			 * test for too-recent dequeues. */
			if (!uhci_cleanup_queue(uhci, qh, urb)) {
				qh->is_stopped = 0;
				return;
			}
1375 1376 1377 1378 1379
			uhci_giveback_urb(uhci, qh, urb, regs);
			goto restart;
		}
	}
	qh->is_stopped = 0;
L
Linus Torvalds 已提交
1380

1381 1382 1383 1384 1385
	/* There are no more dequeued URBs.  If there are still URBs on the
	 * queue, the QH can now be re-activated. */
	if (!list_empty(&qh->queue)) {
		if (qh->needs_fixup)
			uhci_fixup_toggles(qh, 0);
A
Alan Stern 已提交
1386 1387 1388 1389 1390 1391 1392 1393 1394 1395 1396 1397

		/* If the first URB on the queue wants FSBR but its time
		 * limit has expired, set the next TD to interrupt on
		 * completion before reactivating the QH. */
		urbp = list_entry(qh->queue.next, struct urb_priv, node);
		if (urbp->fsbr && qh->wait_expired) {
			struct uhci_td *td = list_entry(urbp->td_list.next,
					struct uhci_td, list);

			td->status |= __cpu_to_le32(TD_CTRL_IOC);
		}

1398
		uhci_activate_qh(uhci, qh);
L
Linus Torvalds 已提交
1399 1400
	}

1401 1402 1403 1404
	/* The queue is empty.  The QH can become idle if it is fully
	 * unlinked. */
	else if (QH_FINISHED_UNLINKING(qh))
		uhci_make_qh_idle(uhci, qh);
L
Linus Torvalds 已提交
1405 1406
}

A
Alan Stern 已提交
1407 1408 1409 1410
/*
 * Check for queues that have made some forward progress.
 * Returns 0 if the queue is not Isochronous, is ACTIVE, and
 * has not advanced since last examined; 1 otherwise.
1411 1412 1413 1414 1415
 *
 * Early Intel controllers have a bug which causes qh->element sometimes
 * not to advance when a TD completes successfully.  The queue remains
 * stuck on the inactive completed TD.  We detect such cases and advance
 * the element pointer by hand.
A
Alan Stern 已提交
1416 1417 1418 1419 1420 1421 1422 1423 1424
 */
static int uhci_advance_check(struct uhci_hcd *uhci, struct uhci_qh *qh)
{
	struct urb_priv *urbp = NULL;
	struct uhci_td *td;
	int ret = 1;
	unsigned status;

	if (qh->type == USB_ENDPOINT_XFER_ISOC)
1425
		goto done;
A
Alan Stern 已提交
1426 1427 1428 1429 1430 1431 1432 1433 1434 1435 1436 1437 1438 1439 1440 1441 1442 1443 1444 1445 1446 1447

	/* Treat an UNLINKING queue as though it hasn't advanced.
	 * This is okay because reactivation will treat it as though
	 * it has advanced, and if it is going to become IDLE then
	 * this doesn't matter anyway.  Furthermore it's possible
	 * for an UNLINKING queue not to have any URBs at all, or
	 * for its first URB not to have any TDs (if it was dequeued
	 * just as it completed).  So it's not easy in any case to
	 * test whether such queues have advanced. */
	if (qh->state != QH_STATE_ACTIVE) {
		urbp = NULL;
		status = 0;

	} else {
		urbp = list_entry(qh->queue.next, struct urb_priv, node);
		td = list_entry(urbp->td_list.next, struct uhci_td, list);
		status = td_status(td);
		if (!(status & TD_CTRL_ACTIVE)) {

			/* We're okay, the queue has advanced */
			qh->wait_expired = 0;
			qh->advance_jiffies = jiffies;
1448
			goto done;
A
Alan Stern 已提交
1449 1450 1451 1452 1453
		}
		ret = 0;
	}

	/* The queue hasn't advanced; check for timeout */
1454 1455 1456 1457
	if (qh->wait_expired)
		goto done;

	if (time_after(jiffies, qh->advance_jiffies + QH_WAIT_TIMEOUT)) {
1458 1459 1460 1461 1462 1463

		/* Detect the Intel bug and work around it */
		if (qh->post_td && qh_element(qh) ==
				cpu_to_le32(qh->post_td->dma_handle)) {
			qh->element = qh->post_td->link;
			qh->advance_jiffies = jiffies;
1464 1465
			ret = 1;
			goto done;
1466 1467
		}

A
Alan Stern 已提交
1468 1469 1470 1471 1472 1473 1474 1475
		qh->wait_expired = 1;

		/* If the current URB wants FSBR, unlink it temporarily
		 * so that we can safely set the next TD to interrupt on
		 * completion.  That way we'll know as soon as the queue
		 * starts moving again. */
		if (urbp && urbp->fsbr && !(status & TD_CTRL_IOC))
			uhci_unlink_qh(uhci, qh);
1476 1477 1478 1479 1480

	} else {
		/* Unmoving but not-yet-expired queues keep FSBR alive */
		if (urbp)
			uhci_urbp_wants_fsbr(uhci, urbp);
A
Alan Stern 已提交
1481
	}
1482 1483

done:
A
Alan Stern 已提交
1484 1485 1486
	return ret;
}

1487 1488 1489
/*
 * Process events in the schedule, but only in one thread at a time
 */
L
Linus Torvalds 已提交
1490 1491
static void uhci_scan_schedule(struct uhci_hcd *uhci, struct pt_regs *regs)
{
1492 1493
	int i;
	struct uhci_qh *qh;
L
Linus Torvalds 已提交
1494 1495 1496 1497 1498 1499 1500

	/* Don't allow re-entrant calls */
	if (uhci->scan_in_progress) {
		uhci->need_rescan = 1;
		return;
	}
	uhci->scan_in_progress = 1;
A
Alan Stern 已提交
1501
rescan:
L
Linus Torvalds 已提交
1502
	uhci->need_rescan = 0;
1503
	uhci->fsbr_is_wanted = 0;
L
Linus Torvalds 已提交
1504

1505
	uhci_clear_next_interrupt(uhci);
L
Linus Torvalds 已提交
1506
	uhci_get_current_frame_number(uhci);
1507
	uhci->cur_iso_frame = uhci->frame_number;
L
Linus Torvalds 已提交
1508

1509 1510 1511 1512 1513 1514 1515
	/* Go through all the QH queues and process the URBs in each one */
	for (i = 0; i < UHCI_NUM_SKELQH - 1; ++i) {
		uhci->next_qh = list_entry(uhci->skelqh[i]->node.next,
				struct uhci_qh, node);
		while ((qh = uhci->next_qh) != uhci->skelqh[i]) {
			uhci->next_qh = list_entry(qh->node.next,
					struct uhci_qh, node);
A
Alan Stern 已提交
1516 1517 1518

			if (uhci_advance_check(uhci, qh)) {
				uhci_scan_qh(uhci, qh, regs);
1519 1520 1521 1522
				if (qh->state == QH_STATE_ACTIVE) {
					uhci_urbp_wants_fsbr(uhci,
	list_entry(qh->queue.next, struct urb_priv, node));
				}
A
Alan Stern 已提交
1523
			}
1524
		}
L
Linus Torvalds 已提交
1525 1526
	}

1527
	uhci->last_iso_frame = uhci->cur_iso_frame;
L
Linus Torvalds 已提交
1528 1529 1530 1531
	if (uhci->need_rescan)
		goto rescan;
	uhci->scan_in_progress = 0;

1532 1533 1534 1535 1536
	if (uhci->fsbr_is_on && !uhci->fsbr_is_wanted &&
			!uhci->fsbr_expiring) {
		uhci->fsbr_expiring = 1;
		mod_timer(&uhci->fsbr_timer, jiffies + FSBR_OFF_DELAY);
	}
A
Alan Stern 已提交
1537

1538
	if (list_empty(&uhci->skel_unlink_qh->node))
L
Linus Torvalds 已提交
1539 1540 1541 1542
		uhci_clear_next_interrupt(uhci);
	else
		uhci_set_next_interrupt(uhci);
}