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