Lines Matching refs:thread
27 struct spdk_thread *thread; member
44 spdk_set_thread(g_ut_threads[thread_id].thread); in set_thread()
52 struct spdk_thread *thread; in allocate_threads() local
64 thread = spdk_thread_create(NULL, NULL); in allocate_threads()
65 assert(thread != NULL); in allocate_threads()
66 g_ut_threads[i].thread = thread; in allocate_threads()
77 struct spdk_thread *thread; in free_threads() local
81 thread = g_ut_threads[i].thread; in free_threads()
82 spdk_thread_exit(thread); in free_threads()
90 thread = g_ut_threads[i].thread; in free_threads()
91 if (thread == NULL) { in free_threads()
95 if (spdk_thread_is_exited(thread)) { in free_threads()
96 g_ut_threads[i].thread = NULL; in free_threads()
98 spdk_thread_destroy(thread); in free_threads()
100 spdk_thread_poll(thread, 0, 0); in free_threads()
116 struct ut_thread *thread = &g_ut_threads[thread_id]; in poll_thread_times() local
134 if (spdk_thread_poll(thread->thread, 1, now) > 0) { in poll_thread_times()
137 now = spdk_thread_get_last_tsc(thread->thread); in poll_thread_times()
150 struct ut_thread *thread = &g_ut_threads[thread_id]; in poll_thread() local
161 while (spdk_thread_poll(thread->thread, 0, now) > 0) { in poll_thread()
162 now = spdk_thread_get_last_tsc(thread->thread); in poll_thread()