Home
last modified time | relevance | path

Searched refs:tasks_by_worker_ (Results 1 – 2 of 2) sorted by relevance

/external/tensorflow/tensorflow/core/data/service/
Ddispatcher_state.cc85 tasks_by_worker_[address] = in RegisterWorker()
161 tasks_by_worker_[create_pending_task.worker_address()][task->task_id] = task; in CreatePendingTask()
195 tasks_by_worker_[create_task.worker_address()][task->task_id] = task; in CreateTask()
205 tasks_by_worker_[task->worker_address].erase(task->task_id); in FinishTask()
335 auto it = tasks_by_worker_.find(worker_address); in TasksForWorker()
336 if (it == tasks_by_worker_.end()) { in TasksForWorker()
Ddispatcher_state.h254 tasks_by_worker_; variable