Commit 6fb6716d authored by Ben Walker's avatar Ben Walker Committed by Tomasz Zawadzki
Browse files

fio_plugin/bdev: Support spdk_threads exiting at run time 



Now that the plugin supports SPDK-created spdk_threads, it needs to
handle those threads being removed at run time.

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


Community-CI: Broadcom CI <spdk-ci.pdl@broadcom.com>
Community-CI: Mellanox Build Bot
Tested-by: default avatarSPDK CI Jenkins <sys_sgci@intel.com>
Reviewed-by: default avatarChangpeng Liu <changpeng.liu@intel.com>
Reviewed-by: default avatarShuhei Matsumoto <smatsumoto@nvidia.com>
parent 0d845de7

examples/bdev/fio_plugin/fio_plugin.c

+7 −1
Original line number Diff line number Diff line
@@ -359,8 +359,14 @@ spdk_init_thread_poll(void *arg) 
		pthread_mutex_lock(&g_init_mtx);

		if (!TAILQ_EMPTY(&g_threads)) {

			TAILQ_FOREACH_SAFE(thread, &g_threads, link, tmp) {

				if (spdk_thread_is_exited(thread->thread)) {

					TAILQ_REMOVE(&g_threads, thread, link);

					free(thread->iocq);

					spdk_thread_destroy(thread->thread);

				} else {

					spdk_fio_poll_thread(thread);

				}

			}



			/* If there are exiting threads to poll, don't sleep. */

			pthread_mutex_unlock(&g_init_mtx);