Lines Matching refs:nvmet_tcp_cmd
108 struct nvmet_tcp_cmd { struct
157 struct nvmet_tcp_cmd *cmds; argument
163 struct nvmet_tcp_cmd *snd_cmd;
169 struct nvmet_tcp_cmd *cmd;
192 struct nvmet_tcp_cmd connect;
215 static void nvmet_tcp_free_cmd(struct nvmet_tcp_cmd *c);
216 static void nvmet_tcp_free_cmd_buffers(struct nvmet_tcp_cmd *cmd);
219 struct nvmet_tcp_cmd *cmd) in nvmet_tcp_cmd_tag()
229 static inline bool nvmet_tcp_has_data_in(struct nvmet_tcp_cmd *cmd) in nvmet_tcp_has_data_in()
235 static inline bool nvmet_tcp_need_data_in(struct nvmet_tcp_cmd *cmd) in nvmet_tcp_need_data_in()
240 static inline bool nvmet_tcp_need_data_out(struct nvmet_tcp_cmd *cmd) in nvmet_tcp_need_data_out()
247 static inline bool nvmet_tcp_has_inline_data(struct nvmet_tcp_cmd *cmd) in nvmet_tcp_has_inline_data()
253 static inline struct nvmet_tcp_cmd *
256 struct nvmet_tcp_cmd *cmd; in nvmet_tcp_get_cmd()
259 struct nvmet_tcp_cmd, entry); in nvmet_tcp_get_cmd()
272 static inline void nvmet_tcp_put_cmd(struct nvmet_tcp_cmd *cmd) in nvmet_tcp_put_cmd()
344 static void nvmet_tcp_free_cmd_buffers(struct nvmet_tcp_cmd *cmd) in nvmet_tcp_free_cmd_buffers()
352 static void nvmet_tcp_build_pdu_iovec(struct nvmet_tcp_cmd *cmd) in nvmet_tcp_build_pdu_iovec()
400 static int nvmet_tcp_map_data(struct nvmet_tcp_cmd *cmd) in nvmet_tcp_map_data()
437 static void nvmet_tcp_calc_ddgst(struct nvmet_tcp_cmd *cmd) in nvmet_tcp_calc_ddgst()
457 static void nvmet_setup_c2h_data_pdu(struct nvmet_tcp_cmd *cmd) in nvmet_setup_c2h_data_pdu()
490 static void nvmet_setup_r2t_pdu(struct nvmet_tcp_cmd *cmd) in nvmet_setup_r2t_pdu()
514 static void nvmet_setup_response_pdu(struct nvmet_tcp_cmd *cmd) in nvmet_setup_response_pdu()
536 struct nvmet_tcp_cmd *cmd; in nvmet_tcp_process_resp_list()
539 cmd = llist_entry(node, struct nvmet_tcp_cmd, lentry); in nvmet_tcp_process_resp_list()
545 static struct nvmet_tcp_cmd *nvmet_tcp_fetch_cmd(struct nvmet_tcp_queue *queue) in nvmet_tcp_fetch_cmd()
548 struct nvmet_tcp_cmd, entry); in nvmet_tcp_fetch_cmd()
553 struct nvmet_tcp_cmd, entry); in nvmet_tcp_fetch_cmd()
573 struct nvmet_tcp_cmd *cmd = in nvmet_tcp_queue_response()
574 container_of(req, struct nvmet_tcp_cmd, req); in nvmet_tcp_queue_response()
577 struct nvmet_tcp_cmd *queue_cmd; in nvmet_tcp_queue_response()
604 static void nvmet_tcp_execute_request(struct nvmet_tcp_cmd *cmd) in nvmet_tcp_execute_request()
612 static int nvmet_try_send_data_pdu(struct nvmet_tcp_cmd *cmd) in nvmet_try_send_data_pdu()
639 static int nvmet_try_send_data(struct nvmet_tcp_cmd *cmd, bool last_in_batch) in nvmet_try_send_data()
692 static int nvmet_try_send_response(struct nvmet_tcp_cmd *cmd, in nvmet_try_send_response()
723 static int nvmet_try_send_r2t(struct nvmet_tcp_cmd *cmd, bool last_in_batch) in nvmet_try_send_r2t()
751 static int nvmet_try_send_ddgst(struct nvmet_tcp_cmd *cmd, bool last_in_batch) in nvmet_try_send_ddgst()
789 struct nvmet_tcp_cmd *cmd = queue->snd_cmd; in nvmet_tcp_try_send_one()
919 struct nvmet_tcp_cmd *cmd, struct nvmet_req *req) in nvmet_tcp_handle_req_failure()
952 struct nvmet_tcp_cmd *cmd; in nvmet_tcp_handle_h2c_data_pdu()
1207 static void nvmet_tcp_prep_recv_ddgst(struct nvmet_tcp_cmd *cmd) in nvmet_tcp_prep_recv_ddgst()
1219 struct nvmet_tcp_cmd *cmd = queue->cmd; in nvmet_tcp_try_recv_data()
1252 struct nvmet_tcp_cmd *cmd = queue->cmd; in nvmet_tcp_try_recv_ddgst()
1427 struct nvmet_tcp_cmd *c) in nvmet_tcp_alloc_cmd()
1474 static void nvmet_tcp_free_cmd(struct nvmet_tcp_cmd *c) in nvmet_tcp_free_cmd()
1484 struct nvmet_tcp_cmd *cmds; in nvmet_tcp_alloc_cmds()
1487 cmds = kcalloc(nr_cmds, sizeof(struct nvmet_tcp_cmd), GFP_KERNEL); in nvmet_tcp_alloc_cmds()
1510 struct nvmet_tcp_cmd *cmds = queue->cmds; in nvmet_tcp_free_cmds()
1537 struct nvmet_tcp_cmd *cmd = queue->cmds; in nvmet_tcp_uninit_data_in_cmds()
1553 struct nvmet_tcp_cmd *cmd = queue->cmds; in nvmet_tcp_free_cmd_data_in_buffers()
2160 struct nvmet_tcp_cmd *cmd = in nvmet_tcp_disc_port_addr()
2161 container_of(req, struct nvmet_tcp_cmd, req); in nvmet_tcp_disc_port_addr()