Commit adfa9f6d authored by Ziye Yang's avatar Ziye Yang Committed by Daniel Verkamp
Browse files

nvmf: disconnect other connections if admin qpair disconnects. 



Also this patch make each io qpair recycled by its own thread.

Change-Id: I386e411f5d4cee4629054e4cce8d1f4401ec49c8
Signed-off-by: default avatarZiye Yang <optimistyzy@gmail.com>
Reviewed-on: https://review.gerrithub.io/407743


Reviewed-by: default avatarBen Walker <benjamin.walker@intel.com>
Reviewed-by: default avatarDaniel Verkamp <daniel.verkamp@intel.com>
Tested-by: default avatarSPDK Automated Test System <sys_sgsw@intel.com>
parent 2f94b4d4

lib/nvmf/ctrlr.c

+36 −11
Original line number Diff line number Diff line
@@ -275,28 +275,53 @@ end: 
}



static void

ctrlr_delete_qpair(void *ctx)

_ctrlr_destruct_check(void *ctx)

{

	struct spdk_nvmf_ctrlr *ctrlr = ctx;



	assert(ctrlr != NULL);

	assert(ctrlr->num_qpairs > 0);

	ctrlr->num_qpairs--;

	if (ctrlr->num_qpairs == 0) {

		assert(ctrlr->subsys != NULL);

		assert(ctrlr->subsys->thread != NULL);

		spdk_thread_send_msg(ctrlr->subsys->thread, ctrlr_destruct, ctrlr);

	}

}



static void

nvmf_qpair_fini(void *ctx)

{

	struct spdk_nvmf_qpair *qpair = ctx;

	struct spdk_nvmf_ctrlr *ctrlr = qpair->ctrlr;

	struct spdk_thread *admin_thread = ctrlr->admin_qpair->group->thread;



	spdk_nvmf_transport_qpair_fini(qpair);

	spdk_thread_send_msg(admin_thread, _ctrlr_destruct_check, ctrlr);

}



static void

ctrlr_delete_qpair(void *ctx)

{

	struct spdk_nvmf_qpair *qpair = ctx, *_qpair, *tmp;

	struct spdk_nvmf_ctrlr *ctrlr = qpair->ctrlr;



	assert(ctrlr != NULL);

	assert(ctrlr->num_qpairs > 0);

	/* Defer the admin qpair deletion since there are still io qpairs */



	/* Delete all io qpairs if receving the admin qpair disconnect event early */

	if ((ctrlr->num_qpairs > 1) && (qpair == ctrlr->admin_qpair)) {

		TAILQ_FOREACH_SAFE(_qpair, &ctrlr->qpairs, link, tmp) {

			if (_qpair != qpair) {

				ctrlr_delete_qpair(_qpair);

			}

		}



		spdk_thread_send_msg(qpair->group->thread, ctrlr_delete_qpair, qpair);

		return;

	}



	ctrlr->num_qpairs--;

	TAILQ_REMOVE(&ctrlr->qpairs, qpair, link);

	spdk_nvmf_transport_qpair_fini(qpair);



	if (ctrlr->num_qpairs == 0) {

		assert(ctrlr->subsys != NULL);

		assert(ctrlr->subsys->thread != NULL);

		spdk_thread_send_msg(ctrlr->subsys->thread, ctrlr_destruct, ctrlr);

	}

	spdk_thread_send_msg(qpair->group->thread, nvmf_qpair_fini, qpair);

}



static void