Commit 192faebe authored by Frederic Weisbecker's avatar Frederic Weisbecker
Browse files

lib: test_objpool: Use kthread_run_on_cpu() 



Use the proper API instead of open coding it.

Reviewed-by: default avatarMatt Wu <wuqiang.matt@bytedance.com>
Signed-off-by: default avatarFrederic Weisbecker <frederic@kernel.org>
parent 294fca60

lib/test_objpool.c

+5 −14
Original line number Diff line number Diff line
@@ -371,14 +371,10 @@ static int ot_start_sync(struct ot_test *test) 
		if (!cpu_online(cpu))

			continue;



		work = kthread_create_on_node(ot_thread_worker, item,

				cpu_to_node(cpu), "ot_worker_%d", cpu);

		if (IS_ERR(work)) {

		work = kthread_run_on_cpu(ot_thread_worker, item,

					  cpu, "ot_worker_%d");

		if (IS_ERR(work))

			pr_err("failed to create thread for cpu %d\n", cpu);

		} else {

			kthread_bind(work, cpu);

			wake_up_process(work);

		}

	}



	/* wait a while to make sure all threads waiting at start line */
@@ -562,14 +558,9 @@ static int ot_start_async(struct ot_test *test) 
		if (!cpu_online(cpu))

			continue;



		work = kthread_create_on_node(ot_thread_worker, item,

				cpu_to_node(cpu), "ot_worker_%d", cpu);

		if (IS_ERR(work)) {

		work = kthread_run_on_cpu(ot_thread_worker, item, cpu, "ot_worker_%d");

		if (IS_ERR(work))

			pr_err("failed to create thread for cpu %d\n", cpu);

		} else {

			kthread_bind(work, cpu);

			wake_up_process(work);

		}

	}



	/* wait a while to make sure all threads waiting at start line */