libpayload: Fix interrupt-queue cleanup for OHCI

We have to free TDs more carefully if they have been processed by the
controller yet. The current code tries to force the controller to post
them back to the done queue, but that seems wrong. We can't be sure,
when they get written back. This resulted in leaking TDs with an invalid
reference to a freed interrupt queue.

The new approach: Mark the interrupt queue to be destroyed and handle
the freeing later, when the controller posted the last TD to the done
queue.

Change-Id: I79d80a9dc89e1ca79dc125c4bbccbf23664227b3
Signed-off-by: Nico Huber <nico.huber@secunet.com>
Reviewed-on: http://review.coreboot.org/1905
Tested-by: build bot (Jenkins)
Reviewed-by: Patrick Georgi <patrick@georgi-clan.de>
This commit is contained in:
Nico Huber 2012-11-22 17:21:57 +01:00 committed by Patrick Georgi
parent b9917c2068
commit 0c2364c17c
1 changed files with 27 additions and 10 deletions

View File

@ -520,6 +520,7 @@ struct _intr_queue {
int reqsize;
endpoint_t *endp;
unsigned int remaining_tds;
int destroy;
};
typedef struct _intrq_td intrq_td_t;
@ -648,7 +649,7 @@ ohci_destroy_intr_queue(endpoint_t *const ep, void *const q_)
/* Free data buffer. */
free(intrq->data);
/* Process done queue and free processed TDs. */
/* Free TDs already fetched from the done queue. */
ohci_process_done_queue(ohci, 1);
while (intrq->head) {
intrq_td_t *const cur_td = intrq->head;
@ -656,12 +657,11 @@ ohci_destroy_intr_queue(endpoint_t *const ep, void *const q_)
free(cur_td);
--intrq->remaining_tds;
}
if (intrq->remaining_tds) {
printf("error: ohci_destroy_intr_queue(): "
"freed all but %d TDs.\n", intrq->remaining_tds);
}
free(intrq);
/* Mark interrupt queue to be destroyed.
ohci_process_done_queue() will free the remaining TDs
and finish the interrupt queue off once all TDs are gone. */
intrq->destroy = 1;
/* Save data toggle. */
ep->toggle = intrq->ed.head_pointer & ED_TOGGLE;
@ -734,11 +734,28 @@ ohci_process_done_queue(ohci_t *const ohci, const int spew_debug)
/* Free processed async TDs. */
free((void *)done_td);
break;
case TD_QUEUETYPE_INTR:
/* Save done TD if it comes from an interrupt queue. */
INTRQ_TD_FROM_TD(done_td)->next = temp_tdq;
temp_tdq = INTRQ_TD_FROM_TD(done_td);
case TD_QUEUETYPE_INTR: {
intrq_td_t *const td = INTRQ_TD_FROM_TD(done_td);
intr_queue_t *const intrq = td->intrq;
/* Check if the corresponding interrupt
queue is still beeing processed. */
if (intrq->destroy) {
/* Free this TD, and */
free(td);
--intrq->remaining_tds;
/* the interrupt queue if it has no more TDs. */
if (!intrq->remaining_tds)
free(intrq);
usb_debug("Freed TD from orphaned interrupt "
"queue, %d TDs remain.\n",
intrq->remaining_tds);
} else {
/* Save done TD to be processed. */
td->next = temp_tdq;
temp_tdq = td;
}
break;
}
default:
break;
}