Searched refs:ThreadState (Results 1 – 8 of 8) sorted by relevance
121 class ThreadState { class123 ThreadState() : awaiting_threads_(false), threads_done_(false), count_(0) { in ThreadState() function in grpc_core::internal::ThreadState154 ~ThreadState() { in ~ThreadState()176 thread_state_ = new internal::ThreadState(); in GlobalInit()238 internal::ThreadState* Fork::thread_state_ = nullptr;
35 class ThreadState; variable95 static internal::ThreadState* thread_state_;
166 enum ThreadState { FAKE, ALIVE, STARTED, DONE, FAILED, MOVED }; enum167 ThreadState state_;
152 thd_state_ = static_cast<ThreadState*>( in SetThreading()153 gpr_zalloc(sizeof(ThreadState) * max_threads_)); in SetThreading()216 ThreadState* ts = static_cast<ThreadState*>(arg); in ThreadMain()286 ThreadState* ts = in Enqueue()287 reinterpret_cast<ThreadState*>(gpr_tls_get(&g_this_thread_state)); in Enqueue()295 ThreadState* orig_ts = ts; in Enqueue()
30 struct ThreadState { struct111 ThreadState* thd_state_;
133 return threads.Any(t => t.ThreadState != ThreadState.Stopped);
1421 } ThreadState; typedef1457 ThreadState *state = task_data; in return_on_cancel_thread()1490 ThreadState thread_state; /* (atomic) */ in test_return_on_cancel()1624 ThreadState thread_state; /* (atomic) */ in test_return_on_cancel_sync()
4536 + ThreadState::Current()->CollectAllGarbageForTesting();