/* Wait until all currently executing or pending works on @worker are finished.  */
void flush_kthread_worker(struct kthread_worker *worker)
/* Wait until all currently executing or pending works on @worker are finished.  */
void flush_kthread_worker(struct kthread_worker *worker)
{
	struct kthread_flush_work fwork = {
		KTHREAD_WORK_INIT(fwork.work, kthread_flush_work_fn),
		COMPLETION_INITIALIZER_ONSTACK(fwork.done),
	};
	queue_kthread_work(worker, &fwork.work);
	wait_for_completion(&fwork.done);
}