uhci-q.c 39.2 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 67 68 69 70 71 72 73 74 75 76 77 78 79

/*
 * 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;
}

static void uhci_qh_wants_fsbr(struct uhci_hcd *uhci, struct uhci_qh *qh)
{
	struct urb_priv *urbp =
			list_entry(qh->queue.next, struct urb_priv, node);

	if (urbp->fsbr) {
		uhci->fsbr_jiffies = jiffies;
		if (!uhci->fsbr_is_on)
			uhci_fsbr_on(uhci);
	}
}


80
static struct uhci_td *uhci_alloc_td(struct uhci_hcd *uhci)
L
Linus Torvalds 已提交
81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97
{
	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;
}

98 99 100 101 102 103 104 105 106 107
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 已提交
108 109 110 111 112 113 114 115
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);
}

116 117 118 119 120 121 122 123 124 125
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 已提交
126
/*
127
 * We insert Isochronous URBs directly into the frame list at the beginning
L
Linus Torvalds 已提交
128
 */
129 130
static inline void uhci_insert_td_in_frame_list(struct uhci_hcd *uhci,
		struct uhci_td *td, unsigned framenum)
L
Linus Torvalds 已提交
131 132 133 134 135 136
{
	framenum &= (UHCI_NUMFRAMES - 1);

	td->frame = framenum;

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

140
		ftd = uhci->frame_cpu[framenum];
L
Linus Torvalds 已提交
141 142 143 144 145 146 147 148
		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 {
149
		td->link = uhci->frame[framenum];
L
Linus Torvalds 已提交
150
		wmb();
151 152
		uhci->frame[framenum] = cpu_to_le32(td->dma_handle);
		uhci->frame_cpu[framenum] = td;
L
Linus Torvalds 已提交
153 154 155
	}
}

156
static inline void uhci_remove_td_from_frame_list(struct uhci_hcd *uhci,
157
		struct uhci_td *td)
L
Linus Torvalds 已提交
158 159
{
	/* If it's not inserted, don't remove it */
160 161
	if (td->frame == -1) {
		WARN_ON(!list_empty(&td->fl_list));
L
Linus Torvalds 已提交
162
		return;
163
	}
L
Linus Torvalds 已提交
164

165
	if (uhci->frame_cpu[td->frame] == td) {
L
Linus Torvalds 已提交
166
		if (list_empty(&td->fl_list)) {
167 168
			uhci->frame[td->frame] = td->link;
			uhci->frame_cpu[td->frame] = NULL;
L
Linus Torvalds 已提交
169 170 171 172
		} else {
			struct uhci_td *ntd;

			ntd = list_entry(td->fl_list.next, struct uhci_td, fl_list);
173 174
			uhci->frame[td->frame] = cpu_to_le32(ntd->dma_handle);
			uhci->frame_cpu[td->frame] = ntd;
L
Linus Torvalds 已提交
175 176 177 178 179 180 181 182 183 184 185 186
		}
	} 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;
}

187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204
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);
	}
}

205 206 207 208
/*
 * 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)
209 210 211 212 213
{
	struct urb_priv *urbp = (struct urb_priv *) urb->hcpriv;
	struct uhci_td *td;

	list_for_each_entry(td, &urbp->td_list, list)
214
		uhci_remove_td_from_frame_list(uhci, td);
215 216
}

217 218
static struct uhci_qh *uhci_alloc_qh(struct uhci_hcd *uhci,
		struct usb_device *udev, struct usb_host_endpoint *hep)
L
Linus Torvalds 已提交
219 220 221 222 223 224 225 226
{
	dma_addr_t dma_handle;
	struct uhci_qh *qh;

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

227
	memset(qh, 0, sizeof(*qh));
L
Linus Torvalds 已提交
228 229 230 231 232
	qh->dma_handle = dma_handle;

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

233 234
	INIT_LIST_HEAD(&qh->queue);
	INIT_LIST_HEAD(&qh->node);
L
Linus Torvalds 已提交
235

236
	if (udev) {		/* Normal QH */
A
Alan Stern 已提交
237 238 239 240 241
		qh->dummy_td = uhci_alloc_td(uhci);
		if (!qh->dummy_td) {
			dma_pool_free(uhci->qh_pool, qh, dma_handle);
			return NULL;
		}
242 243 244 245
		qh->state = QH_STATE_IDLE;
		qh->hep = hep;
		qh->udev = udev;
		hep->hcpriv = qh;
246
		qh->type = hep->desc.bmAttributes & USB_ENDPOINT_XFERTYPE_MASK;
L
Linus Torvalds 已提交
247

248 249
	} else {		/* Skeleton QH */
		qh->state = QH_STATE_ACTIVE;
250
		qh->type = -1;
251
	}
L
Linus Torvalds 已提交
252 253 254 255 256
	return qh;
}

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

261 262 263
	list_del(&qh->node);
	if (qh->udev) {
		qh->hep->hcpriv = NULL;
A
Alan Stern 已提交
264
		uhci_free_td(uhci, qh->dummy_td);
265
	}
L
Linus Torvalds 已提交
266 267 268
	dma_pool_free(uhci->qh_pool, qh, qh->dma_handle);
}

269
/*
270 271 272
 * 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).
273 274
 *
 * Returns 0 if the URB should not yet be given back, 1 otherwise.
275
 */
276
static int uhci_cleanup_queue(struct uhci_hcd *uhci, struct uhci_qh *qh,
277
		struct urb *urb)
278
{
279
	struct urb_priv *urbp = urb->hcpriv;
280
	struct uhci_td *td;
281
	int ret = 1;
282

283
	/* Isochronous pipes don't use toggles and their TD link pointers
284 285 286 287 288 289 290 291
	 * 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);
		return ret;
	}
292 293 294 295 296 297 298 299 300 301 302 303 304 305 306

	/* 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;
307
		return ret;
308 309
	}

310 311
	/* If the QH element pointer is UHCI_PTR_TERM then then currently
	 * executing URB has already been unlinked, so this one isn't it. */
312
	if (qh_element(qh) == UHCI_PTR_TERM)
313
		return ret;
314 315
	qh->element = UHCI_PTR_TERM;

316 317
	/* Control pipes have to worry about toggles */
	if (qh->type == USB_ENDPOINT_XFER_CONTROL)
318
		return ret;
319

320
	/* Save the next toggle value */
321 322 323 324
	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));
325
	return ret;
326 327 328 329 330 331 332 333 334 335 336 337 338 339 340 341 342 343 344 345 346 347 348 349 350 351
}

/*
 * 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. */
352
	urbp = list_prepare_entry(urbp, &qh->queue, node);
353 354 355 356 357 358 359 360 361 362 363 364 365 366 367 368 369 370 371 372 373 374 375 376 377 378 379
	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 已提交
380
/*
381
 * Put a QH on the schedule in both hardware and software
L
Linus Torvalds 已提交
382
 */
383
static void uhci_activate_qh(struct uhci_hcd *uhci, struct uhci_qh *qh)
L
Linus Torvalds 已提交
384
{
385
	struct uhci_qh *pqh;
L
Linus Torvalds 已提交
386

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

389 390 391 392 393 394 395
	/* 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 已提交
396

397
		qh->element = cpu_to_le32(td->dma_handle);
L
Linus Torvalds 已提交
398 399
	}

A
Alan Stern 已提交
400 401 402 403
	/* Treat the queue as if it has just advanced */
	qh->wait_expired = 0;
	qh->advance_jiffies = jiffies;

404 405 406 407 408 409
	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 */
410 411 412
	if (qh == uhci->next_qh)
		uhci->next_qh = list_entry(qh->node.next, struct uhci_qh,
				node);
413 414 415 416 417 418 419
	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 已提交
420 421 422
}

/*
423
 * Take a QH off the hardware schedule
L
Linus Torvalds 已提交
424
 */
425
static void uhci_unlink_qh(struct uhci_hcd *uhci, struct uhci_qh *qh)
L
Linus Torvalds 已提交
426 427 428
{
	struct uhci_qh *pqh;

429
	if (qh->state == QH_STATE_UNLINKING)
L
Linus Torvalds 已提交
430
		return;
431 432
	WARN_ON(qh->state != QH_STATE_ACTIVE || !qh->udev);
	qh->state = QH_STATE_UNLINKING;
L
Linus Torvalds 已提交
433

434 435 436 437
	/* 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 已提交
438 439

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

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

446
	/* Move the QH from its old list to the end of the unlinking list */
447 448 449
	if (qh == uhci->next_qh)
		uhci->next_qh = list_entry(qh->node.next, struct uhci_qh,
				node);
450
	list_move_tail(&qh->node, &uhci->skel_unlink_qh->node);
L
Linus Torvalds 已提交
451 452
}

453 454 455 456 457 458 459
/*
 * 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 已提交
460
{
461
	WARN_ON(qh->state == QH_STATE_ACTIVE);
L
Linus Torvalds 已提交
462

463 464 465
	if (qh == uhci->next_qh)
		uhci->next_qh = list_entry(qh->node.next, struct uhci_qh,
				node);
466 467
	list_move(&qh->node, &uhci->idle_qh_list);
	qh->state = QH_STATE_IDLE;
L
Linus Torvalds 已提交
468

469 470 471 472 473 474
	/* 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;
	}

475 476 477
	/* 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 已提交
478 479
}

480 481
static inline struct urb_priv *uhci_alloc_urb_priv(struct uhci_hcd *uhci,
		struct urb *urb)
L
Linus Torvalds 已提交
482 483 484 485 486 487 488 489 490 491
{
	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;
492
	urb->hcpriv = urbp;
L
Linus Torvalds 已提交
493
	
494
	INIT_LIST_HEAD(&urbp->node);
L
Linus Torvalds 已提交
495 496 497 498 499
	INIT_LIST_HEAD(&urbp->td_list);

	return urbp;
}

500 501
static void uhci_free_urb_priv(struct uhci_hcd *uhci,
		struct urb_priv *urbp)
L
Linus Torvalds 已提交
502 503 504
{
	struct uhci_td *td, *tmp;

505 506 507
	if (!list_empty(&urbp->node))
		dev_warn(uhci_dev(uhci), "urb %p still on QH's list!\n",
				urbp->urb);
L
Linus Torvalds 已提交
508 509

	list_for_each_entry_safe(td, tmp, &urbp->td_list, list) {
510 511
		uhci_remove_td_from_urbp(td);
		uhci_free_td(uhci, td);
L
Linus Torvalds 已提交
512 513
	}

514
	urbp->urb->hcpriv = NULL;
L
Linus Torvalds 已提交
515 516 517 518 519 520 521 522 523 524 525 526 527 528 529 530 531 532 533 534 535 536 537 538 539 540 541 542 543 544 545 546 547 548 549
	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
 */
550 551
static int uhci_submit_control(struct uhci_hcd *uhci, struct urb *urb,
		struct uhci_qh *qh)
L
Linus Torvalds 已提交
552 553 554
{
	struct uhci_td *td;
	unsigned long destination, status;
555
	int maxsze = le16_to_cpu(qh->hep->desc.wMaxPacketSize);
L
Linus Torvalds 已提交
556 557
	int len = urb->transfer_buffer_length;
	dma_addr_t data = urb->transfer_dma;
558
	__le32 *plink;
559
	struct urb_priv *urbp = urb->hcpriv;
L
Linus Torvalds 已提交
560 561 562 563

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

A
Alan Stern 已提交
564 565
	/* 3 errors, dummy TD remains inactive */
	status = uhci_maxerr(3);
L
Linus Torvalds 已提交
566 567 568 569 570 571
	if (urb->dev->speed == USB_SPEED_LOW)
		status |= TD_CTRL_LS;

	/*
	 * Build the TD for the control request setup packet
	 */
A
Alan Stern 已提交
572
	td = qh->dummy_td;
573
	uhci_add_td_to_urbp(td, urbp);
574
	uhci_fill_td(td, status, destination | uhci_explen(8),
575 576
			urb->setup_dma);
	plink = &td->link;
A
Alan Stern 已提交
577
	status |= TD_CTRL_ACTIVE;
L
Linus Torvalds 已提交
578 579 580 581 582 583 584 585 586 587 588 589 590 591

	/*
	 * 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;
	}

	/*
592
	 * Build the DATA TDs
L
Linus Torvalds 已提交
593 594
	 */
	while (len > 0) {
595
		int pktsze = min(len, maxsze);
L
Linus Torvalds 已提交
596

597
		td = uhci_alloc_td(uhci);
L
Linus Torvalds 已提交
598
		if (!td)
A
Alan Stern 已提交
599
			goto nomem;
600
		*plink = cpu_to_le32(td->dma_handle);
L
Linus Torvalds 已提交
601 602 603 604

		/* Alternate Data0/1 (start with Data1) */
		destination ^= TD_TOKEN_TOGGLE;
	
605
		uhci_add_td_to_urbp(td, urbp);
606
		uhci_fill_td(td, status, destination | uhci_explen(pktsze),
607 608
				data);
		plink = &td->link;
L
Linus Torvalds 已提交
609 610 611 612 613 614 615 616

		data += pktsze;
		len -= pktsze;
	}

	/*
	 * Build the final TD for control status 
	 */
617
	td = uhci_alloc_td(uhci);
L
Linus Torvalds 已提交
618
	if (!td)
A
Alan Stern 已提交
619
		goto nomem;
620
	*plink = cpu_to_le32(td->dma_handle);
L
Linus Torvalds 已提交
621 622 623 624 625 626 627 628 629 630 631 632 633 634 635

	/*
	 * 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;

636
	uhci_add_td_to_urbp(td, urbp);
L
Linus Torvalds 已提交
637
	uhci_fill_td(td, status | TD_CTRL_IOC,
638
			destination | uhci_explen(0), 0);
A
Alan Stern 已提交
639 640 641 642 643 644 645 646 647 648 649 650 651 652
	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 已提交
653 654 655 656

	/* 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
657
	 * isn't in the CONFIGURED state. */
L
Linus Torvalds 已提交
658
	if (urb->dev->speed == USB_SPEED_LOW ||
659
			urb->dev->state != USB_STATE_CONFIGURED)
660
		qh->skel = uhci->skel_ls_control_qh;
L
Linus Torvalds 已提交
661
	else {
662
		qh->skel = uhci->skel_fs_control_qh;
A
Alan Stern 已提交
663
		uhci_add_fsbr(uhci, urb);
L
Linus Torvalds 已提交
664
	}
665 666

	urb->actual_length = -8;	/* Account for the SETUP packet */
667
	return 0;
A
Alan Stern 已提交
668 669 670

nomem:
	/* Remove the dummy TD from the td_list so it doesn't get freed */
671
	uhci_remove_td_from_urbp(qh->dummy_td);
A
Alan Stern 已提交
672
	return -ENOMEM;
L
Linus Torvalds 已提交
673 674 675 676 677
}

/*
 * Common submit for bulk and interrupt
 */
678 679
static int uhci_submit_common(struct uhci_hcd *uhci, struct urb *urb,
		struct uhci_qh *qh)
L
Linus Torvalds 已提交
680 681 682
{
	struct uhci_td *td;
	unsigned long destination, status;
683
	int maxsze = le16_to_cpu(qh->hep->desc.wMaxPacketSize);
L
Linus Torvalds 已提交
684 685
	int len = urb->transfer_buffer_length;
	dma_addr_t data = urb->transfer_dma;
A
Alan Stern 已提交
686
	__le32 *plink;
687
	struct urb_priv *urbp = urb->hcpriv;
A
Alan Stern 已提交
688
	unsigned int toggle;
L
Linus Torvalds 已提交
689 690 691 692 693 694

	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 已提交
695 696
	toggle = usb_gettoggle(urb->dev, usb_pipeendpoint(urb->pipe),
			 usb_pipeout(urb->pipe));
L
Linus Torvalds 已提交
697

A
Alan Stern 已提交
698 699
	/* 3 errors, dummy TD remains inactive */
	status = uhci_maxerr(3);
L
Linus Torvalds 已提交
700 701 702 703 704 705
	if (urb->dev->speed == USB_SPEED_LOW)
		status |= TD_CTRL_LS;
	if (usb_pipein(urb->pipe))
		status |= TD_CTRL_SPD;

	/*
706
	 * Build the DATA TDs
L
Linus Torvalds 已提交
707
	 */
A
Alan Stern 已提交
708 709
	plink = NULL;
	td = qh->dummy_td;
L
Linus Torvalds 已提交
710 711 712
	do {	/* Allow zero length packets */
		int pktsze = maxsze;

713
		if (len <= pktsze) {		/* The last packet */
L
Linus Torvalds 已提交
714 715 716 717 718
			pktsze = len;
			if (!(urb->transfer_flags & URB_SHORT_NOT_OK))
				status &= ~TD_CTRL_SPD;
		}

A
Alan Stern 已提交
719 720 721 722 723 724
		if (plink) {
			td = uhci_alloc_td(uhci);
			if (!td)
				goto nomem;
			*plink = cpu_to_le32(td->dma_handle);
		}
725
		uhci_add_td_to_urbp(td, urbp);
726
		uhci_fill_td(td, status,
A
Alan Stern 已提交
727 728 729
				destination | uhci_explen(pktsze) |
					(toggle << TD_TOKEN_TOGGLE_SHIFT),
				data);
730
		plink = &td->link;
A
Alan Stern 已提交
731
		status |= TD_CTRL_ACTIVE;
L
Linus Torvalds 已提交
732 733 734

		data += pktsze;
		len -= maxsze;
A
Alan Stern 已提交
735
		toggle ^= 1;
L
Linus Torvalds 已提交
736 737 738 739 740 741 742 743 744
	} 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.
	 */
745 746 747
	if ((urb->transfer_flags & URB_ZERO_PACKET) &&
			usb_pipeout(urb->pipe) && len == 0 &&
			urb->transfer_buffer_length > 0) {
748
		td = uhci_alloc_td(uhci);
L
Linus Torvalds 已提交
749
		if (!td)
A
Alan Stern 已提交
750
			goto nomem;
751
		*plink = cpu_to_le32(td->dma_handle);
L
Linus Torvalds 已提交
752

753
		uhci_add_td_to_urbp(td, urbp);
A
Alan Stern 已提交
754 755 756 757 758
		uhci_fill_td(td, status,
				destination | uhci_explen(0) |
					(toggle << TD_TOKEN_TOGGLE_SHIFT),
				data);
		plink = &td->link;
L
Linus Torvalds 已提交
759

A
Alan Stern 已提交
760
		toggle ^= 1;
L
Linus Torvalds 已提交
761 762 763 764 765 766 767 768
	}

	/* 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. */
769
	td->status |= __constant_cpu_to_le32(TD_CTRL_IOC);
L
Linus Torvalds 已提交
770

A
Alan Stern 已提交
771 772 773 774 775 776 777 778 779 780 781 782
	/*
	 * 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;
783
	qh->period = urb->interval;
A
Alan Stern 已提交
784 785 786

	usb_settoggle(urb->dev, usb_pipeendpoint(urb->pipe),
			usb_pipeout(urb->pipe), toggle);
787
	return 0;
A
Alan Stern 已提交
788 789 790

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

795 796
static inline int uhci_submit_bulk(struct uhci_hcd *uhci, struct urb *urb,
		struct uhci_qh *qh)
L
Linus Torvalds 已提交
797 798 799 800 801 802 803
{
	int ret;

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

804 805 806
	qh->skel = uhci->skel_bulk_qh;
	ret = uhci_submit_common(uhci, urb, qh);
	if (ret == 0)
A
Alan Stern 已提交
807
		uhci_add_fsbr(uhci, urb);
L
Linus Torvalds 已提交
808 809 810
	return ret;
}

811
static int uhci_submit_interrupt(struct uhci_hcd *uhci, struct urb *urb,
812
		struct uhci_qh *qh)
L
Linus Torvalds 已提交
813
{
814 815
	int exponent;

816 817 818
	/* 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 已提交
819
	 */
820 821 822 823 824 825 826 827 828 829 830 831 832 833 834

	/* 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 */

835
	return uhci_submit_common(uhci, urb, qh);
L
Linus Torvalds 已提交
836 837
}

838 839 840 841
/*
 * Fix up the data structures following a short transfer
 */
static int uhci_fixup_short_transfer(struct uhci_hcd *uhci,
842
		struct uhci_qh *qh, struct urb_priv *urbp)
843 844
{
	struct uhci_td *td;
845 846
	struct list_head *tmp;
	int ret;
847 848 849 850 851 852 853

	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. */
854
		WARN_ON(list_empty(&urbp->td_list));
855
		qh->element = cpu_to_le32(td->dma_handle);
856
		tmp = td->list.prev;
857 858
		ret = -EINPROGRESS;

859
	} else {
860 861 862 863

		/* 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. */
864
		qh->initial_toggle = uhci_toggle(td_token(qh->post_td)) ^ 1;
865 866
		uhci_fixup_toggles(qh, 1);

867 868
		if (list_empty(&urbp->td_list))
			td = qh->post_td;
869
		qh->element = td->link;
870 871
		tmp = urbp->td_list.prev;
		ret = 0;
872 873
	}

874 875 876 877 878
	/* 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;

879 880
		uhci_remove_td_from_urbp(td);
		uhci_free_td(uhci, td);
881
	}
882 883 884 885 886 887 888 889 890 891
	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;
892
	struct uhci_td *td, *tmp;
893 894 895
	unsigned status;
	int ret = 0;

896
	list_for_each_entry_safe(td, tmp, &urbp->td_list, list) {
897 898 899 900 901 902 903 904 905 906 907 908 909 910 911 912 913 914 915 916 917 918 919 920 921 922 923 924 925 926 927 928 929 930 931 932 933
		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 */
				dev_dbg(uhci_dev(uhci),
						"%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;
			else if (ctrlstat & TD_CTRL_SPD)
				ret = 1;
		}

934
		uhci_remove_td_from_urbp(td);
935
		if (qh->post_td)
936
			uhci_free_td(uhci, qh->post_td);
937 938
		qh->post_td = td;

939 940 941 942 943 944 945 946 947 948 949 950 951 952 953 954 955 956 957 958
		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 */
959
		ret = uhci_fixup_short_transfer(uhci, qh, urbp);
960 961 962
	return ret;
}

L
Linus Torvalds 已提交
963 964 965
/*
 * Isochronous transfers
 */
966 967
static int uhci_submit_isochronous(struct uhci_hcd *uhci, struct urb *urb,
		struct uhci_qh *qh)
L
Linus Torvalds 已提交
968
{
969 970 971 972
	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 已提交
973

974 975 976
	/* Values must not be too big (could overflow below) */
	if (urb->interval >= UHCI_NUMFRAMES ||
			urb->number_of_packets >= UHCI_NUMFRAMES)
L
Linus Torvalds 已提交
977 978
		return -EFBIG;

979 980 981
	/* Check the period and figure out the starting frame number */
	if (qh->period == 0) {
		if (urb->transfer_flags & URB_ISO_ASAP) {
982
			uhci_get_current_frame_number(uhci);
983 984
			urb->start_frame = uhci->frame_number + 10;
		} else {
985
			i = urb->start_frame - uhci->last_iso_frame;
986 987 988 989 990
			if (i <= 0 || i >= UHCI_NUMFRAMES)
				return -EINVAL;
		}
	} else if (qh->period != urb->interval) {
		return -EINVAL;		/* Can't change the period */
L
Linus Torvalds 已提交
991

992
	} else {	/* Pick up where the last URB leaves off */
993
		if (list_empty(&qh->queue)) {
994
			frame = qh->iso_frame;
995 996
		} else {
			struct urb *lurb;
997

998
			lurb = list_entry(qh->queue.prev,
999
					struct urb_priv, node)->urb;
1000 1001 1002
			frame = lurb->start_frame +
					lurb->number_of_packets *
					lurb->interval;
1003
		}
1004 1005
		if (urb->transfer_flags & URB_ISO_ASAP)
			urb->start_frame = frame;
1006 1007
		else if (urb->start_frame != frame)
			return -EINVAL;
L
Linus Torvalds 已提交
1008 1009
	}

1010
	/* Make sure we won't have to go too far into the future */
1011
	if (uhci_frame_before_eq(uhci->last_iso_frame + UHCI_NUMFRAMES,
1012 1013 1014 1015 1016 1017 1018
			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);

1019
	for (i = 0; i < urb->number_of_packets; i++) {
1020
		td = uhci_alloc_td(uhci);
L
Linus Torvalds 已提交
1021 1022 1023
		if (!td)
			return -ENOMEM;

1024
		uhci_add_td_to_urbp(td, urbp);
1025 1026 1027 1028
		uhci_fill_td(td, status, destination |
				uhci_explen(urb->iso_frame_desc[i].length),
				urb->transfer_dma +
					urb->iso_frame_desc[i].offset);
1029
	}
L
Linus Torvalds 已提交
1030

1031 1032 1033 1034
	/* 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;
1035
	qh->period = urb->interval;
1036 1037

	/* Add the TDs to the frame list */
1038 1039
	frame = urb->start_frame;
	list_for_each_entry(td, &urbp->td_list, list) {
1040
		uhci_insert_td_in_frame_list(uhci, td, frame);
1041 1042 1043 1044 1045 1046 1047
		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 已提交
1048 1049
	}

1050
	return 0;
L
Linus Torvalds 已提交
1051 1052 1053 1054
}

static int uhci_result_isochronous(struct uhci_hcd *uhci, struct urb *urb)
{
1055 1056 1057
	struct uhci_td *td, *tmp;
	struct urb_priv *urbp = urb->hcpriv;
	struct uhci_qh *qh = urbp->qh;
L
Linus Torvalds 已提交
1058

1059 1060 1061
	list_for_each_entry_safe(td, tmp, &urbp->td_list, list) {
		unsigned int ctrlstat;
		int status;
L
Linus Torvalds 已提交
1062 1063
		int actlength;

1064
		if (uhci_frame_before_eq(uhci->cur_iso_frame, qh->iso_frame))
L
Linus Torvalds 已提交
1065 1066
			return -EINPROGRESS;

1067 1068 1069 1070 1071 1072 1073 1074 1075 1076 1077 1078 1079 1080
		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 已提交
1081 1082 1083

		if (status) {
			urb->error_count++;
1084
			qh->iso_status = status;
L
Linus Torvalds 已提交
1085 1086
		}

1087 1088 1089 1090
		uhci_remove_td_from_urbp(td);
		uhci_free_td(uhci, td);
		qh->iso_frame += qh->period;
		++qh->iso_packet_desc;
L
Linus Torvalds 已提交
1091
	}
1092
	return qh->iso_status;
L
Linus Torvalds 已提交
1093 1094 1095
}

static int uhci_urb_enqueue(struct usb_hcd *hcd,
1096
		struct usb_host_endpoint *hep,
A
Al Viro 已提交
1097
		struct urb *urb, gfp_t mem_flags)
L
Linus Torvalds 已提交
1098 1099 1100 1101
{
	int ret;
	struct uhci_hcd *uhci = hcd_to_uhci(hcd);
	unsigned long flags;
1102 1103
	struct urb_priv *urbp;
	struct uhci_qh *qh;
L
Linus Torvalds 已提交
1104 1105 1106 1107 1108 1109
	int bustime;

	spin_lock_irqsave(&uhci->lock, flags);

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

1112 1113 1114 1115
	ret = -ENOMEM;
	urbp = uhci_alloc_urb_priv(uhci, urb);
	if (!urbp)
		goto done;
L
Linus Torvalds 已提交
1116

1117 1118 1119 1120 1121 1122
	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 已提交
1123
	}
1124
	urbp->qh = qh;
L
Linus Torvalds 已提交
1125

1126 1127
	switch (qh->type) {
	case USB_ENDPOINT_XFER_CONTROL:
1128 1129
		ret = uhci_submit_control(uhci, urb, qh);
		break;
1130
	case USB_ENDPOINT_XFER_BULK:
1131
		ret = uhci_submit_bulk(uhci, urb, qh);
L
Linus Torvalds 已提交
1132
		break;
1133
	case USB_ENDPOINT_XFER_INT:
1134
		if (list_empty(&qh->queue)) {
L
Linus Torvalds 已提交
1135 1136 1137 1138
			bustime = usb_check_bandwidth(urb->dev, urb);
			if (bustime < 0)
				ret = bustime;
			else {
1139 1140
				ret = uhci_submit_interrupt(uhci, urb, qh);
				if (ret == 0)
L
Linus Torvalds 已提交
1141 1142 1143
					usb_claim_bandwidth(urb->dev, urb, bustime, 0);
			}
		} else {	/* inherit from parent */
1144 1145 1146 1147 1148 1149
			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 已提交
1150 1151
		}
		break;
1152
	case USB_ENDPOINT_XFER_ISOC:
1153
		urb->error_count = 0;
L
Linus Torvalds 已提交
1154 1155 1156 1157 1158 1159
		bustime = usb_check_bandwidth(urb->dev, urb);
		if (bustime < 0) {
			ret = bustime;
			break;
		}

1160 1161
		ret = uhci_submit_isochronous(uhci, urb, qh);
		if (ret == 0)
L
Linus Torvalds 已提交
1162 1163 1164
			usb_claim_bandwidth(urb->dev, urb, bustime, 1);
		break;
	}
1165 1166
	if (ret != 0)
		goto err_submit_failed;
L
Linus Torvalds 已提交
1167

1168 1169 1170
	/* Add this URB to the QH */
	urbp->qh = qh;
	list_add_tail(&urbp->node, &qh->queue);
L
Linus Torvalds 已提交
1171

1172 1173
	/* 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
1174 1175
	 * become idle, so we can activate it right away.  But only if the
	 * queue isn't stopped. */
A
Alan Stern 已提交
1176
	if (qh->queue.next == &urbp->node && !qh->is_stopped) {
1177
		uhci_activate_qh(uhci, qh);
A
Alan Stern 已提交
1178 1179
		uhci_qh_wants_fsbr(uhci, qh);
	}
1180 1181 1182 1183 1184
	goto done;

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

1186 1187 1188 1189
err_no_qh:
	uhci_free_urb_priv(uhci, urbp);

done:
L
Linus Torvalds 已提交
1190 1191 1192 1193
	spin_unlock_irqrestore(&uhci->lock, flags);
	return ret;
}

1194 1195 1196 1197 1198
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;
1199
	struct uhci_qh *qh;
1200 1201 1202 1203 1204

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

	/* Remove Isochronous TDs from the frame list ASAP */
1208
	if (qh->type == USB_ENDPOINT_XFER_ISOC) {
1209
		uhci_unlink_isochronous_tds(uhci, urb);
1210 1211 1212 1213 1214 1215 1216 1217 1218
		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);
1219 1220 1221 1222 1223 1224

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

L
Linus Torvalds 已提交
1225
/*
1226
 * Finish unlinking an URB and give it back
L
Linus Torvalds 已提交
1227
 */
1228 1229 1230 1231
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 已提交
1232
{
1233
	struct urb_priv *urbp = (struct urb_priv *) urb->hcpriv;
L
Linus Torvalds 已提交
1234

1235 1236 1237 1238 1239 1240 1241 1242 1243 1244 1245 1246
	/* 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 已提交
1247

1248 1249 1250 1251 1252 1253 1254 1255 1256 1257
	/* 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 已提交
1258

1259 1260
	switch (qh->type) {
	case USB_ENDPOINT_XFER_ISOC:
L
Linus Torvalds 已提交
1261 1262 1263 1264
		/* Release bandwidth for Interrupt or Isoc. transfers */
		if (urb->bandwidth)
			usb_release_bandwidth(urb->dev, urb, 1);
		break;
1265
	case USB_ENDPOINT_XFER_INT:
L
Linus Torvalds 已提交
1266 1267
		/* Release bandwidth for Interrupt or Isoc. transfers */
		/* Make sure we don't release if we have a queued URB */
1268
		if (list_empty(&qh->queue) && urb->bandwidth)
L
Linus Torvalds 已提交
1269 1270 1271 1272 1273 1274 1275 1276
			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;
	}

1277 1278 1279
	spin_unlock(&uhci->lock);
	usb_hcd_giveback_urb(uhci_to_hcd(uhci), urb, regs);
	spin_lock(&uhci->lock);
L
Linus Torvalds 已提交
1280

1281 1282 1283 1284
	/* 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 已提交
1285

1286
		/* Bandwidth stuff not yet implemented */
1287
		qh->period = 0;
1288
	}
1289
}
L
Linus Torvalds 已提交
1290

1291
/*
1292
 * Scan the URBs in a QH's queue
1293
 */
1294 1295 1296
#define QH_FINISHED_UNLINKING(qh)			\
		(qh->state == QH_STATE_UNLINKING &&	\
		uhci->frame_number + uhci->is_stopped != qh->unlink_frame)
L
Linus Torvalds 已提交
1297

1298 1299
static void uhci_scan_qh(struct uhci_hcd *uhci, struct uhci_qh *qh,
		struct pt_regs *regs)
L
Linus Torvalds 已提交
1300 1301
{
	struct urb_priv *urbp;
1302 1303
	struct urb *urb;
	int status;
L
Linus Torvalds 已提交
1304

1305 1306 1307
	while (!list_empty(&qh->queue)) {
		urbp = list_entry(qh->queue.next, struct urb_priv, node);
		urb = urbp->urb;
L
Linus Torvalds 已提交
1308

1309
		if (qh->type == USB_ENDPOINT_XFER_ISOC)
1310
			status = uhci_result_isochronous(uhci, urb);
1311
		else
1312 1313 1314
			status = uhci_result_common(uhci, urb);
		if (status == -EINPROGRESS)
			break;
L
Linus Torvalds 已提交
1315

1316 1317 1318 1319
		spin_lock(&urb->lock);
		if (urb->status == -EINPROGRESS)	/* Not dequeued */
			urb->status = status;
		else
1320
			status = ECONNRESET;		/* Not -ECONNRESET */
1321
		spin_unlock(&urb->lock);
L
Linus Torvalds 已提交
1322

1323 1324
		/* Dequeued but completed URBs can't be given back unless
		 * the QH is stopped or has finished unlinking. */
1325 1326 1327 1328 1329 1330
		if (status == ECONNRESET) {
			if (QH_FINISHED_UNLINKING(qh))
				qh->is_stopped = 1;
			else if (!qh->is_stopped)
				return;
		}
L
Linus Torvalds 已提交
1331

1332
		uhci_giveback_urb(uhci, qh, urb, regs);
1333
		if (status < 0)
1334 1335
			break;
	}
L
Linus Torvalds 已提交
1336

1337 1338
	/* If the QH is neither stopped nor finished unlinking (normal case),
	 * our work here is done. */
1339 1340 1341
	if (QH_FINISHED_UNLINKING(qh))
		qh->is_stopped = 1;
	else if (!qh->is_stopped)
1342
		return;
L
Linus Torvalds 已提交
1343

1344
	/* Otherwise give back each of the dequeued URBs */
1345
restart:
1346 1347 1348
	list_for_each_entry(urbp, &qh->queue, node) {
		urb = urbp->urb;
		if (urb->status != -EINPROGRESS) {
1349 1350 1351 1352 1353 1354 1355 1356

			/* 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;
			}
1357 1358 1359 1360 1361
			uhci_giveback_urb(uhci, qh, urb, regs);
			goto restart;
		}
	}
	qh->is_stopped = 0;
L
Linus Torvalds 已提交
1362

1363 1364 1365 1366 1367
	/* 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 已提交
1368 1369 1370 1371 1372 1373 1374 1375 1376 1377 1378 1379

		/* 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);
		}

1380
		uhci_activate_qh(uhci, qh);
L
Linus Torvalds 已提交
1381 1382
	}

1383 1384 1385 1386
	/* 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 已提交
1387 1388
}

A
Alan Stern 已提交
1389 1390 1391 1392
/*
 * 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.
1393 1394 1395 1396 1397
 *
 * 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 已提交
1398 1399 1400 1401 1402 1403 1404 1405 1406 1407 1408 1409 1410 1411 1412 1413 1414 1415 1416 1417 1418 1419 1420 1421 1422 1423 1424 1425 1426 1427 1428 1429 1430 1431 1432 1433 1434 1435 1436 1437
 */
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)
		return ret;

	/* 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;
			return ret;
		}
		ret = 0;
	}

	/* The queue hasn't advanced; check for timeout */
	if (!qh->wait_expired && time_after(jiffies,
			qh->advance_jiffies + QH_WAIT_TIMEOUT)) {
1438 1439 1440 1441 1442 1443 1444 1445 1446

		/* 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;
			return 1;
		}

A
Alan Stern 已提交
1447 1448 1449 1450 1451 1452 1453 1454 1455 1456 1457 1458
		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);
	}
	return ret;
}

1459 1460 1461
/*
 * Process events in the schedule, but only in one thread at a time
 */
L
Linus Torvalds 已提交
1462 1463
static void uhci_scan_schedule(struct uhci_hcd *uhci, struct pt_regs *regs)
{
1464 1465
	int i;
	struct uhci_qh *qh;
L
Linus Torvalds 已提交
1466 1467 1468 1469 1470 1471 1472

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

1476
	uhci_clear_next_interrupt(uhci);
L
Linus Torvalds 已提交
1477
	uhci_get_current_frame_number(uhci);
1478
	uhci->cur_iso_frame = uhci->frame_number;
L
Linus Torvalds 已提交
1479

1480 1481 1482 1483 1484 1485 1486
	/* 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 已提交
1487 1488 1489 1490 1491 1492

			if (uhci_advance_check(uhci, qh)) {
				uhci_scan_qh(uhci, qh, regs);
				if (qh->state == QH_STATE_ACTIVE)
					uhci_qh_wants_fsbr(uhci, qh);
			}
1493
		}
L
Linus Torvalds 已提交
1494 1495
	}

1496
	uhci->last_iso_frame = uhci->cur_iso_frame;
L
Linus Torvalds 已提交
1497 1498 1499 1500
	if (uhci->need_rescan)
		goto rescan;
	uhci->scan_in_progress = 0;

A
Alan Stern 已提交
1501 1502 1503 1504
	if (uhci->fsbr_is_on && time_after(jiffies,
			uhci->fsbr_jiffies + FSBR_OFF_DELAY))
		uhci_fsbr_off(uhci);

1505
	if (list_empty(&uhci->skel_unlink_qh->node))
L
Linus Torvalds 已提交
1506 1507 1508 1509
		uhci_clear_next_interrupt(uhci);
	else
		uhci_set_next_interrupt(uhci);
}