Searched refs:WorkerState (Results 1 – 6 of 6) sorted by relevance
348 assert { state === WorkerState.TERMINATED } // Expected TERMINATED state in <lambda>()364 currentWorker?.tryReleaseCpu(WorkerState.TERMINATED) in <lambda>()500 if (state === WorkerState.TERMINATED) return task in <lambda>()502 if (task.mode == TASK_NON_BLOCKING && state === WorkerState.BLOCKING) { in <lambda>()532 WorkerState.PARKING -> ++parkedWorkers in <lambda>()533 WorkerState.BLOCKING -> { in <lambda>()537 WorkerState.CPU_ACQUIRED -> { in <lambda>()541 WorkerState.DORMANT -> { in <lambda>()545 WorkerState.TERMINATED -> ++terminated in <lambda>()608 var state = WorkerState.DORMANT in <lambda>()[all …]
56 WorkerState state; in GetOrCreateWorker()95 struct WorkerState { struct in tensorflow::__anonbb7751530111::WorkerFreeListCache102 std::unordered_map<string, WorkerState> workers_ TF_GUARDED_BY(mu_);
163 assertEquals(CoroutineScheduler.WorkerState.CPU_ACQUIRED, thread.state) in <lambda>()169 assertEquals(CoroutineScheduler.WorkerState.BLOCKING, thread.state) in <lambda>()
313 WorkerState* current_worker = &workers_[current_worker_index]; in GetNextInternal()588 struct WorkerState { struct in tensorflow::data::experimental::ParallelInterleaveDatasetOp::Dataset::Iterator1135 std::vector<WorkerState> workers_ TF_GUARDED_BY(mu_);
META-INF/ META-INF/MANIFEST.MF DebugProbesKt.bin META-INF/LICENSE ...
META-INF/ META-INF/MANIFEST.MF kotlinx/ kotlinx/coroutines/ kotlinx/ ...