Searched refs:WorkerState (Results 1 – 3 of 3) sorted by relevance
314 assert { state === WorkerState.TERMINATED } // Expected TERMINATED state in <lambda>()326 currentWorker?.tryReleaseCpu(WorkerState.TERMINATED) in <lambda>()490 if (worker.state === WorkerState.TERMINATED) return NOT_ADDED in <lambda>()557 WorkerState.PARKING -> ++parkedWorkers in <lambda>()558 WorkerState.BLOCKING -> { in <lambda>()562 WorkerState.CPU_ACQUIRED -> { in <lambda>()566 WorkerState.RETIRING -> { in <lambda>()570 WorkerState.TERMINATED -> ++terminated in <lambda>()629 var state = WorkerState.RETIRING in <lambda>()631 val isParking: Boolean get() = state == WorkerState.PARKING in <lambda>()[all …]
56 WorkerState state; in GetOrCreateWorker()95 struct WorkerState { struct in tensorflow::__anond7fc9e3e0111::WorkerFreeListCache102 std::unordered_map<string, WorkerState> workers_ GUARDED_BY(mu_);
266 WorkerState* current_worker = &workers_[current_worker_index]; in GetNextInternal()527 struct WorkerState { struct in tensorflow::data::experimental::ParallelInterleaveDatasetOp::Dataset::Iterator1060 std::vector<WorkerState> workers_ GUARDED_BY(mu_);