Searched refs:ready_consumers (Results 1 – 3 of 3) sorted by relevance
173 task.ready_consumers.clear(); in ClientHeartbeat()177 task.ready_consumers.insert(job_client_id); in ClientHeartbeat()178 if (task.ready_consumers.size() == job->num_consumers.value()) { in ClientHeartbeat()
119 absl::flat_hash_set<int64> ready_consumers; member
748 !task.ready_consumers.contains(request->job_client_id())) { in ClientHeartbeat()