Lines Matching defs:nvme_tcp_queue
21 struct nvme_tcp_queue;
81 struct nvme_tcp_queue *queue;
112 struct nvme_tcp_queue {
155 struct nvme_tcp_queue *queues;
176 static int nvme_tcp_try_send(struct nvme_tcp_queue *queue);
183 static inline int nvme_tcp_queue_id(struct nvme_tcp_queue *queue)
188 static inline struct blk_mq_tags *nvme_tcp_tagset(struct nvme_tcp_queue *queue)
197 static inline u8 nvme_tcp_hdgst_len(struct nvme_tcp_queue *queue)
202 static inline u8 nvme_tcp_ddgst_len(struct nvme_tcp_queue *queue)
207 static inline size_t nvme_tcp_inline_data_size(struct nvme_tcp_queue *queue)
303 static inline void nvme_tcp_send_all(struct nvme_tcp_queue *queue)
313 static inline bool nvme_tcp_queue_more(struct nvme_tcp_queue *queue)
322 struct nvme_tcp_queue *queue = req->queue;
343 static void nvme_tcp_process_req_list(struct nvme_tcp_queue *queue)
355 nvme_tcp_fetch_request(struct nvme_tcp_queue *queue)
401 static int nvme_tcp_verify_hdgst(struct nvme_tcp_queue *queue,
428 static int nvme_tcp_check_ddgst(struct nvme_tcp_queue *queue, void *pdu)
463 struct nvme_tcp_queue *queue = &ctrl->queues[queue_idx];
482 struct nvme_tcp_queue *queue = &ctrl->queues[hctx_idx + 1];
492 struct nvme_tcp_queue *queue = &ctrl->queues[0];
499 nvme_tcp_recv_state(struct nvme_tcp_queue *queue)
506 static void nvme_tcp_init_recv_ctx(struct nvme_tcp_queue *queue)
524 static int nvme_tcp_process_nvme_cqe(struct nvme_tcp_queue *queue,
545 static int nvme_tcp_handle_c2h_data(struct nvme_tcp_queue *queue,
579 static int nvme_tcp_handle_comp(struct nvme_tcp_queue *queue,
605 struct nvme_tcp_queue *queue = req->queue;
654 static int nvme_tcp_handle_r2t(struct nvme_tcp_queue *queue,
682 static int nvme_tcp_recv_pdu(struct nvme_tcp_queue *queue, struct sk_buff *skb,
740 static int nvme_tcp_recv_data(struct nvme_tcp_queue *queue, struct sk_buff *skb,
810 static int nvme_tcp_recv_ddgst(struct nvme_tcp_queue *queue,
852 struct nvme_tcp_queue *queue = desc->arg.data;
884 struct nvme_tcp_queue *queue;
896 struct nvme_tcp_queue *queue;
909 struct nvme_tcp_queue *queue;
935 static inline void nvme_tcp_done_send_req(struct nvme_tcp_queue *queue)
955 struct nvme_tcp_queue *queue = req->queue;
1011 struct nvme_tcp_queue *queue = req->queue;
1051 struct nvme_tcp_queue *queue = req->queue;
1082 struct nvme_tcp_queue *queue = req->queue;
1109 static int nvme_tcp_try_send(struct nvme_tcp_queue *queue)
1155 static int nvme_tcp_try_recv(struct nvme_tcp_queue *queue)
1173 struct nvme_tcp_queue *queue =
1174 container_of(w, struct nvme_tcp_queue, io_work);
1204 static void nvme_tcp_free_crypto(struct nvme_tcp_queue *queue)
1213 static int nvme_tcp_alloc_crypto(struct nvme_tcp_queue *queue)
1248 struct nvme_tcp_queue *queue = &ctrl->queues[0];
1265 struct nvme_tcp_queue *queue = &ctrl->queues[qid];
1278 static int nvme_tcp_init_connection(struct nvme_tcp_queue *queue)
1376 static bool nvme_tcp_admin_queue(struct nvme_tcp_queue *queue)
1381 static bool nvme_tcp_default_queue(struct nvme_tcp_queue *queue)
1390 static bool nvme_tcp_read_queue(struct nvme_tcp_queue *queue)
1401 static bool nvme_tcp_poll_queue(struct nvme_tcp_queue *queue)
1414 static void nvme_tcp_set_queue_io_cpu(struct nvme_tcp_queue *queue)
1434 struct nvme_tcp_queue *queue = &ctrl->queues[qid];
1557 static void nvme_tcp_restore_sock_ops(struct nvme_tcp_queue *queue)
1569 static void __nvme_tcp_stop_queue(struct nvme_tcp_queue *queue)
1579 struct nvme_tcp_queue *queue = &ctrl->queues[qid];
1587 static void nvme_tcp_setup_sock_ops(struct nvme_tcp_queue *queue)
1606 struct nvme_tcp_queue *queue = &ctrl->queues[idx];
2214 static void nvme_tcp_set_sg_inline(struct nvme_tcp_queue *queue,
2238 struct nvme_tcp_queue *queue = &ctrl->queues[0];
2312 static blk_status_t nvme_tcp_map_data(struct nvme_tcp_queue *queue,
2337 struct nvme_tcp_queue *queue = req->queue;
2386 struct nvme_tcp_queue *queue = hctx->driver_data;
2396 struct nvme_tcp_queue *queue = hctx->driver_data;
2463 struct nvme_tcp_queue *queue = hctx->driver_data;