Searched refs:FakeClock (Results 1 – 25 of 27) sorted by relevance
12
39 FakeClock fakeClock = new FakeClock(); in testScheduledExecutorService_sameInstance()47 FakeClock fakeClock = new FakeClock(); in testScheduledExecutorService_isDone()60 FakeClock fakeClock = new FakeClock(); in testScheduledExecutorService_cancel()73 FakeClock fakeClock = new FakeClock(); in testScheduledExecutorService_getDelay()83 FakeClock fakeClock = new FakeClock(); in testScheduledExecutorService_result()101 FakeClock fakeClock = new FakeClock(); in testStopWatch()129 FakeClock fakeClock = new FakeClock(); in testPendingAndDueTasks()163 FakeClock fakeClock = new FakeClock(); in testTaskFilter()179 FakeClock.TaskFilter filter = new FakeClock.TaskFilter() { in testTaskFilter()
54 import io.grpc.internal.FakeClock.ScheduledTask;80 private final FakeClock timer = new FakeClock();81 private final FakeClock executor = new FakeClock();82 private final FakeClock oobExecutor = new FakeClock();
36 private final FakeClock scheduler = new FakeClock();
84 private final FakeClock fakeClock = new FakeClock();86 private final FakeClock fakeExecutor = new FakeClock();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()
44 private final FakeClock executor = new FakeClock();
101 private final FakeClock fakeExecutor = new FakeClock();323 FakeClock wfr3Executor = new FakeClock(); in reprocessSemantics()
159 private final FakeClock timer = new FakeClock();160 private final FakeClock executor = new FakeClock();161 private final FakeClock oobExecutor = new FakeClock();162 private static final FakeClock.TaskFilter NAME_RESOLVER_REFRESH_TASK_FILTER =163 new FakeClock.TaskFilter() {627 FakeClock callExecutor = new FakeClock(); in callOptionsExecutor()735 FakeClock.ScheduledTask nameResolverBackoff = getNameResolverRefresh(); in nameResolutionFailed_delayedTransportShutdownCancelsBackoff()2052 FakeClock.ScheduledTask nameResolverBackoff = getNameResolverRefresh(); in resetConnectBackoff()2475 FakeClock callExecutor = new FakeClock(); in channelsAndSubchannels_oob_instrumented0()2957 private FakeClock.ScheduledTask getNameResolverRefresh() { in getNameResolverRefresh()
128 private static final FakeClock.TaskFilter CONTEXT_CLOSER_TASK_FITLER =129 new FakeClock.TaskFilter() {146 private final FakeClock executor = new FakeClock();147 private final FakeClock timer = new FakeClock();
92 private final FakeClock fakeClock = new FakeClock();93 private final FakeClock fakeExecutor = new FakeClock();
42 public final class FakeClock { class
88 private final FakeClock fakeClock = new FakeClock();
21 import io.grpc.internal.FakeClock;35 private final FakeClock fakeClock = new FakeClock();
25 import io.grpc.internal.FakeClock;38 private final FakeClock fakeClock = new FakeClock();
33 import io.grpc.internal.FakeClock;105 private final FakeClock fakeClock = new FakeClock();107 FakeClock fakeClock() { in fakeClock()
54 import io.grpc.internal.FakeClock;436 FakeClock clock = new FakeClock(); in failingToConstructChannelShouldFailGracefully()
22 import io.grpc.internal.FakeClock;37 private final FakeClock fakeClock = new FakeClock();
28 import io.grpc.internal.FakeClock;153 new FakeClock().getScheduledExecutorService(); in scheduledExecutorService_custom()
18 private FakeClock fakeClock;23 fakeClock = new FakeClock(); in setUp()119 private static class FakeClock implements Clock { class in PerfStatsCollectorTest
39 import io.grpc.internal.FakeClock;60 private static final FakeClock.TaskFilter SHUTDOWN_SCHEDULED_TASK_FILTER =61 new FakeClock.TaskFilter() {71 private final FakeClock clock = new FakeClock();
72 import io.grpc.internal.FakeClock;116 private static final FakeClock.TaskFilter LOAD_REPORTING_TASK_FILTER =117 new FakeClock.TaskFilter() {123 private static final FakeClock.TaskFilter FALLBACK_MODE_TASK_FILTER =124 new FakeClock.TaskFilter() {130 private static final FakeClock.TaskFilter LB_RPC_RETRY_TASK_FILTER =131 new FakeClock.TaskFilter() {148 private final FakeClock fakeClock = new FakeClock();636 FakeClock.ScheduledTask scheduledTask = fakeClock.getPendingTasks().iterator().next(); in abundantInitialResponse()674 FakeClock.ScheduledTask scheduledTask = fakeClock.getPendingTasks().iterator().next(); in raceBetweenLoadReportingAndLbStreamClosure()
23 import io.grpc.internal.FakeClock;52 new FakeClock().getScheduledExecutorService(); in scheduledExecutorService_custom()
21 import io.grpc.internal.FakeClock;48 final ScheduledExecutorService ses = new FakeClock().getScheduledExecutorService(); in serverHoldsRefToScheduler()
26 import io.grpc.internal.FakeClock;76 new FakeClock().getScheduledExecutorService(); in scheduledExecutorService_custom()
31 import io.grpc.internal.FakeClock;216 FakeClock fakeClock = new FakeClock(); in statusFromCancelled_TimeoutExceptionShouldMapToDeadlineExceeded()
35 import io.grpc.internal.FakeClock;52 public static final FakeClock fakeClock = new FakeClock();