Searched refs:new_tasks (Results 1 – 6 of 6) sorted by relevance
318 std::vector<TaskDef> new_tasks; in Heartbeat() local322 current_tasks, new_tasks, tasks_to_delete)); in Heartbeat()324 for (const auto& task : new_tasks) { in Heartbeat()
62 const std::vector<int64>& current_tasks, std::vector<TaskDef>& new_tasks, in WorkerHeartbeat() argument77 for (const auto& task : resp.new_tasks()) { in WorkerHeartbeat()78 new_tasks.push_back(task); in WorkerHeartbeat()
93 std::vector<TaskDef>& new_tasks,
22 repeated TaskDef new_tasks = 1; field
498 std::vector<string> new_tasks; in SortDevicesAndTasks() local500 new_tasks.reserve(gp->group_size); in SortDevicesAndTasks()503 new_tasks.push_back(gp->task_names[pi]); in SortDevicesAndTasks()506 gp->task_names = std::move(new_tasks); in SortDevicesAndTasks()
720 Index new_tasks = divup(nm0, gm) * divup(nn0, gn);721 double new_parallelism = static_cast<double>(new_tasks) /722 (divup<int>(new_tasks, num_threads) * num_threads);