Lines Matching refs:q

569     io_queue_cb_t *q = t->io_queues;  in thread_io_queue_add()  local
570 while (q->type != IO_QUEUE_NONE) { in thread_io_queue_add()
571 q++; in thread_io_queue_add()
573 q->type = type; in thread_io_queue_add()
574 q->ctx = ctx; in thread_io_queue_add()
575 q->submit_cb = cb; in thread_io_queue_add()
581 io_queue_t *q = c->io_queues; in conn_io_queue_setup() local
583 q->type = qcb->type; in conn_io_queue_setup()
584 q->ctx = qcb->ctx; in conn_io_queue_setup()
585 q->stack_ctx = NULL; in conn_io_queue_setup()
586 q->count = 0; in conn_io_queue_setup()
588 q++; in conn_io_queue_setup()
594 for (io_queue_t *q = c->io_queues; q->type != IO_QUEUE_NONE; q++) { in conn_io_queue_reset() local
595 assert(q->count == 0); in conn_io_queue_reset()
596 q->stack_ctx = NULL; in conn_io_queue_reset()
601 io_queue_cb_t *q = t->io_queues; in thread_io_queue_get() local
602 while (q->type != IO_QUEUE_NONE) { in thread_io_queue_get()
603 if (q->type == type) { in thread_io_queue_get()
604 return q; in thread_io_queue_get()
606 q++; in thread_io_queue_get()
612 io_queue_t *q = c->io_queues; in conn_io_queue_get() local
613 while (q->type != IO_QUEUE_NONE) { in conn_io_queue_get()
614 if (q->type == type) { in conn_io_queue_get()
615 return q; in conn_io_queue_get()
617 q++; in conn_io_queue_get()
2158 static char *conn_queue_to_str(const conn *c, io_queue_t *q) { in conn_queue_to_str() argument
2159 if (q->type == IO_QUEUE_EXTSTORE) { in conn_queue_to_str()
2161 } else if (q->type == IO_QUEUE_PROXY) { in conn_queue_to_str()
2204 for (io_queue_t *q = sc->io_queues; q->type != IO_QUEUE_NONE; q++) { in process_stats_conns() local
2205 if (q->count) { in process_stats_conns()
2206 const char *qname = conn_queue_to_str(sc, q); in process_stats_conns()
2207 APPEND_NUM_STAT(i, qname, "%d", q->count); in process_stats_conns()
3316 for (io_queue_t *q = c->io_queues; q->type != IO_QUEUE_NONE; q++) { local
3317 if (q->stack_ctx != NULL) {
3318 io_queue_cb_t *qcb = thread_io_queue_get(c->thread, q->type);
3319 qcb->submit_cb(q);