Lines Matching defs:queue
23 struct nvme_loop_queue *queue;
69 static inline int nvme_loop_queue_idx(struct nvme_loop_queue *queue)
71 return queue - queue->ctrl->queues;
82 static struct blk_mq_tags *nvme_loop_tagset(struct nvme_loop_queue *queue)
84 u32 queue_idx = nvme_loop_queue_idx(queue);
87 return queue->ctrl->admin_tag_set.tags[queue_idx];
88 return queue->ctrl->tag_set.tags[queue_idx - 1];
93 struct nvme_loop_queue *queue =
99 * survive any kind of queue freeze and often don't respond to
103 if (unlikely(nvme_is_aen_req(nvme_loop_queue_idx(queue),
105 nvme_complete_async_event(&queue->ctrl->ctrl, cqe->status,
110 rq = nvme_find_rq(nvme_loop_tagset(queue), cqe->command_id);
112 dev_err(queue->ctrl->ctrl.device,
113 "got bad command_id %#x on queue %d\n",
114 cqe->command_id, nvme_loop_queue_idx(queue));
134 struct nvme_ns *ns = hctx->queue->queuedata;
135 struct nvme_loop_queue *queue = hctx->driver_data;
138 bool queue_ready = test_bit(NVME_LOOP_Q_LIVE, &queue->flags);
141 if (!nvme_check_ready(&queue->ctrl->ctrl, req, queue_ready))
142 return nvme_fail_nonready_command(&queue->ctrl->ctrl, req);
150 iod->req.port = queue->ctrl->port;
151 if (!nvmet_req_init(&iod->req, &queue->nvme_cq,
152 &queue->nvme_sq, &nvme_loop_ops))
176 struct nvme_loop_queue *queue = &ctrl->queues[0];
184 if (!nvmet_req_init(&iod->req, &queue->nvme_cq, &queue->nvme_sq,
198 iod->queue = &ctrl->queues[queue_idx];
222 struct nvme_loop_queue *queue = &ctrl->queues[hctx_idx + 1];
230 * flush queue, that way may cause horrible boot delay.
234 hctx->driver_data = queue;
242 struct nvme_loop_queue *queue = &ctrl->queues[0];
246 hctx->driver_data = queue;
362 /* reset stopped state for the fresh admin queue */