Searched refs:target_round (Results 1 – 3 of 3) sorted by relevance
111 explicit PendingTask(std::shared_ptr<Task> task, int64 target_round) in PendingTask()112 : task(std::move(task)), target_round(target_round) {} in PendingTask()116 int64 target_round; member
174 task.target_round = client_heartbeat.task_rejected().new_target_round(); in ClientHeartbeat()179 task.task->starting_round = task.target_round; in ClientHeartbeat()
734 << ". target_round: " << task.target_round; in ClientHeartbeat()735 if (request->current_round() >= task.target_round) { in ClientHeartbeat()747 blocked_round.value() <= task.target_round && in ClientHeartbeat()757 response->set_block_round(job->pending_tasks.front().target_round); in ClientHeartbeat()