dev/usb/usb_transfer.c

2001 	struct usb_xfer_queue *pq;
2020 	pq = &info->done_q;
2022 	if (pq->curr == xfer) {
2285 	struct usb_xfer_queue *pq = &info->done_q;
2289 	if (pq->curr != xfer) {
2290 		usbd_transfer_enqueue(pq, xfer);
2292 	if (!pq->recurse_1) {
2303 		pq->recurse_2 = 0;
2318 usbd_callback_wrapper(struct usb_xfer_queue *pq)
2320 	struct usb_xfer *xfer = pq->curr;
2324 	if ((pq->recurse_3 != 0 || mtx_owned(info->xfer_mtx) == 0) &&
2476 	struct usb_xfer_queue *pq;
2478 	pq = xfer->wait_queue;
2479 	if (pq) {
2480 		TAILQ_REMOVE(&pq->head, xfer, wait_entry);
2494 usbd_transfer_enqueue(struct usb_xfer_queue *pq, struct usb_xfer *xfer)
2501 		xfer->wait_queue = pq;
2502 		TAILQ_INSERT_TAIL(&pq->head, xfer, wait_entry);
2552 		struct usb_xfer_queue *pq;
2558 		pq = &info->dma_q;
2560 		if (pq->curr == xfer) {
2562 			usb_command_wrapper(pq, NULL);
2670 usbd_pipe_start(struct usb_xfer_queue *pq)
2676 	xfer = pq->curr;
3020 usb_command_wrapper(struct usb_xfer_queue *pq, struct usb_xfer *xfer)
3027 		if (pq->curr != xfer) {
3028 			usbd_transfer_enqueue(pq, xfer);
3029 			if (pq->curr != NULL) {
3031 				DPRINTFN(6, "busy %p\n", pq->curr);
3037 		pq->curr = NULL;
3040 	if (!pq->recurse_1) {
3043 		pq->recurse_3 = 0;
3047 			pq->recurse_1 = 1;
3048 			pq->recurse_2 = 1;
3050 			if (pq->curr == NULL) {
3051 				xfer = TAILQ_FIRST(&pq->head);
3053 					TAILQ_REMOVE(&pq->head, xfer,
3056 					pq->curr = xfer;
3061 			DPRINTFN(6, "cb %p (enter)\n", pq->curr);
3062 			(pq->command) (pq);
3063 			DPRINTFN(6, "cb %p (leave)\n", pq->curr);
3069 			pq->recurse_3 = 1;
3071 		} while (!pq->recurse_2);
3074 		pq->recurse_1 = 0;
3078 		pq->recurse_2 = 0;