Lines Matching defs:cur_thread

2033 	struct spdk_thread *cur_thread;
2062 	ct->cur_thread = TAILQ_NEXT(ct->cur_thread, tailq);
2063 	while (ct->cur_thread && ct->cur_thread->state != SPDK_THREAD_STATE_RUNNING) {
2065 			      ct->cur_thread->name);
2066 		ct->cur_thread = TAILQ_NEXT(ct->cur_thread, tailq);
2070 	if (!ct->cur_thread) {
2076 			      ct->cur_thread->name);
2078 		rc = spdk_thread_send_msg(ct->cur_thread, _on_thread, ctx);
2113 	ct->cur_thread = TAILQ_FIRST(&g_threads);
2119 	rc = spdk_thread_send_msg(ct->cur_thread, _on_thread, ct);
2557 	struct spdk_thread *cur_thread;
2607 	ch = thread_get_io_channel(i->cur_thread, i->dev);
2663 			i->cur_thread = thread;
2697 	assert(i->cur_thread == spdk_get_thread());
2707 	thread = TAILQ_NEXT(i->cur_thread, tailq);
2711 			i->cur_thread = thread;