Lines Matching refs:q
483 void proxy_submit_cb(io_queue_t *q) { in proxy_submit_cb() argument
484 proxy_event_thread_t *e = ((proxy_ctx_t *)q->ctx)->proxy_io_thread; in proxy_submit_cb()
485 io_pending_proxy_t *p = q->stack_ctx; in proxy_submit_cb()
509 q->count++; in proxy_submit_cb()
541 q->stack_ctx = NULL; in proxy_submit_cb()
600 io_queue_t *q = conn_io_queue_get(p->c, p->io_queue_type); in proxy_return_rctx_cb() local
610 q->count--; in proxy_return_rctx_cb()
611 if (q->count == 0) { in proxy_return_rctx_cb()
1308 io_queue_t *q = conn_io_queue_get(c, IO_QUEUE_PROXY); in mcp_queue_rctx_io() local
1354 p->next = q->stack_ctx; in mcp_queue_rctx_io()
1355 q->stack_ctx = p; in mcp_queue_rctx_io()