Lines Matching refs:queue

60 	struct nvme_fc_queue	*queue;
101 struct nvme_fc_queue *queue;
1171 struct nvme_fc_queue *queue, u16 qsize, u16 ersp_ratio)
1219 lsop->queue = queue;
1265 queue->qnum, validation_errors[fcret]);
1270 queue->connection_id =
1272 set_bit(NVME_FC_Q_CONNECTED, &queue->flags);
1281 "queue %d connect admin queue failed (%d).\n",
1282 queue->qnum, ret);
1287 nvme_fc_connect_queue(struct nvme_fc_ctrl *ctrl, struct nvme_fc_queue *queue,
1331 conn_rqst->connect_cmd.qid = cpu_to_be16(queue->qnum);
1334 lsop->queue = queue;
1371 queue->qnum, validation_errors[fcret]);
1373 queue->connection_id =
1375 set_bit(NVME_FC_Q_CONNECTED, &queue->flags);
1383 "queue %d connect I/O queue failed (%d).\n",
1384 queue->qnum, ret);
1403 * terminates the FC-NVME connections (per queue, both admin and io
1862 op->queue->lldd_handle,
1933 struct nvme_fc_queue *queue = op->queue;
2070 nvme_complete_async_event(&queue->ctrl->ctrl, status, &result);
2089 struct nvme_fc_queue *queue, struct nvme_fc_fcp_op *op,
2104 op->queue = queue;
2111 if (queue->qnum)
2147 struct nvme_fc_queue *queue = &ctrl->queues[queue_idx];
2150 res = __nvme_fc_init_request(ctrl, queue, &op->op, rq, queue->rqcnt++);
2219 struct nvme_fc_queue *queue = &ctrl->queues[qidx];
2221 hctx->driver_data = queue;
2222 queue->hctx = hctx;
2242 struct nvme_fc_queue *queue;
2244 queue = &ctrl->queues[idx];
2245 memset(queue, 0, sizeof(*queue));
2246 queue->ctrl = ctrl;
2247 queue->qnum = idx;
2248 atomic_set(&queue->csn, 0);
2249 queue->dev = ctrl->dev;
2252 queue->cmnd_capsule_len = ctrl->ctrl.ioccsz * 16;
2254 queue->cmnd_capsule_len = sizeof(struct nvme_command);
2269 * This routine terminates a queue at the transport level.
2271 * the queue have been terminated.
2273 * the queue's connection. Termination of the admin queue will also
2277 nvme_fc_free_queue(struct nvme_fc_queue *queue)
2279 if (!test_and_clear_bit(NVME_FC_Q_CONNECTED, &queue->flags))
2282 clear_bit(NVME_FC_Q_LIVE, &queue->flags);
2284 * Current implementation never disconnects a single queue.
2286 * a disconnect(queue) LS sent to the target.
2289 queue->connection_id = 0;
2290 atomic_set(&queue->csn, 0);
2295 struct nvme_fc_queue *queue, unsigned int qidx)
2299 queue->lldd_handle);
2300 queue->lldd_handle = NULL;
2314 struct nvme_fc_queue *queue, unsigned int qidx, u16 qsize)
2318 queue->lldd_handle = NULL;
2321 qidx, qsize, &queue->lldd_handle);
2329 struct nvme_fc_queue *queue = &ctrl->queues[ctrl->ctrl.queue_count - 1];
2332 for (i = ctrl->ctrl.queue_count - 1; i >= 1; i--, queue--)
2333 __nvme_fc_delete_hw_queue(ctrl, queue, i);
2339 struct nvme_fc_queue *queue = &ctrl->queues[1];
2342 for (i = 1; i < ctrl->ctrl.queue_count; i++, queue++) {
2343 ret = __nvme_fc_create_hw_queue(ctrl, queue, i, qsize);
2442 * io on a queue that is to be terminated. The transport uses
2523 * clean up the admin queue. Same thing as above.
2570 u16 qnum = op->queue->qnum;
2648 * In FC, the queue is a logical thing. At transport connect, the target
2649 * creates its "queue" and returns a handle that is to be given to the
2671 nvme_fc_start_fcp_op(struct nvme_fc_ctrl *ctrl, struct nvme_fc_queue *queue,
2690 cmdiu->connection_id = cpu_to_be64(queue->connection_id);
2708 op->fcp_req.sqid = cpu_to_le16(queue->qnum);
2748 cmdiu->csn = cpu_to_be32(atomic_inc_return(&queue->csn));
2751 queue->lldd_handle, &op->fcp_req);
2790 struct nvme_ns *ns = hctx->queue->queuedata;
2791 struct nvme_fc_queue *queue = hctx->driver_data;
2792 struct nvme_fc_ctrl *ctrl = queue->ctrl;
2796 bool queue_ready = test_bit(NVME_FC_Q_LIVE, &queue->flags);
2801 !nvme_check_ready(&queue->ctrl->ctrl, rq, queue_ready))
2802 return nvme_fail_nonready_command(&queue->ctrl->ctrl, rq);
2826 return nvme_fc_start_fcp_op(ctrl, queue, op, data_len, io_dir);
2841 ret = nvme_fc_start_fcp_op(ctrl, aen_op->queue, aen_op, 0,
2875 /* Call LLDD map queue functionality if defined */
2966 "Fail Reconnect: At least 1 io queue "
2978 "reconnect: revising io queue count from %d to %d\n",
3084 * Create the admin queue
3512 /* io queue count */
3516 ctrl->ctrl.queue_count++; /* +1 for admin queue */
3533 * for max io queue count before we can do so.