| /spdk/lib/nvme/ |
| H A D | nvme_qpair.c | 13 static int nvme_qpair_resubmit_request(struct spdk_nvme_qpair *qpair, struct nvme_request *req);
274 spdk_nvme_qpair_print_command(struct spdk_nvme_qpair *qpair, struct spdk_nvme_cmd *cmd) in spdk_nvme_qpair_print_command() argument
276 assert(qpair != NULL); in spdk_nvme_qpair_print_command()
279 spdk_nvme_print_command(qpair->id, cmd); in spdk_nvme_qpair_print_command()
481 spdk_nvme_qpair_print_completion(struct spdk_nvme_qpair *qpair, struct spdk_nvme_cpl *cpl) in spdk_nvme_qpair_print_completion() argument
483 spdk_nvme_print_completion(qpair->id, cpl); in spdk_nvme_qpair_print_completion()
542 nvme_qpair_manual_complete_request(struct spdk_nvme_qpair *qpair, in nvme_qpair_manual_complete_request() argument
550 cpl.sqid = qpair->id; in nvme_qpair_manual_complete_request()
557 if (error && print_on_error && !qpair->ctrlr->opts.disable_error_logging) { in nvme_qpair_manual_complete_request()
559 spdk_nvme_qpair_print_command(qpair, in nvme_qpair_manual_complete_request()
567 nvme_qpair_abort_queued_reqs(struct spdk_nvme_qpair * qpair) nvme_qpair_abort_queued_reqs() argument
592 _nvme_qpair_complete_abort_queued_reqs(struct spdk_nvme_qpair * qpair) _nvme_qpair_complete_abort_queued_reqs() argument
613 nvme_qpair_abort_queued_reqs_with_cbarg(struct spdk_nvme_qpair * qpair,void * cmd_cb_arg) nvme_qpair_abort_queued_reqs_with_cbarg() argument
636 nvme_qpair_check_enabled(struct spdk_nvme_qpair * qpair) nvme_qpair_check_enabled() argument
698 nvme_qpair_resubmit_requests(struct spdk_nvme_qpair * qpair,uint32_t num_requests) nvme_qpair_resubmit_requests() argument
725 nvme_complete_register_operations(struct spdk_nvme_qpair * qpair) nvme_complete_register_operations() argument
756 spdk_nvme_qpair_process_completions(struct spdk_nvme_qpair * qpair,uint32_t max_completions) spdk_nvme_qpair_process_completions() argument
835 spdk_nvme_qpair_get_failure_reason(struct spdk_nvme_qpair * qpair) spdk_nvme_qpair_get_failure_reason() argument
841 spdk_nvme_qpair_set_abort_dnr(struct spdk_nvme_qpair * qpair,bool dnr) spdk_nvme_qpair_set_abort_dnr() argument
847 spdk_nvme_qpair_is_connected(struct spdk_nvme_qpair * qpair) spdk_nvme_qpair_is_connected() argument
854 nvme_qpair_init(struct spdk_nvme_qpair * qpair,uint16_t id,struct spdk_nvme_ctrlr * ctrlr,enum spdk_nvme_qprio qprio,uint32_t num_requests,bool async) nvme_qpair_init() argument
911 nvme_qpair_complete_error_reqs(struct spdk_nvme_qpair * qpair) nvme_qpair_complete_error_reqs() argument
925 nvme_qpair_deinit(struct spdk_nvme_qpair * qpair) nvme_qpair_deinit() argument
942 _nvme_qpair_submit_request(struct spdk_nvme_qpair * qpair,struct nvme_request * req) _nvme_qpair_submit_request() argument
1088 nvme_qpair_submit_request(struct spdk_nvme_qpair * qpair,struct nvme_request * req) nvme_qpair_submit_request() argument
1119 nvme_qpair_resubmit_request(struct spdk_nvme_qpair * qpair,struct nvme_request * req) nvme_qpair_resubmit_request() argument
1139 nvme_qpair_abort_all_queued_reqs(struct spdk_nvme_qpair * qpair) nvme_qpair_abort_all_queued_reqs() argument
1151 spdk_nvme_qpair_add_cmd_error_injection(struct spdk_nvme_ctrlr * ctrlr,struct spdk_nvme_qpair * qpair,uint8_t opc,bool do_not_submit,uint64_t timeout_in_us,uint32_t err_count,uint8_t sct,uint8_t sc) spdk_nvme_qpair_add_cmd_error_injection() argument
1197 spdk_nvme_qpair_remove_cmd_error_injection(struct spdk_nvme_ctrlr * ctrlr,struct spdk_nvme_qpair * qpair,uint8_t opc) spdk_nvme_qpair_remove_cmd_error_injection() argument
1221 spdk_nvme_qpair_get_id(struct spdk_nvme_qpair * qpair) spdk_nvme_qpair_get_id() argument
1227 spdk_nvme_qpair_get_num_outstanding_reqs(struct spdk_nvme_qpair * qpair) spdk_nvme_qpair_get_num_outstanding_reqs() argument
[all...] |
| H A D | nvme_transport.c | 49 * transport object in either the controller struct or the admin qpair. This means
452 struct spdk_nvme_qpair *qpair;
456 qpair = transport->ops.ctrlr_create_io_qpair(ctrlr, qid, opts); in nvme_transport_connect_qpair_fail()
457 if (qpair != NULL && !nvme_qpair_is_admin_queue(qpair)) { in nvme_transport_connect_qpair_fail()
458 qpair->transport = transport; in nvme_transport_connect_qpair_fail()
461 return qpair; in nvme_transport_connect_qpair_fail()
465 nvme_transport_ctrlr_delete_io_qpair(struct spdk_nvme_ctrlr *ctrlr, struct spdk_nvme_qpair *qpair) in nvme_transport_ctrlr_connect_qpair()
472 /* Do not rely on qpair->transport. For multi-process cases, a foreign process may delete in nvme_transport_ctrlr_connect_qpair()
473 * the IO qpair, i in nvme_transport_ctrlr_connect_qpair()
420 struct spdk_nvme_qpair *qpair; nvme_transport_ctrlr_create_io_qpair() local
433 nvme_transport_ctrlr_delete_io_qpair(struct spdk_nvme_ctrlr * ctrlr,struct spdk_nvme_qpair * qpair) nvme_transport_ctrlr_delete_io_qpair() argument
454 nvme_transport_connect_qpair_fail(struct spdk_nvme_qpair * qpair,void * unused) nvme_transport_connect_qpair_fail() argument
464 nvme_transport_ctrlr_connect_qpair(struct spdk_nvme_ctrlr * ctrlr,struct spdk_nvme_qpair * qpair) nvme_transport_ctrlr_connect_qpair() argument
520 nvme_transport_ctrlr_disconnect_qpair(struct spdk_nvme_ctrlr * ctrlr,struct spdk_nvme_qpair * qpair) nvme_transport_ctrlr_disconnect_qpair() argument
540 nvme_transport_ctrlr_disconnect_qpair_done(struct spdk_nvme_qpair * qpair) nvme_transport_ctrlr_disconnect_qpair_done() argument
564 nvme_transport_qpair_abort_reqs(struct spdk_nvme_qpair * qpair) nvme_transport_qpair_abort_reqs() argument
578 nvme_transport_qpair_reset(struct spdk_nvme_qpair * qpair) nvme_transport_qpair_reset() argument
592 nvme_transport_qpair_submit_request(struct spdk_nvme_qpair * qpair,struct nvme_request * req) nvme_transport_qpair_submit_request() argument
606 nvme_transport_qpair_process_completions(struct spdk_nvme_qpair * qpair,uint32_t max_completions) nvme_transport_qpair_process_completions() argument
620 nvme_transport_qpair_iterate_requests(struct spdk_nvme_qpair * qpair,int (* iter_fn)(struct nvme_request * req,void * arg),void * arg) nvme_transport_qpair_iterate_requests() argument
636 nvme_transport_admin_qpair_abort_aers(struct spdk_nvme_qpair * qpair) nvme_transport_admin_qpair_abort_aers() argument
662 nvme_transport_qpair_get_optimal_poll_group(const struct spdk_nvme_transport * transport,struct spdk_nvme_qpair * qpair) nvme_transport_qpair_get_optimal_poll_group() argument
673 nvme_transport_poll_group_add(struct spdk_nvme_transport_poll_group * tgroup,struct spdk_nvme_qpair * qpair) nvme_transport_poll_group_add() argument
690 nvme_transport_poll_group_remove(struct spdk_nvme_transport_poll_group * tgroup,struct spdk_nvme_qpair * qpair) nvme_transport_poll_group_remove() argument
726 nvme_transport_poll_group_disconnect_qpair(struct spdk_nvme_qpair * qpair) nvme_transport_poll_group_disconnect_qpair() argument
754 nvme_transport_poll_group_connect_qpair(struct spdk_nvme_qpair * qpair) nvme_transport_poll_group_connect_qpair() argument
[all...] |
| H A D | nvme_auth.c | 134 nvme_auth_digest_allowed(struct spdk_nvme_qpair *qpair, uint8_t digest) in nvme_auth_digest_allowed() argument
136 struct spdk_nvme_ctrlr *ctrlr = qpair->ctrlr; in nvme_auth_digest_allowed()
142 nvme_auth_dhgroup_allowed(struct spdk_nvme_qpair *qpair, uint8_t dhgroup) in nvme_auth_dhgroup_allowed() argument
144 struct spdk_nvme_ctrlr *ctrlr = qpair->ctrlr; in nvme_auth_dhgroup_allowed()
150 nvme_auth_set_state(struct spdk_nvme_qpair *qpair, enum nvme_qpair_auth_state state) in nvme_auth_set_state() argument
163 AUTH_DEBUGLOG(qpair, "auth state: %s\n", state_names[state]); in nvme_auth_set_state()
164 qpair->auth.state = state; in nvme_auth_set_state()
168 nvme_auth_set_failure(struct spdk_nvme_qpair *qpair, int status, bool failure2) in nvme_auth_set_failure() argument
170 if (qpair->auth.status == 0) { in nvme_auth_set_failure()
171 qpair in nvme_auth_set_failure()
180 nvme_auth_print_cpl(struct spdk_nvme_qpair * qpair,const char * msg) nvme_auth_print_cpl() argument
189 nvme_auth_get_seqnum(struct spdk_nvme_qpair * qpair) nvme_auth_get_seqnum() argument
663 nvme_auth_submit_request(struct spdk_nvme_qpair * qpair,enum spdk_nvmf_fabric_cmd_types type,uint32_t len) nvme_auth_submit_request() argument
707 nvme_auth_recv_message(struct spdk_nvme_qpair * qpair) nvme_auth_recv_message() argument
715 nvme_auth_send_failure2(struct spdk_nvme_qpair * qpair,enum spdk_nvmf_auth_failure_reason reason) nvme_auth_send_failure2() argument
732 nvme_auth_check_message(struct spdk_nvme_qpair * qpair,enum spdk_nvmf_auth_id auth_id) nvme_auth_check_message() argument
780 nvme_auth_send_negotiate(struct spdk_nvme_qpair * qpair) nvme_auth_send_negotiate() argument
820 nvme_auth_check_challenge(struct spdk_nvme_qpair * qpair) nvme_auth_check_challenge() argument
900 nvme_auth_send_reply(struct spdk_nvme_qpair * qpair) nvme_auth_send_reply() argument
1006 nvme_auth_check_success1(struct spdk_nvme_qpair * qpair) nvme_auth_check_success1() argument
1057 nvme_auth_send_success2(struct spdk_nvme_qpair * qpair) nvme_auth_send_success2() argument
1072 nvme_fabric_qpair_authenticate_poll(struct spdk_nvme_qpair * qpair) nvme_fabric_qpair_authenticate_poll() argument
1206 nvme_fabric_qpair_authenticate_async(struct spdk_nvme_qpair * qpair) nvme_fabric_qpair_authenticate_async() argument
[all...] |
| H A D | nvme_pcie_common.c | 24 static void nvme_pcie_fail_request_bad_vtophys(struct spdk_nvme_qpair *qpair,
39 nvme_pcie_qpair_reset(struct spdk_nvme_qpair *qpair) in nvme_pcie_qpair_reset() argument
41 struct nvme_pcie_qpair *pqpair = nvme_pcie_qpair(qpair); in nvme_pcie_qpair_reset()
63 nvme_pcie_qpair_get_fd(struct spdk_nvme_qpair *qpair, struct spdk_event_handler_opts *opts) in nvme_qpair_construct_tracker()
65 struct spdk_nvme_ctrlr *ctrlr = qpair->ctrlr; in nvme_qpair_construct_tracker()
74 return spdk_pci_device_get_interrupt_efd_by_index(devhandle, qpair->id); in nvme_pcie_ctrlr_alloc_cmb()
84 return spdk_pci_device_get_interrupt_efd_by_index(devhandle, qpair->id); in nvme_pcie_ctrlr_alloc_cmb()
123 nvme_pcie_qpair_construct(struct spdk_nvme_qpair *qpair, in nvme_pcie_qpair_construct()
126 struct spdk_nvme_ctrlr *ctrlr = qpair->ctrlr; in nvme_pcie_qpair_construct()
128 struct nvme_pcie_qpair *pqpair = nvme_pcie_qpair(qpair); in nvme_pcie_qpair_construct()
98 nvme_pcie_qpair_construct(struct spdk_nvme_qpair * qpair,const struct spdk_nvme_io_qpair_opts * opts) nvme_pcie_qpair_construct() argument
273 nvme_pcie_qpair_insert_pending_admin_request(struct spdk_nvme_qpair * qpair,struct nvme_request * req,struct spdk_nvme_cpl * cpl) nvme_pcie_qpair_insert_pending_admin_request() argument
304 nvme_pcie_qpair_complete_pending_admin_request(struct spdk_nvme_qpair * qpair) nvme_pcie_qpair_complete_pending_admin_request() argument
386 nvme_pcie_ctrlr_cmd_delete_io_cq(struct spdk_nvme_ctrlr * ctrlr,struct spdk_nvme_qpair * qpair,spdk_nvme_cmd_cb cb_fn,void * cb_arg) nvme_pcie_ctrlr_cmd_delete_io_cq() argument
405 nvme_pcie_ctrlr_cmd_delete_io_sq(struct spdk_nvme_ctrlr * ctrlr,struct spdk_nvme_qpair * qpair,spdk_nvme_cmd_cb cb_fn,void * cb_arg) nvme_pcie_ctrlr_cmd_delete_io_sq() argument
426 struct spdk_nvme_qpair *qpair = arg; nvme_completion_sq_error_delete_cq_cb() local
439 struct spdk_nvme_qpair *qpair = arg; nvme_completion_create_sq_cb() local
487 struct spdk_nvme_qpair *qpair = arg; nvme_completion_create_cq_cb() local
524 _nvme_pcie_ctrlr_create_io_qpair(struct spdk_nvme_ctrlr * ctrlr,struct spdk_nvme_qpair * qpair,uint16_t qid) _nvme_pcie_ctrlr_create_io_qpair() argument
560 nvme_pcie_ctrlr_connect_qpair(struct spdk_nvme_ctrlr * ctrlr,struct spdk_nvme_qpair * qpair) nvme_pcie_ctrlr_connect_qpair() argument
574 nvme_pcie_ctrlr_disconnect_qpair(struct spdk_nvme_ctrlr * ctrlr,struct spdk_nvme_qpair * qpair) nvme_pcie_ctrlr_disconnect_qpair() argument
622 nvme_pcie_qpair_submit_tracker(struct spdk_nvme_qpair * qpair,struct nvme_tracker * tr) nvme_pcie_qpair_submit_tracker() argument
668 nvme_pcie_qpair_complete_tracker(struct spdk_nvme_qpair * qpair,struct nvme_tracker * tr,struct spdk_nvme_cpl * cpl,bool print_on_error) nvme_pcie_qpair_complete_tracker() argument
719 nvme_pcie_qpair_manual_complete_tracker(struct spdk_nvme_qpair * qpair,struct nvme_tracker * tr,uint32_t sct,uint32_t sc,uint32_t dnr,bool print_on_error) nvme_pcie_qpair_manual_complete_tracker() argument
735 nvme_pcie_qpair_abort_trackers(struct spdk_nvme_qpair * qpair,uint32_t dnr) nvme_pcie_qpair_abort_trackers() argument
757 nvme_pcie_admin_qpair_abort_aers(struct spdk_nvme_qpair * qpair) nvme_pcie_admin_qpair_abort_aers() argument
777 nvme_pcie_admin_qpair_destroy(struct spdk_nvme_qpair * qpair) nvme_pcie_admin_qpair_destroy() argument
783 nvme_pcie_qpair_abort_reqs(struct spdk_nvme_qpair * qpair,uint32_t dnr) nvme_pcie_qpair_abort_reqs() argument
789 nvme_pcie_qpair_check_timeout(struct spdk_nvme_qpair * qpair) nvme_pcie_qpair_check_timeout() argument
828 nvme_pcie_qpair_process_completions(struct spdk_nvme_qpair * qpair,uint32_t max_completions) nvme_pcie_qpair_process_completions() argument
993 nvme_pcie_qpair_destroy(struct spdk_nvme_qpair * qpair) nvme_pcie_qpair_destroy() argument
1040 struct spdk_nvme_qpair *qpair; nvme_pcie_ctrlr_create_io_qpair() local
1073 nvme_pcie_ctrlr_delete_io_qpair(struct spdk_nvme_ctrlr * ctrlr,struct spdk_nvme_qpair * qpair) nvme_pcie_ctrlr_delete_io_qpair() argument
1166 nvme_pcie_fail_request_bad_vtophys(struct spdk_nvme_qpair * qpair,struct nvme_tracker * tr) nvme_pcie_fail_request_bad_vtophys() argument
1265 nvme_pcie_qpair_build_request_invalid(struct spdk_nvme_qpair * qpair,struct nvme_request * req,struct nvme_tracker * tr,bool dword_aligned) nvme_pcie_qpair_build_request_invalid() argument
1277 nvme_pcie_qpair_build_contig_request(struct spdk_nvme_qpair * qpair,struct nvme_request * req,struct nvme_tracker * tr,bool dword_aligned) nvme_pcie_qpair_build_contig_request() argument
1300 nvme_pcie_qpair_build_contig_hw_sgl_request(struct spdk_nvme_qpair * qpair,struct nvme_request * req,struct nvme_tracker * tr,bool dword_aligned) nvme_pcie_qpair_build_contig_hw_sgl_request() argument
1380 nvme_pcie_qpair_build_hw_sgl_request(struct spdk_nvme_qpair * qpair,struct nvme_request * req,struct nvme_tracker * tr,bool dword_aligned) nvme_pcie_qpair_build_hw_sgl_request() argument
1514 nvme_pcie_qpair_build_prps_sgl_request(struct spdk_nvme_qpair * qpair,struct nvme_request * req,struct nvme_tracker * tr,bool dword_aligned) nvme_pcie_qpair_build_prps_sgl_request() argument
1581 nvme_pcie_qpair_build_metadata(struct spdk_nvme_qpair * qpair,struct nvme_tracker * tr,bool sgl_supported,bool mptr_sgl_supported,bool dword_aligned) nvme_pcie_qpair_build_metadata() argument
1624 nvme_pcie_qpair_submit_request(struct spdk_nvme_qpair * qpair,struct nvme_request * req) nvme_pcie_qpair_submit_request() argument
1724 nvme_pcie_poll_group_connect_qpair(struct spdk_nvme_qpair * qpair) nvme_pcie_poll_group_connect_qpair() argument
1730 nvme_pcie_poll_group_disconnect_qpair(struct spdk_nvme_qpair * qpair) nvme_pcie_poll_group_disconnect_qpair() argument
1737 nvme_pcie_poll_group_add(struct spdk_nvme_transport_poll_group * tgroup,struct spdk_nvme_qpair * qpair) nvme_pcie_poll_group_add() argument
1744 nvme_pcie_poll_group_remove(struct spdk_nvme_transport_poll_group * tgroup,struct spdk_nvme_qpair * qpair) nvme_pcie_poll_group_remove() argument
1756 struct spdk_nvme_qpair *qpair, *tmp_qpair; nvme_pcie_poll_group_process_completions() local
[all...] |
| H A D | nvme_pcie_internal.h | 171 * Base qpair structure.
175 struct spdk_nvme_qpair qpair;
206 nvme_pcie_qpair(struct spdk_nvme_qpair *qpair) in nvme_pcie_qpair()
208 return SPDK_CONTAINEROF(qpair, struct nvme_pcie_qpair, qpair);
249 nvme_pcie_qpair_ring_sq_doorbell(struct spdk_nvme_qpair *qpair) in nvme_pcie_qpair_ring_sq_doorbell()
251 struct nvme_pcie_qpair *pqpair = nvme_pcie_qpair(qpair); in nvme_pcie_qpair_ring_sq_doorbell()
252 struct nvme_pcie_ctrlr *pctrlr = nvme_pcie_ctrlr(qpair->ctrlr); in nvme_pcie_qpair_ring_sq_doorbell()
255 if (qpair->last_fuse == SPDK_NVME_IO_FLAGS_FUSE_FIRST) { in nvme_pcie_qpair_ring_sq_doorbell()
278 nvme_pcie_qpair_ring_cq_doorbell(struct spdk_nvme_qpair *qpair) in nvme_pcie_qpair_ring_cq_doorbell()
172 struct spdk_nvme_qpair qpair; global() member
203 nvme_pcie_qpair(struct spdk_nvme_qpair * qpair) nvme_pcie_qpair() argument
246 nvme_pcie_qpair_ring_sq_doorbell(struct spdk_nvme_qpair * qpair) nvme_pcie_qpair_ring_sq_doorbell() argument
275 nvme_pcie_qpair_ring_cq_doorbell(struct spdk_nvme_qpair * qpair) nvme_pcie_qpair_ring_cq_doorbell() argument
[all...] |
| H A D | nvme_zns.c | 68 spdk_nvme_zns_zone_append(struct spdk_nvme_ns *ns, struct spdk_nvme_qpair *qpair, in spdk_nvme_zns_zone_append() argument
73 return nvme_ns_cmd_zone_append_with_md(ns, qpair, buffer, NULL, zslba, lba_count, in spdk_nvme_zns_zone_append()
78 spdk_nvme_zns_zone_append_with_md(struct spdk_nvme_ns *ns, struct spdk_nvme_qpair *qpair, in spdk_nvme_zns_zone_append_with_md() argument
83 return nvme_ns_cmd_zone_append_with_md(ns, qpair, buffer, metadata, zslba, lba_count, in spdk_nvme_zns_zone_append_with_md()
88 spdk_nvme_zns_zone_appendv(struct spdk_nvme_ns *ns, struct spdk_nvme_qpair *qpair, in spdk_nvme_zns_zone_appendv() argument
94 return nvme_ns_cmd_zone_appendv_with_md(ns, qpair, zslba, lba_count, cb_fn, cb_arg, in spdk_nvme_zns_zone_appendv()
100 spdk_nvme_zns_zone_appendv_with_md(struct spdk_nvme_ns *ns, struct spdk_nvme_qpair *qpair, in spdk_nvme_zns_zone_appendv_with_md() argument
107 return nvme_ns_cmd_zone_appendv_with_md(ns, qpair, zslba, lba_count, cb_fn, cb_arg, in spdk_nvme_zns_zone_appendv_with_md()
113 nvme_zns_zone_mgmt_recv(struct spdk_nvme_ns *ns, struct spdk_nvme_qpair *qpair, in nvme_zns_zone_mgmt_recv() argument
121 req = nvme_allocate_request_user_copy(qpair, payload, payload_size, cb_fn, cb_arg, false); in nvme_zns_zone_mgmt_recv()
[all …]
|
| H A D | nvme_ns_cmd.c | 12 struct spdk_nvme_qpair *qpair,
76 _nvme_add_child_request(struct spdk_nvme_ns *ns, struct spdk_nvme_qpair *qpair, in _nvme_add_child_request() argument
85 child = _nvme_ns_cmd_rw(ns, qpair, payload, payload_offset, md_offset, lba, lba_count, cb_fn, in _nvme_add_child_request()
99 struct spdk_nvme_qpair *qpair, in _nvme_ns_cmd_split_request() argument
123 child = _nvme_add_child_request(ns, qpair, payload, payload_offset, md_offset, in _nvme_ns_cmd_split_request()
152 _is_accel_sequence_valid(struct spdk_nvme_qpair *qpair, void *seq) in _is_accel_sequence_valid() argument
154 /* An accel sequence can only be executed if the controller supports accel and a qpair is in _is_accel_sequence_valid()
156 if (spdk_likely(seq == NULL || ((qpair->ctrlr->flags & SPDK_NVME_CTRLR_ACCEL_SEQUENCE_SUPPORTED) && in _is_accel_sequence_valid()
157 qpair->poll_group != NULL))) { in _is_accel_sequence_valid()
202 struct spdk_nvme_qpair *qpair, in _nvme_ns_cmd_split_request_prp() argument
332 _nvme_ns_cmd_split_request_sgl(struct spdk_nvme_ns * ns,struct spdk_nvme_qpair * qpair,const struct nvme_payload * payload,uint32_t payload_offset,uint32_t md_offset,uint64_t lba,uint32_t lba_count,spdk_nvme_cmd_cb cb_fn,void * cb_arg,uint32_t opc,uint32_t io_flags,struct nvme_request * req,uint16_t apptag_mask,uint16_t apptag,uint32_t cdw13,void * accel_sequence,int * rc) _nvme_ns_cmd_split_request_sgl() argument
423 _nvme_ns_cmd_rw(struct spdk_nvme_ns * ns,struct spdk_nvme_qpair * qpair,const struct nvme_payload * payload,uint32_t payload_offset,uint32_t md_offset,uint64_t lba,uint32_t lba_count,spdk_nvme_cmd_cb cb_fn,void * cb_arg,uint32_t opc,uint32_t io_flags,uint16_t apptag_mask,uint16_t apptag,uint32_t cdw13,bool check_sgl,void * accel_sequence,int * rc) _nvme_ns_cmd_rw() argument
497 spdk_nvme_ns_cmd_compare(struct spdk_nvme_ns * ns,struct spdk_nvme_qpair * qpair,void * buffer,uint64_t lba,uint32_t lba_count,spdk_nvme_cmd_cb cb_fn,void * cb_arg,uint32_t io_flags) spdk_nvme_ns_cmd_compare() argument
528 spdk_nvme_ns_cmd_compare_with_md(struct spdk_nvme_ns * ns,struct spdk_nvme_qpair * qpair,void * buffer,void * metadata,uint64_t lba,uint32_t lba_count,spdk_nvme_cmd_cb cb_fn,void * cb_arg,uint32_t io_flags,uint16_t apptag_mask,uint16_t apptag) spdk_nvme_ns_cmd_compare_with_md() argument
561 spdk_nvme_ns_cmd_comparev(struct spdk_nvme_ns * ns,struct spdk_nvme_qpair * qpair,uint64_t lba,uint32_t lba_count,spdk_nvme_cmd_cb cb_fn,void * cb_arg,uint32_t io_flags,spdk_nvme_req_reset_sgl_cb reset_sgl_fn,spdk_nvme_req_next_sge_cb next_sge_fn) spdk_nvme_ns_cmd_comparev() argument
596 spdk_nvme_ns_cmd_comparev_with_md(struct spdk_nvme_ns * ns,struct spdk_nvme_qpair * qpair,uint64_t lba,uint32_t lba_count,spdk_nvme_cmd_cb cb_fn,void * cb_arg,uint32_t io_flags,spdk_nvme_req_reset_sgl_cb reset_sgl_fn,spdk_nvme_req_next_sge_cb next_sge_fn,void * metadata,uint16_t apptag_mask,uint16_t apptag) spdk_nvme_ns_cmd_comparev_with_md() argument
632 spdk_nvme_ns_cmd_read(struct spdk_nvme_ns * ns,struct spdk_nvme_qpair * qpair,void * buffer,uint64_t lba,uint32_t lba_count,spdk_nvme_cmd_cb cb_fn,void * cb_arg,uint32_t io_flags) spdk_nvme_ns_cmd_read() argument
662 spdk_nvme_ns_cmd_read_with_md(struct spdk_nvme_ns * ns,struct spdk_nvme_qpair * qpair,void * buffer,void * metadata,uint64_t lba,uint32_t lba_count,spdk_nvme_cmd_cb cb_fn,void * cb_arg,uint32_t io_flags,uint16_t apptag_mask,uint16_t apptag) spdk_nvme_ns_cmd_read_with_md() argument
693 nvme_ns_cmd_rw_ext(struct spdk_nvme_ns * ns,struct spdk_nvme_qpair * qpair,void * buffer,uint64_t lba,uint32_t lba_count,spdk_nvme_cmd_cb cb_fn,void * cb_arg,struct spdk_nvme_ns_cmd_ext_io_opts * opts,enum spdk_nvme_nvm_opcode opc) nvme_ns_cmd_rw_ext() argument
732 spdk_nvme_ns_cmd_read_ext(struct spdk_nvme_ns * ns,struct spdk_nvme_qpair * qpair,void * buffer,uint64_t lba,uint32_t lba_count,spdk_nvme_cmd_cb cb_fn,void * cb_arg,struct spdk_nvme_ns_cmd_ext_io_opts * opts) spdk_nvme_ns_cmd_read_ext() argument
742 spdk_nvme_ns_cmd_readv(struct spdk_nvme_ns * ns,struct spdk_nvme_qpair * qpair,uint64_t lba,uint32_t lba_count,spdk_nvme_cmd_cb cb_fn,void * cb_arg,uint32_t io_flags,spdk_nvme_req_reset_sgl_cb reset_sgl_fn,spdk_nvme_req_next_sge_cb next_sge_fn) spdk_nvme_ns_cmd_readv() argument
776 spdk_nvme_ns_cmd_readv_with_md(struct spdk_nvme_ns * ns,struct spdk_nvme_qpair * qpair,uint64_t lba,uint32_t lba_count,spdk_nvme_cmd_cb cb_fn,void * cb_arg,uint32_t io_flags,spdk_nvme_req_reset_sgl_cb reset_sgl_fn,spdk_nvme_req_next_sge_cb next_sge_fn,void * metadata,uint16_t apptag_mask,uint16_t apptag) spdk_nvme_ns_cmd_readv_with_md() argument
811 nvme_ns_cmd_rwv_ext(struct spdk_nvme_ns * ns,struct spdk_nvme_qpair * qpair,uint64_t lba,uint32_t lba_count,spdk_nvme_cmd_cb cb_fn,void * cb_arg,spdk_nvme_req_reset_sgl_cb reset_sgl_fn,spdk_nvme_req_next_sge_cb next_sge_fn,struct spdk_nvme_ns_cmd_ext_io_opts * opts,enum spdk_nvme_nvm_opcode opc) nvme_ns_cmd_rwv_ext() argument
861 spdk_nvme_ns_cmd_readv_ext(struct spdk_nvme_ns * ns,struct spdk_nvme_qpair * qpair,uint64_t lba,uint32_t lba_count,spdk_nvme_cmd_cb cb_fn,void * cb_arg,spdk_nvme_req_reset_sgl_cb reset_sgl_fn,spdk_nvme_req_next_sge_cb next_sge_fn,struct spdk_nvme_ns_cmd_ext_io_opts * opts) spdk_nvme_ns_cmd_readv_ext() argument
872 spdk_nvme_ns_cmd_write(struct spdk_nvme_ns * ns,struct spdk_nvme_qpair * qpair,void * buffer,uint64_t lba,uint32_t lba_count,spdk_nvme_cmd_cb cb_fn,void * cb_arg,uint32_t io_flags) spdk_nvme_ns_cmd_write() argument
921 nvme_ns_cmd_zone_append_with_md(struct spdk_nvme_ns * ns,struct spdk_nvme_qpair * qpair,void * buffer,void * metadata,uint64_t zslba,uint32_t lba_count,spdk_nvme_cmd_cb cb_fn,void * cb_arg,uint32_t io_flags,uint16_t apptag_mask,uint16_t apptag) nvme_ns_cmd_zone_append_with_md() argument
968 nvme_ns_cmd_zone_appendv_with_md(struct spdk_nvme_ns * ns,struct spdk_nvme_qpair * qpair,uint64_t zslba,uint32_t lba_count,spdk_nvme_cmd_cb cb_fn,void * cb_arg,uint32_t io_flags,spdk_nvme_req_reset_sgl_cb reset_sgl_fn,spdk_nvme_req_next_sge_cb next_sge_fn,void * metadata,uint16_t apptag_mask,uint16_t apptag) nvme_ns_cmd_zone_appendv_with_md() argument
1026 spdk_nvme_ns_cmd_write_with_md(struct spdk_nvme_ns * ns,struct spdk_nvme_qpair * qpair,void * buffer,void * metadata,uint64_t lba,uint32_t lba_count,spdk_nvme_cmd_cb cb_fn,void * cb_arg,uint32_t io_flags,uint16_t apptag_mask,uint16_t apptag) spdk_nvme_ns_cmd_write_with_md() argument
1055 spdk_nvme_ns_cmd_write_ext(struct spdk_nvme_ns * ns,struct spdk_nvme_qpair * qpair,void * buffer,uint64_t lba,uint32_t lba_count,spdk_nvme_cmd_cb cb_fn,void * cb_arg,struct spdk_nvme_ns_cmd_ext_io_opts * opts) spdk_nvme_ns_cmd_write_ext() argument
1065 spdk_nvme_ns_cmd_writev(struct spdk_nvme_ns * ns,struct spdk_nvme_qpair * qpair,uint64_t lba,uint32_t lba_count,spdk_nvme_cmd_cb cb_fn,void * cb_arg,uint32_t io_flags,spdk_nvme_req_reset_sgl_cb reset_sgl_fn,spdk_nvme_req_next_sge_cb next_sge_fn) spdk_nvme_ns_cmd_writev() argument
1099 spdk_nvme_ns_cmd_writev_with_md(struct spdk_nvme_ns * ns,struct spdk_nvme_qpair * qpair,uint64_t lba,uint32_t lba_count,spdk_nvme_cmd_cb cb_fn,void * cb_arg,uint32_t io_flags,spdk_nvme_req_reset_sgl_cb reset_sgl_fn,spdk_nvme_req_next_sge_cb next_sge_fn,void * metadata,uint16_t apptag_mask,uint16_t apptag) spdk_nvme_ns_cmd_writev_with_md() argument
1134 spdk_nvme_ns_cmd_writev_ext(struct spdk_nvme_ns * ns,struct spdk_nvme_qpair * qpair,uint64_t lba,uint32_t lba_count,spdk_nvme_cmd_cb cb_fn,void * cb_arg,spdk_nvme_req_reset_sgl_cb reset_sgl_fn,spdk_nvme_req_next_sge_cb next_sge_fn,struct spdk_nvme_ns_cmd_ext_io_opts * opts) spdk_nvme_ns_cmd_writev_ext() argument
1145 spdk_nvme_ns_cmd_write_zeroes(struct spdk_nvme_ns * ns,struct spdk_nvme_qpair * qpair,uint64_t lba,uint32_t lba_count,spdk_nvme_cmd_cb cb_fn,void * cb_arg,uint32_t io_flags) spdk_nvme_ns_cmd_write_zeroes() argument
1181 spdk_nvme_ns_cmd_verify(struct spdk_nvme_ns * ns,struct spdk_nvme_qpair * qpair,uint64_t lba,uint32_t lba_count,spdk_nvme_cmd_cb cb_fn,void * cb_arg,uint32_t io_flags) spdk_nvme_ns_cmd_verify() argument
1215 spdk_nvme_ns_cmd_write_uncorrectable(struct spdk_nvme_ns * ns,struct spdk_nvme_qpair * qpair,uint64_t lba,uint32_t lba_count,spdk_nvme_cmd_cb cb_fn,void * cb_arg) spdk_nvme_ns_cmd_write_uncorrectable() argument
1244 spdk_nvme_ns_cmd_dataset_management(struct spdk_nvme_ns * ns,struct spdk_nvme_qpair * qpair,uint32_t type,const struct spdk_nvme_dsm_range * ranges,uint16_t num_ranges,spdk_nvme_cmd_cb cb_fn,void * cb_arg) spdk_nvme_ns_cmd_dataset_management() argument
1278 spdk_nvme_ns_cmd_copy(struct spdk_nvme_ns * ns,struct spdk_nvme_qpair * qpair,const struct spdk_nvme_scc_source_range * ranges,uint16_t num_ranges,uint64_t dest_lba,spdk_nvme_cmd_cb cb_fn,void * cb_arg) spdk_nvme_ns_cmd_copy() argument
1312 spdk_nvme_ns_cmd_flush(struct spdk_nvme_ns * ns,struct spdk_nvme_qpair * qpair,spdk_nvme_cmd_cb cb_fn,void * cb_arg) spdk_nvme_ns_cmd_flush() argument
1332 spdk_nvme_ns_cmd_reservation_register(struct spdk_nvme_ns * ns,struct spdk_nvme_qpair * qpair,struct spdk_nvme_reservation_register_data * payload,bool ignore_key,enum spdk_nvme_reservation_register_action action,enum spdk_nvme_reservation_register_cptpl cptpl,spdk_nvme_cmd_cb cb_fn,void * cb_arg) spdk_nvme_ns_cmd_reservation_register() argument
1362 spdk_nvme_ns_cmd_reservation_release(struct spdk_nvme_ns * ns,struct spdk_nvme_qpair * qpair,struct spdk_nvme_reservation_key_data * payload,bool ignore_key,enum spdk_nvme_reservation_release_action action,enum spdk_nvme_reservation_type type,spdk_nvme_cmd_cb cb_fn,void * cb_arg) spdk_nvme_ns_cmd_reservation_release() argument
1392 spdk_nvme_ns_cmd_reservation_acquire(struct spdk_nvme_ns * ns,struct spdk_nvme_qpair * qpair,struct spdk_nvme_reservation_acquire_data * payload,bool ignore_key,enum spdk_nvme_reservation_acquire_action action,enum spdk_nvme_reservation_type type,spdk_nvme_cmd_cb cb_fn,void * cb_arg) spdk_nvme_ns_cmd_reservation_acquire() argument
1422 spdk_nvme_ns_cmd_reservation_report(struct spdk_nvme_ns * ns,struct spdk_nvme_qpair * qpair,void * payload,uint32_t len,spdk_nvme_cmd_cb cb_fn,void * cb_arg) spdk_nvme_ns_cmd_reservation_report() argument
1450 spdk_nvme_ns_cmd_io_mgmt_recv(struct spdk_nvme_ns * ns,struct spdk_nvme_qpair * qpair,void * payload,uint32_t len,uint8_t mo,uint16_t mos,spdk_nvme_cmd_cb cb_fn,void * cb_arg) spdk_nvme_ns_cmd_io_mgmt_recv() argument
1481 spdk_nvme_ns_cmd_io_mgmt_send(struct spdk_nvme_ns * ns,struct spdk_nvme_qpair * qpair,void * payload,uint32_t len,uint8_t mo,uint16_t mos,spdk_nvme_cmd_cb cb_fn,void * cb_arg) spdk_nvme_ns_cmd_io_mgmt_send() argument
[all...] |
| H A D | nvme_internal.h | 318 struct spdk_nvme_qpair *qpair;
467 * Members for handling IO qpair deletion inside of a completion context.
476 * which allocated this qpair exited unexpectedly.
485 /* The user is destroying qpair */
495 /* request object used only for this qpair's FABRICS/CONNECT command (if needed) */
904 * Admin qpair was disconnected, controller needs to be re-initialized
986 * can use this to skip unnecessary parts of the qpair deletion process
1193 nvme_qpair_is_admin_queue(struct spdk_nvme_qpair *qpair) in nvme_robust_mutex_unlock()
1195 return qpair->id == 0; in nvme_robust_mutex_unlock()
1199 nvme_qpair_is_io_queue(struct spdk_nvme_qpair *qpair) in nvme_ctrlr_unlock()
316 struct spdk_nvme_qpair *qpair; global() member
1156 nvme_qpair_is_admin_queue(struct spdk_nvme_qpair * qpair) nvme_qpair_is_admin_queue() argument
1162 nvme_qpair_is_io_queue(struct spdk_nvme_qpair * qpair) nvme_qpair_is_io_queue() argument
1388 nvme_allocate_request(struct spdk_nvme_qpair * qpair,const struct nvme_payload * payload,uint32_t payload_size,uint32_t md_size,spdk_nvme_cmd_cb cb_fn,void * cb_arg) nvme_allocate_request() argument
1408 nvme_allocate_request_contig(struct spdk_nvme_qpair * qpair,void * buffer,uint32_t payload_size,spdk_nvme_cmd_cb cb_fn,void * cb_arg) nvme_allocate_request_contig() argument
1420 nvme_allocate_request_null(struct spdk_nvme_qpair * qpair,spdk_nvme_cmd_cb cb_fn,void * cb_arg) nvme_allocate_request_null() argument
1430 _nvme_free_request(struct nvme_request * req,struct spdk_nvme_qpair * qpair) _nvme_free_request() argument
1454 nvme_complete_request(spdk_nvme_cmd_cb cb_fn,void * cb_arg,struct spdk_nvme_qpair * qpair,struct nvme_request * req,struct spdk_nvme_cpl * cpl) nvme_complete_request() argument
1519 nvme_qpair_set_state(struct spdk_nvme_qpair * qpair,enum nvme_qpair_state state) nvme_qpair_set_state() argument
1528 nvme_qpair_get_state(struct spdk_nvme_qpair * qpair) nvme_qpair_get_state() argument
[all...] |
| H A D | nvme_rdma.c | 33 * NVME RDMA qpair Resource Defaults
65 * Number of microseconds to wait until the lingering qpair becomes quiet.
188 /* NVMe RDMA qpair extensions for spdk_nvme_qpair */
190 struct spdk_nvme_qpair qpair;
317 struct spdk_nvme_qpair *qpair); in nvme_rdma_qpair()
331 nvme_rdma_qpair(struct spdk_nvme_qpair *qpair) in nvme_rdma_ctrlr()
333 assert(qpair->trtype == SPDK_NVME_TRANSPORT_RDMA);
334 return SPDK_CONTAINEROF(qpair, struct nvme_rdma_qpair, qpair); in nvme_rdma_req_get()
391 struct spdk_nvme_qpair *qpair; in nvme_rdma_cm_event_str_get()
189 struct spdk_nvme_qpair qpair; global() member
314 nvme_rdma_qpair(struct spdk_nvme_qpair * qpair) nvme_rdma_qpair() argument
362 struct spdk_nvme_qpair *qpair; nvme_rdma_req_complete() local
637 nvme_rdma_qpair_set_poller(struct spdk_nvme_qpair * qpair) nvme_rdma_qpair_set_poller() argument
1183 nvme_rdma_ctrlr_connect_qpair(struct spdk_nvme_ctrlr * ctrlr,struct spdk_nvme_qpair * qpair) nvme_rdma_ctrlr_connect_qpair() argument
1261 struct spdk_nvme_qpair *qpair = &rqpair->qpair; nvme_rdma_stale_conn_reconnect() local
1272 nvme_rdma_ctrlr_connect_qpair_poll(struct spdk_nvme_ctrlr * ctrlr,struct spdk_nvme_qpair * qpair) nvme_rdma_ctrlr_connect_qpair_poll() argument
1742 struct spdk_nvme_qpair *qpair; nvme_rdma_ctrlr_create_qpair() local
1778 struct spdk_nvme_qpair *qpair = &rqpair->qpair; nvme_rdma_qpair_destroy() local
1886 struct spdk_nvme_qpair *qpair = &rqpair->qpair; nvme_rdma_qpair_wait_until_quiet() local
1910 _nvme_rdma_ctrlr_disconnect_qpair(struct spdk_nvme_ctrlr * ctrlr,struct spdk_nvme_qpair * qpair,nvme_rdma_cm_event_cb disconnected_qpair_cb) _nvme_rdma_ctrlr_disconnect_qpair() argument
1937 nvme_rdma_ctrlr_disconnect_qpair_poll(struct spdk_nvme_ctrlr * ctrlr,struct spdk_nvme_qpair * qpair) nvme_rdma_ctrlr_disconnect_qpair_poll() argument
1972 nvme_rdma_ctrlr_disconnect_qpair(struct spdk_nvme_ctrlr * ctrlr,struct spdk_nvme_qpair * qpair) nvme_rdma_ctrlr_disconnect_qpair() argument
2001 struct spdk_nvme_qpair *qpair = &rqpair->qpair; nvme_rdma_stale_conn_disconnected() local
2022 struct spdk_nvme_qpair *qpair = &rqpair->qpair; nvme_rdma_stale_conn_retry() local
2041 nvme_rdma_ctrlr_delete_io_qpair(struct spdk_nvme_ctrlr * ctrlr,struct spdk_nvme_qpair * qpair) nvme_rdma_ctrlr_delete_io_qpair() argument
2231 nvme_rdma_qpair_submit_request(struct spdk_nvme_qpair * qpair,struct nvme_request * req) nvme_rdma_qpair_submit_request() argument
2283 nvme_rdma_qpair_reset(struct spdk_nvme_qpair * qpair) nvme_rdma_qpair_reset() argument
2290 nvme_rdma_qpair_abort_reqs(struct spdk_nvme_qpair * qpair,uint32_t dnr) nvme_rdma_qpair_abort_reqs() argument
2317 nvme_rdma_qpair_check_timeout(struct spdk_nvme_qpair * qpair) nvme_rdma_qpair_check_timeout() argument
2379 nvme_rdma_fail_qpair(struct spdk_nvme_qpair * qpair,int failure_reason) nvme_rdma_fail_qpair() argument
2393 struct spdk_nvme_qpair *qpair; get_rdma_qpair_from_wc() local
2636 dummy_disconnected_qpair_cb(struct spdk_nvme_qpair * qpair,void * poll_group_ctx) dummy_disconnected_qpair_cb() argument
2642 nvme_rdma_qpair_process_completions(struct spdk_nvme_qpair * qpair,uint32_t max_completions) nvme_rdma_qpair_process_completions() argument
2765 nvme_rdma_qpair_iterate_requests(struct spdk_nvme_qpair * qpair,int (* iter_fn)(struct nvme_request * req,void * arg),void * arg) nvme_rdma_qpair_iterate_requests() argument
2788 nvme_rdma_admin_qpair_abort_aers(struct spdk_nvme_qpair * qpair) nvme_rdma_admin_qpair_abort_aers() argument
3000 nvme_rdma_poll_group_connect_qpair(struct spdk_nvme_qpair * qpair) nvme_rdma_poll_group_connect_qpair() argument
3006 nvme_rdma_poll_group_disconnect_qpair(struct spdk_nvme_qpair * qpair) nvme_rdma_poll_group_disconnect_qpair() argument
3024 nvme_rdma_poll_group_add(struct spdk_nvme_transport_poll_group * tgroup,struct spdk_nvme_qpair * qpair) nvme_rdma_poll_group_add() argument
3031 nvme_rdma_poll_group_remove(struct spdk_nvme_transport_poll_group * tgroup,struct spdk_nvme_qpair * qpair) nvme_rdma_poll_group_remove() argument
3048 struct spdk_nvme_qpair *qpair = &rqpair->qpair; nvme_rdma_qpair_process_submits() local
3083 struct spdk_nvme_qpair *qpair, *tmp_qpair; nvme_rdma_poll_group_process_completions() local
[all...] |
| H A D | nvme_ns_ocssd_cmd.c | 11 struct spdk_nvme_qpair *qpair, in spdk_nvme_ocssd_ns_cmd_vector_reset() argument
24 req = nvme_allocate_request_null(qpair, cb_fn, cb_arg); in spdk_nvme_ocssd_ns_cmd_vector_reset()
50 return nvme_qpair_submit_request(qpair, req); in spdk_nvme_ocssd_ns_cmd_vector_reset()
55 struct spdk_nvme_qpair *qpair, in _nvme_ocssd_ns_cmd_vector_rw_with_md() argument
78 req = nvme_allocate_request(qpair, &payload, num_lbas * ns->sector_size, num_lbas * ns->md_size, in _nvme_ocssd_ns_cmd_vector_rw_with_md()
102 return nvme_qpair_submit_request(qpair, req); in _nvme_ocssd_ns_cmd_vector_rw_with_md()
107 struct spdk_nvme_qpair *qpair, in spdk_nvme_ocssd_ns_cmd_vector_write_with_md() argument
113 return _nvme_ocssd_ns_cmd_vector_rw_with_md(ns, qpair, buffer, metadata, lba_list, in spdk_nvme_ocssd_ns_cmd_vector_write_with_md()
119 struct spdk_nvme_qpair *qpair, in spdk_nvme_ocssd_ns_cmd_vector_write() argument
125 return _nvme_ocssd_ns_cmd_vector_rw_with_md(ns, qpair, buffer, NULL, lba_list, in spdk_nvme_ocssd_ns_cmd_vector_write()
[all …]
|
| H A D | nvme_poll_group.c | 113 spdk_nvme_qpair_get_optimal_poll_group(struct spdk_nvme_qpair *qpair)
117 tgroup = nvme_transport_qpair_get_optimal_poll_group(qpair->transport, qpair); in spdk_nvme_poll_group_remove()
149 /* Write to the disconnect qpair fd. This will generate event on the epoll fd of poll in spdk_nvme_poll_group_process_completions()
155 SPDK_ERRLOG("failed to write the disconnect qpair fd: %s.\n", strerror(errno)); in spdk_nvme_poll_group_process_completions()
196 spdk_nvme_poll_group_add(struct spdk_nvme_poll_group *group, struct spdk_nvme_qpair *qpair) in spdk_nvme_poll_group_all_connected()
202 if (nvme_qpair_get_state(qpair) != NVME_QPAIR_DISCONNECTED) {
208 group->enable_interrupts = qpair->ctrlr->opts.enable_interrupts;
215 } else if (qpair->ctrlr->opts.enable_interrupts != group->enable_interrupts) { in spdk_nvme_poll_group_destroy()
217 qpair in spdk_nvme_poll_group_destroy()
65 spdk_nvme_qpair_get_optimal_poll_group(struct spdk_nvme_qpair * qpair) spdk_nvme_qpair_get_optimal_poll_group() argument
79 spdk_nvme_poll_group_add(struct spdk_nvme_poll_group * group,struct spdk_nvme_qpair * qpair) spdk_nvme_poll_group_add() argument
115 spdk_nvme_poll_group_remove(struct spdk_nvme_poll_group * group,struct spdk_nvme_qpair * qpair) spdk_nvme_poll_group_remove() argument
129 nvme_poll_group_connect_qpair(struct spdk_nvme_qpair * qpair) nvme_poll_group_connect_qpair() argument
135 nvme_poll_group_disconnect_qpair(struct spdk_nvme_qpair * qpair) nvme_poll_group_disconnect_qpair() argument
176 struct spdk_nvme_qpair *qpair; spdk_nvme_poll_group_all_connected() local
[all...] |
| /spdk/test/unit/lib/nvme/nvme_qpair.c/ |
| H A D | nvme_qpair_ut.c | 26 DEFINE_STUB_V(nvme_transport_qpair_abort_reqs, (struct spdk_nvme_qpair *qpair));
28 (struct spdk_nvme_qpair *qpair, struct nvme_request *req), 0);
29 DEFINE_STUB(spdk_nvme_ctrlr_free_io_qpair, int, (struct spdk_nvme_qpair *qpair), 0);
31 struct spdk_nvme_qpair *qpair));
32 DEFINE_STUB_V(nvme_ctrlr_disconnect_qpair, (struct spdk_nvme_qpair *qpair));
36 (struct spdk_nvme_ctrlr *ctrlr, struct spdk_nvme_qpair *qpair), 0);
50 nvme_transport_qpair_process_completions(struct spdk_nvme_qpair *qpair, uint32_t max_completions) in nvme_transport_qpair_process_completions() argument
57 prepare_submit_request_test(struct spdk_nvme_qpair *qpair, in prepare_submit_request_test() argument
65 nvme_qpair_init(qpair, 1, ctrlr, 0, 32, false); in prepare_submit_request_test()
69 cleanup_submit_request_test(struct spdk_nvme_qpair *qpair) in cleanup_submit_request_test() argument
89 struct spdk_nvme_qpair qpair = {}; test3() local
109 struct spdk_nvme_qpair qpair = {}; test_ctrlr_failed() local
158 struct spdk_nvme_qpair qpair = {0}; test_nvme_qpair_process_completions() local
428 struct spdk_nvme_qpair qpair = {}; test_nvme_qpair_add_cmd_error_injection() local
494 allocate_request_tree(struct spdk_nvme_qpair * qpair) allocate_request_tree() argument
558 struct spdk_nvme_qpair qpair = {}; test_nvme_qpair_submit_request() local
582 struct spdk_nvme_qpair qpair = {}; test_nvme_qpair_resubmit_request_with_transport_failed() local
621 struct spdk_nvme_qpair qpair = {}; test_nvme_qpair_manual_complete_request() local
651 struct spdk_nvme_qpair qpair = {}; test_nvme_qpair_init_deinit() local
[all...] |
| /spdk/lib/nvmf/ |
| H A D | auth.c | 93 nvmf_auth_set_state(struct spdk_nvmf_qpair *qpair, enum nvmf_qpair_auth_state state) in nvmf_auth_set_state()
95 struct spdk_nvmf_qpair_auth *auth = qpair->auth; in nvmf_auth_set_state()
101 AUTH_DEBUGLOG(qpair, "auth state: %s\n", nvmf_auth_get_state_name(state)); in nvmf_auth_set_state()
106 nvmf_auth_disconnect_qpair(struct spdk_nvmf_qpair *qpair) in nvmf_auth_disconnect_qpair()
108 nvmf_auth_set_state(qpair, NVMF_QPAIR_AUTH_ERROR); in nvmf_auth_disconnect_qpair()
109 spdk_nvmf_qpair_disconnect(qpair); in nvmf_auth_disconnect_qpair()
115 struct spdk_nvmf_qpair *qpair = req->qpair; in nvmf_auth_request_fail1()
116 struct spdk_nvmf_qpair_auth *auth = qpair->auth; in nvmf_auth_request_fail1()
118 nvmf_auth_set_state(qpair, NVMF_QPAIR_AUTH_FAILURE in nvmf_auth_request_fail1()
92 nvmf_auth_set_state(struct spdk_nvmf_qpair * qpair,enum nvmf_qpair_auth_state state) nvmf_auth_set_state() argument
105 nvmf_auth_disconnect_qpair(struct spdk_nvmf_qpair * qpair) nvmf_auth_disconnect_qpair() argument
114 struct spdk_nvmf_qpair *qpair = req->qpair; nvmf_auth_request_fail1() local
127 nvmf_auth_digest_allowed(struct spdk_nvmf_qpair * qpair,uint8_t digest) nvmf_auth_digest_allowed() argument
135 nvmf_auth_dhgroup_allowed(struct spdk_nvmf_qpair * qpair,uint8_t dhgroup) nvmf_auth_dhgroup_allowed() argument
145 struct spdk_nvmf_qpair *qpair = ctx; nvmf_auth_timeout_poller() local
157 nvmf_auth_rearm_poller(struct spdk_nvmf_qpair * qpair) nvmf_auth_rearm_poller() argument
187 struct spdk_nvmf_qpair *qpair = req->qpair; nvmf_auth_check_command() local
218 struct spdk_nvmf_qpair *qpair = req->qpair; nvmf_auth_negotiate_exec() local
337 struct spdk_nvmf_qpair *qpair = req->qpair; nvmf_auth_reply_exec() local
472 struct spdk_nvmf_qpair *qpair = req->qpair; nvmf_auth_success2_exec() local
501 struct spdk_nvmf_qpair *qpair = req->qpair; nvmf_auth_failure2_exec() local
529 struct spdk_nvmf_qpair *qpair = req->qpair; nvmf_auth_send_exec() local
594 struct spdk_nvmf_qpair *qpair = req->qpair; nvmf_auth_recv_failure1() local
618 nvmf_auth_get_seqnum(struct spdk_nvmf_qpair * qpair) nvmf_auth_get_seqnum() argument
645 struct spdk_nvmf_qpair *qpair = req->qpair; nvmf_auth_recv_challenge() local
712 struct spdk_nvmf_qpair *qpair = req->qpair; nvmf_auth_recv_success1() local
757 struct spdk_nvmf_qpair *qpair = req->qpair; nvmf_auth_recv_exec() local
795 struct spdk_nvmf_qpair *qpair = req->qpair; nvmf_auth_request_exec() local
824 nvmf_qpair_auth_init(struct spdk_nvmf_qpair * qpair) nvmf_qpair_auth_init() argument
850 nvmf_qpair_auth_destroy(struct spdk_nvmf_qpair * qpair) nvmf_qpair_auth_destroy() argument
862 nvmf_qpair_auth_dump(struct spdk_nvmf_qpair * qpair,struct spdk_json_write_ctx * w) nvmf_qpair_auth_dump() argument
[all...] |
| H A D | nvmf.c | 31 struct spdk_nvmf_qpair *qpair; member
38 * In order to do this sequentially without overlap, we must provide a context to recover the next qpair from
39 * to enable calling nvmf_qpair_disconnect on the next desired qpair.
139 nvmf_qpair_set_state(struct spdk_nvmf_qpair *qpair, in nvmf_qpair_set_state() argument
142 assert(qpair != NULL); in nvmf_qpair_set_state()
143 assert(qpair->group->thread == spdk_get_thread()); in nvmf_qpair_set_state()
145 qpair->state = state; in nvmf_qpair_set_state()
289 struct spdk_nvmf_qpair *qpair, *qpair_tmp; in nvmf_tgt_create_poll_group()
295 TAILQ_FOREACH_SAFE(qpair, &group->qpairs, link, qpair_tmp) { in nvmf_tgt_create_poll_group()
296 rc = spdk_nvmf_qpair_disconnect(qpair); in nvmf_tgt_create_poll_group()
312 struct spdk_nvmf_qpair *qpair, *qpair_tmp; _nvmf_tgt_disconnect_qpairs() local
1131 struct spdk_nvmf_qpair *qpair; global() member
1139 struct spdk_nvmf_qpair *qpair = ctx->qpair; _nvmf_poll_group_add() local
1151 spdk_nvmf_tgt_new_qpair(struct spdk_nvmf_tgt * tgt,struct spdk_nvmf_qpair * qpair) spdk_nvmf_tgt_new_qpair() argument
1216 spdk_nvmf_poll_group_add(struct spdk_nvmf_poll_group * group,struct spdk_nvmf_qpair * qpair) spdk_nvmf_poll_group_add() argument
1299 spdk_nvmf_poll_group_remove(struct spdk_nvmf_qpair * qpair) spdk_nvmf_poll_group_remove() argument
1324 _nvmf_qpair_sgroup_req_clean(struct spdk_nvmf_subsystem_poll_group * sgroup,const struct spdk_nvmf_qpair * qpair) _nvmf_qpair_sgroup_req_clean() argument
1341 struct spdk_nvmf_qpair *qpair = qpair_ctx->qpair; _nvmf_qpair_destroy() local
1390 spdk_nvmf_qpair_disconnect(struct spdk_nvmf_qpair * qpair) spdk_nvmf_qpair_disconnect() argument
1447 spdk_nvmf_qpair_get_peer_trid(struct spdk_nvmf_qpair * qpair,struct spdk_nvme_transport_id * trid) spdk_nvmf_qpair_get_peer_trid() argument
1455 spdk_nvmf_qpair_get_local_trid(struct spdk_nvmf_qpair * qpair,struct spdk_nvme_transport_id * trid) spdk_nvmf_qpair_get_local_trid() argument
1463 spdk_nvmf_qpair_get_listen_trid(struct spdk_nvmf_qpair * qpair,struct spdk_nvme_transport_id * trid) spdk_nvmf_qpair_get_listen_trid() argument
1686 struct spdk_nvmf_qpair *qpair, *qpair_tmp; nvmf_poll_group_remove_subsystem_msg() local
1874 spdk_nvmf_get_optimal_poll_group(struct spdk_nvmf_qpair * qpair) spdk_nvmf_get_optimal_poll_group() argument
[all...] |
| /spdk/test/unit/lib/nvme/nvme_transport.c/ |
| H A D | nvme_transport_ut.c | 14 DEFINE_STUB(nvme_poll_group_connect_qpair, int, (struct spdk_nvme_qpair *qpair), 0);
15 DEFINE_STUB_V(nvme_qpair_abort_all_queued_reqs, (struct spdk_nvme_qpair *qpair));
16 DEFINE_STUB(nvme_poll_group_disconnect_qpair, int, (struct spdk_nvme_qpair *qpair), 0);
17 DEFINE_STUB(spdk_nvme_ctrlr_free_io_qpair, int, (struct spdk_nvme_qpair *qpair), 0);
20 DEFINE_STUB(spdk_nvme_qpair_process_completions, int32_t, (struct spdk_nvme_qpair *qpair,
55 ut_poll_group_connect_qpair(struct spdk_nvme_qpair *qpair) in ut_poll_group_connect_qpair() argument
64 struct spdk_nvme_qpair qpair = {}; in test_nvme_transport_poll_group_connect_qpair() local
68 qpair.poll_group = &tgroup; in test_nvme_transport_poll_group_connect_qpair()
75 qpair.poll_group_tailq_head = &tgroup.connected_qpairs; in test_nvme_transport_poll_group_connect_qpair()
77 rc = nvme_transport_poll_group_connect_qpair(&qpair); in test_nvme_transport_poll_group_connect_qpair()
[all …]
|
| /spdk/test/unit/lib/nvme/nvme_poll_group.c/ |
| H A D | nvme_poll_group_ut.c | 52 struct spdk_nvme_qpair *qpair), in nvme_transport_poll_group_get_stats()
59 DEFINE_STUB(spdk_nvme_qpair_get_fd, int, (struct spdk_nvme_qpair *qpair, in nvme_transport_poll_group_get_stats()
83 unit_test_disconnected_qpair_cb(struct spdk_nvme_qpair *qpair, void *poll_group_ctx) in nvme_get_next_transport()
101 nvme_transport_poll_group_disconnect_qpair(struct spdk_nvme_qpair *qpair) in nvme_transport_poll_group_disconnect_qpair()
106 tgroup = qpair->poll_group; in nvme_transport_poll_group_disconnect_qpair()
109 if (qpair == iter_qp) { in nvme_transport_poll_group_disconnect_qpair()
110 STAILQ_REMOVE(&tgroup->connected_qpairs, qpair, spdk_nvme_qpair, poll_group_stailq); in nvme_transport_poll_group_disconnect_qpair()
111 STAILQ_INSERT_TAIL(&tgroup->disconnected_qpairs, qpair, poll_group_stailq);
117 if (qpair == iter_qp) { in nvme_transport_poll_group_connect_qpair()
126 nvme_transport_poll_group_connect_qpair(struct spdk_nvme_qpair *qpair) in nvme_transport_poll_group_connect_qpair()
70 unit_test_disconnected_qpair_cb(struct spdk_nvme_qpair * qpair,void * poll_group_ctx) unit_test_disconnected_qpair_cb() argument
88 nvme_transport_poll_group_disconnect_qpair(struct spdk_nvme_qpair * qpair) nvme_transport_poll_group_disconnect_qpair() argument
113 nvme_transport_poll_group_connect_qpair(struct spdk_nvme_qpair * qpair) nvme_transport_poll_group_connect_qpair() argument
161 nvme_transport_poll_group_add(struct spdk_nvme_transport_poll_group * tgroup,struct spdk_nvme_qpair * qpair) nvme_transport_poll_group_add() argument
171 nvme_transport_poll_group_remove(struct spdk_nvme_transport_poll_group * tgroup,struct spdk_nvme_qpair * qpair) nvme_transport_poll_group_remove() argument
238 struct spdk_nvme_qpair *qpair; test_spdk_nvme_poll_group_add_remove() local
[all...] |
| /spdk/test/external_code/nvme/ |
| H A D | nvme.c | 17 /* Command identifier and position within qpair's requests array */
200 free_qpair(struct nvme_qpair *qpair) in free_qpair() argument
202 spdk_free(qpair->cmd); in free_qpair()
203 spdk_free(qpair->cpl); in free_qpair()
204 free(qpair->requests); in free_qpair()
205 free(qpair); in free_qpair()
211 struct nvme_qpair *qpair; in init_qpair() local
217 qpair = calloc(1, sizeof(*qpair)); in init_qpair()
218 if (!qpair) { in init_qpair()
342 allocate_request(struct nvme_qpair * qpair) allocate_request() argument
359 submit_request(struct nvme_qpair * qpair,struct nvme_request * request) submit_request() argument
422 process_completions(struct nvme_qpair * qpair) process_completions() argument
[all...] |
| /spdk/test/unit/lib/nvme/nvme_ns_cmd.c/ |
| H A D | nvme_ns_cmd_ut.c | 40 (struct spdk_nvme_qpair *qpair, uint32_t max_completions),
171 nvme_qpair_submit_request(struct spdk_nvme_qpair *qpair, struct nvme_request *req) in nvme_qpair_submit_request()
205 struct spdk_nvme_qpair *qpair, in prepare_for_test()
239 memset(qpair, 0, sizeof(*qpair)); in prepare_for_test()
240 qpair->ctrlr = ctrlr; in prepare_for_test()
241 qpair->req_buf = calloc(num_requests, sizeof(struct nvme_request)); in prepare_for_test()
242 SPDK_CU_ASSERT_FATAL(qpair->req_buf != NULL); in prepare_for_test()
245 struct nvme_request *req = qpair->req_buf + i * sizeof(struct nvme_request); in prepare_for_test()
247 req->qpair in prepare_for_test()
166 nvme_qpair_submit_request(struct spdk_nvme_qpair * qpair,struct nvme_request * req) nvme_qpair_submit_request() argument
200 prepare_for_test(struct spdk_nvme_ns * ns,struct spdk_nvme_ctrlr * ctrlr,struct spdk_nvme_qpair * qpair,uint32_t sector_size,uint32_t md_size,uint32_t max_xfer_size,uint32_t stripe_size,bool extended_lba) prepare_for_test() argument
250 cleanup_after_test(struct spdk_nvme_qpair * qpair) cleanup_after_test() argument
268 struct spdk_nvme_qpair qpair; split_test() local
300 struct spdk_nvme_qpair qpair; split_test2() local
355 struct spdk_nvme_qpair qpair; split_test3() local
412 struct spdk_nvme_qpair qpair; split_test4() local
491 struct spdk_nvme_qpair qpair; test_cmd_child_request() local
551 struct spdk_nvme_qpair qpair; test_nvme_ns_cmd_flush() local
573 struct spdk_nvme_qpair qpair; test_nvme_ns_cmd_write_zeroes() local
600 struct spdk_nvme_qpair qpair; test_nvme_ns_cmd_write_uncorrectable() local
627 struct spdk_nvme_qpair qpair; test_nvme_ns_cmd_dataset_management() local
677 struct spdk_nvme_qpair qpair; test_nvme_ns_cmd_copy() local
730 struct spdk_nvme_qpair qpair; test_nvme_ns_cmd_readv() local
778 struct spdk_nvme_qpair qpair; test_nvme_ns_cmd_writev() local
837 struct spdk_nvme_qpair qpair; test_nvme_ns_cmd_comparev() local
872 struct spdk_nvme_qpair qpair; test_nvme_ns_cmd_comparev_with_md() local
1081 struct spdk_nvme_qpair qpair; test_nvme_ns_cmd_compare_and_write() local
1128 struct spdk_nvme_qpair qpair; test_io_flags() local
1181 struct spdk_nvme_qpair qpair; test_nvme_ns_cmd_reservation_register() local
1219 struct spdk_nvme_qpair qpair; test_nvme_ns_cmd_reservation_release() local
1257 struct spdk_nvme_qpair qpair; test_nvme_ns_cmd_reservation_acquire() local
1295 struct spdk_nvme_qpair qpair; test_nvme_ns_cmd_reservation_report() local
1327 struct spdk_nvme_qpair qpair; test_nvme_ns_cmd_write_with_md() local
1561 struct spdk_nvme_qpair qpair; test_nvme_ns_cmd_zone_append_with_md() local
1680 struct spdk_nvme_qpair qpair; test_nvme_ns_cmd_zone_appendv_with_md() local
1757 struct spdk_nvme_qpair qpair; test_nvme_ns_cmd_read_with_md() local
1803 struct spdk_nvme_qpair qpair; test_nvme_ns_cmd_compare_with_md() local
2030 struct spdk_nvme_qpair qpair; test_spdk_nvme_ns_cmd_readv_with_md() local
2073 struct spdk_nvme_qpair qpair; test_spdk_nvme_ns_cmd_writev_ext() local
2145 struct spdk_nvme_qpair qpair; test_spdk_nvme_ns_cmd_readv_ext() local
2215 struct spdk_nvme_qpair qpair; test_nvme_ns_cmd_verify() local
2240 struct spdk_nvme_qpair qpair; test_nvme_ns_cmd_io_mgmt_send() local
2279 struct spdk_nvme_qpair qpair; test_nvme_ns_cmd_io_mgmt_recv() local
[all...] |
| /spdk/test/unit/lib/nvme/nvme_ns_ocssd_cmd.c/ |
| H A D | nvme_ns_ocssd_cmd_ut.c | 40 (struct spdk_nvme_qpair *qpair, uint32_t max_completions),
69 nvme_qpair_submit_request(struct spdk_nvme_qpair *qpair, struct nvme_request *req) in nvme_qpair_submit_request()
139 struct spdk_nvme_qpair *qpair, in prepare_for_test()
168 memset(qpair, 0, sizeof(*qpair)); in prepare_for_test()
169 qpair->ctrlr = ctrlr; in prepare_for_test()
170 qpair->req_buf = calloc(num_requests, sizeof(struct nvme_request)); in prepare_for_test()
171 SPDK_CU_ASSERT_FATAL(qpair->req_buf != NULL); in prepare_for_test()
174 struct nvme_request *req = qpair->req_buf + i * sizeof(struct nvme_request); in prepare_for_test()
176 req->qpair in prepare_for_test()
64 nvme_qpair_submit_request(struct spdk_nvme_qpair * qpair,struct nvme_request * req) nvme_qpair_submit_request() argument
134 prepare_for_test(struct spdk_nvme_ns * ns,struct spdk_nvme_ctrlr * ctrlr,struct spdk_nvme_qpair * qpair,uint32_t sector_size,uint32_t md_size,uint32_t max_xfer_size,uint32_t stripe_size,bool extended_lba) prepare_for_test() argument
179 cleanup_after_test(struct spdk_nvme_qpair * qpair) cleanup_after_test() argument
192 struct spdk_nvme_qpair qpair; test_nvme_ocssd_ns_cmd_vector_reset_single_entry() local
223 struct spdk_nvme_qpair qpair; test_nvme_ocssd_ns_cmd_vector_reset() local
253 struct spdk_nvme_qpair qpair; test_nvme_ocssd_ns_cmd_vector_read_with_md_single_entry() local
297 struct spdk_nvme_qpair qpair; test_nvme_ocssd_ns_cmd_vector_read_with_md() local
339 struct spdk_nvme_qpair qpair; test_nvme_ocssd_ns_cmd_vector_read_single_entry() local
377 struct spdk_nvme_qpair qpair; test_nvme_ocssd_ns_cmd_vector_read() local
414 struct spdk_nvme_qpair qpair; test_nvme_ocssd_ns_cmd_vector_write_with_md_single_entry() local
459 struct spdk_nvme_qpair qpair; test_nvme_ocssd_ns_cmd_vector_write_with_md() local
501 struct spdk_nvme_qpair qpair; test_nvme_ocssd_ns_cmd_vector_write_single_entry() local
540 struct spdk_nvme_qpair qpair; test_nvme_ocssd_ns_cmd_vector_write() local
578 struct spdk_nvme_qpair qpair; test_nvme_ocssd_ns_cmd_vector_copy_single_entry() local
611 struct spdk_nvme_qpair qpair; test_nvme_ocssd_ns_cmd_vector_copy() local
[all...] |
| /spdk/test/unit/lib/nvme/nvme_pcie_common.c/ |
| H A D | nvme_pcie_common_ut.c | 24 (struct spdk_nvme_qpair *qpair,
29 DEFINE_STUB_V(spdk_nvme_qpair_print_command, (struct spdk_nvme_qpair *qpair,
32 DEFINE_STUB_V(spdk_nvme_qpair_print_completion, (struct spdk_nvme_qpair *qpair,
35 DEFINE_STUB_V(nvme_qpair_deinit, (struct spdk_nvme_qpair *qpair));
41 (struct spdk_nvme_qpair *qpair, uint32_t max_completions), 0);
51 DEFINE_STUB_V(nvme_transport_ctrlr_disconnect_qpair_done, (struct spdk_nvme_qpair *qpair));
56 nvme_qpair_init(struct spdk_nvme_qpair *qpair, uint16_t id, in nvme_qpair_init()
61 qpair->id = id; in nvme_qpair_init()
62 qpair->qprio = qprio; in nvme_qpair_init()
63 qpair in nvme_qpair_init()
54 nvme_qpair_init(struct spdk_nvme_qpair * qpair,uint16_t id,struct spdk_nvme_ctrlr * ctrlr,enum spdk_nvme_qprio qprio,uint32_t num_requests,bool async) nvme_qpair_init() argument
[all...] |
| /spdk/test/common/lib/nvme/ |
| H A D | common_stubs.h | 54 DEFINE_STUB_V(nvme_qpair_deinit, (struct spdk_nvme_qpair *qpair));
57 struct spdk_nvme_qpair *qpair), 0);
58 DEFINE_STUB_V(nvme_transport_ctrlr_disconnect_qpair_done, (struct spdk_nvme_qpair *qpair));
66 DEFINE_STUB(spdk_nvme_qpair_process_completions, int32_t, (struct spdk_nvme_qpair *qpair,
72 DEFINE_STUB_V(nvme_ctrlr_disconnect_qpair, (struct spdk_nvme_qpair *qpair));
91 DEFINE_STUB(nvme_fabric_qpair_connect, int, (struct spdk_nvme_qpair *qpair, uint32_t num_entries),
93 DEFINE_STUB(nvme_fabric_qpair_connect_async, int, (struct spdk_nvme_qpair *qpair,
95 DEFINE_STUB(nvme_fabric_qpair_connect_poll, int, (struct spdk_nvme_qpair *qpair), 0);
96 DEFINE_STUB(nvme_fabric_qpair_auth_required, bool, (struct spdk_nvme_qpair *qpair), false);
97 DEFINE_STUB(nvme_fabric_qpair_authenticate_async, int, (struct spdk_nvme_qpair *qpair),
101 nvme_qpair_init(struct spdk_nvme_qpair * qpair,uint16_t id,struct spdk_nvme_ctrlr * ctrlr,enum spdk_nvme_qprio qprio,uint32_t num_requests,bool async) nvme_qpair_init() argument
[all...] |
| /spdk/test/unit/lib/bdev/nvme/bdev_nvme.c/ |
| H A D | bdev_nvme_ut.c | 46 DEFINE_STUB(spdk_nvme_qpair_get_id, uint16_t, (struct spdk_nvme_qpair *qpair), 0);
78 DEFINE_STUB_V(spdk_nvme_qpair_set_abort_dnr, (struct spdk_nvme_qpair *qpair, bool dnr));
148 struct spdk_nvme_qpair *qpair, uint16_t cid, spdk_nvme_cmd_cb cb_fn, void *cb_arg), 0);
151 struct spdk_nvme_qpair *qpair, struct spdk_nvme_cmd *cmd, void *buf,
155 struct spdk_nvme_qpair *qpair, struct spdk_nvme_cmd *cmd, void *buf,
159 struct spdk_nvme_ctrlr *ctrlr, struct spdk_nvme_qpair *qpair,
207 (struct spdk_nvme_ns *ns, struct spdk_nvme_qpair *qpair, void *buffer, void *metadata,
212 (struct spdk_nvme_ns *ns, struct spdk_nvme_qpair *qpair, uint64_t zslba,
218 (struct spdk_nvme_ns *ns, struct spdk_nvme_qpair *qpair,
224 (struct spdk_nvme_ns *ns, struct spdk_nvme_qpair *qpair, uint64_
344 spdk_nvme_qpair_get_num_outstanding_reqs(struct spdk_nvme_qpair * qpair) spdk_nvme_qpair_get_num_outstanding_reqs() argument
505 ut_submit_nvme_request(struct spdk_nvme_ns * ns,struct spdk_nvme_qpair * qpair,uint16_t opc,spdk_nvme_cmd_cb cb_fn,void * cb_arg) ut_submit_nvme_request() argument
529 ut_get_outstanding_nvme_request(struct spdk_nvme_qpair * qpair,void * cb_arg) ut_get_outstanding_nvme_request() argument
718 struct spdk_nvme_qpair *qpair; spdk_nvme_ctrlr_alloc_io_qpair() local
733 nvme_poll_group_connect_qpair(struct spdk_nvme_qpair * qpair) nvme_poll_group_connect_qpair() argument
745 nvme_poll_group_disconnect_qpair(struct spdk_nvme_qpair * qpair) nvme_poll_group_disconnect_qpair() argument
758 spdk_nvme_ctrlr_connect_io_qpair(struct spdk_nvme_ctrlr * ctrlr,struct spdk_nvme_qpair * qpair) spdk_nvme_ctrlr_connect_io_qpair() argument
775 spdk_nvme_ctrlr_disconnect_io_qpair(struct spdk_nvme_qpair * qpair) spdk_nvme_ctrlr_disconnect_io_qpair() argument
789 spdk_nvme_ctrlr_free_io_qpair(struct spdk_nvme_qpair * qpair) spdk_nvme_ctrlr_free_io_qpair() argument
930 spdk_nvme_ctrlr_cmd_abort_ext(struct spdk_nvme_ctrlr * ctrlr,struct spdk_nvme_qpair * qpair,void * cmd_cb_arg,spdk_nvme_cmd_cb cb_fn,void * cb_arg) spdk_nvme_ctrlr_cmd_abort_ext() argument
1021 spdk_nvme_ns_cmd_read_with_md(struct spdk_nvme_ns * ns,struct spdk_nvme_qpair * qpair,void * buffer,void * metadata,uint64_t lba,uint32_t lba_count,spdk_nvme_cmd_cb cb_fn,void * cb_arg,uint32_t io_flags,uint16_t apptag_mask,uint16_t apptag) spdk_nvme_ns_cmd_read_with_md() argument
1030 spdk_nvme_ns_cmd_write_with_md(struct spdk_nvme_ns * ns,struct spdk_nvme_qpair * qpair,void * buffer,void * metadata,uint64_t lba,uint32_t lba_count,spdk_nvme_cmd_cb cb_fn,void * cb_arg,uint32_t io_flags,uint16_t apptag_mask,uint16_t apptag) spdk_nvme_ns_cmd_write_with_md() argument
1039 spdk_nvme_ns_cmd_readv_with_md(struct spdk_nvme_ns * ns,struct spdk_nvme_qpair * qpair,uint64_t lba,uint32_t lba_count,spdk_nvme_cmd_cb cb_fn,void * cb_arg,uint32_t io_flags,spdk_nvme_req_reset_sgl_cb reset_sgl_fn,spdk_nvme_req_next_sge_cb next_sge_fn,void * metadata,uint16_t apptag_mask,uint16_t apptag) spdk_nvme_ns_cmd_readv_with_md() argument
1050 spdk_nvme_ns_cmd_writev_with_md(struct spdk_nvme_ns * ns,struct spdk_nvme_qpair * qpair,uint64_t lba,uint32_t lba_count,spdk_nvme_cmd_cb cb_fn,void * cb_arg,uint32_t io_flags,spdk_nvme_req_reset_sgl_cb reset_sgl_fn,spdk_nvme_req_next_sge_cb next_sge_fn,void * metadata,uint16_t apptag_mask,uint16_t apptag) spdk_nvme_ns_cmd_writev_with_md() argument
1062 spdk_nvme_ns_cmd_readv_ext(struct spdk_nvme_ns * ns,struct spdk_nvme_qpair * qpair,uint64_t lba,uint32_t lba_count,spdk_nvme_cmd_cb cb_fn,void * cb_arg,spdk_nvme_req_reset_sgl_cb reset_sgl_fn,spdk_nvme_req_next_sge_cb next_sge_fn,struct spdk_nvme_ns_cmd_ext_io_opts * opts) spdk_nvme_ns_cmd_readv_ext() argument
1075 spdk_nvme_ns_cmd_read_ext(struct spdk_nvme_ns * ns,struct spdk_nvme_qpair * qpair,void * buffer,uint64_t lba,uint32_t lba_count,spdk_nvme_cmd_cb cb_fn,void * cb_arg,struct spdk_nvme_ns_cmd_ext_io_opts * opts) spdk_nvme_ns_cmd_read_ext() argument
1085 spdk_nvme_ns_cmd_writev_ext(struct spdk_nvme_ns * ns,struct spdk_nvme_qpair * qpair,uint64_t lba,uint32_t lba_count,spdk_nvme_cmd_cb cb_fn,void * cb_arg,spdk_nvme_req_reset_sgl_cb reset_sgl_fn,spdk_nvme_req_next_sge_cb next_sge_fn,struct spdk_nvme_ns_cmd_ext_io_opts * opts) spdk_nvme_ns_cmd_writev_ext() argument
1098 spdk_nvme_ns_cmd_write_ext(struct spdk_nvme_ns * ns,struct spdk_nvme_qpair * qpair,void * buffer,uint64_t lba,uint32_t lba_count,spdk_nvme_cmd_cb cb_fn,void * cb_arg,struct spdk_nvme_ns_cmd_ext_io_opts * opts) spdk_nvme_ns_cmd_write_ext() argument
1107 spdk_nvme_ns_cmd_comparev_with_md(struct spdk_nvme_ns * ns,struct spdk_nvme_qpair * qpair,uint64_t lba,uint32_t lba_count,spdk_nvme_cmd_cb cb_fn,void * cb_arg,uint32_t io_flags,spdk_nvme_req_reset_sgl_cb reset_sgl_fn,spdk_nvme_req_next_sge_cb next_sge_fn,void * metadata,uint16_t apptag_mask,uint16_t apptag) spdk_nvme_ns_cmd_comparev_with_md() argument
1118 spdk_nvme_ns_cmd_dataset_management(struct spdk_nvme_ns * ns,struct spdk_nvme_qpair * qpair,uint32_t type,const struct spdk_nvme_dsm_range * ranges,uint16_t num_ranges,spdk_nvme_cmd_cb cb_fn,void * cb_arg) spdk_nvme_ns_cmd_dataset_management() argument
1126 spdk_nvme_ns_cmd_write_zeroes(struct spdk_nvme_ns * ns,struct spdk_nvme_qpair * qpair,uint64_t lba,uint32_t lba_count,spdk_nvme_cmd_cb cb_fn,void * cb_arg,uint32_t io_flags) spdk_nvme_ns_cmd_write_zeroes() argument
1135 spdk_nvme_ns_cmd_copy(struct spdk_nvme_ns * ns,struct spdk_nvme_qpair * qpair,const struct spdk_nvme_scc_source_range * ranges,uint16_t num_ranges,uint64_t dest_lba,spdk_nvme_cmd_cb cb_fn,void * cb_arg) spdk_nvme_ns_cmd_copy() argument
1177 spdk_nvme_qpair_get_failure_reason(struct spdk_nvme_qpair * qpair) spdk_nvme_qpair_get_failure_reason() argument
1183 spdk_nvme_qpair_is_connected(struct spdk_nvme_qpair * qpair) spdk_nvme_qpair_is_connected() argument
1189 spdk_nvme_qpair_process_completions(struct spdk_nvme_qpair * qpair,uint32_t max_completions) spdk_nvme_qpair_process_completions() argument
1224 struct spdk_nvme_qpair *qpair, *tmp_qpair; spdk_nvme_poll_group_process_completions() local
1260 spdk_nvme_poll_group_add(struct spdk_nvme_poll_group * group,struct spdk_nvme_qpair * qpair) spdk_nvme_poll_group_add() argument
1273 spdk_nvme_poll_group_remove(struct spdk_nvme_poll_group * group,struct spdk_nvme_qpair * qpair) spdk_nvme_poll_group_remove() argument
2263 struct spdk_nvme_qpair *qpair; ut_test_submit_nvme_cmd() local
2291 struct spdk_nvme_qpair *qpair; ut_test_submit_nop() local
2315 struct spdk_nvme_qpair *qpair; ut_test_submit_fused_nvme_cmd() local
2907 struct spdk_nvme_qpair *qpair; test_get_io_qpair() local
[all...] |
| /spdk/include/spdk/ |
| H A D | nvme_zns.h | 150 int spdk_nvme_zns_zone_append(struct spdk_nvme_ns *ns, struct spdk_nvme_qpair *qpair,
181 int spdk_nvme_zns_zone_append_with_md(struct spdk_nvme_ns *ns, struct spdk_nvme_qpair *qpair,
209 int spdk_nvme_zns_zone_appendv(struct spdk_nvme_ns *ns, struct spdk_nvme_qpair *qpair,
242 int spdk_nvme_zns_zone_appendv_with_md(struct spdk_nvme_ns *ns, struct spdk_nvme_qpair *qpair,
262 int spdk_nvme_zns_close_zone(struct spdk_nvme_ns *ns, struct spdk_nvme_qpair *qpair,
279 int spdk_nvme_zns_finish_zone(struct spdk_nvme_ns *ns, struct spdk_nvme_qpair *qpair,
296 int spdk_nvme_zns_open_zone(struct spdk_nvme_ns *ns, struct spdk_nvme_qpair *qpair,
313 int spdk_nvme_zns_reset_zone(struct spdk_nvme_ns *ns, struct spdk_nvme_qpair *qpair,
330 int spdk_nvme_zns_offline_zone(struct spdk_nvme_ns *ns, struct spdk_nvme_qpair *qpair,
347 int spdk_nvme_zns_set_zone_desc_ext(struct spdk_nvme_ns *ns, struct spdk_nvme_qpair *qpair,
[all …]
|
| /spdk/test/unit/lib/nvmf/ctrlr.c/ |
| H A D | ctrlr_ut.c | 100 (struct spdk_nvmf_qpair *qpair, struct spdk_nvme_transport_id *trid),
181 (struct spdk_nvmf_qpair *qpair, struct spdk_nvmf_request *req));
232 nvmf_qpair_set_state(struct spdk_nvmf_qpair *qpair, enum spdk_nvmf_qpair_state state)
234 qpair->state = state; in spdk_nvmf_qpair_disconnect() argument
238 spdk_nvmf_qpair_disconnect(struct spdk_nvmf_qpair *qpair)
358 struct spdk_nvmf_qpair qpair = {}; in test_get_log_page()
368 qpair.ctrlr = &ctrlr; in test_get_log_page()
370 req.qpair = &qpair; in test_get_log_page()
429 req.qpair
228 nvmf_qpair_set_state(struct spdk_nvmf_qpair * qpair,enum spdk_nvmf_qpair_state state) nvmf_qpair_set_state() argument
338 struct spdk_nvmf_qpair qpair = {}; test_get_log_page() local
440 struct spdk_nvmf_qpair qpair; test_connect() local
939 struct spdk_nvmf_qpair qpair; test_get_ns_id_desc_list() local
1632 struct spdk_nvmf_qpair qpair; test_reservation_notification_log_page() local
1702 struct spdk_nvmf_qpair qpair = {}; test_get_dif_ctx() local
1902 struct spdk_nvmf_qpair qpair; test_custom_admin_cmd() local
1957 struct spdk_nvmf_qpair qpair = {}; test_fused_compare_and_write() local
2064 struct spdk_nvmf_qpair qpair = {}; test_multi_async_event_reqs() local
2320 struct spdk_nvmf_qpair qpair = {}; test_multi_async_events() local
2394 struct spdk_nvmf_qpair qpair = {}; test_rae() local
2494 struct spdk_nvmf_qpair qpair = {}; test_nvmf_ctrlr_create_destruct() local
2597 struct spdk_nvmf_qpair qpair = {}; test_nvmf_ctrlr_use_zcopy() local
2694 struct spdk_nvmf_qpair qpair = {}; test_spdk_nvmf_request_zcopy_start() local
2838 struct spdk_nvmf_qpair qpair = {}; test_zcopy_read() local
2928 struct spdk_nvmf_qpair qpair = {}; test_zcopy_write() local
3019 struct spdk_nvmf_qpair qpair = {}; test_nvmf_property_set() local
3080 struct spdk_nvmf_qpair qpair = {}; test_nvmf_ctrlr_get_features_host_behavior_support() local
3126 struct spdk_nvmf_qpair qpair = {}; test_nvmf_ctrlr_set_features_host_behavior_support() local
3310 struct spdk_nvmf_qpair qpair = { .outstanding = TAILQ_HEAD_INITIALIZER(qpair.outstanding) }; test_nvmf_check_qpair_active() local
[all...] |
| /spdk/test/nvme/reserve/ |
| H A D | reserve.c | 148 reservation_ns_register(struct spdk_nvme_ctrlr *ctrlr, struct spdk_nvme_qpair *qpair, in reservation_ns_register() argument
171 ret = spdk_nvme_ns_cmd_reservation_register(ns, qpair, &rr_data, true, in reservation_ns_register()
182 spdk_nvme_qpair_process_completions(qpair, 100); in reservation_ns_register()
194 reservation_ns_report(struct spdk_nvme_ctrlr *ctrlr, struct spdk_nvme_qpair *qpair, uint32_t ns_id) in reservation_ns_report() argument
213 ret = spdk_nvme_ns_cmd_reservation_report(ns, qpair, payload, 0x1000, in reservation_ns_report()
223 spdk_nvme_qpair_process_completions(qpair, 100); in reservation_ns_report()
252 reservation_ns_acquire(struct spdk_nvme_ctrlr *ctrlr, struct spdk_nvme_qpair *qpair, uint32_t ns_id) in reservation_ns_acquire() argument
265 ret = spdk_nvme_ns_cmd_reservation_acquire(ns, qpair, &cdata, in reservation_ns_acquire()
277 spdk_nvme_qpair_process_completions(qpair, 100); in reservation_ns_acquire()
289 reservation_ns_release(struct spdk_nvme_ctrlr *ctrlr, struct spdk_nvme_qpair *qpair, uint32_ argument
328 struct spdk_nvme_qpair *qpair; reserve_controller() local
[all...] |