Home
last modified time | relevance | path

Searched refs:getPendingTasks (Results 1 – 7 of 7) sorted by relevance

/external/grpc-grpc-java/grpclb/src/test/java/io/grpc/grpclb/
DCachedSubchannelPoolTest.java190 assertThat(clock.getPendingTasks(SHUTDOWN_SCHEDULED_TASK_FILTER)).isEmpty(); in returnDuplicateAddressSubchannel()
192 assertThat(clock.getPendingTasks(SHUTDOWN_SCHEDULED_TASK_FILTER)).hasSize(1); in returnDuplicateAddressSubchannel()
198 assertThat(clock.getPendingTasks(SHUTDOWN_SCHEDULED_TASK_FILTER)).hasSize(1); in returnDuplicateAddressSubchannel()
202 assertThat(clock.getPendingTasks(SHUTDOWN_SCHEDULED_TASK_FILTER)).hasSize(2); in returnDuplicateAddressSubchannel()
205 assertThat(clock.getPendingTasks(SHUTDOWN_SCHEDULED_TASK_FILTER)).hasSize(2); in returnDuplicateAddressSubchannel()
DGrpclbLoadBalancerTest.java289 assertThat(fakeClock.getPendingTasks()).isEmpty(); in tearDown()
635 FakeClock.ScheduledTask scheduledTask = fakeClock.getPendingTasks().iterator().next(); in abundantInitialResponse()
641 assertThat(fakeClock.getPendingTasks(LOAD_REPORTING_TASK_FILTER)) in abundantInitialResponse()
673 FakeClock.ScheduledTask scheduledTask = fakeClock.getPendingTasks().iterator().next(); in raceBetweenLoadReportingAndLbStreamClosure()
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DFakeClockTest.java189 assertEquals(2, fakeClock.getPendingTasks().size()); in testTaskFilter()
190 assertEquals(1, fakeClock.getPendingTasks(filter).size()); in testTaskFilter()
191 assertSame(selectedRunnable, fakeClock.getPendingTasks(filter).iterator().next().command); in testTaskFilter()
DFakeClock.java249 public Collection<ScheduledTask> getPendingTasks() { in getPendingTasks() method in FakeClock
250 return getPendingTasks(ACCEPT_ALL_FILTER); in getPendingTasks()
256 public Collection<ScheduledTask> getPendingTasks(TaskFilter filter) { in getPendingTasks() method in FakeClock
DManagedChannelImplIdlenessTest.java169 Collection<ScheduledTask> pendingTimerTasks = timer.getPendingTasks(); in allPendingTasksAreRun()
173 assertEquals(executor.getPendingTasks() + " should be empty", 0, executor.numPendingTasks()); in allPendingTasksAreRun()
DManagedChannelImplTest.java276 assertEquals(executor.getPendingTasks() + " should be empty", 0, executor.numPendingTasks()); in allPendingTasksAreRun()
2663 assertThat(timer.getPendingTasks()).isEmpty(); in retryBackoffThenChannelShutdown_retryShouldStillHappen_newCallShouldFail()
2670 assertThat(timer.getPendingTasks()).hasSize(1); in retryBackoffThenChannelShutdown_retryShouldStillHappen_newCallShouldFail()
2676 assertThat(timer.getPendingTasks()).hasSize(1); in retryBackoffThenChannelShutdown_retryShouldStillHappen_newCallShouldFail()
2689 assertThat(timer.getPendingTasks()).isEmpty(); in retryBackoffThenChannelShutdown_retryShouldStillHappen_newCallShouldFail()
2967 return Iterables.getOnlyElement(timer.getPendingTasks(NAME_RESOLVER_REFRESH_TASK_FILTER), null); in getNameResolverRefresh()
DInternalSubchannelTest.java720 for (FakeClock.ScheduledTask task : fakeClock.getPendingTasks()) { in shutdownBeforeTransportCreated()
931 for (FakeClock.ScheduledTask task : fakeClock.getPendingTasks()) { in resetConnectBackoff()