/spdk/module/bdev/nvme/ |
H A D | bdev_mdns_client.c | 38 struct spdk_nvme_transport_id trid; 64 create_mdns_discovery_entry_ctx(struct mdns_discovery_ctx *ctx, struct spdk_nvme_transport_id *trid) in create_mdns_discovery_entry_ctx() 69 assert(trid); in create_mdns_discovery_entry_ctx() 77 memcpy(&new_ctx->trid, trid, sizeof(struct spdk_nvme_transport_id)); in create_mdns_discovery_entry_ctx() 92 status = bdev_nvme_start_discovery(&entry_ctx->trid, entry_ctx->name, in mdns_bdev_nvme_start_discovery() 97 SPDK_ERRLOG("Error starting discovery for name %s addr %s port %s subnqn %s &trid %p\n", in mdns_bdev_nvme_start_discovery() 98 entry_ctx->ctx->name, entry_ctx->trid.traddr, entry_ctx->trid.trsvcid, in mdns_bdev_nvme_start_discovery() 99 entry_ctx->trid in mdns_bdev_nvme_start_discovery() 37 struct spdk_nvme_transport_id trid; global() member 63 create_mdns_discovery_entry_ctx(struct mdns_discovery_ctx * ctx,struct spdk_nvme_transport_id * trid) create_mdns_discovery_entry_ctx() argument 246 struct spdk_nvme_transport_id *trid = NULL; mdns_resolve_handler() local [all...] |
H A D | bdev_nvme.c | 36 (spdk_nvme_trtype_is_fabrics(nvme_ctrlr->active_path_id->trid.trtype) ? \ 37 nvme_ctrlr->active_path_id->trid.subnqn : nvme_ctrlr->active_path_id->trid.traddr) 145 struct spdk_nvme_transport_id trid; 317 const struct spdk_nvme_transport_id *trid, const char *hostnqn) in nvme_bdev_ctrlr_get_bdev() 324 if (spdk_nvme_transport_id_compare(trid, &nvme_ctrlr->active_path_id->trid) == 0 && in nvme_ctrlr_get_ns() 394 nvme_ctrlr_get(const struct spdk_nvme_transport_id *trid, const char *hostnqn) in nvme_bdev_ctrlr_for_each() 401 nvme_ctrlr = nvme_bdev_ctrlr_get_ctrlr(nbdev_ctrlr, trid, hostnqn); in nvme_bdev_dump_trid_json() argument 566 nvme_bdev_dump_trid_json(const struct spdk_nvme_transport_id *trid, struc in nvme_ctrlr_can_be_unregistered() 103 struct spdk_nvme_transport_id trid; global() member 274 nvme_bdev_ctrlr_get_ctrlr(struct nvme_bdev_ctrlr * nbdev_ctrlr,const struct spdk_nvme_transport_id * trid,const char * hostnqn) nvme_bdev_ctrlr_get_ctrlr() argument 351 nvme_ctrlr_get(const struct spdk_nvme_transport_id * trid,const char * hostnqn) nvme_ctrlr_get() argument 3599 struct spdk_nvme_transport_id *trid; nvme_ctrlr_info_json() local 3656 const struct spdk_nvme_transport_id *trid; nvme_namespace_info_json() local 4347 hotplug_probe_cb(void * cb_ctx,const struct spdk_nvme_transport_id * trid,struct spdk_nvme_ctrlr_opts * opts) hotplug_probe_cb() argument 5432 nvme_ctrlr_create(struct spdk_nvme_ctrlr * ctrlr,const char * name,const struct spdk_nvme_transport_id * trid,struct nvme_async_probe_ctx * ctx) nvme_ctrlr_create() argument 5576 attach_cb(void * cb_ctx,const struct spdk_nvme_transport_id * trid,struct spdk_nvme_ctrlr * ctrlr,const struct spdk_nvme_ctrlr_opts * drv_opts) attach_cb() argument 5867 bdev_nvme_check_secondary_trid(struct nvme_ctrlr * nvme_ctrlr,struct spdk_nvme_ctrlr * new_ctrlr,struct spdk_nvme_transport_id * trid) bdev_nvme_check_secondary_trid() argument 5928 _bdev_nvme_add_secondary_trid(struct nvme_ctrlr * nvme_ctrlr,struct spdk_nvme_transport_id * trid) _bdev_nvme_add_secondary_trid() argument 5970 bdev_nvme_add_secondary_trid(struct nvme_ctrlr * nvme_ctrlr,struct spdk_nvme_ctrlr * new_ctrlr,struct spdk_nvme_transport_id * trid) bdev_nvme_add_secondary_trid() argument 5999 connect_attach_cb(void * cb_ctx,const struct spdk_nvme_transport_id * trid,struct spdk_nvme_ctrlr * ctrlr,const struct spdk_nvme_ctrlr_opts * opts) connect_attach_cb() argument 6017 connect_set_failover_cb(void * cb_ctx,const struct spdk_nvme_transport_id * trid,struct spdk_nvme_ctrlr * ctrlr,const struct spdk_nvme_ctrlr_opts * opts) connect_set_failover_cb() argument 6151 bdev_nvme_create(struct spdk_nvme_transport_id * trid,const char * base_name,const char ** names,uint32_t count,spdk_bdev_create_nvme_fn cb_fn,void * cb_ctx,struct spdk_nvme_ctrlr_opts * drv_opts,struct nvme_ctrlr_opts * bdev_opts,bool multipath) bdev_nvme_create() argument 6544 struct spdk_nvme_transport_id trid; global() member 6559 struct spdk_nvme_transport_id trid; global() member 6631 build_trid_from_log_page_entry(struct spdk_nvme_transport_id * trid,struct spdk_nvmf_discovery_log_page_entry * entry) build_trid_from_log_page_entry() argument 6720 struct spdk_nvme_transport_id trid = {}; remove_discovery_entry() local 6816 create_discovery_entry_ctx(struct discovery_ctx * ctx,struct spdk_nvme_transport_id * trid) create_discovery_entry_ctx() argument 6861 struct spdk_nvme_transport_id trid = {}; discovery_log_page_cb() local 6975 discovery_attach_cb(void * cb_ctx,const struct spdk_nvme_transport_id * trid,struct spdk_nvme_ctrlr * ctrlr,const struct spdk_nvme_ctrlr_opts * opts) discovery_attach_cb() argument 7000 struct spdk_nvme_transport_id *trid; discovery_poller() local 7110 bdev_nvme_start_discovery(struct spdk_nvme_transport_id * trid,const char * base_name,struct spdk_nvme_ctrlr_opts * drv_opts,struct nvme_ctrlr_opts * bdev_opts,uint64_t attach_timeout,bool from_mdns,spdk_bdev_nvme_start_discovery_fn cb_fn,void * cb_ctx) bdev_nvme_start_discovery() argument 8368 struct spdk_nvme_transport_id trid; bdev_nvme_discovery_config_json() local 8421 struct spdk_nvme_transport_id *trid; nvme_ctrlr_config_json() local 8593 const struct spdk_nvme_transport_id *trid; nvme_io_path_info_json() local [all...] |
H A D | bdev_nvme_rpc.c | 401 struct spdk_nvme_transport_id trid = {}; in rpc_bdev_nvme_attach_controller() 440 rc = spdk_nvme_transport_id_populate_trstring(&trid, ctx->req.trtype); in rpc_bdev_nvme_attach_controller() 449 rc = spdk_nvme_transport_id_parse_trtype(&trid.trtype, ctx->req.trtype); in rpc_bdev_nvme_attach_controller() 453 maxlen = sizeof(trid.traddr); in rpc_bdev_nvme_attach_controller() 460 memcpy(trid.traddr, ctx->req.traddr, len + 1); in rpc_bdev_nvme_attach_controller() 464 rc = spdk_nvme_transport_id_parse_adrfam(&trid.adrfam, ctx->req.adrfam); in rpc_bdev_nvme_attach_controller() 475 maxlen = sizeof(trid.trsvcid); in rpc_bdev_nvme_attach_controller() 482 memcpy(trid.trsvcid, ctx->req.trsvcid, len + 1); in rpc_bdev_nvme_attach_controller() 487 trid.priority = spdk_strtol(ctx->req.priority, 10); in rpc_bdev_nvme_attach_controller() 492 maxlen = sizeof(trid in rpc_bdev_nvme_attach_controller() 400 struct spdk_nvme_transport_id trid = {}; rpc_bdev_nvme_attach_controller() local 1455 const struct spdk_nvme_transport_id *trid = NULL; get_health_log_page_completion() local 1691 struct spdk_nvme_transport_id trid = {}; rpc_bdev_nvme_start_discovery() local 2556 struct spdk_nvme_transport_id trid; global() member [all...] |
/spdk/lib/nvme/ |
H A D | nvme.c | 29 return ctrlr->trid.trtype == SPDK_NVME_TRANSPORT_PCIE; in nvme_ctrlr_shared() 271 if (qpair->ctrlr->trid.trtype == SPDK_NVME_TRANSPORT_PCIE) { in nvme_wait_for_completion_robust_lock_timeout_poll() 645 nvme_ctrlr_probe(const struct spdk_nvme_transport_id *trid, 651 assert(trid != NULL); in nvme_ctrlr_probe() 655 if (!probe_ctx->probe_cb || probe_ctx->probe_cb(probe_ctx->cb_ctx, trid, &opts)) { in nvme_ctrlr_probe() 656 ctrlr = nvme_get_ctrlr_by_trid_unsafe(trid, opts.hostnqn); in nvme_ctrlr_probe() 663 trid->traddr); in nvme_ctrlr_probe() 664 probe_ctx->attach_fail_cb(probe_ctx->cb_ctx, trid, -EBUSY); in nvme_ctrlr_probe() 674 probe_ctx->attach_cb(probe_ctx->cb_ctx, &ctrlr->trid, ctrlr, &ctrlr->opts); in nvme_ctrlr_probe() 680 ctrlr = nvme_transport_ctrlr_construct(trid, in nvme_ctrlr_probe() 647 nvme_ctrlr_probe(const struct spdk_nvme_transport_id * trid,struct spdk_nvme_probe_ctx * probe_ctx,void * devhandle) nvme_ctrlr_probe() argument 764 nvme_get_ctrlr_by_trid(const struct spdk_nvme_transport_id * trid,const char * hostnqn) nvme_get_ctrlr_by_trid() argument 777 nvme_get_ctrlr_by_trid_unsafe(const struct spdk_nvme_transport_id * trid,const char * hostnqn) nvme_get_ctrlr_by_trid_unsafe() argument 880 nvme_probe_ctx_init(struct spdk_nvme_probe_ctx * probe_ctx,const struct spdk_nvme_transport_id * trid,const struct spdk_nvme_ctrlr_opts * opts,void * cb_ctx,spdk_nvme_probe_cb probe_cb,spdk_nvme_attach_cb attach_cb,spdk_nvme_remove_cb remove_cb) nvme_probe_ctx_init() argument 897 spdk_nvme_probe(const struct spdk_nvme_transport_id * trid,void * cb_ctx,spdk_nvme_probe_cb probe_cb,spdk_nvme_attach_cb attach_cb,spdk_nvme_remove_cb remove_cb) spdk_nvme_probe() argument 925 nvme_connect_probe_cb(void * cb_ctx,const struct spdk_nvme_transport_id * trid,struct spdk_nvme_ctrlr_opts * opts) nvme_connect_probe_cb() argument 999 spdk_nvme_connect(const struct spdk_nvme_transport_id * trid,const struct spdk_nvme_ctrlr_opts * opts,size_t opts_size) spdk_nvme_connect() argument 1043 spdk_nvme_trid_populate_transport(struct spdk_nvme_transport_id * trid,enum spdk_nvme_transport_type trtype) spdk_nvme_trid_populate_transport() argument 1077 spdk_nvme_transport_id_populate_trstring(struct spdk_nvme_transport_id * trid,const char * trstring) spdk_nvme_transport_id_populate_trstring() argument 1241 spdk_nvme_transport_id_parse(struct spdk_nvme_transport_id * trid,const char * str) spdk_nvme_transport_id_parse() argument 1508 spdk_nvme_probe_async(const struct spdk_nvme_transport_id * trid,void * cb_ctx,spdk_nvme_probe_cb probe_cb,spdk_nvme_attach_cb attach_cb,spdk_nvme_remove_cb remove_cb) spdk_nvme_probe_async() argument 1563 spdk_nvme_connect_async(const struct spdk_nvme_transport_id * trid,const struct spdk_nvme_ctrlr_opts * opts,spdk_nvme_attach_cb attach_cb) spdk_nvme_connect_async() argument [all...] |
H A D | nvme_fabric.c | 287 struct spdk_nvme_transport_id trid; in nvme_fabric_discover_probe() local 291 memset(&trid, 0, sizeof(trid)); in nvme_fabric_discover_probe() 303 trid.trtype = entry->trtype; in nvme_fabric_discover_probe() 304 spdk_nvme_transport_id_populate_trstring(&trid, spdk_nvme_transport_id_trtype_str(entry->trtype)); in nvme_fabric_discover_probe() 305 if (!spdk_nvme_transport_available_by_name(trid.trstring)) { in nvme_fabric_discover_probe() 307 trid.trtype); in nvme_fabric_discover_probe() 311 trid.adrfam = entry->adrfam; in nvme_fabric_discover_probe() 320 memcpy(trid.subnqn, entry->subnqn, len); in nvme_fabric_discover_probe() 321 trid in nvme_fabric_discover_probe() [all...] |
H A D | nvme_transport.c | 102 struct spdk_nvme_ctrlr *nvme_transport_ctrlr_construct(const struct spdk_nvme_transport_id *trid, in nvme_transport_ctrlr_construct() 106 const struct spdk_nvme_transport *transport = nvme_get_transport(trid->trstring); in nvme_transport_ctrlr_construct() 110 SPDK_ERRLOG("Transport %s doesn't exist.", trid->trstring); in nvme_transport_ctrlr_construct() 114 ctrlr = transport->ops.ctrlr_construct(trid, opts, devhandle); in nvme_transport_ctrlr_construct() 123 const struct spdk_nvme_transport *transport = nvme_get_transport(probe_ctx->trid.trstring); in nvme_transport_ctrlr_scan() 126 SPDK_ERRLOG("Transport %s doesn't exist.", probe_ctx->trid.trstring); in nvme_transport_ctrlr_scan() 136 const struct spdk_nvme_transport *transport = nvme_get_transport(probe_ctx->trid.trstring); in nvme_transport_ctrlr_destruct() 139 SPDK_ERRLOG("Transport %s doesn't exist.", probe_ctx->trid.trstring); in nvme_transport_ctrlr_destruct() 147 probe_ctx->trid.trstring); in nvme_transport_ctrlr_enable() 154 const struct spdk_nvme_transport *transport = nvme_get_transport(ctrlr->trid in nvme_transport_ctrlr_ready() 101 nvme_transport_ctrlr_construct(const struct spdk_nvme_transport_id * trid,const struct spdk_nvme_ctrlr_opts * opts,void * devhandle) nvme_transport_ctrlr_construct() argument [all...] |
H A D | nvme_vfio_user.c | 49 SPDK_DEBUGLOG(nvme_vfio, "ctrlr %s: offset 0x%x, value 0x%x\n", ctrlr->trid.traddr, offset, value); in nvme_vfio_ctrlr_set_reg_4() 61 SPDK_DEBUGLOG(nvme_vfio, "ctrlr %s: offset 0x%x, value 0x%"PRIx64"\n", ctrlr->trid.traddr, offset, in nvme_vfio_ctrlr_set_reg_8() 83 …SPDK_DEBUGLOG(nvme_vfio, "ctrlr %s: offset 0x%x, value 0x%x\n", ctrlr->trid.traddr, offset, *value… in nvme_vfio_ctrlr_get_reg_4() 103 SPDK_DEBUGLOG(nvme_vfio, "ctrlr %s: offset 0x%x, value 0x%"PRIx64"\n", ctrlr->trid.traddr, offset, in nvme_vfio_ctrlr_get_reg_8() 145 nvme_vfio_ctrlr_construct(const struct spdk_nvme_transport_id *trid, in nvme_vfio_ctrlr_construct() argument 156 snprintf(ctrlr_path, sizeof(ctrlr_path), "%s/cntrl", trid->traddr); in nvme_vfio_ctrlr_construct() 185 pctrlr->ctrlr.trid = *trid; in nvme_vfio_ctrlr_construct() 249 if (probe_ctx->trid.trtype != SPDK_NVME_TRANSPORT_VFIOUSER) { in nvme_vfio_ctrlr_scan() 254 ret = access(probe_ctx->trid.traddr, F_OK); in nvme_vfio_ctrlr_scan() 256 SPDK_ERRLOG("Error to access file %s\n", probe_ctx->trid.traddr); in nvme_vfio_ctrlr_scan() [all …]
|
H A D | nvme_pcie.c | 63 struct spdk_nvme_transport_id trid; in _nvme_pcie_event_process() local 74 memset(&trid, 0, sizeof(trid)); in _nvme_pcie_event_process() 75 spdk_nvme_trid_populate_transport(&trid, SPDK_NVME_TRANSPORT_PCIE); in _nvme_pcie_event_process() 77 if (spdk_pci_addr_fmt(trid.traddr, sizeof(trid.traddr), &event->traddr) < 0) { in _nvme_pcie_event_process() 82 ctrlr = nvme_get_ctrlr_by_trid_unsafe(&trid, NULL); in _nvme_pcie_event_process() 86 SPDK_DEBUGLOG(nvme, "remove nvme address: %s\n", trid.traddr); in _nvme_pcie_event_process() 121 if (ctrlr->trid.trtype != SPDK_NVME_TRANSPORT_PCIE) { in _nvme_pcie_hotplug_monitor() 826 struct spdk_nvme_transport_id trid in pcie_nvme_enum_cb() local 890 nvme_pcie_ctrlr_construct(const struct spdk_nvme_transport_id * trid,const struct spdk_nvme_ctrlr_opts * opts,void * devhandle) nvme_pcie_ctrlr_construct() argument [all...] |
/spdk/test/unit/lib/bdev/nvme/bdev_nvme.c/ |
H A D | bdev_nvme_ut.c | 23 (const struct spdk_nvme_transport_id *trid, void *cb_ctx, 27 DEFINE_STUB_V(spdk_nvme_trid_populate_transport, (struct spdk_nvme_transport_id *trid, 36 struct spdk_nvme_transport_id *trid), 0); 82 DEFINE_STUB(spdk_nvme_scan_attached, int, (const struct spdk_nvme_transport_id *trid), 0); in spdk_nvme_ctrlr_get_memory_domains() 327 struct spdk_nvme_transport_id trid; in spdk_nvme_ctrlr_get_first_active_ns() 341 struct spdk_nvme_transport_id trid; in spdk_nvme_ctrlr_get_next_active_ns() 390 ut_init_trid(struct spdk_nvme_transport_id *trid) in cmp_int() 392 trid->trtype = SPDK_NVME_TRANSPORT_TCP; 393 snprintf(trid->subnqn, SPDK_NVMF_NQN_MAX_LEN, "%s", "nqn.2016-06.io.spdk:cnode1"); in spdk_nvme_transport_id_compare() 394 snprintf(trid in spdk_nvme_transport_id_compare() 297 struct spdk_nvme_transport_id trid; global() member 311 struct spdk_nvme_transport_id trid; global() member 360 ut_init_trid(struct spdk_nvme_transport_id * trid) ut_init_trid() argument 369 ut_init_trid2(struct spdk_nvme_transport_id * trid) ut_init_trid2() argument 378 ut_init_trid3(struct spdk_nvme_transport_id * trid) ut_init_trid3() argument 430 ut_attach_ctrlr(const struct spdk_nvme_transport_id * trid,uint32_t num_ns,bool ana_reporting,bool multipath) ut_attach_ctrlr() argument 606 spdk_nvme_connect_async(const struct spdk_nvme_transport_id * trid,const struct spdk_nvme_ctrlr_opts * opts,spdk_nvme_attach_cb attach_cb) spdk_nvme_connect_async() argument 1394 struct spdk_nvme_transport_id trid = {}; test_create_ctrlr() local 1431 struct spdk_nvme_transport_id trid = {}; test_reset_ctrlr() local 1571 struct spdk_nvme_transport_id trid = {}; test_race_between_reset_and_destruct_ctrlr() local 1893 struct spdk_nvme_transport_id trid = {}; test_pending_reset() local 2030 struct spdk_nvme_transport_id trid = {}; test_attach_ctrlr() local 2161 struct spdk_nvme_transport_id trid = {}; test_aer_cb() local 2372 struct spdk_nvme_transport_id trid = {}; test_submit_nvme_cmd() local 2654 struct spdk_nvme_transport_id trid = {}; test_abort() local 2902 struct spdk_nvme_transport_id trid = {}; test_get_io_qpair() local 2949 struct spdk_nvme_transport_id trid = {}; test_bdev_unregister() local 3070 struct spdk_nvme_transport_id trid = {}; test_init_ana_log_page() local 3227 struct spdk_nvme_transport_id trid = {}; test_reconnect_qpair() local 4874 struct spdk_nvme_transport_id trid = {}; test_concurrent_read_ana_log_page() local 5312 struct spdk_nvme_transport_id trid = {}; test_reconnect_ctrlr() local 5465 ut_get_path_id_by_trid(struct nvme_ctrlr * nvme_ctrlr,const struct spdk_nvme_transport_id * trid) ut_get_path_id_by_trid() argument 6663 struct spdk_nvme_transport_id trid = {}; test_race_between_reset_and_disconnected() local 6808 struct spdk_nvme_transport_id trid = {}; test_ctrlr_op_rpc() local 7083 struct spdk_nvme_transport_id trid = {}; test_disable_enable_ctrlr() local 7273 struct spdk_nvme_transport_id trid = {}; test_delete_ctrlr_done() local [all...] |
/spdk/lib/nvmf/ |
H A D | transport.c | 102 nvmf_transport_listen_dump_trid(const struct spdk_nvme_transport_id *trid, in nvmf_transport_listen_dump_trid() argument 105 const char *adrfam = spdk_nvme_transport_id_adrfam_str(trid->adrfam); in nvmf_transport_listen_dump_trid() 107 spdk_json_write_named_string(w, "trtype", trid->trstring); in nvmf_transport_listen_dump_trid() 109 spdk_json_write_named_string(w, "traddr", trid->traddr); in nvmf_transport_listen_dump_trid() 110 spdk_json_write_named_string(w, "trsvcid", trid->trsvcid); in nvmf_transport_listen_dump_trid() 371 transport->ops->stop_listen(transport, &listener->trid); in spdk_nvmf_transport_destroy() 385 const struct spdk_nvme_transport_id *trid) in nvmf_transport_find_listener() argument 390 if (spdk_nvme_transport_id_compare(&listener->trid, trid) == 0) { in nvmf_transport_find_listener() 400 const struct spdk_nvme_transport_id *trid, struc in spdk_nvmf_transport_listen() argument 439 spdk_nvmf_transport_stop_listen(struct spdk_nvmf_transport * transport,const struct spdk_nvme_transport_id * trid) spdk_nvmf_transport_stop_listen() argument 461 struct spdk_nvme_transport_id trid; global() member 537 spdk_nvmf_transport_stop_listen_async(struct spdk_nvmf_transport * transport,const struct spdk_nvme_transport_id * trid,struct spdk_nvmf_subsystem * subsystem,spdk_nvmf_tgt_subsystem_listen_done_fn cb_fn,void * cb_arg) spdk_nvmf_transport_stop_listen_async() argument 568 nvmf_transport_listener_discover(struct spdk_nvmf_transport * transport,struct spdk_nvme_transport_id * trid,struct spdk_nvmf_discovery_log_page_entry * entry) nvmf_transport_listener_discover() argument 762 nvmf_transport_qpair_get_peer_trid(struct spdk_nvmf_qpair * qpair,struct spdk_nvme_transport_id * trid) nvmf_transport_qpair_get_peer_trid() argument 769 nvmf_transport_qpair_get_local_trid(struct spdk_nvmf_qpair * qpair,struct spdk_nvme_transport_id * trid) nvmf_transport_qpair_get_local_trid() argument 776 nvmf_transport_qpair_get_listen_trid(struct spdk_nvmf_qpair * qpair,struct spdk_nvme_transport_id * trid) nvmf_transport_qpair_get_listen_trid() argument [all...] |
H A D | nvmf.c | 50 const struct spdk_nvme_transport_id *trid) in nvmf_tgt_find_referral() argument 55 if (spdk_nvme_transport_id_compare(&referral->trid, trid) == 0) { in nvmf_tgt_find_referral() 69 struct spdk_nvme_transport_id *trid = &opts.trid; in spdk_nvmf_tgt_add_referral() local 72 if (trid->subnqn[0] == '\0') { in spdk_nvmf_tgt_add_referral() 73 snprintf(trid->subnqn, sizeof(trid->subnqn), "%s", SPDK_NVMF_DISCOVERY_NQN); in spdk_nvmf_tgt_add_referral() 76 if (!nvmf_nqn_is_valid(trid->subnqn)) { in spdk_nvmf_tgt_add_referral() 82 if (nvmf_tgt_find_referral(tgt, trid)) { in spdk_nvmf_tgt_add_referral() 118 struct spdk_nvme_transport_id *trid = &opts.trid; spdk_nvmf_tgt_remove_referral() local 687 const struct spdk_nvme_transport_id *trid; nvmf_write_subsystem_config_json() local 820 spdk_nvmf_tgt_listen_ext(struct spdk_nvmf_tgt * tgt,const struct spdk_nvme_transport_id * trid,struct spdk_nvmf_listen_opts * opts) spdk_nvmf_tgt_listen_ext() argument 855 spdk_nvmf_tgt_stop_listen(struct spdk_nvmf_tgt * tgt,struct spdk_nvme_transport_id * trid) spdk_nvmf_tgt_stop_listen() argument 1448 spdk_nvmf_qpair_get_peer_trid(struct spdk_nvmf_qpair * qpair,struct spdk_nvme_transport_id * trid) spdk_nvmf_qpair_get_peer_trid() argument 1456 spdk_nvmf_qpair_get_local_trid(struct spdk_nvmf_qpair * qpair,struct spdk_nvme_transport_id * trid) spdk_nvmf_qpair_get_local_trid() argument 1464 spdk_nvmf_qpair_get_listen_trid(struct spdk_nvmf_qpair * qpair,struct spdk_nvme_transport_id * trid) spdk_nvmf_qpair_get_listen_trid() argument [all...] |
H A D | transport.h | 16 struct spdk_nvme_transport_id *trid, 45 struct spdk_nvme_transport_id *trid); 48 struct spdk_nvme_transport_id *trid); 51 struct spdk_nvme_transport_id *trid);
|
H A D | ctrlr_discovery.c | 133 if (!nvmf_discovery_compare_trid(tgt->discovery_filter, listener->trid, cmd_source_trid)) { in nvmf_generate_discovery_log() 137 SPDK_DEBUGLOG(nvmf, "listener %s:%s trtype %s\n", listener->trid->traddr, listener->trid->trsvcid, in nvmf_generate_discovery_log() 138 listener->trid->trstring); in nvmf_generate_discovery_log() 170 nvmf_transport_listener_discover(listener->transport, listener->trid, entry); in nvmf_generate_discovery_log() 177 SPDK_DEBUGLOG(nvmf, "referral %s:%s trtype %s\n", referral->trid.traddr, referral->trid.trsvcid, in nvmf_generate_discovery_log() 178 referral->trid.trstring); in nvmf_generate_discovery_log()
|
H A D | nvmf_rpc.c | 178 const struct spdk_nvme_transport_id *trid; in dump_nvmf_subsystem() 180 trid = spdk_nvmf_subsystem_listener_get_trid(listener); in dump_nvmf_subsystem() local 183 nvmf_transport_listen_dump_trid(trid, w); in dump_nvmf_subsystem() 633 struct spdk_nvme_transport_id trid; in free_rpc_listen_address() 692 spdk_nvmf_tgt_stop_listen(ctx->tgt, &ctx->trid); in nvmf_rpc_listen_resumed() 761 if (nvmf_subsystem_find_listener(subsystem, &ctx->trid)) { in nvmf_rpc_set_ana_state_done() 769 rc = spdk_nvmf_tgt_listen_ext(ctx->tgt, &ctx->trid, &ctx->opts); in nvmf_rpc_set_ana_state_done() 777 spdk_nvmf_subsystem_add_listener_ext(ctx->subsystem, &ctx->trid, nvmf_rpc_subsystem_listen, ctx, 781 rc = spdk_nvmf_subsystem_remove_listener(subsystem, &ctx->trid); in nvmf_rpc_listen_paused() 790 spdk_nvmf_transport_stop_listen_async(ctx->transport, &ctx->trid, subsyste in nvmf_rpc_listen_paused() 659 struct spdk_nvme_transport_id trid; global() member 840 rpc_listen_address_to_trid(const struct rpc_listen_address * address,struct spdk_nvme_transport_id * trid) rpc_listen_address_to_trid() argument 1085 struct spdk_nvme_transport_id trid = {}; rpc_nvmf_add_referral() local 1160 struct spdk_nvme_transport_id trid = {}; rpc_nvmf_remove_referral() local 2727 struct spdk_nvme_transport_id trid = {}; dump_nvmf_qpair() local 2779 const struct spdk_nvme_transport_id *trid = listener->trid; dump_nvmf_subsystem_listener() local [all...] |
H A D | mdns_server.c | 126 if (listener->trid->trtype == SPDK_NVME_TRANSPORT_TCP) { in publish_pull_registration_request() 128 } else if (listener->trid->trtype == SPDK_NVME_TRANSPORT_RDMA) { in publish_pull_registration_request() 133 SPDK_ERRLOG("mDNS PRR does not support trtype %d", listener->trid->trtype); in publish_pull_registration_request() 143 port = spdk_strtol(listener->trid->trsvcid, 10); in publish_pull_registration_request()
|
/spdk/test/unit/lib/nvme/nvme.c/ |
H A D | nvme_ut.c | 29 (void *cb_ctx, const struct spdk_nvme_transport_id *trid, 32 (const struct spdk_nvme_transport_id *trid, 107 if (probe_ctx->trid.trtype != SPDK_NVME_TRANSPORT_PCIE) { in ut_nvme_pcie_ctrlr_scan() 117 rc = nvme_ctrlr_probe(&probe_ctx->trid, probe_ctx, NULL); in ut_nvme_pcie_ctrlr_scan() 122 rc = nvme_ctrlr_probe(&probe_ctx->trid, probe_ctx, NULL); in ut_nvme_pcie_ctrlr_scan() 143 CU_ASSERT(probe_ctx->trid.trtype == SPDK_NVME_TRANSPORT_PCIE); in nvme_transport_ctrlr_scan() 152 ctrlr = nvme_get_ctrlr_by_trid(&probe_ctx->trid, NULL); in nvme_transport_ctrlr_scan() 154 probe_ctx->probe_cb(probe_ctx->cb_ctx, &probe_ctx->trid, &ctrlr->opts); in nvme_transport_ctrlr_scan() 161 dummy_attach_cb(void *cb_ctx, const struct spdk_nvme_transport_id *trid, in dummy_attach_cb() 169 dummy_attach_fail_cb(void *cb_ctx, const struct spdk_nvme_transport_id *trid, in in test_spdk_nvme_probe() 160 dummy_attach_cb(void * cb_ctx,const struct spdk_nvme_transport_id * trid,struct spdk_nvme_ctrlr * ctrlr,const struct spdk_nvme_ctrlr_opts * opts) dummy_attach_cb() argument 170 const struct spdk_nvme_transport_id *trid = NULL; test_spdk_nvme_probe() local 233 struct spdk_nvme_transport_id trid = {}; test_spdk_nvme_connect() local 828 const struct spdk_nvme_transport_id trid = {}; test_nvme_ctrlr_probe() local 1413 struct spdk_nvme_transport_id trid = {}; test_nvme_ctrlr_probe_internal() local [all...] |
/spdk/test/unit/lib/nvmf/ctrlr_discovery.c/ |
H A D | ctrlr_discovery_ut.c | 28 const struct spdk_nvme_transport_id *trid), 0); 114 const struct spdk_nvme_transport_id *trid, struct spdk_nvmf_listen_opts *opts) in spdk_nvmf_transport_listen() 123 const struct spdk_nvme_transport_id *trid) in nvmf_transport_find_listener() 132 if (spdk_nvme_transport_id_compare(&listener->trid, trid) == 0) { in nvmf_transport_find_listener() 142 struct spdk_nvme_transport_id *trid, in nvmf_transport_listener_discover() 145 transport->ops->listener_discover(transport, trid, entry); in nvmf_transport_listener_discover() 150 struct spdk_nvme_transport_id *trid, struct spdk_nvmf_discovery_log_page_entry *entry) in test_dummy_listener_discover() 259 test_gen_trid(struct spdk_nvme_transport_id *trid, enum spdk_nvme_transport_type trtype, in test_gen_trid() 262 snprintf(trid in test_gen_trid() 113 spdk_nvmf_transport_listen(struct spdk_nvmf_transport * transport,const struct spdk_nvme_transport_id * trid,struct spdk_nvmf_listen_opts * opts) spdk_nvmf_transport_listen() argument 122 nvmf_transport_find_listener(struct spdk_nvmf_transport * transport,const struct spdk_nvme_transport_id * trid) nvmf_transport_find_listener() argument 141 nvmf_transport_listener_discover(struct spdk_nvmf_transport * transport,struct spdk_nvme_transport_id * trid,struct spdk_nvmf_discovery_log_page_entry * entry) nvmf_transport_listener_discover() argument 149 test_dummy_listener_discover(struct spdk_nvmf_transport * transport,struct spdk_nvme_transport_id * trid,struct spdk_nvmf_discovery_log_page_entry * entry) test_dummy_listener_discover() argument 258 test_gen_trid(struct spdk_nvme_transport_id * trid,enum spdk_nvme_transport_type trtype,enum spdk_nvmf_adrfam adrfam,const char * tradd,const char * trsvcid) test_gen_trid() argument 286 struct spdk_nvme_transport_id trid = {}; test_discovery_log() local 387 test_rdma_discover(struct spdk_nvmf_transport * transport,struct spdk_nvme_transport_id * trid,struct spdk_nvmf_discovery_log_page_entry * entry) test_rdma_discover() argument 397 test_tcp_discover(struct spdk_nvmf_transport * transport,struct spdk_nvme_transport_id * trid,struct spdk_nvmf_discovery_log_page_entry * entry) test_tcp_discover() argument [all...] |
/spdk/test/unit/lib/nvme/nvme_fabric.c/ |
H A D | nvme_fabric_ut.c | 46 (const struct spdk_nvme_transport_id *trid, 103 spdk_nvme_transport_id_populate_trstring(struct spdk_nvme_transport_id *trid, const char *trstring) in spdk_nvme_transport_id_populate_trstring() argument 116 rc = snprintf(trid->trstring, SPDK_NVMF_TRSTRING_MAX_LEN, "%s", trstring); in spdk_nvme_transport_id_populate_trstring() 123 trid->trstring[i] = toupper(trid->trstring[i]); in spdk_nvme_transport_id_populate_trstring() 132 nvme_ctrlr_probe(const struct spdk_nvme_transport_id *trid, in nvme_ctrlr_probe() argument 135 g_ut_trid = *trid; in nvme_ctrlr_probe() 315 memcpy(probe_ctx.trid.trstring, trstring, sizeof(probe_ctx.trid.trstring)); in test_nvme_fabric_discover_probe() 372 memcpy(ctrlr.trid.subnqn, subnqn, sizeof(subnqn)); in test_nvme_fabric_qpair_connect() 384 CU_ASSERT(!strncmp(g_nvmf_data.subnqn, ctrlr.trid.subnqn, sizeof(ctrlr.trid.subnqn))); in test_nvme_fabric_qpair_connect() 406 CU_ASSERT(!strncmp(g_nvmf_data.subnqn, ctrlr.trid.subnqn, sizeof(ctrlr.trid.subnqn))); in test_nvme_fabric_qpair_connect()
|
/spdk/test/env/env_dpdk_post_init/ |
H A D | env_dpdk_post_init.c | 28 probe_cb(void *cb_ctx, const struct spdk_nvme_transport_id *trid, in probe_cb() argument 31 printf("Attaching to %s\n", trid->traddr); in probe_cb() 37 attach_cb(void *cb_ctx, const struct spdk_nvme_transport_id *trid, in attach_cb() argument 60 trid->traddr); in attach_cb()
|
/spdk/test/nvme/boot_partition/ |
H A D | boot_partition.c | 12 struct spdk_nvme_transport_id trid; member 206 snprintf(&g_ctrlr.trid.traddr[0], SPDK_NVMF_TRADDR_MAX_LEN + 1, in parse_args() 209 g_ctrlr.trid.trtype = SPDK_NVME_TRANSPORT_PCIE; in parse_args() 211 spdk_nvme_transport_id_populate_trstring(&g_ctrlr.trid, in parse_args() 212 spdk_nvme_transport_id_trtype_str(g_ctrlr.trid.trtype)); in parse_args() 260 g_ctrlr.ctrlr = spdk_nvme_connect(&g_ctrlr.trid, NULL, 0); in main()
|
/spdk/test/app/fuzz/nvme_fuzz/ |
H A D | nvme_fuzz.c | 51 struct spdk_nvme_transport_id trid; member 533 struct nvme_fuzz_trid *trid, *tmp; in free_trids() local 535 TAILQ_FOREACH_SAFE(trid, &g_trid_list, tailq, tmp) { in free_trids() 536 TAILQ_REMOVE(&g_trid_list, trid, tailq); in free_trids() 537 free(trid); in free_trids() 685 struct nvme_fuzz_trid *trid; in begin_fuzz() local 696 TAILQ_FOREACH(trid, &g_trid_list, tailq) { in begin_fuzz() 697 ctrlr = spdk_nvme_connect(&trid->trid, NULL, 0); in begin_fuzz() 700 trid->trid.traddr); in begin_fuzz() 766 struct nvme_fuzz_trid *trid; in nvme_fuzz_parse() local [all …]
|
/spdk/test/nvmf/target/ |
H A D | fabrics_fuzz.sh | 27 trid="trtype:$TEST_TRANSPORT adrfam:IPv4 subnqn:nqn.2016-06.io.spdk:cnode1 traddr:$NVMF_FIRST_TARGE… 30 $rootdir/test/app/fuzz/nvme_fuzz/nvme_fuzz -m 0x2 -t 30 -S 123456 -F "$trid" -N -a 2> $output_dir/n… 32 $rootdir/test/app/fuzz/nvme_fuzz/nvme_fuzz -m 0x2 -F "$trid" -j $rootdir/test/app/fuzz/nvme_fuzz/ex…
|
/spdk/test/nvme/startup/ |
H A D | startup.c | 30 probe_cb(void *cb_ctx, const struct spdk_nvme_transport_id *trid, in probe_cb() argument 33 printf("Attaching to %s\n", trid->traddr); in probe_cb() 39 attach_cb(void *cb_ctx, const struct spdk_nvme_transport_id *trid, in attach_cb() argument 52 printf("Attached to %s\n", trid->traddr); in attach_cb()
|
/spdk/test/unit/lib/nvmf/nvmf.c/ |
H A D | nvmf_ut.c | 78 const struct spdk_nvme_transport_id *trid, 82 const struct spdk_nvme_transport_id *trid), 0) 90 struct spdk_nvme_transport_id *trid), 0); 93 struct spdk_nvme_transport_id *trid), 0); 96 struct spdk_nvme_transport_id *trid), 0); 109 DEFINE_STUB_V(nvmf_transport_listen_dump_trid, (const struct spdk_nvme_transport_id *trid,
|
/spdk/test/nvme/err_injection/ |
H A D | err_injection.c | 33 probe_cb(void *cb_ctx, const struct spdk_nvme_transport_id *trid, in probe_cb() argument 36 printf("Attaching to %s\n", trid->traddr); in probe_cb() 42 attach_cb(void *cb_ctx, const struct spdk_nvme_transport_id *trid, in attach_cb() argument 65 trid->traddr); in attach_cb()
|