Searched refs:task_progress (Results 1 – 3 of 3) sorted by relevance
259 std::vector<TaskProgress> task_progress; in SendTaskUpdates() local264 task_progress.reserve(pending_completed_tasks_.size()); in SendTaskUpdates()266 task_progress.emplace_back(); in SendTaskUpdates()267 task_progress.back().set_task_id(task_id); in SendTaskUpdates()268 task_progress.back().set_completed(true); in SendTaskUpdates()272 TF_RETURN_IF_ERROR(dispatcher_->WorkerUpdate(worker_address_, task_progress)); in SendTaskUpdates()274 for (const auto& update : task_progress) { in SendTaskUpdates()277 VLOG(3) << "Sent " << task_progress.size() << " task updates "; in SendTaskUpdates()
98 std::vector<TaskProgress>& task_progress);
88 std::vector<TaskProgress>& task_progress) { in WorkerUpdate() argument92 for (const auto& update : task_progress) { in WorkerUpdate()