| /spdk/lib/nvme/ |
| H A D | nvme_tcp.c | 155 struct nvme_tcp_qpair *tqpair; global() member
192 nvme_tcp_req_get(struct nvme_tcp_qpair * tqpair) nvme_tcp_req_get() argument
220 nvme_tcp_req_put(struct nvme_tcp_qpair * tqpair,struct nvme_tcp_req * tcp_req) nvme_tcp_req_put() argument
268 nvme_tcp_free_reqs(struct nvme_tcp_qpair * tqpair) nvme_tcp_free_reqs() argument
278 nvme_tcp_alloc_reqs(struct nvme_tcp_qpair * tqpair) nvme_tcp_alloc_reqs() argument
323 nvme_tcp_qpair_set_recv_state(struct nvme_tcp_qpair * tqpair,enum nvme_tcp_pdu_recv_state state) nvme_tcp_qpair_set_recv_state() argument
344 struct nvme_tcp_qpair *tqpair = nvme_tcp_qpair(qpair); nvme_tcp_ctrlr_disconnect_qpair() local
390 struct nvme_tcp_qpair *tqpair = nvme_tcp_qpair(qpair); nvme_tcp_ctrlr_delete_io_qpair() local
439 nvme_tcp_cond_schedule_qpair_polling(struct nvme_tcp_qpair * tqpair) nvme_tcp_cond_schedule_qpair_polling() argument
462 struct nvme_tcp_qpair *tqpair = pdu->qpair; pdu_write_done() local
479 struct nvme_tcp_qpair *tqpair = pdu->qpair; pdu_write_fail() local
502 struct nvme_tcp_qpair *tqpair = pdu->qpair; _tcp_write_pdu() local
543 struct nvme_tcp_qpair *tqpair = pdu->qpair; tcp_write_pdu() local
588 struct nvme_tcp_qpair *tqpair = pdu->qpair; pdu_accel_compute_crc32_seq_cb() local
619 struct nvme_tcp_qpair *tqpair = pdu->qpair; pdu_accel_compute_crc32() local
696 struct nvme_tcp_qpair *tqpair = pdu->qpair; pdu_compute_crc32() local
725 nvme_tcp_qpair_write_pdu(struct nvme_tcp_qpair * tqpair,struct nvme_tcp_pdu * pdu,nvme_tcp_qpair_xfer_complete_cb cb_fn,void * cb_arg) nvme_tcp_qpair_write_pdu() argument
780 nvme_tcp_build_contig_request(struct nvme_tcp_qpair * tqpair,struct nvme_tcp_req * tcp_req) nvme_tcp_build_contig_request() argument
808 nvme_tcp_build_sgl_request(struct nvme_tcp_qpair * tqpair,struct nvme_tcp_req * tcp_req) nvme_tcp_build_sgl_request() argument
859 nvme_tcp_req_init(struct nvme_tcp_qpair * tqpair,struct nvme_request * req,struct nvme_tcp_req * tcp_req) nvme_tcp_req_init() argument
959 nvme_tcp_qpair_capsule_cmd_send(struct nvme_tcp_qpair * tqpair,struct nvme_tcp_req * tcp_req) nvme_tcp_qpair_capsule_cmd_send() argument
1020 struct nvme_tcp_qpair *tqpair; nvme_tcp_qpair_submit_request() local
1056 nvme_tcp_req_complete(struct nvme_tcp_req * tcp_req,struct nvme_tcp_qpair * tqpair,struct spdk_nvme_cpl * rsp,bool print_on_error) nvme_tcp_req_complete() argument
1103 struct nvme_tcp_qpair *tqpair = nvme_tcp_qpair(qpair); nvme_tcp_qpair_abort_reqs() local
1123 struct nvme_tcp_qpair *tqpair = cb_arg; nvme_tcp_qpair_send_h2c_term_req_complete() local
1129 nvme_tcp_qpair_send_h2c_term_req(struct nvme_tcp_qpair * tqpair,struct nvme_tcp_pdu * pdu,enum spdk_nvme_tcp_term_req_fes fes,uint32_t error_offset) nvme_tcp_qpair_send_h2c_term_req() argument
1164 nvme_tcp_qpair_recv_state_valid(struct nvme_tcp_qpair * tqpair) nvme_tcp_qpair_recv_state_valid() argument
1177 nvme_tcp_pdu_ch_handle(struct nvme_tcp_qpair * tqpair) nvme_tcp_pdu_ch_handle() argument
1269 get_nvme_active_req_by_cid(struct nvme_tcp_qpair * tqpair,uint32_t cid) get_nvme_active_req_by_cid() argument
1284 struct nvme_tcp_qpair *tqpair = treq->tqpair; nvme_tcp_recv_payload_seq_cb() local
1301 nvme_tcp_c2h_data_payload_handle(struct nvme_tcp_qpair * tqpair,struct nvme_tcp_pdu * pdu,uint32_t * reaped) nvme_tcp_c2h_data_payload_handle() argument
1368 nvme_tcp_c2h_term_req_payload_handle(struct nvme_tcp_qpair * tqpair,struct nvme_tcp_pdu * pdu) nvme_tcp_c2h_term_req_payload_handle() argument
1376 _nvme_tcp_pdu_payload_handle(struct nvme_tcp_qpair * tqpair,uint32_t * reaped) _nvme_tcp_pdu_payload_handle() argument
1405 struct nvme_tcp_qpair *tqpair; nvme_tcp_accel_recv_compute_crc32_done() local
1452 struct nvme_tcp_qpair *tqpair = treq->tqpair; nvme_tcp_accel_seq_recv_compute_crc32_done() local
1467 struct nvme_tcp_qpair *tqpair = treq->tqpair; nvme_tcp_accel_recv_compute_crc32() local
1512 nvme_tcp_pdu_payload_handle(struct nvme_tcp_qpair * tqpair,uint32_t * reaped) nvme_tcp_pdu_payload_handle() argument
1553 struct nvme_tcp_qpair *tqpair = cb_arg; nvme_tcp_send_icreq_complete() local
1566 nvme_tcp_icresp_handle(struct nvme_tcp_qpair * tqpair,struct nvme_tcp_pdu * pdu) nvme_tcp_icresp_handle() argument
1639 nvme_tcp_capsule_resp_hdr_handle(struct nvme_tcp_qpair * tqpair,struct nvme_tcp_pdu * pdu,uint32_t * reaped) nvme_tcp_capsule_resp_hdr_handle() argument
1686 nvme_tcp_c2h_term_req_hdr_handle(struct nvme_tcp_qpair * tqpair,struct nvme_tcp_pdu * pdu) nvme_tcp_c2h_term_req_hdr_handle() argument
1710 nvme_tcp_c2h_data_hdr_handle(struct nvme_tcp_qpair * tqpair,struct nvme_tcp_pdu * pdu) nvme_tcp_c2h_data_hdr_handle() argument
1829 struct nvme_tcp_qpair *tqpair = nvme_tcp_qpair(tcp_req->req->qpair); nvme_tcp_send_h2c_data() local
1888 nvme_tcp_r2t_hdr_handle(struct nvme_tcp_qpair * tqpair,struct nvme_tcp_pdu * pdu) nvme_tcp_r2t_hdr_handle() argument
1965 nvme_tcp_pdu_psh_handle(struct nvme_tcp_qpair * tqpair,uint32_t * reaped) nvme_tcp_pdu_psh_handle() argument
2018 nvme_tcp_read_pdu(struct nvme_tcp_qpair * tqpair,uint32_t * reaped,uint32_t max_completions) nvme_tcp_read_pdu() argument
2134 struct nvme_tcp_qpair *tqpair = nvme_tcp_qpair(qpair); nvme_tcp_qpair_check_timeout() local
2178 struct nvme_tcp_qpair *tqpair = nvme_tcp_qpair(qpair); nvme_tcp_qpair_process_completions() local
2264 struct nvme_tcp_qpair *tqpair = nvme_tcp_qpair(qpair); nvme_tcp_qpair_sock_cb() local
2282 nvme_tcp_qpair_icreq_send(struct nvme_tcp_qpair * tqpair) nvme_tcp_qpair_icreq_send() argument
2314 struct nvme_tcp_qpair *tqpair; nvme_tcp_qpair_connect_sock() local
2395 struct nvme_tcp_qpair *tqpair; nvme_tcp_ctrlr_connect_qpair_poll() local
2455 struct nvme_tcp_qpair *tqpair; nvme_tcp_ctrlr_connect_qpair() local
2511 struct nvme_tcp_qpair *tqpair; nvme_tcp_ctrlr_create_qpair() local
2743 struct nvme_tcp_qpair *tqpair = nvme_tcp_qpair(qpair); nvme_tcp_qpair_iterate_requests() local
2766 struct nvme_tcp_qpair *tqpair = nvme_tcp_qpair(qpair); nvme_tcp_admin_qpair_abort_aers() local
2806 struct nvme_tcp_qpair *tqpair = nvme_tcp_qpair(qpair); nvme_tcp_qpair_get_optimal_poll_group() local
2822 struct nvme_tcp_qpair *tqpair = nvme_tcp_qpair(qpair); nvme_tcp_poll_group_connect_qpair() local
2834 struct nvme_tcp_qpair *tqpair = nvme_tcp_qpair(qpair); nvme_tcp_poll_group_disconnect_qpair() local
2853 struct nvme_tcp_qpair *tqpair = nvme_tcp_qpair(qpair); nvme_tcp_poll_group_add() local
2870 struct nvme_tcp_qpair *tqpair; nvme_tcp_poll_group_remove() local
2895 struct nvme_tcp_qpair *tqpair, *tmp_tqpair; nvme_tcp_poll_group_process_completions() local
[all...] |
| /spdk/lib/nvmf/ |
| H A D | tcp.c | 429 tqpair->state_cntr[tcp_req->state]--; in nvmf_tcp_req_get() argument
405 struct spdk_nvmf_tcp_qpair *tqpair; nvmf_tcp_req_set_state() local
452 nvmf_tcp_req_put(struct spdk_nvmf_tcp_qpair * tqpair,struct spdk_nvmf_tcp_req * tcp_req) nvmf_tcp_req_put() argument
488 nvmf_tcp_drain_state_queue(struct spdk_nvmf_tcp_qpair * tqpair,enum spdk_nvmf_tcp_req_state state) nvmf_tcp_drain_state_queue() argument
502 nvmf_tcp_cleanup_all_states(struct spdk_nvmf_tcp_qpair * tqpair) nvmf_tcp_cleanup_all_states() argument
524 nvmf_tcp_dump_qpair_req_contents(struct spdk_nvmf_tcp_qpair * tqpair) nvmf_tcp_dump_qpair_req_contents() argument
544 struct spdk_nvmf_tcp_qpair *tqpair = _tqpair; _nvmf_tcp_qpair_destroy() local
586 nvmf_tcp_qpair_destroy(struct spdk_nvmf_tcp_qpair * tqpair) nvmf_tcp_qpair_destroy() argument
1038 nvmf_tcp_qpair_set_state(struct spdk_nvmf_tcp_qpair * tqpair,enum nvme_tcp_qpair_state state) nvmf_tcp_qpair_set_state() argument
1046 nvmf_tcp_qpair_disconnect(struct spdk_nvmf_tcp_qpair * tqpair) nvmf_tcp_qpair_disconnect() argument
1065 struct spdk_nvmf_tcp_qpair *tqpair = _tqpair; _mgmt_pdu_write_done() local
1082 struct spdk_nvmf_tcp_qpair *tqpair = pdu->qpair; _req_pdu_write_done() local
1113 struct spdk_nvmf_tcp_qpair *tqpair = pdu->qpair; _tcp_write_pdu() local
1154 struct spdk_nvmf_tcp_qpair *tqpair = pdu->qpair; pdu_data_crc32_compute() local
1177 nvmf_tcp_qpair_write_pdu(struct spdk_nvmf_tcp_qpair * tqpair,struct nvme_tcp_pdu * pdu,nvme_tcp_qpair_xfer_complete_cb cb_fn,void * cb_arg) nvmf_tcp_qpair_write_pdu() argument
1205 nvmf_tcp_qpair_write_mgmt_pdu(struct spdk_nvmf_tcp_qpair * tqpair,nvme_tcp_qpair_xfer_complete_cb cb_fn,void * cb_arg) nvmf_tcp_qpair_write_mgmt_pdu() argument
1218 nvmf_tcp_qpair_write_req_pdu(struct spdk_nvmf_tcp_qpair * tqpair,struct spdk_nvmf_tcp_req * tcp_req,nvme_tcp_qpair_xfer_complete_cb cb_fn,void * cb_arg) nvmf_tcp_qpair_write_req_pdu() argument
1235 nvmf_tcp_qpair_init_mem_resource(struct spdk_nvmf_tcp_qpair * tqpair) nvmf_tcp_qpair_init_mem_resource() argument
1322 struct spdk_nvmf_tcp_qpair *tqpair; nvmf_tcp_qpair_init() local
1343 nvmf_tcp_qpair_sock_init(struct spdk_nvmf_tcp_qpair * tqpair) nvmf_tcp_qpair_sock_init() argument
1373 struct spdk_nvmf_tcp_qpair *tqpair; nvmf_tcp_handle_connect() local
1579 struct spdk_nvmf_tcp_qpair *tqpair; nvmf_tcp_get_optimal_poll_group() local
1649 nvmf_tcp_qpair_set_recv_state(struct spdk_nvmf_tcp_qpair * tqpair,enum nvme_tcp_pdu_recv_state state) nvmf_tcp_qpair_set_recv_state() argument
1688 struct spdk_nvmf_tcp_qpair *tqpair = ctx; nvmf_tcp_qpair_handle_timeout() local
1702 struct spdk_nvmf_tcp_qpair *tqpair = (struct spdk_nvmf_tcp_qpair *)cb_arg; nvmf_tcp_send_c2h_term_req_complete() local
1711 nvmf_tcp_send_c2h_term_req(struct spdk_nvmf_tcp_qpair * tqpair,struct nvme_tcp_pdu * pdu,enum spdk_nvme_tcp_term_req_fes fes,uint32_t error_offset) nvmf_tcp_send_c2h_term_req() argument
1746 nvmf_tcp_capsule_cmd_hdr_handle(struct spdk_nvmf_tcp_transport * ttransport,struct spdk_nvmf_tcp_qpair * tqpair,struct nvme_tcp_pdu * pdu) nvmf_tcp_capsule_cmd_hdr_handle() argument
1780 nvmf_tcp_capsule_cmd_payload_handle(struct spdk_nvmf_tcp_transport * ttransport,struct spdk_nvmf_tcp_qpair * tqpair,struct nvme_tcp_pdu * pdu) nvmf_tcp_capsule_cmd_payload_handle() argument
1820 nvmf_tcp_h2c_data_hdr_handle(struct spdk_nvmf_tcp_transport * ttransport,struct spdk_nvmf_tcp_qpair * tqpair,struct nvme_tcp_pdu * pdu) nvmf_tcp_h2c_data_hdr_handle() argument
1893 nvmf_tcp_send_capsule_resp_pdu(struct spdk_nvmf_tcp_req * tcp_req,struct spdk_nvmf_tcp_qpair * tqpair) nvmf_tcp_send_capsule_resp_pdu() argument
1919 struct spdk_nvmf_tcp_qpair *tqpair = SPDK_CONTAINEROF(tcp_req->req.qpair, nvmf_tcp_pdu_c2h_data_complete() local
1956 nvmf_tcp_send_r2t_pdu(struct spdk_nvmf_tcp_qpair * tqpair,struct spdk_nvmf_tcp_req * tcp_req) nvmf_tcp_send_r2t_pdu() argument
1989 nvmf_tcp_h2c_data_payload_handle(struct spdk_nvmf_tcp_transport * ttransport,struct spdk_nvmf_tcp_qpair * tqpair,struct nvme_tcp_pdu * pdu) nvmf_tcp_h2c_data_payload_handle() argument
2031 nvmf_tcp_h2c_term_req_hdr_handle(struct spdk_nvmf_tcp_qpair * tqpair,struct nvme_tcp_pdu * pdu) nvmf_tcp_h2c_term_req_hdr_handle() argument
2055 nvmf_tcp_h2c_term_req_payload_handle(struct spdk_nvmf_tcp_qpair * tqpair,struct nvme_tcp_pdu * pdu) nvmf_tcp_h2c_term_req_payload_handle() argument
2065 _nvmf_tcp_pdu_payload_handle(struct spdk_nvmf_tcp_qpair * tqpair,struct nvme_tcp_pdu * pdu) _nvmf_tcp_pdu_payload_handle() argument
2103 struct spdk_nvmf_tcp_qpair *tqpair = pdu->qpair; data_crc32_calc_done() local
2122 nvmf_tcp_pdu_payload_handle(struct spdk_nvmf_tcp_qpair * tqpair,struct nvme_tcp_pdu * pdu) nvmf_tcp_pdu_payload_handle() argument
2150 struct spdk_nvmf_tcp_qpair *tqpair = cb_arg; nvmf_tcp_send_icresp_complete() local
2157 nvmf_tcp_icreq_handle(struct spdk_nvmf_tcp_transport * ttransport,struct spdk_nvmf_tcp_qpair * tqpair,struct nvme_tcp_pdu * pdu) nvmf_tcp_icreq_handle() argument
2230 nvmf_tcp_pdu_psh_handle(struct spdk_nvmf_tcp_qpair * tqpair,struct spdk_nvmf_tcp_transport * ttransport) nvmf_tcp_pdu_psh_handle() argument
2282 nvmf_tcp_pdu_ch_handle(struct spdk_nvmf_tcp_qpair * tqpair) nvmf_tcp_pdu_ch_handle() argument
2375 nvmf_tcp_sock_process(struct spdk_nvmf_tcp_qpair * tqpair) nvmf_tcp_sock_process() argument
2552 struct spdk_nvmf_tcp_qpair *tqpair; nvmf_tcp_req_parse_sgl() local
2705 _nvmf_tcp_send_c2h_data(struct spdk_nvmf_tcp_qpair * tqpair,struct spdk_nvmf_tcp_req * tcp_req) _nvmf_tcp_send_c2h_data() argument
2825 nvmf_tcp_send_c2h_data(struct spdk_nvmf_tcp_qpair * tqpair,struct spdk_nvmf_tcp_req * tcp_req) nvmf_tcp_send_c2h_data() argument
2837 struct spdk_nvmf_tcp_qpair *tqpair; request_transfer_out() local
2867 nvmf_tcp_check_fused_ordering(struct spdk_nvmf_tcp_transport * ttransport,struct spdk_nvmf_tcp_qpair * tqpair,struct spdk_nvmf_tcp_req * tcp_req) nvmf_tcp_check_fused_ordering() argument
2921 struct spdk_nvmf_tcp_qpair *tqpair; nvmf_tcp_req_process() local
3276 struct spdk_nvmf_tcp_qpair *tqpair = arg; nvmf_tcp_sock_cb() local
3293 struct spdk_nvmf_tcp_qpair *tqpair; nvmf_tcp_poll_group_add() local
3337 struct spdk_nvmf_tcp_qpair *tqpair; nvmf_tcp_poll_group_remove() local
3401 struct spdk_nvmf_tcp_qpair *tqpair; nvmf_tcp_close_qpair() local
3422 struct spdk_nvmf_tcp_qpair *tqpair, *tqpair_tmp; nvmf_tcp_poll_group_poll() local
3463 struct spdk_nvmf_tcp_qpair *tqpair; nvmf_tcp_qpair_get_trid() local
3526 struct spdk_nvmf_tcp_qpair *tqpair = SPDK_CONTAINEROF(req->req_to_abort->qpair, _nvmf_tcp_qpair_abort_request() local
3578 struct spdk_nvmf_tcp_qpair *tqpair; nvmf_tcp_qpair_abort_request() local
[all...] |
| /spdk/test/unit/lib/nvme/nvme_tcp.c/ |
| H A D | nvme_tcp_ut.c | 240 struct nvme_tcp_qpair tqpair; test_nvme_tcp_build_sgl_request() local
470 struct nvme_tcp_qpair tqpair = {{0}}; test_nvme_tcp_req_complete_safe() local
532 struct nvme_tcp_qpair tqpair = {}; test_nvme_tcp_req_init() local
597 struct nvme_tcp_qpair tqpair = {}; test_nvme_tcp_req_get() local
629 struct nvme_tcp_qpair tqpair = {}; test_nvme_tcp_qpair_capsule_cmd_send() local
734 struct nvme_tcp_qpair tqpair = {}; test_nvme_tcp_qpair_write_pdu() local
822 struct nvme_tcp_qpair tqpair = {}; test_nvme_tcp_qpair_set_recv_state() local
838 struct nvme_tcp_qpair tqpair = {}; test_nvme_tcp_alloc_reqs() local
872 struct nvme_tcp_qpair tqpair = {}; test_nvme_tcp_qpair_send_h2c_term_req() local
904 struct nvme_tcp_qpair tqpair = {}; test_nvme_tcp_pdu_ch_handle() local
1050 struct nvme_tcp_qpair tqpair = {}; test_nvme_tcp_qpair_connect_sock() local
1090 struct nvme_tcp_qpair tqpair = {}; test_nvme_tcp_qpair_icreq_send() local
1124 struct nvme_tcp_qpair tqpair = {}; test_nvme_tcp_c2h_payload_handle() local
1217 struct nvme_tcp_qpair tqpair = {}; test_nvme_tcp_icresp_handle() local
1283 struct nvme_tcp_qpair tqpair = {}; test_nvme_tcp_pdu_payload_handle() local
1340 struct nvme_tcp_qpair tqpair = {}; test_nvme_tcp_capsule_resp_hdr_handle() local
1394 struct nvme_tcp_qpair *tqpair; test_nvme_tcp_ctrlr_connect_qpair() local
1472 struct nvme_tcp_qpair tqpair = { test_nvme_tcp_ctrlr_disconnect_qpair() local
1626 struct nvme_tcp_qpair *tqpair; test_nvme_tcp_ctrlr_create_io_qpair() local
1679 struct nvme_tcp_qpair *tqpair; test_nvme_tcp_ctrlr_delete_io_qpair() local
1745 struct nvme_tcp_qpair *tqpair = NULL; test_nvme_tcp_ctrlr_construct() local
1814 struct nvme_tcp_qpair *tqpair = NULL; test_nvme_tcp_qpair_submit_request() local
[all...] |
| /spdk/test/unit/lib/nvmf/tcp.c/ |
| H A D | tcp_ut.c | 559 struct spdk_nvmf_tcp_qpair tqpair = {}; test_nvmf_tcp_send_c2h_data() local
642 struct spdk_nvmf_tcp_qpair tqpair = {}; test_nvmf_tcp_h2c_data_hdr_handle() local
685 struct spdk_nvmf_tcp_qpair tqpair = {}; test_nvmf_tcp_in_capsule_data_handle() local
777 struct spdk_nvmf_tcp_qpair *tqpair = NULL; test_nvmf_tcp_qpair_init_mem_resource() local
850 struct spdk_nvmf_tcp_qpair tqpair = {}; test_nvmf_tcp_send_c2h_term_req() local
885 struct spdk_nvmf_tcp_qpair tqpair = {}; test_nvmf_tcp_send_capsule_resp_pdu() local
930 struct spdk_nvmf_tcp_qpair tqpair = {}; test_nvmf_tcp_icreq_handle() local
984 struct spdk_nvmf_tcp_qpair tqpair = {}; test_nvmf_tcp_check_xfer_type() local
1058 struct spdk_nvmf_tcp_qpair tqpair = {}; test_nvmf_tcp_invalid_sgl() local
1132 struct spdk_nvmf_tcp_qpair tqpair = {}; test_nvmf_tcp_pdu_ch_handle() local
[all...] |