Lines Matching refs:hctx
167 if (WARN_ON(!q->hctx)) in rnbd_clt_dev_requeue()
171 blk_mq_run_hw_queue(q->hctx, true); in rnbd_clt_dev_requeue()
1117 struct blk_mq_hw_ctx *hctx, in rnbd_clt_dev_kick_mq_queue() argument
1120 struct rnbd_queue *q = hctx->driver_data; in rnbd_clt_dev_kick_mq_queue()
1123 blk_mq_delay_run_hw_queue(hctx, delay); in rnbd_clt_dev_kick_mq_queue()
1129 blk_mq_delay_run_hw_queue(hctx, 10/*ms*/); in rnbd_clt_dev_kick_mq_queue()
1132 static blk_status_t rnbd_queue_rq(struct blk_mq_hw_ctx *hctx, in rnbd_queue_rq() argument
1147 rnbd_clt_dev_kick_mq_queue(dev, hctx, RNBD_DELAY_IFBUSY); in rnbd_queue_rq()
1161 rnbd_clt_dev_kick_mq_queue(dev, hctx, 10/*ms*/); in rnbd_queue_rq()
1171 rnbd_clt_dev_kick_mq_queue(dev, hctx, 10/*ms*/); in rnbd_queue_rq()
1179 static int rnbd_rdma_poll(struct blk_mq_hw_ctx *hctx, struct io_comp_batch *iob) in rnbd_rdma_poll() argument
1181 struct rnbd_queue *q = hctx->driver_data; in rnbd_rdma_poll()
1185 cnt = rtrs_clt_rdma_cq_direct(dev->sess->rtrs, hctx->queue_num); in rnbd_rdma_poll()
1337 struct blk_mq_hw_ctx *hctx) in rnbd_init_hw_queue() argument
1341 q->hctx = hctx; in rnbd_init_hw_queue()
1347 struct blk_mq_hw_ctx *hctx; in rnbd_init_mq_hw_queues() local
1350 queue_for_each_hw_ctx(dev->queue, hctx, i) { in rnbd_init_mq_hw_queues()
1352 rnbd_init_hw_queue(dev, q, hctx); in rnbd_init_mq_hw_queues()
1353 hctx->driver_data = q; in rnbd_init_mq_hw_queues()