Searched refs:create_pending_task (Results 1 – 3 of 3) sorted by relevance
49 CreatePendingTask(update.create_pending_task()); in Apply()151 const CreatePendingTaskUpdate& create_pending_task) { in CreatePendingTask() argument152 int64 task_id = create_pending_task.task_id(); in CreatePendingTask()155 auto& job = jobs_[create_pending_task.job_id()]; in CreatePendingTask()158 std::make_shared<Task>(task_id, job, create_pending_task.worker_address(), in CreatePendingTask()159 create_pending_task.transfer_address()); in CreatePendingTask()160 job->pending_tasks.emplace(task, create_pending_task.starting_round()); in CreatePendingTask()161 tasks_by_worker_[create_pending_task.worker_address()][task->task_id] = task; in CreatePendingTask()
18 CreatePendingTaskUpdate create_pending_task = 9; field
219 void CreatePendingTask(const CreatePendingTaskUpdate& create_pending_task);