Commit e13da83e authored by Ben Walker's avatar Ben Walker Committed by Jim Harris
Browse files

nvmf: nvmf_tgt_host_trid stores a pg instead of a core 



Change-Id: I53bb89f6999ab9bbc4bd8e960970454d60beebee
Signed-off-by: default avatarBen Walker <benjamin.walker@intel.com>
Reviewed-on: https://review.gerrithub.io/c/spdk/spdk/+/452473


Tested-by: default avatarSPDK CI Jenkins <sys_sgci@intel.com>
Reviewed-by: default avatarShuhei Matsumoto <shuhei.matsumoto.xt@hitachi.com>
Reviewed-by: default avatarSeth Howell <seth.howell5141@gmail.com>
Reviewed-by: default avatarJim Harris <james.r.harris@intel.com>
parent 53424038

lib/event/subsystems/nvmf/nvmf_tgt.c

+3 −4
Original line number Diff line number Diff line
@@ -62,7 +62,7 @@ struct nvmf_tgt_poll_group { 


struct nvmf_tgt_host_trid {

	struct spdk_nvme_transport_id       host_trid;

	uint32_t                            core;

	struct nvmf_tgt_poll_group          *pg;

	uint32_t                            ref;

	TAILQ_ENTRY(nvmf_tgt_host_trid)     link;

};
@@ -174,8 +174,7 @@ nvmf_tgt_get_pg(struct spdk_nvmf_qpair *qpair) 
			if (tmp_trid && !strncmp(tmp_trid->host_trid.traddr,

						 trid.traddr, SPDK_NVMF_TRADDR_MAX_LEN + 1)) {

				tmp_trid->ref++;

				core = tmp_trid->core;

				pg = &g_poll_groups[core];

				pg = tmp_trid->pg;

				break;

			}

		}
@@ -188,7 +187,7 @@ nvmf_tgt_get_pg(struct spdk_nvmf_qpair *qpair) 
			}

			/* Get the next available core for the new host */

			pg = spdk_nvmf_get_next_pg();

			new_trid->core = pg->core;

			new_trid->pg = pg;

			memcpy(new_trid->host_trid.traddr, trid.traddr,

			       SPDK_NVMF_TRADDR_MAX_LEN + 1);

			TAILQ_INSERT_TAIL(&g_nvmf_tgt_host_trids, new_trid, link);