Searched refs:ScheduledTask (Results 1 – 7 of 7) sorted by relevance
53 private final PriorityBlockingQueue<ScheduledTask> tasks =54 new PriorityBlockingQueue<ScheduledTask>();72 public class ScheduledTask extends AbstractFuture<Void> implements ScheduledFuture<Void> { class in FakeClock76 ScheduledTask(long dueTimeNanos, Runnable command) { in ScheduledTask() method in FakeClock.ScheduledTask91 ScheduledTask otherTask = (ScheduledTask) other; in compareTo()118 ScheduledTask task = new ScheduledTask(currentTimeNanos + unit.toNanos(delay), cmd); in schedule()219 ScheduledTask task = tasks.peek(); in runDueTasks()235 public Collection<ScheduledTask> getDueTasks() { in getDueTasks()236 ArrayList<ScheduledTask> result = new ArrayList<>(); in getDueTasks()237 for (ScheduledTask task : tasks) { in getDueTasks()[all …]
54 import io.grpc.internal.FakeClock.ScheduledTask;169 Collection<ScheduledTask> pendingTimerTasks = timer.getPendingTasks(); in allPendingTasksAreRun()170 for (ScheduledTask a : pendingTimerTasks) { in allPendingTasksAreRun()
719 FakeClock.ScheduledTask reconnectTask = null; in shutdownBeforeTransportCreated()720 for (FakeClock.ScheduledTask task : fakeClock.getPendingTasks()) { in shutdownBeforeTransportCreated()930 FakeClock.ScheduledTask reconnectTask = null; in resetConnectBackoff()931 for (FakeClock.ScheduledTask task : fakeClock.getPendingTasks()) { in resetConnectBackoff()
735 FakeClock.ScheduledTask nameResolverBackoff = getNameResolverRefresh(); in nameResolutionFailed_delayedTransportShutdownCancelsBackoff()2052 FakeClock.ScheduledTask nameResolverBackoff = getNameResolverRefresh(); in resetConnectBackoff()2957 private FakeClock.ScheduledTask getNameResolverRefresh() { in getNameResolverRefresh()
65 struct ScheduledTask { struct72 std::map<MessageLoop::TaskId, ScheduledTask> tasks_; argument
28 tasks_.emplace(current_id, ScheduledTask{from_here, false, task}); in PostDelayedTask()45 tasks_.emplace(current_id, ScheduledTask{from_here, persistent, task}); in WatchFileDescriptor()
636 FakeClock.ScheduledTask scheduledTask = fakeClock.getPendingTasks().iterator().next(); in abundantInitialResponse()674 FakeClock.ScheduledTask scheduledTask = fakeClock.getPendingTasks().iterator().next(); in raceBetweenLoadReportingAndLbStreamClosure()