Lines Matching defs:queue

33 	struct nvme_tcp_queue	*queue;  member
130 static inline int nvme_tcp_queue_id(struct nvme_tcp_queue *queue) in nvme_tcp_queue_id()
135 static inline struct blk_mq_tags *nvme_tcp_tagset(struct nvme_tcp_queue *queue) in nvme_tcp_tagset()
144 static inline u8 nvme_tcp_hdgst_len(struct nvme_tcp_queue *queue) in nvme_tcp_hdgst_len()
149 static inline u8 nvme_tcp_ddgst_len(struct nvme_tcp_queue *queue) in nvme_tcp_ddgst_len()
154 static inline size_t nvme_tcp_inline_data_size(struct nvme_tcp_queue *queue) in nvme_tcp_inline_data_size()
254 struct nvme_tcp_queue *queue = req->queue; in nvme_tcp_queue_request() local
264 nvme_tcp_fetch_request(struct nvme_tcp_queue *queue) in nvme_tcp_fetch_request()
306 static int nvme_tcp_verify_hdgst(struct nvme_tcp_queue *queue, in nvme_tcp_verify_hdgst()
333 static int nvme_tcp_check_ddgst(struct nvme_tcp_queue *queue, void *pdu) in nvme_tcp_check_ddgst()
368 struct nvme_tcp_queue *queue = &ctrl->queues[queue_idx]; in nvme_tcp_init_request() local
387 struct nvme_tcp_queue *queue = &ctrl->queues[hctx_idx + 1]; in nvme_tcp_init_hctx() local
397 struct nvme_tcp_queue *queue = &ctrl->queues[0]; in nvme_tcp_init_admin_hctx() local
404 nvme_tcp_recv_state(struct nvme_tcp_queue *queue) in nvme_tcp_recv_state()
411 static void nvme_tcp_init_recv_ctx(struct nvme_tcp_queue *queue) in nvme_tcp_init_recv_ctx()
428 static int nvme_tcp_process_nvme_cqe(struct nvme_tcp_queue *queue, in nvme_tcp_process_nvme_cqe()
448 static int nvme_tcp_handle_c2h_data(struct nvme_tcp_queue *queue, in nvme_tcp_handle_c2h_data()
482 static int nvme_tcp_handle_comp(struct nvme_tcp_queue *queue, in nvme_tcp_handle_comp()
508 struct nvme_tcp_queue *queue = req->queue; in nvme_tcp_setup_h2c_data_pdu() local
550 static int nvme_tcp_handle_r2t(struct nvme_tcp_queue *queue, in nvme_tcp_handle_r2t()
578 static int nvme_tcp_recv_pdu(struct nvme_tcp_queue *queue, struct sk_buff *skb, in nvme_tcp_recv_pdu()
635 static int nvme_tcp_recv_data(struct nvme_tcp_queue *queue, struct sk_buff *skb, in nvme_tcp_recv_data()
713 static int nvme_tcp_recv_ddgst(struct nvme_tcp_queue *queue, in nvme_tcp_recv_ddgst()
755 struct nvme_tcp_queue *queue = desc->arg.data; in nvme_tcp_recv_skb() local
787 struct nvme_tcp_queue *queue; in nvme_tcp_data_ready() local
798 struct nvme_tcp_queue *queue; in nvme_tcp_write_space() local
811 struct nvme_tcp_queue *queue; in nvme_tcp_state_change() local
838 static inline void nvme_tcp_done_send_req(struct nvme_tcp_queue *queue) in nvme_tcp_done_send_req()
850 struct nvme_tcp_queue *queue = req->queue; in nvme_tcp_try_send_data() local
898 struct nvme_tcp_queue *queue = req->queue; in nvme_tcp_try_send_cmd_pdu() local
933 struct nvme_tcp_queue *queue = req->queue; in nvme_tcp_try_send_data_pdu() local
964 struct nvme_tcp_queue *queue = req->queue; in nvme_tcp_try_send_ddgst() local
985 static int nvme_tcp_try_send(struct nvme_tcp_queue *queue) in nvme_tcp_try_send()
1025 static int nvme_tcp_try_recv(struct nvme_tcp_queue *queue) in nvme_tcp_try_recv()
1043 struct nvme_tcp_queue *queue = in nvme_tcp_io_work() local
1075 static void nvme_tcp_free_crypto(struct nvme_tcp_queue *queue) in nvme_tcp_free_crypto()
1084 static int nvme_tcp_alloc_crypto(struct nvme_tcp_queue *queue) in nvme_tcp_alloc_crypto()
1119 struct nvme_tcp_queue *queue = &ctrl->queues[0]; in nvme_tcp_alloc_async_req() local
1136 struct nvme_tcp_queue *queue = &ctrl->queues[qid]; in nvme_tcp_free_queue() local
1148 static int nvme_tcp_init_connection(struct nvme_tcp_queue *queue) in nvme_tcp_init_connection()
1250 struct nvme_tcp_queue *queue = &ctrl->queues[qid]; in nvme_tcp_alloc_queue() local
1409 static void nvme_tcp_restore_sock_calls(struct nvme_tcp_queue *queue) in nvme_tcp_restore_sock_calls()
1421 static void __nvme_tcp_stop_queue(struct nvme_tcp_queue *queue) in __nvme_tcp_stop_queue()
1431 struct nvme_tcp_queue *queue = &ctrl->queues[qid]; in nvme_tcp_stop_queue() local
1993 static void nvme_tcp_set_sg_inline(struct nvme_tcp_queue *queue, in nvme_tcp_set_sg_inline()
2017 struct nvme_tcp_queue *queue = &ctrl->queues[0]; in nvme_tcp_submit_async_event() local
2079 static blk_status_t nvme_tcp_map_data(struct nvme_tcp_queue *queue, in nvme_tcp_map_data()
2102 struct nvme_tcp_queue *queue = req->queue; in nvme_tcp_setup_cmd_pdu() local
2152 struct nvme_tcp_queue *queue = hctx->driver_data; in nvme_tcp_queue_rq() local
2219 struct nvme_tcp_queue *queue = hctx->driver_data; in nvme_tcp_poll() local