git.oblomov.eu Git - linux-2.6/blob - drivers/usb/host/uhci-q.c

   1 /*
   2  * Universal Host Controller Interface driver for USB.
   3  *
   4  * Maintainer: Alan Stern <stern@rowland.harvard.edu>
   5  *
   6  * (C) Copyright 1999 Linus Torvalds
   7  * (C) Copyright 1999-2002 Johannes Erdfelt, johannes@erdfelt.com
   8  * (C) Copyright 1999 Randy Dunlap
   9  * (C) Copyright 1999 Georg Acher, acher@in.tum.de
  10  * (C) Copyright 1999 Deti Fliegl, deti@fliegl.de
  11  * (C) Copyright 1999 Thomas Sailer, sailer@ife.ee.ethz.ch
  12  * (C) Copyright 1999 Roman Weissgaerber, weissg@vienna.at
  13  * (C) Copyright 2000 Yggdrasil Computing, Inc. (port of new PCI interface
  14  *               support from usb-ohci.c by Adam Richter, adam@yggdrasil.com).
  15  * (C) Copyright 1999 Gregory P. Smith (from usb-ohci.c)
  16  * (C) Copyright 2004 Alan Stern, stern@rowland.harvard.edu
  17  */
  18
  19 static int uhci_urb_dequeue(struct usb_hcd *hcd, struct urb *urb);
  20 static void uhci_unlink_generic(struct uhci_hcd *uhci, struct urb *urb);
  21 static void uhci_remove_pending_urbps(struct uhci_hcd *uhci);
  22 static void uhci_free_pending_qhs(struct uhci_hcd *uhci);
  23 static void uhci_free_pending_tds(struct uhci_hcd *uhci);
  24
  25 /*
  26  * Technically, updating td->status here is a race, but it's not really a
  27  * problem. The worst that can happen is that we set the IOC bit again
  28  * generating a spurious interrupt. We could fix this by creating another
  29  * QH and leaving the IOC bit always set, but then we would have to play
  30  * games with the FSBR code to make sure we get the correct order in all
  31  * the cases. I don't think it's worth the effort
  32  */
  33 static inline void uhci_set_next_interrupt(struct uhci_hcd *uhci)
  34 {
  35         if (uhci->is_stopped)
  36                 mod_timer(&uhci_to_hcd(uhci)->rh_timer, jiffies);
  37         uhci->term_td->status |= cpu_to_le32(TD_CTRL_IOC);
  38 }
  39
  40 static inline void uhci_clear_next_interrupt(struct uhci_hcd *uhci)
  41 {
  42         uhci->term_td->status &= ~cpu_to_le32(TD_CTRL_IOC);
  43 }
  44
  45 static inline void uhci_moveto_complete(struct uhci_hcd *uhci,
  46                                         struct urb_priv *urbp)
  47 {
  48         list_move_tail(&urbp->urb_list, &uhci->complete_list);
  49 }
  50
  51 static struct uhci_td *uhci_alloc_td(struct uhci_hcd *uhci)
  52 {
  53         dma_addr_t dma_handle;
  54         struct uhci_td *td;
  55
  56         td = dma_pool_alloc(uhci->td_pool, GFP_ATOMIC, &dma_handle);
  57         if (!td)
  58                 return NULL;
  59
  60         td->dma_handle = dma_handle;
  61
  62         td->link = UHCI_PTR_TERM;
  63         td->buffer = 0;
  64
  65         td->frame = -1;
  66
  67         INIT_LIST_HEAD(&td->list);
  68         INIT_LIST_HEAD(&td->remove_list);
  69         INIT_LIST_HEAD(&td->fl_list);
  70
  71         return td;
  72 }
  73
  74 static inline void uhci_fill_td(struct uhci_td *td, u32 status,
  75                 u32 token, u32 buffer)
  76 {
  77         td->status = cpu_to_le32(status);
  78         td->token = cpu_to_le32(token);
  79         td->buffer = cpu_to_le32(buffer);
  80 }
  81
  82 /*
  83  * We insert Isochronous URBs directly into the frame list at the beginning
  84  */
  85 static void uhci_insert_td_frame_list(struct uhci_hcd *uhci, struct uhci_td *td, unsigned framenum)
  86 {
  87         framenum &= (UHCI_NUMFRAMES - 1);
  88
  89         td->frame = framenum;
  90
  91         /* Is there a TD already mapped there? */
  92         if (uhci->frame_cpu[framenum]) {
  93                 struct uhci_td *ftd, *ltd;
  94
  95                 ftd = uhci->frame_cpu[framenum];
  96                 ltd = list_entry(ftd->fl_list.prev, struct uhci_td, fl_list);
  97
  98                 list_add_tail(&td->fl_list, &ftd->fl_list);
  99
 100                 td->link = ltd->link;
 101                 wmb();
 102                 ltd->link = cpu_to_le32(td->dma_handle);
 103         } else {
 104                 td->link = uhci->frame[framenum];
 105                 wmb();
 106                 uhci->frame[framenum] = cpu_to_le32(td->dma_handle);
 107                 uhci->frame_cpu[framenum] = td;
 108         }
 109 }
 110
 111 static inline void uhci_remove_td_frame_list(struct uhci_hcd *uhci,
 112                 struct uhci_td *td)
 113 {
 114         /* If it's not inserted, don't remove it */
 115         if (td->frame == -1) {
 116                 WARN_ON(!list_empty(&td->fl_list));
 117                 return;
 118         }
 119
 120         if (uhci->frame_cpu[td->frame] == td) {
 121                 if (list_empty(&td->fl_list)) {
 122                         uhci->frame[td->frame] = td->link;
 123                         uhci->frame_cpu[td->frame] = NULL;
 124                 } else {
 125                         struct uhci_td *ntd;
 126
 127                         ntd = list_entry(td->fl_list.next, struct uhci_td, fl_list);
 128                         uhci->frame[td->frame] = cpu_to_le32(ntd->dma_handle);
 129                         uhci->frame_cpu[td->frame] = ntd;
 130                 }
 131         } else {
 132                 struct uhci_td *ptd;
 133
 134                 ptd = list_entry(td->fl_list.prev, struct uhci_td, fl_list);
 135                 ptd->link = td->link;
 136         }
 137
 138         list_del_init(&td->fl_list);
 139         td->frame = -1;
 140 }
 141
 142 static void unlink_isochronous_tds(struct uhci_hcd *uhci, struct urb *urb)
 143 {
 144         struct urb_priv *urbp = (struct urb_priv *) urb->hcpriv;
 145         struct uhci_td *td;
 146
 147         list_for_each_entry(td, &urbp->td_list, list)
 148                 uhci_remove_td_frame_list(uhci, td);
 149         wmb();
 150 }
 151
 152 /*
 153  * Inserts a td list into qh.
 154  */
 155 static void uhci_insert_tds_in_qh(struct uhci_qh *qh, struct urb *urb, __le32 breadth)
 156 {
 157         struct urb_priv *urbp = (struct urb_priv *)urb->hcpriv;
 158         struct uhci_td *td;
 159         __le32 *plink;
 160
 161         /* Ordering isn't important here yet since the QH hasn't been */
 162         /* inserted into the schedule yet */
 163         plink = &qh->element;
 164         list_for_each_entry(td, &urbp->td_list, list) {
 165                 *plink = cpu_to_le32(td->dma_handle) | breadth;
 166                 plink = &td->link;
 167         }
 168         *plink = UHCI_PTR_TERM;
 169 }
 170
 171 static void uhci_free_td(struct uhci_hcd *uhci, struct uhci_td *td)
 172 {
 173         if (!list_empty(&td->list))
 174                 dev_warn(uhci_dev(uhci), "td %p still in list!\n", td);
 175         if (!list_empty(&td->remove_list))
 176                 dev_warn(uhci_dev(uhci), "td %p still in remove_list!\n", td);
 177         if (!list_empty(&td->fl_list))
 178                 dev_warn(uhci_dev(uhci), "td %p still in fl_list!\n", td);
 179
 180         dma_pool_free(uhci->td_pool, td, td->dma_handle);
 181 }
 182
 183 static struct uhci_qh *uhci_alloc_qh(struct uhci_hcd *uhci)
 184 {
 185         dma_addr_t dma_handle;
 186         struct uhci_qh *qh;
 187
 188         qh = dma_pool_alloc(uhci->qh_pool, GFP_ATOMIC, &dma_handle);
 189         if (!qh)
 190                 return NULL;
 191
 192         qh->dma_handle = dma_handle;
 193
 194         qh->element = UHCI_PTR_TERM;
 195         qh->link = UHCI_PTR_TERM;
 196
 197         qh->urbp = NULL;
 198
 199         INIT_LIST_HEAD(&qh->list);
 200         INIT_LIST_HEAD(&qh->remove_list);
 201
 202         return qh;
 203 }
 204
 205 static void uhci_free_qh(struct uhci_hcd *uhci, struct uhci_qh *qh)
 206 {
 207         if (!list_empty(&qh->list))
 208                 dev_warn(uhci_dev(uhci), "qh %p list not empty!\n", qh);
 209         if (!list_empty(&qh->remove_list))
 210                 dev_warn(uhci_dev(uhci), "qh %p still in remove_list!\n", qh);
 211
 212         dma_pool_free(uhci->qh_pool, qh, qh->dma_handle);
 213 }
 214
 215 /*
 216  * Append this urb's qh after the last qh in skelqh->list
 217  *
 218  * Note that urb_priv.queue_list doesn't have a separate queue head;
 219  * it's a ring with every element "live".
 220  */
 221 static void uhci_insert_qh(struct uhci_hcd *uhci, struct uhci_qh *skelqh, struct urb *urb)
 222 {
 223         struct urb_priv *urbp = (struct urb_priv *)urb->hcpriv;
 224         struct urb_priv *turbp;
 225         struct uhci_qh *lqh;
 226
 227         /* Grab the last QH */
 228         lqh = list_entry(skelqh->list.prev, struct uhci_qh, list);
 229
 230         /* Point to the next skelqh */
 231         urbp->qh->link = lqh->link;
 232         wmb();                          /* Ordering is important */
 233
 234         /*
 235          * Patch QHs for previous endpoint's queued URBs?  HC goes
 236          * here next, not to the next skelqh it now points to.
 237          *
 238          *    lqh --> td ... --> qh ... --> td --> qh ... --> td
 239          *     |                 |                 |
 240          *     v                 v                 v
 241          *     +<----------------+-----------------+
 242          *     v
 243          *    newqh --> td ... --> td
 244          *     |
 245          *     v
 246          *    ...
 247          *
 248          * The HC could see (and use!) any of these as we write them.
 249          */
 250         lqh->link = cpu_to_le32(urbp->qh->dma_handle) | UHCI_PTR_QH;
 251         if (lqh->urbp) {
 252                 list_for_each_entry(turbp, &lqh->urbp->queue_list, queue_list)
 253                         turbp->qh->link = lqh->link;
 254         }
 255
 256         list_add_tail(&urbp->qh->list, &skelqh->list);
 257 }
 258
 259 /*
 260  * Start removal of QH from schedule; it finishes next frame.
 261  * TDs should be unlinked before this is called.
 262  */
 263 static void uhci_remove_qh(struct uhci_hcd *uhci, struct uhci_qh *qh)
 264 {
 265         struct uhci_qh *pqh;
 266         __le32 newlink;
 267
 268         if (!qh)
 269                 return;
 270
 271         /*
 272          * Only go through the hoops if it's actually linked in
 273          */
 274         if (!list_empty(&qh->list)) {
 275
 276                 /* If our queue is nonempty, make the next URB the head */
 277                 if (!list_empty(&qh->urbp->queue_list)) {
 278                         struct urb_priv *nurbp;
 279
 280                         nurbp = list_entry(qh->urbp->queue_list.next,
 281                                         struct urb_priv, queue_list);
 282                         nurbp->queued = 0;
 283                         list_add(&nurbp->qh->list, &qh->list);
 284                         newlink = cpu_to_le32(nurbp->qh->dma_handle) | UHCI_PTR_QH;
 285                 } else
 286                         newlink = qh->link;
 287
 288                 /* Fix up the previous QH's queue to link to either
 289                  * the new head of this queue or the start of the
 290                  * next endpoint's queue. */
 291                 pqh = list_entry(qh->list.prev, struct uhci_qh, list);
 292                 pqh->link = newlink;
 293                 if (pqh->urbp) {
 294                         struct urb_priv *turbp;
 295
 296                         list_for_each_entry(turbp, &pqh->urbp->queue_list,
 297                                         queue_list)
 298                                 turbp->qh->link = newlink;
 299                 }
 300                 wmb();
 301
 302                 /* Leave qh->link in case the HC is on the QH now, it will */
 303                 /* continue the rest of the schedule */
 304                 qh->element = UHCI_PTR_TERM;
 305
 306                 list_del_init(&qh->list);
 307         }
 308
 309         list_del_init(&qh->urbp->queue_list);
 310         qh->urbp = NULL;
 311
 312         uhci_get_current_frame_number(uhci);
 313         if (uhci->frame_number + uhci->is_stopped != uhci->qh_remove_age) {
 314                 uhci_free_pending_qhs(uhci);
 315                 uhci->qh_remove_age = uhci->frame_number;
 316         }
 317
 318         /* Check to see if the remove list is empty. Set the IOC bit */
 319         /* to force an interrupt so we can remove the QH */
 320         if (list_empty(&uhci->qh_remove_list))
 321                 uhci_set_next_interrupt(uhci);
 322
 323         list_add(&qh->remove_list, &uhci->qh_remove_list);
 324 }
 325
 326 static int uhci_fixup_toggle(struct urb *urb, unsigned int toggle)
 327 {
 328         struct urb_priv *urbp = (struct urb_priv *)urb->hcpriv;
 329         struct uhci_td *td;
 330
 331         list_for_each_entry(td, &urbp->td_list, list) {
 332                 if (toggle)
 333                         td->token |= cpu_to_le32(TD_TOKEN_TOGGLE);
 334                 else
 335                         td->token &= ~cpu_to_le32(TD_TOKEN_TOGGLE);
 336
 337                 toggle ^= 1;
 338         }
 339
 340         return toggle;
 341 }
 342
 343 /* This function will append one URB's QH to another URB's QH. This is for */
 344 /* queuing interrupt, control or bulk transfers */
 345 static void uhci_append_queued_urb(struct uhci_hcd *uhci, struct urb *eurb, struct urb *urb)
 346 {
 347         struct urb_priv *eurbp, *urbp, *furbp, *lurbp;
 348         struct uhci_td *lltd;
 349
 350         eurbp = eurb->hcpriv;
 351         urbp = urb->hcpriv;
 352
 353         /* Find the first URB in the queue */
 354         furbp = eurbp;
 355         if (eurbp->queued) {
 356                 list_for_each_entry(furbp, &eurbp->queue_list, queue_list)
 357                         if (!furbp->queued)
 358                                 break;
 359         }
 360
 361         lurbp = list_entry(furbp->queue_list.prev, struct urb_priv, queue_list);
 362
 363         lltd = list_entry(lurbp->td_list.prev, struct uhci_td, list);
 364
 365         /* Control transfers always start with toggle 0 */
 366         if (!usb_pipecontrol(urb->pipe))
 367                 usb_settoggle(urb->dev, usb_pipeendpoint(urb->pipe),
 368                                 usb_pipeout(urb->pipe),
 369                                 uhci_fixup_toggle(urb,
 370                                         uhci_toggle(td_token(lltd)) ^ 1));
 371
 372         /* All qhs in the queue need to link to the next queue */
 373         urbp->qh->link = eurbp->qh->link;
 374
 375         wmb();                  /* Make sure we flush everything */
 376
 377         lltd->link = cpu_to_le32(urbp->qh->dma_handle) | UHCI_PTR_QH;
 378
 379         list_add_tail(&urbp->queue_list, &furbp->queue_list);
 380
 381         urbp->queued = 1;
 382 }
 383
 384 static void uhci_delete_queued_urb(struct uhci_hcd *uhci, struct urb *urb)
 385 {
 386         struct urb_priv *urbp, *nurbp, *purbp, *turbp;
 387         struct uhci_td *pltd;
 388         unsigned int toggle;
 389
 390         urbp = urb->hcpriv;
 391
 392         if (list_empty(&urbp->queue_list))
 393                 return;
 394
 395         nurbp = list_entry(urbp->queue_list.next, struct urb_priv, queue_list);
 396
 397         /*
 398          * Fix up the toggle for the following URBs in the queue.
 399          * Only needed for bulk and interrupt: control and isochronous
 400          * endpoints don't propagate toggles between messages.
 401          */
 402         if (usb_pipebulk(urb->pipe) || usb_pipeint(urb->pipe)) {
 403                 if (!urbp->queued)
 404                         /* We just set the toggle in uhci_unlink_generic */
 405                         toggle = usb_gettoggle(urb->dev,
 406                                         usb_pipeendpoint(urb->pipe),
 407                                         usb_pipeout(urb->pipe));
 408                 else {
 409                         /* If we're in the middle of the queue, grab the */
 410                         /* toggle from the TD previous to us */
 411                         purbp = list_entry(urbp->queue_list.prev,
 412                                         struct urb_priv, queue_list);
 413                         pltd = list_entry(purbp->td_list.prev,
 414                                         struct uhci_td, list);
 415                         toggle = uhci_toggle(td_token(pltd)) ^ 1;
 416                 }
 417
 418                 list_for_each_entry(turbp, &urbp->queue_list, queue_list) {
 419                         if (!turbp->queued)
 420                                 break;
 421                         toggle = uhci_fixup_toggle(turbp->urb, toggle);
 422                 }
 423
 424                 usb_settoggle(urb->dev, usb_pipeendpoint(urb->pipe),
 425                                 usb_pipeout(urb->pipe), toggle);
 426         }
 427
 428         if (urbp->queued) {
 429                 /* We're somewhere in the middle (or end).  The case where
 430                  * we're at the head is handled in uhci_remove_qh(). */
 431                 purbp = list_entry(urbp->queue_list.prev, struct urb_priv,
 432                                 queue_list);
 433
 434                 pltd = list_entry(purbp->td_list.prev, struct uhci_td, list);
 435                 if (nurbp->queued)
 436                         pltd->link = cpu_to_le32(nurbp->qh->dma_handle) | UHCI_PTR_QH;
 437                 else
 438                         /* The next URB happens to be the beginning, so */
 439                         /*  we're the last, end the chain */
 440                         pltd->link = UHCI_PTR_TERM;
 441         }
 442
 443         /* urbp->queue_list is handled in uhci_remove_qh() */
 444 }
 445
 446 static struct urb_priv *uhci_alloc_urb_priv(struct uhci_hcd *uhci, struct urb *urb)
 447 {
 448         struct urb_priv *urbp;
 449
 450         urbp = kmem_cache_alloc(uhci_up_cachep, SLAB_ATOMIC);
 451         if (!urbp)
 452                 return NULL;
 453
 454         memset((void *)urbp, 0, sizeof(*urbp));
 455
 456         urbp->fsbrtime = jiffies;
 457         urbp->urb = urb;
 458
 459         INIT_LIST_HEAD(&urbp->td_list);
 460         INIT_LIST_HEAD(&urbp->queue_list);
 461         INIT_LIST_HEAD(&urbp->urb_list);
 462
 463         list_add_tail(&urbp->urb_list, &uhci->urb_list);
 464
 465         urb->hcpriv = urbp;
 466
 467         return urbp;
 468 }
 469
 470 static void uhci_add_td_to_urb(struct urb *urb, struct uhci_td *td)
 471 {
 472         struct urb_priv *urbp = (struct urb_priv *)urb->hcpriv;
 473
 474         list_add_tail(&td->list, &urbp->td_list);
 475 }
 476
 477 static void uhci_remove_td_from_urb(struct uhci_td *td)
 478 {
 479         if (list_empty(&td->list))
 480                 return;
 481
 482         list_del_init(&td->list);
 483 }
 484
 485 static void uhci_destroy_urb_priv(struct uhci_hcd *uhci, struct urb *urb)
 486 {
 487         struct uhci_td *td, *tmp;
 488         struct urb_priv *urbp;
 489
 490         urbp = (struct urb_priv *)urb->hcpriv;
 491         if (!urbp)
 492                 return;
 493
 494         if (!list_empty(&urbp->urb_list))
 495                 dev_warn(uhci_dev(uhci), "urb %p still on uhci->urb_list "
 496                                 "or uhci->remove_list!\n", urb);
 497
 498         uhci_get_current_frame_number(uhci);
 499         if (uhci->frame_number + uhci->is_stopped != uhci->td_remove_age) {
 500                 uhci_free_pending_tds(uhci);
 501                 uhci->td_remove_age = uhci->frame_number;
 502         }
 503
 504         /* Check to see if the remove list is empty. Set the IOC bit */
 505         /* to force an interrupt so we can remove the TDs*/
 506         if (list_empty(&uhci->td_remove_list))
 507                 uhci_set_next_interrupt(uhci);
 508
 509         list_for_each_entry_safe(td, tmp, &urbp->td_list, list) {
 510                 uhci_remove_td_from_urb(td);
 511                 list_add(&td->remove_list, &uhci->td_remove_list);
 512         }
 513
 514         urb->hcpriv = NULL;
 515         kmem_cache_free(uhci_up_cachep, urbp);
 516 }
 517
 518 static void uhci_inc_fsbr(struct uhci_hcd *uhci, struct urb *urb)
 519 {
 520         struct urb_priv *urbp = (struct urb_priv *)urb->hcpriv;
 521
 522         if ((!(urb->transfer_flags & URB_NO_FSBR)) && !urbp->fsbr) {
 523                 urbp->fsbr = 1;
 524                 if (!uhci->fsbr++ && !uhci->fsbrtimeout)
 525                         uhci->skel_term_qh->link = cpu_to_le32(uhci->skel_fs_control_qh->dma_handle) | UHCI_PTR_QH;
 526         }
 527 }
 528
 529 static void uhci_dec_fsbr(struct uhci_hcd *uhci, struct urb *urb)
 530 {
 531         struct urb_priv *urbp = (struct urb_priv *)urb->hcpriv;
 532
 533         if ((!(urb->transfer_flags & URB_NO_FSBR)) && urbp->fsbr) {
 534                 urbp->fsbr = 0;
 535                 if (!--uhci->fsbr)
 536                         uhci->fsbrtimeout = jiffies + FSBR_DELAY;
 537         }
 538 }
 539
 540 /*
 541  * Map status to standard result codes
 542  *
 543  * <status> is (td_status(td) & 0xF60000), a.k.a.
 544  * uhci_status_bits(td_status(td)).
 545  * Note: <status> does not include the TD_CTRL_NAK bit.
 546  * <dir_out> is True for output TDs and False for input TDs.
 547  */
 548 static int uhci_map_status(int status, int dir_out)
 549 {
 550         if (!status)
 551                 return 0;
 552         if (status & TD_CTRL_BITSTUFF)                  /* Bitstuff error */
 553                 return -EPROTO;
 554         if (status & TD_CTRL_CRCTIMEO) {                /* CRC/Timeout */
 555                 if (dir_out)
 556                         return -EPROTO;
 557                 else
 558                         return -EILSEQ;
 559         }
 560         if (status & TD_CTRL_BABBLE)                    /* Babble */
 561                 return -EOVERFLOW;
 562         if (status & TD_CTRL_DBUFERR)                   /* Buffer error */
 563                 return -ENOSR;
 564         if (status & TD_CTRL_STALLED)                   /* Stalled */
 565                 return -EPIPE;
 566         WARN_ON(status & TD_CTRL_ACTIVE);               /* Active */
 567         return 0;
 568 }
 569
 570 /*
 571  * Control transfers
 572  */
 573 static int uhci_submit_control(struct uhci_hcd *uhci, struct urb *urb, struct urb *eurb)
 574 {
 575         struct urb_priv *urbp = (struct urb_priv *)urb->hcpriv;
 576         struct uhci_td *td;
 577         struct uhci_qh *qh, *skelqh;
 578         unsigned long destination, status;
 579         int maxsze = usb_maxpacket(urb->dev, urb->pipe, usb_pipeout(urb->pipe));
 580         int len = urb->transfer_buffer_length;
 581         dma_addr_t data = urb->transfer_dma;
 582
 583         /* The "pipe" thing contains the destination in bits 8--18 */
 584         destination = (urb->pipe & PIPE_DEVEP_MASK) | USB_PID_SETUP;
 585
 586         /* 3 errors */
 587         status = TD_CTRL_ACTIVE | uhci_maxerr(3);
 588         if (urb->dev->speed == USB_SPEED_LOW)
 589                 status |= TD_CTRL_LS;
 590
 591         /*
 592          * Build the TD for the control request setup packet
 593          */
 594         td = uhci_alloc_td(uhci);
 595         if (!td)
 596                 return -ENOMEM;
 597
 598         uhci_add_td_to_urb(urb, td);
 599         uhci_fill_td(td, status, destination | uhci_explen(8),
 600                 urb->setup_dma);
 601
 602         /*
 603          * If direction is "send", change the packet ID from SETUP (0x2D)
 604          * to OUT (0xE1).  Else change it from SETUP to IN (0x69) and
 605          * set Short Packet Detect (SPD) for all data packets.
 606          */
 607         if (usb_pipeout(urb->pipe))
 608                 destination ^= (USB_PID_SETUP ^ USB_PID_OUT);
 609         else {
 610                 destination ^= (USB_PID_SETUP ^ USB_PID_IN);
 611                 status |= TD_CTRL_SPD;
 612         }
 613
 614         /*
 615          * Build the DATA TDs
 616          */
 617         while (len > 0) {
 618                 int pktsze = len;
 619
 620                 if (pktsze > maxsze)
 621                         pktsze = maxsze;
 622
 623                 td = uhci_alloc_td(uhci);
 624                 if (!td)
 625                         return -ENOMEM;
 626
 627                 /* Alternate Data0/1 (start with Data1) */
 628                 destination ^= TD_TOKEN_TOGGLE;
 629
 630                 uhci_add_td_to_urb(urb, td);
 631                 uhci_fill_td(td, status, destination | uhci_explen(pktsze),
 632                         data);
 633
 634                 data += pktsze;
 635                 len -= pktsze;
 636         }
 637
 638         /*
 639          * Build the final TD for control status
 640          */
 641         td = uhci_alloc_td(uhci);
 642         if (!td)
 643                 return -ENOMEM;
 644
 645         /*
 646          * It's IN if the pipe is an output pipe or we're not expecting
 647          * data back.
 648          */
 649         destination &= ~TD_TOKEN_PID_MASK;
 650         if (usb_pipeout(urb->pipe) || !urb->transfer_buffer_length)
 651                 destination |= USB_PID_IN;
 652         else
 653                 destination |= USB_PID_OUT;
 654
 655         destination |= TD_TOKEN_TOGGLE;         /* End in Data1 */
 656
 657         status &= ~TD_CTRL_SPD;
 658
 659         uhci_add_td_to_urb(urb, td);
 660         uhci_fill_td(td, status | TD_CTRL_IOC,
 661                 destination | uhci_explen(0), 0);
 662
 663         qh = uhci_alloc_qh(uhci);
 664         if (!qh)
 665                 return -ENOMEM;
 666
 667         urbp->qh = qh;
 668         qh->urbp = urbp;
 669
 670         uhci_insert_tds_in_qh(qh, urb, UHCI_PTR_BREADTH);
 671
 672         /* Low-speed transfers get a different queue, and won't hog the bus.
 673          * Also, some devices enumerate better without FSBR; the easiest way
 674          * to do that is to put URBs on the low-speed queue while the device
 675          * is in the DEFAULT state. */
 676         if (urb->dev->speed == USB_SPEED_LOW ||
 677                         urb->dev->state == USB_STATE_DEFAULT)
 678                 skelqh = uhci->skel_ls_control_qh;
 679         else {
 680                 skelqh = uhci->skel_fs_control_qh;
 681                 uhci_inc_fsbr(uhci, urb);
 682         }
 683
 684         if (eurb)
 685                 uhci_append_queued_urb(uhci, eurb, urb);
 686         else
 687                 uhci_insert_qh(uhci, skelqh, urb);
 688
 689         return -EINPROGRESS;
 690 }
 691
 692 /*
 693  * If control-IN transfer was short, the status packet wasn't sent.
 694  * This routine changes the element pointer in the QH to point at the
 695  * status TD.  It's safe to do this even while the QH is live, because
 696  * the hardware only updates the element pointer following a successful
 697  * transfer.  The inactive TD for the short packet won't cause an update,
 698  * so the pointer won't get overwritten.  The next time the controller
 699  * sees this QH, it will send the status packet.
 700  */
 701 static int usb_control_retrigger_status(struct uhci_hcd *uhci, struct urb *urb)
 702 {
 703         struct urb_priv *urbp = (struct urb_priv *)urb->hcpriv;
 704         struct uhci_td *td;
 705
 706         urbp->short_control_packet = 1;
 707
 708         td = list_entry(urbp->td_list.prev, struct uhci_td, list);
 709         urbp->qh->element = cpu_to_le32(td->dma_handle);
 710
 711         return -EINPROGRESS;
 712 }
 713
 714
 715 static int uhci_result_control(struct uhci_hcd *uhci, struct urb *urb)
 716 {
 717         struct list_head *tmp, *head;
 718         struct urb_priv *urbp = urb->hcpriv;
 719         struct uhci_td *td;
 720         unsigned int status;
 721         int ret = 0;
 722
 723         if (list_empty(&urbp->td_list))
 724                 return -EINVAL;
 725
 726         head = &urbp->td_list;
 727
 728         if (urbp->short_control_packet) {
 729                 tmp = head->prev;
 730                 goto status_stage;
 731         }
 732
 733         tmp = head->next;
 734         td = list_entry(tmp, struct uhci_td, list);
 735
 736         /* The first TD is the SETUP stage, check the status, but skip */
 737         /*  the count */
 738         status = uhci_status_bits(td_status(td));
 739         if (status & TD_CTRL_ACTIVE)
 740                 return -EINPROGRESS;
 741
 742         if (status)
 743                 goto td_error;
 744
 745         urb->actual_length = 0;
 746
 747         /* The rest of the TDs (but the last) are data */
 748         tmp = tmp->next;
 749         while (tmp != head && tmp->next != head) {
 750                 unsigned int ctrlstat;
 751
 752                 td = list_entry(tmp, struct uhci_td, list);
 753                 tmp = tmp->next;
 754
 755                 ctrlstat = td_status(td);
 756                 status = uhci_status_bits(ctrlstat);
 757                 if (status & TD_CTRL_ACTIVE)
 758                         return -EINPROGRESS;
 759
 760                 urb->actual_length += uhci_actual_length(ctrlstat);
 761
 762                 if (status)
 763                         goto td_error;
 764
 765                 /* Check to see if we received a short packet */
 766                 if (uhci_actual_length(ctrlstat) <
 767                                 uhci_expected_length(td_token(td))) {
 768                         if (urb->transfer_flags & URB_SHORT_NOT_OK) {
 769                                 ret = -EREMOTEIO;
 770                                 goto err;
 771                         }
 772
 773                         if (uhci_packetid(td_token(td)) == USB_PID_IN)
 774                                 return usb_control_retrigger_status(uhci, urb);
 775                         else
 776                                 return 0;
 777                 }
 778         }
 779
 780 status_stage:
 781         td = list_entry(tmp, struct uhci_td, list);
 782
 783         /* Control status stage */
 784         status = td_status(td);
 785
 786 #ifdef I_HAVE_BUGGY_APC_BACKUPS
 787         /* APC BackUPS Pro kludge */
 788         /* It tries to send all of the descriptor instead of the amount */
 789         /*  we requested */
 790         if (status & TD_CTRL_IOC &&     /* IOC is masked out by uhci_status_bits */
 791             status & TD_CTRL_ACTIVE &&
 792             status & TD_CTRL_NAK)
 793                 return 0;
 794 #endif
 795
 796         status = uhci_status_bits(status);
 797         if (status & TD_CTRL_ACTIVE)
 798                 return -EINPROGRESS;
 799
 800         if (status)
 801                 goto td_error;
 802
 803         return 0;
 804
 805 td_error:
 806         ret = uhci_map_status(status, uhci_packetout(td_token(td)));
 807
 808 err:
 809         if ((debug == 1 && ret != -EPIPE) || debug > 1) {
 810                 /* Some debugging code */
 811                 dev_dbg(uhci_dev(uhci), "%s: failed with status %x\n",
 812                                 __FUNCTION__, status);
 813
 814                 if (errbuf) {
 815                         /* Print the chain for debugging purposes */
 816                         uhci_show_qh(urbp->qh, errbuf, ERRBUF_LEN, 0);
 817
 818                         lprintk(errbuf);
 819                 }
 820         }
 821
 822         return ret;
 823 }
 824
 825 /*
 826  * Common submit for bulk and interrupt
 827  */
 828 static int uhci_submit_common(struct uhci_hcd *uhci, struct urb *urb, struct urb *eurb, struct uhci_qh *skelqh)
 829 {
 830         struct uhci_td *td;
 831         struct uhci_qh *qh;
 832         unsigned long destination, status;
 833         int maxsze = usb_maxpacket(urb->dev, urb->pipe, usb_pipeout(urb->pipe));
 834         int len = urb->transfer_buffer_length;
 835         struct urb_priv *urbp = (struct urb_priv *)urb->hcpriv;
 836         dma_addr_t data = urb->transfer_dma;
 837
 838         if (len < 0)
 839                 return -EINVAL;
 840
 841         /* The "pipe" thing contains the destination in bits 8--18 */
 842         destination = (urb->pipe & PIPE_DEVEP_MASK) | usb_packetid(urb->pipe);
 843
 844         status = uhci_maxerr(3) | TD_CTRL_ACTIVE;
 845         if (urb->dev->speed == USB_SPEED_LOW)
 846                 status |= TD_CTRL_LS;
 847         if (usb_pipein(urb->pipe))
 848                 status |= TD_CTRL_SPD;
 849
 850         /*
 851          * Build the DATA TDs
 852          */
 853         do {    /* Allow zero length packets */
 854                 int pktsze = maxsze;
 855
 856                 if (pktsze >= len) {
 857                         pktsze = len;
 858                         if (!(urb->transfer_flags & URB_SHORT_NOT_OK))
 859                                 status &= ~TD_CTRL_SPD;
 860                 }
 861
 862                 td = uhci_alloc_td(uhci);
 863                 if (!td)
 864                         return -ENOMEM;
 865
 866                 uhci_add_td_to_urb(urb, td);
 867                 uhci_fill_td(td, status, destination | uhci_explen(pktsze) |
 868                         (usb_gettoggle(urb->dev, usb_pipeendpoint(urb->pipe),
 869                          usb_pipeout(urb->pipe)) << TD_TOKEN_TOGGLE_SHIFT),
 870                         data);
 871
 872                 data += pktsze;
 873                 len -= maxsze;
 874
 875                 usb_dotoggle(urb->dev, usb_pipeendpoint(urb->pipe),
 876                         usb_pipeout(urb->pipe));
 877         } while (len > 0);
 878
 879         /*
 880          * URB_ZERO_PACKET means adding a 0-length packet, if direction
 881          * is OUT and the transfer_length was an exact multiple of maxsze,
 882          * hence (len = transfer_length - N * maxsze) == 0
 883          * however, if transfer_length == 0, the zero packet was already
 884          * prepared above.
 885          */
 886         if (usb_pipeout(urb->pipe) && (urb->transfer_flags & URB_ZERO_PACKET) &&
 887             !len && urb->transfer_buffer_length) {
 888                 td = uhci_alloc_td(uhci);
 889                 if (!td)
 890                         return -ENOMEM;
 891
 892                 uhci_add_td_to_urb(urb, td);
 893                 uhci_fill_td(td, status, destination | uhci_explen(0) |
 894                         (usb_gettoggle(urb->dev, usb_pipeendpoint(urb->pipe),
 895                          usb_pipeout(urb->pipe)) << TD_TOKEN_TOGGLE_SHIFT),
 896                         data);
 897
 898                 usb_dotoggle(urb->dev, usb_pipeendpoint(urb->pipe),
 899                         usb_pipeout(urb->pipe));
 900         }
 901
 902         /* Set the interrupt-on-completion flag on the last packet.
 903          * A more-or-less typical 4 KB URB (= size of one memory page)
 904          * will require about 3 ms to transfer; that's a little on the
 905          * fast side but not enough to justify delaying an interrupt
 906          * more than 2 or 3 URBs, so we will ignore the URB_NO_INTERRUPT
 907          * flag setting. */
 908         td->status |= cpu_to_le32(TD_CTRL_IOC);
 909
 910         qh = uhci_alloc_qh(uhci);
 911         if (!qh)
 912                 return -ENOMEM;
 913
 914         urbp->qh = qh;
 915         qh->urbp = urbp;
 916
 917         /* Always breadth first */
 918         uhci_insert_tds_in_qh(qh, urb, UHCI_PTR_BREADTH);
 919
 920         if (eurb)
 921                 uhci_append_queued_urb(uhci, eurb, urb);
 922         else
 923                 uhci_insert_qh(uhci, skelqh, urb);
 924
 925         return -EINPROGRESS;
 926 }
 927
 928 /*
 929  * Common result for bulk and interrupt
 930  */
 931 static int uhci_result_common(struct uhci_hcd *uhci, struct urb *urb)
 932 {
 933         struct urb_priv *urbp = urb->hcpriv;
 934         struct uhci_td *td;
 935         unsigned int status = 0;
 936         int ret = 0;
 937
 938         urb->actual_length = 0;
 939
 940         list_for_each_entry(td, &urbp->td_list, list) {
 941                 unsigned int ctrlstat = td_status(td);
 942
 943                 status = uhci_status_bits(ctrlstat);
 944                 if (status & TD_CTRL_ACTIVE)
 945                         return -EINPROGRESS;
 946
 947                 urb->actual_length += uhci_actual_length(ctrlstat);
 948
 949                 if (status)
 950                         goto td_error;
 951
 952                 if (uhci_actual_length(ctrlstat) <
 953                                 uhci_expected_length(td_token(td))) {
 954                         if (urb->transfer_flags & URB_SHORT_NOT_OK) {
 955                                 ret = -EREMOTEIO;
 956                                 goto err;
 957                         } else
 958                                 return 0;
 959                 }
 960         }
 961
 962         return 0;
 963
 964 td_error:
 965         ret = uhci_map_status(status, uhci_packetout(td_token(td)));
 966
 967 err:
 968         /*
 969          * Enable this chunk of code if you want to see some more debugging.
 970          * But be careful, it has the tendancy to starve out khubd and prevent
 971          * disconnects from happening successfully if you have a slow debug
 972          * log interface (like a serial console.
 973          */
 974 #if 0
 975         if ((debug == 1 && ret != -EPIPE) || debug > 1) {
 976                 /* Some debugging code */
 977                 dev_dbg(uhci_dev(uhci), "%s: failed with status %x\n",
 978                                 __FUNCTION__, status);
 979
 980                 if (errbuf) {
 981                         /* Print the chain for debugging purposes */
 982                         uhci_show_qh(urbp->qh, errbuf, ERRBUF_LEN, 0);
 983
 984                         lprintk(errbuf);
 985                 }
 986         }
 987 #endif
 988         return ret;
 989 }
 990
 991 static inline int uhci_submit_bulk(struct uhci_hcd *uhci, struct urb *urb, struct urb *eurb)
 992 {
 993         int ret;
 994
 995         /* Can't have low-speed bulk transfers */
 996         if (urb->dev->speed == USB_SPEED_LOW)
 997                 return -EINVAL;
 998
 999         ret = uhci_submit_common(uhci, urb, eurb, uhci->skel_bulk_qh);
1000         if (ret == -EINPROGRESS)
1001                 uhci_inc_fsbr(uhci, urb);
1002
1003         return ret;
1004 }
1005
1006 static inline int uhci_submit_interrupt(struct uhci_hcd *uhci, struct urb *urb, struct urb *eurb)
1007 {
1008         /* USB 1.1 interrupt transfers only involve one packet per interval;
1009          * that's the uhci_submit_common() "breadth first" policy.  Drivers
1010          * can submit urbs of any length, but longer ones might need many
1011          * intervals to complete.
1012          */
1013         return uhci_submit_common(uhci, urb, eurb, uhci->skelqh[__interval_to_skel(urb->interval)]);
1014 }
1015
1016 /*
1017  * Isochronous transfers
1018  */
1019 static int isochronous_find_limits(struct uhci_hcd *uhci, struct urb *urb, unsigned int *start, unsigned int *end)
1020 {
1021         struct urb *last_urb = NULL;
1022         struct urb_priv *up;
1023         int ret = 0;
1024
1025         list_for_each_entry(up, &uhci->urb_list, urb_list) {
1026                 struct urb *u = up->urb;
1027
1028                 /* look for pending URBs with identical pipe handle */
1029                 if ((urb->pipe == u->pipe) && (urb->dev == u->dev) &&
1030                     (u->status == -EINPROGRESS) && (u != urb)) {
1031                         if (!last_urb)
1032                                 *start = u->start_frame;
1033                         last_urb = u;
1034                 }
1035         }
1036
1037         if (last_urb) {
1038                 *end = (last_urb->start_frame + last_urb->number_of_packets *
1039                                 last_urb->interval) & (UHCI_NUMFRAMES-1);
1040                 ret = 0;
1041         } else
1042                 ret = -1;       /* no previous urb found */
1043
1044         return ret;
1045 }
1046
1047 static int isochronous_find_start(struct uhci_hcd *uhci, struct urb *urb)
1048 {
1049         int limits;
1050         unsigned int start = 0, end = 0;
1051
1052         if (urb->number_of_packets > 900)       /* 900? Why? */
1053                 return -EFBIG;
1054
1055         limits = isochronous_find_limits(uhci, urb, &start, &end);
1056
1057         if (urb->transfer_flags & URB_ISO_ASAP) {
1058                 if (limits) {
1059                         uhci_get_current_frame_number(uhci);
1060                         urb->start_frame = (uhci->frame_number + 10)
1061                                         & (UHCI_NUMFRAMES - 1);
1062                 } else
1063                         urb->start_frame = end;
1064         } else {
1065                 urb->start_frame &= (UHCI_NUMFRAMES - 1);
1066                 /* FIXME: Sanity check */
1067         }
1068
1069         return 0;
1070 }
1071
1072 /*
1073  * Isochronous transfers
1074  */
1075 static int uhci_submit_isochronous(struct uhci_hcd *uhci, struct urb *urb)
1076 {
1077         struct uhci_td *td;
1078         int i, ret, frame;
1079         int status, destination;
1080         struct urb_priv *urbp = (struct urb_priv *) urb->hcpriv;
1081
1082         status = TD_CTRL_ACTIVE | TD_CTRL_IOS;
1083         destination = (urb->pipe & PIPE_DEVEP_MASK) | usb_packetid(urb->pipe);
1084
1085         ret = isochronous_find_start(uhci, urb);
1086         if (ret)
1087                 return ret;
1088
1089         for (i = 0; i < urb->number_of_packets; i++) {
1090                 td = uhci_alloc_td(uhci);
1091                 if (!td)
1092                         return -ENOMEM;
1093
1094                 uhci_add_td_to_urb(urb, td);
1095                 uhci_fill_td(td, status, destination | uhci_explen(urb->iso_frame_desc[i].length),
1096                         urb->transfer_dma + urb->iso_frame_desc[i].offset);
1097
1098                 if (i + 1 >= urb->number_of_packets)
1099                         td->status |= cpu_to_le32(TD_CTRL_IOC);
1100         }
1101
1102         frame = urb->start_frame;
1103         list_for_each_entry(td, &urbp->td_list, list) {
1104                 uhci_insert_td_frame_list(uhci, td, frame);
1105                 frame += urb->interval;
1106         }
1107
1108         return -EINPROGRESS;
1109 }
1110
1111 static int uhci_result_isochronous(struct uhci_hcd *uhci, struct urb *urb)
1112 {
1113         struct uhci_td *td;
1114         struct urb_priv *urbp = (struct urb_priv *)urb->hcpriv;
1115         int status;
1116         int i, ret = 0;
1117
1118         urb->actual_length = urb->error_count = 0;
1119
1120         i = 0;
1121         list_for_each_entry(td, &urbp->td_list, list) {
1122                 int actlength;
1123                 unsigned int ctrlstat = td_status(td);
1124
1125                 if (ctrlstat & TD_CTRL_ACTIVE)
1126                         return -EINPROGRESS;
1127
1128                 actlength = uhci_actual_length(ctrlstat);
1129                 urb->iso_frame_desc[i].actual_length = actlength;
1130                 urb->actual_length += actlength;
1131
1132                 status = uhci_map_status(uhci_status_bits(ctrlstat),
1133                                 usb_pipeout(urb->pipe));
1134                 urb->iso_frame_desc[i].status = status;
1135                 if (status) {
1136                         urb->error_count++;
1137                         ret = status;
1138                 }
1139
1140                 i++;
1141         }
1142         unlink_isochronous_tds(uhci, urb);
1143
1144         return ret;
1145 }
1146
1147 static struct urb *uhci_find_urb_ep(struct uhci_hcd *uhci, struct urb *urb)
1148 {
1149         struct urb_priv *up;
1150
1151         /* We don't match Isoc transfers since they are special */
1152         if (usb_pipeisoc(urb->pipe))
1153                 return NULL;
1154
1155         list_for_each_entry(up, &uhci->urb_list, urb_list) {
1156                 struct urb *u = up->urb;
1157
1158                 if (u->dev == urb->dev && u->status == -EINPROGRESS) {
1159                         /* For control, ignore the direction */
1160                         if (usb_pipecontrol(urb->pipe) &&
1161                             (u->pipe & ~USB_DIR_IN) == (urb->pipe & ~USB_DIR_IN))
1162                                 return u;
1163                         else if (u->pipe == urb->pipe)
1164                                 return u;
1165                 }
1166         }
1167
1168         return NULL;
1169 }
1170
1171 static int uhci_urb_enqueue(struct usb_hcd *hcd,
1172                 struct usb_host_endpoint *ep,
1173                 struct urb *urb, gfp_t mem_flags)
1174 {
1175         int ret;
1176         struct uhci_hcd *uhci = hcd_to_uhci(hcd);
1177         unsigned long flags;
1178         struct urb *eurb;
1179         int bustime;
1180
1181         spin_lock_irqsave(&uhci->lock, flags);
1182
1183         ret = urb->status;
1184         if (ret != -EINPROGRESS)                /* URB already unlinked! */
1185                 goto out;
1186
1187         eurb = uhci_find_urb_ep(uhci, urb);
1188
1189         if (!uhci_alloc_urb_priv(uhci, urb)) {
1190                 ret = -ENOMEM;
1191                 goto out;
1192         }
1193
1194         switch (usb_pipetype(urb->pipe)) {
1195         case PIPE_CONTROL:
1196                 ret = uhci_submit_control(uhci, urb, eurb);
1197                 break;
1198         case PIPE_INTERRUPT:
1199                 if (!eurb) {
1200                         bustime = usb_check_bandwidth(urb->dev, urb);
1201                         if (bustime < 0)
1202                                 ret = bustime;
1203                         else {
1204                                 ret = uhci_submit_interrupt(uhci, urb, eurb);
1205                                 if (ret == -EINPROGRESS)
1206                                         usb_claim_bandwidth(urb->dev, urb, bustime, 0);
1207                         }
1208                 } else {        /* inherit from parent */
1209                         urb->bandwidth = eurb->bandwidth;
1210                         ret = uhci_submit_interrupt(uhci, urb, eurb);
1211                 }
1212                 break;
1213         case PIPE_BULK:
1214                 ret = uhci_submit_bulk(uhci, urb, eurb);
1215                 break;
1216         case PIPE_ISOCHRONOUS:
1217                 bustime = usb_check_bandwidth(urb->dev, urb);
1218                 if (bustime < 0) {
1219                         ret = bustime;
1220                         break;
1221                 }
1222
1223                 ret = uhci_submit_isochronous(uhci, urb);
1224                 if (ret == -EINPROGRESS)
1225                         usb_claim_bandwidth(urb->dev, urb, bustime, 1);
1226                 break;
1227         }
1228
1229         if (ret != -EINPROGRESS) {
1230                 /* Submit failed, so delete it from the urb_list */
1231                 struct urb_priv *urbp = urb->hcpriv;
1232
1233                 list_del_init(&urbp->urb_list);
1234                 uhci_destroy_urb_priv(uhci, urb);
1235         } else
1236                 ret = 0;
1237
1238 out:
1239         spin_unlock_irqrestore(&uhci->lock, flags);
1240         return ret;
1241 }
1242
1243 /*
1244  * Return the result of a transfer
1245  */
1246 static void uhci_transfer_result(struct uhci_hcd *uhci, struct urb *urb)
1247 {
1248         int ret = -EINPROGRESS;
1249         struct urb_priv *urbp;
1250
1251         spin_lock(&urb->lock);
1252
1253         urbp = (struct urb_priv *)urb->hcpriv;
1254
1255         if (urb->status != -EINPROGRESS)        /* URB already dequeued */
1256                 goto out;
1257
1258         switch (usb_pipetype(urb->pipe)) {
1259         case PIPE_CONTROL:
1260                 ret = uhci_result_control(uhci, urb);
1261                 break;
1262         case PIPE_BULK:
1263         case PIPE_INTERRUPT:
1264                 ret = uhci_result_common(uhci, urb);
1265                 break;
1266         case PIPE_ISOCHRONOUS:
1267                 ret = uhci_result_isochronous(uhci, urb);
1268                 break;
1269         }
1270
1271         if (ret == -EINPROGRESS)
1272                 goto out;
1273         urb->status = ret;
1274
1275         switch (usb_pipetype(urb->pipe)) {
1276         case PIPE_CONTROL:
1277         case PIPE_BULK:
1278         case PIPE_ISOCHRONOUS:
1279                 /* Release bandwidth for Interrupt or Isoc. transfers */
1280                 if (urb->bandwidth)
1281                         usb_release_bandwidth(urb->dev, urb, 1);
1282                 uhci_unlink_generic(uhci, urb);
1283                 break;
1284         case PIPE_INTERRUPT:
1285                 /* Release bandwidth for Interrupt or Isoc. transfers */
1286                 /* Make sure we don't release if we have a queued URB */
1287                 if (list_empty(&urbp->queue_list) && urb->bandwidth)
1288                         usb_release_bandwidth(urb->dev, urb, 0);
1289                 else
1290                         /* bandwidth was passed on to queued URB, */
1291                         /* so don't let usb_unlink_urb() release it */
1292                         urb->bandwidth = 0;
1293                 uhci_unlink_generic(uhci, urb);
1294                 break;
1295         default:
1296                 dev_info(uhci_dev(uhci), "%s: unknown pipe type %d "
1297                                 "for urb %p\n",
1298                                 __FUNCTION__, usb_pipetype(urb->pipe), urb);
1299         }
1300
1301         /* Move it from uhci->urb_list to uhci->complete_list */
1302         uhci_moveto_complete(uhci, urbp);
1303
1304 out:
1305         spin_unlock(&urb->lock);
1306 }
1307
1308 static void uhci_unlink_generic(struct uhci_hcd *uhci, struct urb *urb)
1309 {
1310         struct list_head *head;
1311         struct uhci_td *td;
1312         struct urb_priv *urbp = (struct urb_priv *)urb->hcpriv;
1313         int prevactive = 0;
1314
1315         uhci_dec_fsbr(uhci, urb);       /* Safe since it checks */
1316
1317         /*
1318          * Now we need to find out what the last successful toggle was
1319          * so we can update the local data toggle for the next transfer
1320          *
1321          * There are 2 ways the last successful completed TD is found:
1322          *
1323          * 1) The TD is NOT active and the actual length < expected length
1324          * 2) The TD is NOT active and it's the last TD in the chain
1325          *
1326          * and a third way the first uncompleted TD is found:
1327          *
1328          * 3) The TD is active and the previous TD is NOT active
1329          *
1330          * Control and Isochronous ignore the toggle, so this is safe
1331          * for all types
1332          *
1333          * FIXME: The toggle fixups won't be 100% reliable until we
1334          * change over to using a single queue for each endpoint and
1335          * stop the queue before unlinking.
1336          */
1337         head = &urbp->td_list;
1338         list_for_each_entry(td, head, list) {
1339                 unsigned int ctrlstat = td_status(td);
1340
1341                 if (!(ctrlstat & TD_CTRL_ACTIVE) &&
1342                                 (uhci_actual_length(ctrlstat) <
1343                                  uhci_expected_length(td_token(td)) ||
1344                                 td->list.next == head))
1345                         usb_settoggle(urb->dev, uhci_endpoint(td_token(td)),
1346                                 uhci_packetout(td_token(td)),
1347                                 uhci_toggle(td_token(td)) ^ 1);
1348                 else if ((ctrlstat & TD_CTRL_ACTIVE) && !prevactive)
1349                         usb_settoggle(urb->dev, uhci_endpoint(td_token(td)),
1350                                 uhci_packetout(td_token(td)),
1351                                 uhci_toggle(td_token(td)));
1352
1353                 prevactive = ctrlstat & TD_CTRL_ACTIVE;
1354         }
1355
1356         uhci_delete_queued_urb(uhci, urb);
1357
1358         /* The interrupt loop will reclaim the QHs */
1359         uhci_remove_qh(uhci, urbp->qh);
1360         urbp->qh = NULL;
1361 }
1362
1363 static int uhci_urb_dequeue(struct usb_hcd *hcd, struct urb *urb)
1364 {
1365         struct uhci_hcd *uhci = hcd_to_uhci(hcd);
1366         unsigned long flags;
1367         struct urb_priv *urbp;
1368
1369         spin_lock_irqsave(&uhci->lock, flags);
1370         urbp = urb->hcpriv;
1371         if (!urbp)                      /* URB was never linked! */
1372                 goto done;
1373         list_del_init(&urbp->urb_list);
1374
1375         if (usb_pipetype(urb->pipe) == PIPE_ISOCHRONOUS)
1376                 unlink_isochronous_tds(uhci, urb);
1377         uhci_unlink_generic(uhci, urb);
1378
1379         uhci_get_current_frame_number(uhci);
1380         if (uhci->frame_number + uhci->is_stopped != uhci->urb_remove_age) {
1381                 uhci_remove_pending_urbps(uhci);
1382                 uhci->urb_remove_age = uhci->frame_number;
1383         }
1384
1385         /* If we're the first, set the next interrupt bit */
1386         if (list_empty(&uhci->urb_remove_list))
1387                 uhci_set_next_interrupt(uhci);
1388         list_add_tail(&urbp->urb_list, &uhci->urb_remove_list);
1389
1390 done:
1391         spin_unlock_irqrestore(&uhci->lock, flags);
1392         return 0;
1393 }
1394
1395 static int uhci_fsbr_timeout(struct uhci_hcd *uhci, struct urb *urb)
1396 {
1397         struct urb_priv *urbp = (struct urb_priv *)urb->hcpriv;
1398         struct list_head *head;
1399         struct uhci_td *td;
1400         int count = 0;
1401
1402         uhci_dec_fsbr(uhci, urb);
1403
1404         urbp->fsbr_timeout = 1;
1405
1406         /*
1407          * Ideally we would want to fix qh->element as well, but it's
1408          * read/write by the HC, so that can introduce a race. It's not
1409          * really worth the hassle
1410          */
1411
1412         head = &urbp->td_list;
1413         list_for_each_entry(td, head, list) {
1414                 /*
1415                  * Make sure we don't do the last one (since it'll have the
1416                  * TERM bit set) as well as we skip every so many TDs to
1417                  * make sure it doesn't hog the bandwidth
1418                  */
1419                 if (td->list.next != head && (count % DEPTH_INTERVAL) ==
1420                                 (DEPTH_INTERVAL - 1))
1421                         td->link |= UHCI_PTR_DEPTH;
1422
1423                 count++;
1424         }
1425
1426         return 0;
1427 }
1428
1429 static void uhci_free_pending_qhs(struct uhci_hcd *uhci)
1430 {
1431         struct uhci_qh *qh, *tmp;
1432
1433         list_for_each_entry_safe(qh, tmp, &uhci->qh_remove_list, remove_list) {
1434                 list_del_init(&qh->remove_list);
1435
1436                 uhci_free_qh(uhci, qh);
1437         }
1438 }
1439
1440 static void uhci_free_pending_tds(struct uhci_hcd *uhci)
1441 {
1442         struct uhci_td *td, *tmp;
1443
1444         list_for_each_entry_safe(td, tmp, &uhci->td_remove_list, remove_list) {
1445                 list_del_init(&td->remove_list);
1446
1447                 uhci_free_td(uhci, td);
1448         }
1449 }
1450
1451 static void
1452 uhci_finish_urb(struct usb_hcd *hcd, struct urb *urb, struct pt_regs *regs)
1453 __releases(uhci->lock)
1454 __acquires(uhci->lock)
1455 {
1456         struct uhci_hcd *uhci = hcd_to_uhci(hcd);
1457
1458         uhci_destroy_urb_priv(uhci, urb);
1459
1460         spin_unlock(&uhci->lock);
1461         usb_hcd_giveback_urb(hcd, urb, regs);
1462         spin_lock(&uhci->lock);
1463 }
1464
1465 static void uhci_finish_completion(struct uhci_hcd *uhci, struct pt_regs *regs)
1466 {
1467         struct urb_priv *urbp, *tmp;
1468
1469         list_for_each_entry_safe(urbp, tmp, &uhci->complete_list, urb_list) {
1470                 struct urb *urb = urbp->urb;
1471
1472                 list_del_init(&urbp->urb_list);
1473                 uhci_finish_urb(uhci_to_hcd(uhci), urb, regs);
1474         }
1475 }
1476
1477 static void uhci_remove_pending_urbps(struct uhci_hcd *uhci)
1478 {
1479
1480         /* Splice the urb_remove_list onto the end of the complete_list */
1481         list_splice_init(&uhci->urb_remove_list, uhci->complete_list.prev);
1482 }
1483
1484 /* Process events in the schedule, but only in one thread at a time */
1485 static void uhci_scan_schedule(struct uhci_hcd *uhci, struct pt_regs *regs)
1486 {
1487         struct urb_priv *urbp, *tmp;
1488
1489         /* Don't allow re-entrant calls */
1490         if (uhci->scan_in_progress) {
1491                 uhci->need_rescan = 1;
1492                 return;
1493         }
1494         uhci->scan_in_progress = 1;
1495  rescan:
1496         uhci->need_rescan = 0;
1497
1498         uhci_clear_next_interrupt(uhci);
1499         uhci_get_current_frame_number(uhci);
1500
1501         if (uhci->frame_number + uhci->is_stopped != uhci->qh_remove_age)
1502                 uhci_free_pending_qhs(uhci);
1503         if (uhci->frame_number + uhci->is_stopped != uhci->td_remove_age)
1504                 uhci_free_pending_tds(uhci);
1505         if (uhci->frame_number + uhci->is_stopped != uhci->urb_remove_age)
1506                 uhci_remove_pending_urbps(uhci);
1507
1508         /* Walk the list of pending URBs to see which ones completed
1509          * (must be _safe because uhci_transfer_result() dequeues URBs) */
1510         list_for_each_entry_safe(urbp, tmp, &uhci->urb_list, urb_list) {
1511                 struct urb *urb = urbp->urb;
1512
1513                 /* Checks the status and does all of the magic necessary */
1514                 uhci_transfer_result(uhci, urb);
1515         }
1516         uhci_finish_completion(uhci, regs);
1517
1518         /* If the controller is stopped, we can finish these off right now */
1519         if (uhci->is_stopped) {
1520                 uhci_free_pending_qhs(uhci);
1521                 uhci_free_pending_tds(uhci);
1522                 uhci_remove_pending_urbps(uhci);
1523         }
1524
1525         if (uhci->need_rescan)
1526                 goto rescan;
1527         uhci->scan_in_progress = 0;
1528
1529         if (list_empty(&uhci->urb_remove_list) &&
1530             list_empty(&uhci->td_remove_list) &&
1531             list_empty(&uhci->qh_remove_list))
1532                 uhci_clear_next_interrupt(uhci);
1533         else
1534                 uhci_set_next_interrupt(uhci);
1535
1536         /* Wake up anyone waiting for an URB to complete */
1537         wake_up_all(&uhci->waitqh);
1538 }
1539
1540 static void check_fsbr(struct uhci_hcd *uhci)
1541 {
1542         struct urb_priv *up;
1543
1544         list_for_each_entry(up, &uhci->urb_list, urb_list) {
1545                 struct urb *u = up->urb;
1546
1547                 spin_lock(&u->lock);
1548
1549                 /* Check if the FSBR timed out */
1550                 if (up->fsbr && !up->fsbr_timeout && time_after_eq(jiffies, up->fsbrtime + IDLE_TIMEOUT))
1551                         uhci_fsbr_timeout(uhci, u);
1552
1553                 spin_unlock(&u->lock);
1554         }
1555
1556         /* Really disable FSBR */
1557         if (!uhci->fsbr && uhci->fsbrtimeout && time_after_eq(jiffies, uhci->fsbrtimeout)) {
1558                 uhci->fsbrtimeout = 0;
1559                 uhci->skel_term_qh->link = UHCI_PTR_TERM;
1560         }
1561 }