Commit d88915f5 authored by Seth Howell's avatar Seth Howell Committed by Jim Harris
Browse files

bdev/nvme: rename ctrlr trid parameter to connected_trid 



This patch paves the way for introducing a tailq containing
multiple alternative paths to the same controller.

Change-Id: I13d30c12b8e0ce38eae687f9e76740be1d11e4d1
Signed-off-by: default avatarSeth Howell <seth.howell@intel.com>
Reviewed-on: https://review.spdk.io/gerrit/c/spdk/spdk/+/3259


Community-CI: Mellanox Build Bot
Tested-by: default avatarSPDK CI Jenkins <sys_sgci@intel.com>
Reviewed-by: default avatarJim Harris <james.r.harris@intel.com>
Reviewed-by: default avatarPaul Luse <paul.e.luse@intel.com>
Reviewed-by: default avatarAleksey Marchuk <alexeymar@mellanox.com>
Reviewed-by: default avatarShuhei Matsumoto <shuhei.matsumoto.xt@hitachi.com>
Reviewed-by: default avatarBen Walker <benjamin.walker@intel.com>
parent a4b5041c

module/bdev/nvme/bdev_nvme.c

+21 −21
Original line number Diff line number Diff line
@@ -852,13 +852,13 @@ bdev_nvme_dump_info_json(void *ctx, struct spdk_json_write_ctx *w) 


	spdk_json_write_named_object_begin(w, "nvme");



	if (nvme_bdev_ctrlr->trid->trtype == SPDK_NVME_TRANSPORT_PCIE) {

		spdk_json_write_named_string(w, "pci_address", nvme_bdev_ctrlr->trid->traddr);

	if (nvme_bdev_ctrlr->connected_trid->trtype == SPDK_NVME_TRANSPORT_PCIE) {

		spdk_json_write_named_string(w, "pci_address", nvme_bdev_ctrlr->connected_trid->traddr);

	}



	spdk_json_write_named_object_begin(w, "trid");



	nvme_bdev_dump_trid_json(nvme_bdev_ctrlr->trid, w);

	nvme_bdev_dump_trid_json(nvme_bdev_ctrlr->connected_trid, w);



	spdk_json_write_object_end(w);
@@ -1370,8 +1370,8 @@ create_ctrlr(struct spdk_nvme_ctrlr *ctrlr, 
		return -ENOMEM;

	}



	nvme_bdev_ctrlr->trid = calloc(1, sizeof(*nvme_bdev_ctrlr->trid));

	if (nvme_bdev_ctrlr->trid == NULL) {

	nvme_bdev_ctrlr->connected_trid = calloc(1, sizeof(*nvme_bdev_ctrlr->connected_trid));

	if (nvme_bdev_ctrlr->connected_trid == NULL) {

		SPDK_ERRLOG("Failed to allocate device trid struct\n");

		free(nvme_bdev_ctrlr);

		return -ENOMEM;
@@ -1381,7 +1381,7 @@ create_ctrlr(struct spdk_nvme_ctrlr *ctrlr, 
	nvme_bdev_ctrlr->namespaces = calloc(nvme_bdev_ctrlr->num_ns, sizeof(struct nvme_bdev_ns *));

	if (!nvme_bdev_ctrlr->namespaces) {

		SPDK_ERRLOG("Failed to allocate block namespaces pointer\n");

		free(nvme_bdev_ctrlr->trid);

		free(nvme_bdev_ctrlr->connected_trid);

		free(nvme_bdev_ctrlr);

		return -ENOMEM;

	}
@@ -1394,7 +1394,7 @@ create_ctrlr(struct spdk_nvme_ctrlr *ctrlr, 
				free(nvme_bdev_ctrlr->namespaces[i - 1]);

			}

			free(nvme_bdev_ctrlr->namespaces);

			free(nvme_bdev_ctrlr->trid);

			free(nvme_bdev_ctrlr->connected_trid);

			free(nvme_bdev_ctrlr);

			return -ENOMEM;

		}
@@ -1404,11 +1404,11 @@ create_ctrlr(struct spdk_nvme_ctrlr *ctrlr, 
	nvme_bdev_ctrlr->adminq_timer_poller = NULL;

	nvme_bdev_ctrlr->ctrlr = ctrlr;

	nvme_bdev_ctrlr->ref = 0;

	*nvme_bdev_ctrlr->trid = *trid;

	*nvme_bdev_ctrlr->connected_trid = *trid;

	nvme_bdev_ctrlr->name = strdup(name);

	if (nvme_bdev_ctrlr->name == NULL) {

		free(nvme_bdev_ctrlr->namespaces);

		free(nvme_bdev_ctrlr->trid);

		free(nvme_bdev_ctrlr->connected_trid);

		free(nvme_bdev_ctrlr);

		return -ENOMEM;

	}
@@ -1419,7 +1419,7 @@ create_ctrlr(struct spdk_nvme_ctrlr *ctrlr, 
			SPDK_ERRLOG("Unable to initialize OCSSD controller\n");

			free(nvme_bdev_ctrlr->name);

			free(nvme_bdev_ctrlr->namespaces);

			free(nvme_bdev_ctrlr->trid);

			free(nvme_bdev_ctrlr->connected_trid);

			free(nvme_bdev_ctrlr);

			return rc;

		}
@@ -1810,12 +1810,12 @@ bdev_nvme_delete(const char *name) 
		return -ENODEV;

	}



	if (nvme_bdev_ctrlr->trid->trtype == SPDK_NVME_TRANSPORT_PCIE) {

	if (nvme_bdev_ctrlr->connected_trid->trtype == SPDK_NVME_TRANSPORT_PCIE) {

		entry = calloc(1, sizeof(*entry));

		if (!entry) {

			return -ENOMEM;

		}

		entry->trid = *nvme_bdev_ctrlr->trid;

		entry->trid = *nvme_bdev_ctrlr->connected_trid;

		TAILQ_INSERT_TAIL(&g_skipped_nvme_ctrlrs, entry, tailq);

	}
@@ -2735,31 +2735,31 @@ bdev_nvme_get_spdk_running_config(FILE *fp) 
		const char *trtype;

		const char *prchk_flags;



		trtype = spdk_nvme_transport_id_trtype_str(nvme_bdev_ctrlr->trid->trtype);

		trtype = spdk_nvme_transport_id_trtype_str(nvme_bdev_ctrlr->connected_trid->trtype);

		if (!trtype) {

			continue;

		}



		if (nvme_bdev_ctrlr->trid->trtype == SPDK_NVME_TRANSPORT_PCIE) {

		if (nvme_bdev_ctrlr->connected_trid->trtype == SPDK_NVME_TRANSPORT_PCIE) {

			fprintf(fp, "TransportID \"trtype:%s traddr:%s\" %s\n",

				trtype,

				nvme_bdev_ctrlr->trid->traddr, nvme_bdev_ctrlr->name);

				nvme_bdev_ctrlr->connected_trid->traddr, nvme_bdev_ctrlr->name);

		} else {

			const char *adrfam;



			adrfam = spdk_nvme_transport_id_adrfam_str(nvme_bdev_ctrlr->trid->adrfam);

			adrfam = spdk_nvme_transport_id_adrfam_str(nvme_bdev_ctrlr->connected_trid->adrfam);

			prchk_flags = spdk_nvme_prchk_flags_str(nvme_bdev_ctrlr->prchk_flags);



			if (adrfam) {

				fprintf(fp, "TransportID \"trtype:%s adrfam:%s traddr:%s trsvcid:%s subnqn:%s\" %s",

					trtype,	adrfam,

					nvme_bdev_ctrlr->trid->traddr, nvme_bdev_ctrlr->trid->trsvcid,

					nvme_bdev_ctrlr->trid->subnqn, nvme_bdev_ctrlr->name);

					nvme_bdev_ctrlr->connected_trid->traddr, nvme_bdev_ctrlr->connected_trid->trsvcid,

					nvme_bdev_ctrlr->connected_trid->subnqn, nvme_bdev_ctrlr->name);

			} else {

				fprintf(fp, "TransportID \"trtype:%s traddr:%s trsvcid:%s subnqn:%s\" %s",

					trtype,

					nvme_bdev_ctrlr->trid->traddr, nvme_bdev_ctrlr->trid->trsvcid,

					nvme_bdev_ctrlr->trid->subnqn, nvme_bdev_ctrlr->name);

					nvme_bdev_ctrlr->connected_trid->traddr, nvme_bdev_ctrlr->connected_trid->trsvcid,

					nvme_bdev_ctrlr->connected_trid->subnqn, nvme_bdev_ctrlr->name);

			}



			if (prchk_flags) {
@@ -2867,7 +2867,7 @@ bdev_nvme_config_json(struct spdk_json_write_ctx *w) 


	pthread_mutex_lock(&g_bdev_nvme_mutex);

	TAILQ_FOREACH(nvme_bdev_ctrlr, &g_nvme_bdev_ctrlrs, tailq) {

		trid = nvme_bdev_ctrlr->trid;

		trid = nvme_bdev_ctrlr->connected_trid;



		spdk_json_write_object_begin(w);

module/bdev/nvme/bdev_nvme_rpc.c

+1 −1
Original line number Diff line number Diff line
@@ -357,7 +357,7 @@ rpc_dump_nvme_controller_info(struct spdk_json_write_ctx *w, 
{

	struct spdk_nvme_transport_id	*trid;



	trid = nvme_bdev_ctrlr->trid;

	trid = nvme_bdev_ctrlr->connected_trid;



	spdk_json_write_object_begin(w);

	spdk_json_write_named_string(w, "name", nvme_bdev_ctrlr->name);

module/bdev/nvme/common.c

+2 −2
Original line number Diff line number Diff line
@@ -45,7 +45,7 @@ nvme_bdev_ctrlr_get(const struct spdk_nvme_transport_id *trid) 
	struct nvme_bdev_ctrlr	*nvme_bdev_ctrlr;



	TAILQ_FOREACH(nvme_bdev_ctrlr, &g_nvme_bdev_ctrlrs, tailq) {

		if (spdk_nvme_transport_id_compare(trid, nvme_bdev_ctrlr->trid) == 0) {

		if (spdk_nvme_transport_id_compare(trid, nvme_bdev_ctrlr->connected_trid) == 0) {

			return nvme_bdev_ctrlr;

		}

	}
@@ -128,7 +128,7 @@ nvme_bdev_unregister_cb(void *io_device) 
		free(nvme_bdev_ctrlr->namespaces[i]);

	}

	free(nvme_bdev_ctrlr->namespaces);

	free(nvme_bdev_ctrlr->trid);

	free(nvme_bdev_ctrlr->connected_trid);

	free(nvme_bdev_ctrlr);



	pthread_mutex_lock(&g_bdev_nvme_mutex);

module/bdev/nvme/common.h

+1 −1
Original line number Diff line number Diff line
@@ -76,7 +76,7 @@ struct nvme_bdev_ctrlr { 
	 *  target for CONTROLLER IDENTIFY command during initialization

	 */

	struct spdk_nvme_ctrlr		*ctrlr;

	struct spdk_nvme_transport_id	*trid;

	struct spdk_nvme_transport_id	*connected_trid;

	char				*name;

	int				ref;

	bool				resetting;

test/unit/lib/bdev/bdev_ocssd.c/bdev_ocssd_ut.c

+3 −3
Original line number Diff line number Diff line
@@ -211,13 +211,13 @@ create_nvme_bdev_controller(const struct spdk_nvme_transport_id *trid, const cha 
	nvme_bdev_ctrlr->namespaces = calloc(ctrlr->ns_count, sizeof(struct nvme_bdev_ns *));

	SPDK_CU_ASSERT_FATAL(nvme_bdev_ctrlr->namespaces != NULL);



	nvme_bdev_ctrlr->trid = calloc(1, sizeof(struct spdk_nvme_transport_id));

	SPDK_CU_ASSERT_FATAL(nvme_bdev_ctrlr->trid != NULL);

	nvme_bdev_ctrlr->connected_trid = calloc(1, sizeof(struct spdk_nvme_transport_id));

	SPDK_CU_ASSERT_FATAL(nvme_bdev_ctrlr->connected_trid != NULL);



	nvme_bdev_ctrlr->ctrlr = ctrlr;

	nvme_bdev_ctrlr->num_ns = ctrlr->ns_count;

	nvme_bdev_ctrlr->ref = 0;

	*nvme_bdev_ctrlr->trid = *trid;

	*nvme_bdev_ctrlr->connected_trid = *trid;

	nvme_bdev_ctrlr->name = strdup(name);



	for (nsid = 0; nsid < ctrlr->ns_count; ++nsid) {