257 		struct dmatest_thread *thread;  in is_threaded_test_run()  local
259 		list_for_each_entry(thread, &dtc->threads, node) {  in is_threaded_test_run()
260 			if (!thread->done && !thread->pending)  in is_threaded_test_run()
273 		struct dmatest_thread *thread;  in is_threaded_test_pending()  local
275 		list_for_each_entry(thread, &dtc->threads, node) {  in is_threaded_test_pending()
276 			if (thread->pending)  in is_threaded_test_pending()
437 	struct dmatest_thread *thread =  in dmatest_callback()  local
439 	if (!thread->done) {  in dmatest_callback()
576 	struct dmatest_thread	*thread = data;  in dmatest_func()  local
577 	struct dmatest_done	*done = &thread->test_done;  in dmatest_func()
611 	thread->pending = false;  in dmatest_func()
612 	info = thread->info;  in dmatest_func()
614 	chan = thread->chan;  in dmatest_func()
618 	src = &thread->src;  in dmatest_func()
619 	dst = &thread->dst;  in dmatest_func()
620 	if (thread->type == DMA_MEMCPY) {  in dmatest_func()
624 	} else if (thread->type == DMA_MEMSET) {  in dmatest_func()
629 	} else if (thread->type == DMA_XOR) {  in dmatest_func()
635 	} else if (thread->type == DMA_PQ) {  in dmatest_func()
793 		if (thread->type == DMA_MEMCPY)  in dmatest_func()
797 		else if (thread->type == DMA_MEMSET)  in dmatest_func()
802 		else if (thread->type == DMA_XOR)  in dmatest_func()
807 		else if (thread->type == DMA_PQ) {  in dmatest_func()
844 			wait_event_freezable_timeout(thread->done_wait,  in dmatest_func()
942 	thread->done = true;  in dmatest_func()
950 	struct dmatest_thread	*thread;  in dmatest_cleanup_channel()  local
954 	list_for_each_entry_safe(thread, _thread, &dtc->threads, node) {  in dmatest_cleanup_channel()
955 		ret = kthread_stop(thread->task);  in dmatest_cleanup_channel()
957 			 thread->task->comm, ret);  in dmatest_cleanup_channel()
958 		list_del(&thread->node);  in dmatest_cleanup_channel()
959 		put_task_struct(thread->task);  in dmatest_cleanup_channel()
960 		kfree(thread);  in dmatest_cleanup_channel()
973 	struct dmatest_thread *thread;  in dmatest_add_threads()  local
990 		thread = kzalloc(sizeof(struct dmatest_thread), GFP_KERNEL);  in dmatest_add_threads()
991 		if (!thread) {  in dmatest_add_threads()
996 		thread->info = info;  in dmatest_add_threads()
997 		thread->chan = dtc->chan;  in dmatest_add_threads()
998 		thread->type = type;  in dmatest_add_threads()
999 		thread->test_done.wait = &thread->done_wait;  in dmatest_add_threads()
1000 		init_waitqueue_head(&thread->done_wait);  in dmatest_add_threads()
1002 		thread->task = kthread_create(dmatest_func, thread, "%s-%s%u",  in dmatest_add_threads()
1004 		if (IS_ERR(thread->task)) {  in dmatest_add_threads()
1007 			kfree(thread);  in dmatest_add_threads()
1012 		get_task_struct(thread->task);  in dmatest_add_threads()
1013 		list_add_tail(&thread->node, &dtc->threads);  in dmatest_add_threads()
1014 		thread->pending = true;  in dmatest_add_threads()
1138 		struct dmatest_thread *thread;  in run_pending_tests()  local
1141 		list_for_each_entry(thread, &dtc->threads, node) {  in run_pending_tests()
1142 			wake_up_process(thread->task);  in run_pending_tests()
1326 		struct dmatest_thread *thread;  in dmatest_test_list_get()  local
1329 		list_for_each_entry(thread, &dtc->threads, node) {  in dmatest_test_list_get()