Lines Matching refs:pq

2026 	struct usb_xfer_queue *pq;  in usbd_transfer_pending()  local
2047 pq = &info->done_q; in usbd_transfer_pending()
2049 if (pq->curr == xfer) { in usbd_transfer_pending()
2318 struct usb_xfer_queue *pq = &info->done_q; in usbd_callback_ss_done_defer() local
2322 if (pq->curr != xfer) { in usbd_callback_ss_done_defer()
2323 usbd_transfer_enqueue(pq, xfer); in usbd_callback_ss_done_defer()
2325 if (!pq->recurse_1) { in usbd_callback_ss_done_defer()
2338 pq->recurse_2 = 0; in usbd_callback_ss_done_defer()
2353 usbd_callback_wrapper(struct usb_xfer_queue *pq) in usbd_callback_wrapper() argument
2355 struct usb_xfer *xfer = pq->curr; in usbd_callback_wrapper()
2506 struct usb_xfer_queue *pq; in usbd_transfer_dequeue() local
2508 pq = xfer->wait_queue; in usbd_transfer_dequeue()
2509 if (pq) { in usbd_transfer_dequeue()
2510 TAILQ_REMOVE(&pq->head, xfer, wait_entry); in usbd_transfer_dequeue()
2524 usbd_transfer_enqueue(struct usb_xfer_queue *pq, struct usb_xfer *xfer) in usbd_transfer_enqueue() argument
2534 xfer->wait_queue = pq; in usbd_transfer_enqueue()
2535 TAILQ_INSERT_TAIL(&pq->head, xfer, wait_entry); in usbd_transfer_enqueue()
2585 struct usb_xfer_queue *pq; in usbd_transfer_done() local
2591 pq = &info->dma_q; in usbd_transfer_done()
2593 if (pq->curr == xfer) { in usbd_transfer_done()
2595 usb_command_wrapper(pq, NULL); in usbd_transfer_done()
2703 usbd_pipe_start(struct usb_xfer_queue *pq) in usbd_pipe_start() argument
2709 xfer = pq->curr; in usbd_pipe_start()
3037 usb_command_wrapper(struct usb_xfer_queue *pq, struct usb_xfer *xfer) in usb_command_wrapper() argument
3044 if (pq->curr != xfer) { in usb_command_wrapper()
3045 usbd_transfer_enqueue(pq, xfer); in usb_command_wrapper()
3046 if (pq->curr != NULL) { in usb_command_wrapper()
3048 DPRINTFN(6, "busy %p\n", pq->curr); in usb_command_wrapper()
3054 pq->curr = NULL; in usb_command_wrapper()
3057 if (!pq->recurse_1) { in usb_command_wrapper()
3062 pq->recurse_1 = 1; in usb_command_wrapper()
3063 pq->recurse_2 = 1; in usb_command_wrapper()
3065 if (pq->curr == NULL) { in usb_command_wrapper()
3066 xfer = TAILQ_FIRST(&pq->head); in usb_command_wrapper()
3068 TAILQ_REMOVE(&pq->head, xfer, in usb_command_wrapper()
3071 pq->curr = xfer; in usb_command_wrapper()
3076 DPRINTFN(6, "cb %p (enter)\n", pq->curr); in usb_command_wrapper()
3077 (pq->command) (pq); in usb_command_wrapper()
3078 DPRINTFN(6, "cb %p (leave)\n", pq->curr); in usb_command_wrapper()
3080 } while (!pq->recurse_2); in usb_command_wrapper()
3083 pq->recurse_1 = 0; in usb_command_wrapper()
3087 pq->recurse_2 = 0; in usb_command_wrapper()