Lines Matching defs:ct

2044 	struct call_thread *ct = ctx;
2046 	assert(ct->orig_thread->for_each_count > 0);
2047 	ct->orig_thread->for_each_count--;
2049 	ct->cpl(ct->ctx);
2056 	struct call_thread *ct = ctx;
2059 	ct->fn(ct->ctx);
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) {
2073 		rc = spdk_thread_send_msg(ct->orig_thread, _back_to_orig_thread, ctx);
2076 			      ct->cur_thread->name);
2078 		rc = spdk_thread_send_msg(ct->cur_thread, _on_thread, ctx);
2086 	struct call_thread *ct;
2090 	ct = calloc(1, sizeof(*ct));
2091 	if (!ct) {
2097 	ct->fn = fn;
2098 	ct->ctx = ctx;
2099 	ct->cpl = cpl;
2104 		free(ct);
2108 	ct->orig_thread = thread;
2110 	ct->orig_thread->for_each_count++;
2113 	ct->cur_thread = TAILQ_FIRST(&g_threads);
2117 		      ct->orig_thread->name);
2119 	rc = spdk_thread_send_msg(ct->cur_thread, _on_thread, ct);