Commit 4b534e73 authored by Anisa Su's avatar Anisa Su Committed by Konrad Sztyber
Browse files

test/unit: add poller_get_state_str unit test 



Change-Id: I469afb87a0626fa70701f2b0ab57811584093952
Signed-off-by: default avatarAnisa Su <anisa.su@samsung.com>
Reviewed-on: https://review.spdk.io/gerrit/c/spdk/spdk/+/24524


Tested-by: default avatarSPDK CI Jenkins <sys_sgci@intel.com>
Community-CI: Mellanox Build Bot
Reviewed-by: default avatarShuhei Matsumoto <smatsumoto@nvidia.com>
Reviewed-by: default avatarJim Harris <jim.harris@samsung.com>
parent 1513b044

test/unit/lib/thread/thread.c/thread_ut.c

+45 −0
Original line number Diff line number Diff line
@@ -1117,6 +1117,14 @@ ut_null_poll(void *ctx) 
	return SPDK_POLLER_IDLE;

}



static int

ut_assert_poller_state_running(void *ctx)

{

	struct spdk_poller *poller = ctx;

	CU_ASSERT_STRING_EQUAL(spdk_poller_get_state_str(poller), "running");

	return SPDK_POLLER_IDLE;

}



static int

ut_nested_ch_create_cb(void *io_device, void *ctx_buf)

{
@@ -2062,6 +2070,42 @@ poller_get_id(void) 
	free_threads();

}



static void

poller_get_state_str(void)

{

	struct spdk_poller *poller = NULL;



	allocate_threads(1);

	set_thread(0);



	poller = spdk_poller_register(ut_assert_poller_state_running, NULL, 0);

	poller->arg = poller;



	/* Assert poller begins in "waiting" state */

	CU_ASSERT_STRING_EQUAL(spdk_poller_get_state_str(poller), "waiting");



	/* Assert poller state changes to "running" while being polled and returns to "waiting" */

	poll_thread(0);

	CU_ASSERT_STRING_EQUAL(spdk_poller_get_state_str(poller), "waiting");



	/* Assert poller state changes to "paused" and remains "paused" */

	spdk_poller_pause(poller);

	CU_ASSERT_STRING_EQUAL(spdk_poller_get_state_str(poller), "pausing");

	poll_thread(0);

	CU_ASSERT_STRING_EQUAL(spdk_poller_get_state_str(poller), "paused");

	poll_thread(0);

	CU_ASSERT_STRING_EQUAL(spdk_poller_get_state_str(poller), "paused");



	/* Assert poller state changes after being resumed  */

	spdk_poller_resume(poller);

	CU_ASSERT_STRING_EQUAL(spdk_poller_get_state_str(poller), "waiting");

	poll_thread(0);

	CU_ASSERT_STRING_EQUAL(spdk_poller_get_state_str(poller), "waiting");



	spdk_poller_unregister(&poller);

	free_threads();

}





int

main(int argc, char **argv)
@@ -2095,6 +2139,7 @@ main(int argc, char **argv) 
	CU_ADD_TEST(suite, for_each_thread_and_thread_exit_race);

	CU_ADD_TEST(suite, poller_get_name);

	CU_ADD_TEST(suite, poller_get_id);

	CU_ADD_TEST(suite, poller_get_state_str);



	num_failures = spdk_ut_run_tests(argc, argv, NULL);

	CU_cleanup_registry();