/* Remove the link from the last async QH to the terminating
* skeleton QH. */
uhci->fsbr_is_on = 0;
lqh = list_entry(uhci->skel_async_qh->node.prev, struct uhci_qh, node);
lqh->link = UHCI_PTR_TERM(uhci);
}
staticvoid 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);
/* Isochronous pipes don't use toggles and their TD link pointers *getadjustedduringuhci_urb_dequeue().Butsincetheirqueues *cannottrulybestopped,wehavetowatchoutfordequeues
* occurring after the nominal unlink frame. */ if (qh->type == USB_ENDPOINT_XFER_ISOC) {
ret = (uhci->frame_number + uhci->is_stopped !=
qh->unlink_frame); goto done;
}
/* If the URB isn't first on its queue, adjust the link pointer *ofthelastTDinthepreviousURB.Thetoggledoesn'tneed
* 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;
/* If the QH element pointer is UHCI_PTR_TERM then then currently
* executing URB has already been unlinked, so this one isn't it. */ if (qh_element(qh) == UHCI_PTR_TERM(uhci)) goto done;
qh->element = UHCI_PTR_TERM(uhci);
/* Control pipes don't have to worry about toggles */ if (qh->type == USB_ENDPOINT_XFER_CONTROL) goto done;
/* Save the next toggle value */
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(uhci, td));
/* 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. */ elseif (qh_element(qh) != UHCI_PTR_TERM(uhci))
toggle = 2;
/* Fix up the toggle for the URBs in the queue. Normally this *loopwon'trunmorethanonce:Whenanerrororshorttransfer
* occurs, the queue usually gets emptied. */
urbp = list_prepare_entry(urbp, &qh->queue, node);
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(uhci, td)) == toggle) {
td = list_entry(urbp->td_list.prev, struct uhci_td,
list);
toggle = uhci_toggle(td_token(uhci, 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 ^= cpu_to_hc32(uhci,
TD_TOKEN_TOGGLE);
toggle ^= 1;
}
}
}
/* Find the predecessor QH for our new one and insert it in the list. *ThelistofQHsisexpectedtobeshort,solinearsearchwon't
* take too long. */
list_for_each_entry_reverse(pqh, &uhci->skel_async_qh->node, node) { if (pqh->skel <= qh->skel) break;
}
list_add(&qh->node, &pqh->node);
/* Link it into the schedule */
qh->link = pqh->link;
wmb();
link_to_new_qh = LINK_TO_QH(uhci, qh);
pqh->link = link_to_new_qh;
/* If this is now the first FSBR QH, link the terminating skeleton
* QH to it. */ if (pqh->skel < SKEL_FSBR && qh->skel >= SKEL_FSBR)
uhci->skel_term_qh->link = link_to_new_qh;
}
/* 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(uhci)) { 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);
qh->element = LINK_TO_TD(uhci, td);
}
/* Treat the queue as if it has just advanced */
qh->wait_expired = 0;
qh->advance_jiffies = jiffies;
if (qh->state == QH_STATE_ACTIVE) return;
qh->state = QH_STATE_ACTIVE;
/* Move the QH from its old list to the correct spot in the appropriate
* skeleton's list */ if (qh == uhci->next_qh)
uhci->next_qh = list_entry(qh->node.next, struct uhci_qh,
node);
list_del(&qh->node);
/* If this was the old first FSBR QH, link the terminating skeleton
* QH to the next (new first FSBR) QH. */ if (pqh->skel < SKEL_FSBR && qh->skel >= SKEL_FSBR)
uhci->skel_term_qh->link = link_to_next_qh;
mb();
}
/* Unlink the QH from the schedule and record when we did it */ if (qh->skel == SKEL_ISO)
; elseif (qh->skel < SKEL_ASYNC)
unlink_interrupt(uhci, qh); else
unlink_async(uhci, qh);
/* Force an interrupt so we know when the QH is fully unlinked */ if (list_empty(&uhci->skel_unlink_qh->node) || uhci->is_stopped)
uhci_set_next_interrupt(uhci);
/* Move the QH from its old list to the end of the unlinking list */ if (qh == uhci->next_qh)
uhci->next_qh = list_entry(qh->node.next, struct uhci_qh,
node);
list_move_tail(&qh->node, &uhci->skel_unlink_qh->node);
}
/* Find the optimal phase (unless it is already set) and get
* its load value. */ if (qh->phase >= 0)
minimax_load = uhci_highest_load(uhci, qh->phase, qh->period); else { int phase, load; int max_phase = min_t(int, MAX_PHASE, qh->period);
/* Low-speed transfers get a different queue, and won't hog the bus. *Also,somedevicesenumeratebetterwithoutFSBR;theeasiestway *todothatistoputURBsonthelow-speedqueuewhilethedevice
* isn't in the CONFIGURED state. */ if (urb->dev->speed == USB_SPEED_LOW ||
urb->dev->state != USB_STATE_CONFIGURED)
skel = SKEL_LS_CONTROL; else {
skel = SKEL_FS_CONTROL;
uhci_add_fsbr(uhci, urb);
} if (qh->state != QH_STATE_ACTIVE)
qh->skel = skel; return0;
nomem: /* Remove the dummy TD from the td_list so it doesn't get freed */
uhci_remove_td_from_urbp(qh->dummy_td); return -ENOMEM;
}
/* *Commonsubmitforbulkandinterrupt
*/ staticint uhci_submit_common(struct uhci_hcd *uhci, struct urb *urb, struct uhci_qh *qh)
{ struct uhci_td *td; unsignedlong destination, status; int maxsze = usb_endpoint_maxp(&qh->hep->desc); int len = urb->transfer_buffer_length; int this_sg_len;
dma_addr_t data;
__hc32 *plink; struct urb_priv *urbp = urb->hcpriv; unsignedint toggle; struct scatterlist *sg; int i;
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);
toggle = usb_gettoggle(urb->dev, usb_pipeendpoint(urb->pipe),
usb_pipeout(urb->pipe));
/* 3 errors, dummy TD remains inactive */
status = uhci_maxerr(3); if (urb->dev->speed == USB_SPEED_LOW)
status |= TD_CTRL_LS; if (usb_pipein(urb->pipe))
status |= TD_CTRL_SPD;
i = urb->num_mapped_sgs; if (len > 0 && i > 0) {
sg = urb->sg;
data = sg_dma_address(sg);
/* urb->transfer_buffer_length may be smaller than the *sizeofthescatterlist(orviceversa)
*/
this_sg_len = min_t(int, sg_dma_len(sg), len);
} else {
sg = NULL;
data = urb->transfer_dma;
this_sg_len = len;
} /* *BuildtheDATATDs
*/
plink = NULL;
td = qh->dummy_td; for (;;) { /* Allow zero length packets */ int pktsze = maxsze;
if (len <= pktsze) { /* The last packet */
pktsze = len; if (!(urb->transfer_flags & URB_SHORT_NOT_OK))
status &= ~TD_CTRL_SPD;
}
/* Set the interrupt-on-completion flag on the last packet. *Amore-or-lesstypical4KBURB(=sizeofonememorypage) *willrequireabout3mstotransfer;that'salittleonthe *fastsidebutnotenoughtojustifydelayinganinterrupt *morethan2or3URBs,sowewillignoretheURB_NO_INTERRUPT
* flag setting. */
td->status |= cpu_to_hc32(uhci, TD_CTRL_IOC);
/* USB 1.1 interrupt transfers only involve one packet per interval. *DriverscansubmitURBsofanylength,butlongeroneswillneed *multipleintervalstocomplete.
*/
if (!qh->bandwidth_reserved) { int exponent;
/* 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;
/* If the slot is full, try a lower period */ do {
qh->period = 1 << exponent;
qh->skel = SKEL_INDEX(exponent);
/* For now, interrupt phase is fixed by the layout *oftheQHlists.
*/
qh->phase = (qh->period / 2) & (MAX_PHASE - 1);
ret = uhci_check_bandwidth(uhci, qh);
} while (ret != 0 && --exponent >= 0); if (ret) return ret;
} elseif (qh->period > urb->interval) return -EINVAL; /* Can't decrease the period */
ret = uhci_submit_common(uhci, urb, qh); if (ret == 0) {
urb->interval = qh->period; if (!qh->bandwidth_reserved)
uhci_reserve_bandwidth(uhci, qh);
} return ret;
}
/* When a control transfer is short, we have to restart *thequeueatthestatusstagetransaction,whichis
* the last TD. */
WARN_ON(list_empty(&urbp->td_list));
qh->element = LINK_TO_TD(uhci, td);
tmp = td->list.prev;
ret = -EINPROGRESS;
} else {
/* When a bulk/interrupt transfer is short, we have to *fixupthetogglesofthefollowingURBsonthequeue
* before restarting the queue at the next URB. */
qh->initial_toggle =
uhci_toggle(td_token(uhci, qh->post_td)) ^ 1;
uhci_fixup_toggles(uhci, qh, 1);
if (list_empty(&urbp->td_list))
td = qh->post_td;
qh->element = td->link;
tmp = urbp->td_list.prev;
ret = 0;
}
/* 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;
list_for_each_entry_safe(td, tmp, &urbp->td_list, list) { unsignedint ctrlstat; int len;
ctrlstat = td_status(uhci, 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(uhci, td))); if ((debug == 1 && ret != -EPIPE) || debug > 1) { /* Some debugging code */
dev_dbg(&urb->dev->dev, "%s: failed with status %x\n",
__func__, status);
if (debug > 1 && errbuf) { /* Print the chain for debugging */
uhci_show_qh(uhci, urbp->qh, errbuf,
ERRBUF_LEN - EXTRA_SPACE, 0);
lprintk(errbuf);
}
}
/* Did we receive a short packet? */
} elseif (len < uhci_expected_length(td_token(uhci, td))) {
/* For control transfers, go to the status TD if
* this isn't already the last data TD */ if (qh->type == USB_ENDPOINT_XFER_CONTROL) { if (td->list.next != urbp->td_list.prev)
ret = 1;
}
/* For bulk and interrupt, this may be an error */ elseif (urb->transfer_flags & URB_SHORT_NOT_OK)
ret = -EREMOTEIO;
/* Fixup needed only if this isn't the URB's last TD */ elseif (&td->list != urbp->td_list.prev)
ret = 1;
}
uhci_remove_td_from_urbp(td); if (qh->post_td)
uhci_free_td(uhci, qh->post_td);
qh->post_td = td;
if (ret != 0) goto err;
} return ret;
err: if (ret < 0) { /* Note that the queue has stopped and save
* the next toggle value */
qh->element = UHCI_PTR_TERM(uhci);
qh->is_stopped = 1;
qh->needs_fixup = (qh->type != USB_ENDPOINT_XFER_CONTROL);
qh->initial_toggle = uhci_toggle(td_token(uhci, td)) ^
(ret == -EREMOTEIO);
} else/* Short packet received */
ret = uhci_fixup_short_transfer(uhci, qh, urbp); return ret;
}
/* Values must not be too big (could overflow below) */ if (urb->interval >= UHCI_NUMFRAMES ||
urb->number_of_packets >= UHCI_NUMFRAMES) return -EFBIG;
uhci_get_current_frame_number(uhci);
/* Check the period and figure out the starting frame number */ if (!qh->bandwidth_reserved) {
qh->period = urb->interval;
qh->phase = -1; /* Find the best phase */
i = uhci_check_bandwidth(uhci, qh); if (i) return i;
/* Allow a little time to allocate the TDs */
next = uhci->frame_number + 10;
frame = qh->phase;
/* Round up to the first available slot */
frame += (next - frame + qh->period - 1) & -qh->period;
} elseif (qh->period != urb->interval) { return -EINVAL; /* Can't change the period */
} else {
next = uhci->frame_number + 1;
/* Find the next unused frame */ if (list_empty(&qh->queue)) {
frame = qh->iso_frame;
} else { struct urb *lurb;
/* Fell behind? */ if (!uhci_frame_before_eq(next, frame)) {
/* USB_ISO_ASAP: Round up to the first available slot */ if (urb->transfer_flags & URB_ISO_ASAP)
frame += (next - frame + qh->period - 1) &
-qh->period;
/* Make sure we won't have to go too far into the future */ if (uhci_frame_before_eq(uhci->last_iso_frame + UHCI_NUMFRAMES,
frame + urb->number_of_packets * urb->interval)) return -EFBIG;
urb->start_frame = frame;
ret = usb_hcd_link_urb_to_ep(hcd, urb); if (ret) goto done_not_linked;
ret = -ENOMEM;
urbp = uhci_alloc_urb_priv(uhci, urb); if (!urbp) goto done;
if (urb->ep->hcpriv)
qh = urb->ep->hcpriv; else {
qh = uhci_alloc_qh(uhci, urb->dev, urb->ep); if (!qh) goto err_no_qh;
}
urbp->qh = qh;
switch (qh->type) { case USB_ENDPOINT_XFER_CONTROL:
ret = uhci_submit_control(uhci, urb, qh); break; case USB_ENDPOINT_XFER_BULK:
ret = uhci_submit_bulk(uhci, urb, qh); break; case USB_ENDPOINT_XFER_INT:
ret = uhci_submit_interrupt(uhci, urb, qh); break; case USB_ENDPOINT_XFER_ISOC:
urb->error_count = 0;
ret = uhci_submit_isochronous(uhci, urb, qh); break;
} if (ret != 0) goto err_submit_failed;
/* Add this URB to the QH */
list_add_tail(&urbp->node, &qh->queue);
/* If the new URB is the first and only one on this QH then either *theQHisnewandidleorelseit'sunlinkedandwaitingto *becomeidle,sowecanactivateitrightaway.Butonlyifthe
* queue isn't stopped. */ if (qh->queue.next == &urbp->node && !qh->is_stopped) {
uhci_activate_qh(uhci, qh);
uhci_urbp_wants_fsbr(uhci, urbp);
} goto done;
/* Remove Isochronous TDs from the frame list ASAP */ if (qh->type == USB_ENDPOINT_XFER_ISOC) {
uhci_unlink_isochronous_tds(uhci, urb);
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;
}
/* Subtract off the length of the SETUP packet from *urb->actual_length.
*/
urb->actual_length -= min_t(u32, 8, urb->actual_length);
}
/* When giving back the first URB in an Isochronous queue,
* reinitialize the QH's iso-related members for the next URB. */ elseif (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;
/* 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;
}
/* 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); if (qh->bandwidth_reserved)
uhci_release_bandwidth(uhci, qh);
}
}
if (qh->type == USB_ENDPOINT_XFER_ISOC)
status = uhci_result_isochronous(uhci, urb); else
status = uhci_result_common(uhci, urb); if (status == -EINPROGRESS) break;
/* Dequeued but completed URBs can't be given back unless
* the QH is stopped or has finished unlinking. */ if (urb->unlinked) { if (QH_FINISHED_UNLINKING(qh))
qh->is_stopped = 1; elseif (!qh->is_stopped) return;
}
uhci_giveback_urb(uhci, qh, urb, status); if (status < 0) break;
}
/* If the QH is neither stopped nor finished unlinking (normal case),
* our work here is done. */ if (QH_FINISHED_UNLINKING(qh))
qh->is_stopped = 1; elseif (!qh->is_stopped) return;
/* Otherwise give back each of the dequeued URBs */
restart:
list_for_each_entry(urbp, &qh->queue, node) {
urb = urbp->urb; if (urb->unlinked) {
/* Fix up the TD links and save the toggles for *non-Isochronousqueues.ForIsochronousqueues,
* test for too-recent dequeues. */ if (!uhci_cleanup_queue(uhci, qh, urb)) {
qh->is_stopped = 0; return;
}
uhci_giveback_urb(uhci, qh, urb, 0); goto restart;
}
}
qh->is_stopped = 0;
/* 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(uhci, qh, 0);
/* If the first URB on the queue wants FSBR but its time *limithasexpired,setthenextTDtointerrupton
* 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_hc32(uhci, TD_CTRL_IOC);
}
uhci_activate_qh(uhci, qh);
}
/* The queue is empty. The QH can become idle if it is fully
* unlinked. */ elseif (QH_FINISHED_UNLINKING(qh))
uhci_make_qh_idle(uhci, qh);
}
if (qh->type == USB_ENDPOINT_XFER_ISOC) goto done;
/* Treat an UNLINKING queue as though it hasn't advanced. *Thisisokaybecausereactivationwilltreatitasthough *ithasadvanced,andifitisgoingtobecomeIDLEthen *thisdoesn'tmatteranyway.Furthermoreit'spossible *foranUNLINKINGqueuenottohaveanyURBsatall,or *foritsfirstURBnottohaveanyTDs(ifitwasdequeued *justasitcompleted).Soit'snoteasyinanycaseto
* test whether such queues have advanced. */ if (qh->state != QH_STATE_ACTIVE) {
urbp = NULL;
status = 0;
/* We're okay, the queue has advanced */
qh->wait_expired = 0;
qh->advance_jiffies = jiffies; goto done;
}
ret = uhci->is_stopped;
}
/* The queue hasn't advanced; check for timeout */ if (qh->wait_expired) goto done;
if (time_after(jiffies, qh->advance_jiffies + QH_WAIT_TIMEOUT)) {
/* Detect the Intel bug and work around it */ if (qh->post_td && qh_element(qh) ==
LINK_TO_TD(uhci, qh->post_td)) {
qh->element = qh->post_td->link;
qh->advance_jiffies = jiffies;
ret = 1; goto done;
}
qh->wait_expired = 1;
/* If the current URB wants FSBR, unlink it temporarily *sothatwecansafelysetthenextTDtointerrupton *completion.Thatwaywe'llknowassoonasthequeue
* starts moving again. */ if (urbp && urbp->fsbr && !(status & TD_CTRL_IOC))
uhci_unlink_qh(uhci, qh);
} else { /* Unmoving but not-yet-expired queues keep FSBR alive */ if (urbp)
uhci_urbp_wants_fsbr(uhci, urbp);
}
/* 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);
if (uhci_advance_check(uhci, qh)) {
uhci_scan_qh(uhci, qh); if (qh->state == QH_STATE_ACTIVE) {
uhci_urbp_wants_fsbr(uhci,
list_entry(qh->queue.next, struct urb_priv, node));
}
}
}
}
uhci->last_iso_frame = uhci->cur_iso_frame; if (uhci->need_rescan) goto rescan;
uhci->scan_in_progress = 0;