Home
last modified time | relevance | path

Searched refs:forwardNanos (Results 1 – 12 of 12) sorted by relevance

/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DFakeClockTest.java51 fakeClock.forwardNanos(99L); in testScheduledExecutorService_isDone()
54 fakeClock.forwardNanos(2L); in testScheduledExecutorService_isDone()
64 fakeClock.forwardNanos(99L); in testScheduledExecutorService_cancel()
67 fakeClock.forwardNanos(2); in testScheduledExecutorService_cancel()
77 fakeClock.forwardNanos(90L); in testScheduledExecutorService_getDelay()
95 fakeClock.forwardNanos(100L); in testScheduledExecutorService_result()
107 fakeClock.forwardNanos(100L); in testStopWatch()
117 fakeClock.forwardNanos(1000L); in testStopWatch()
150 fakeClock.forwardNanos(90L); in testPendingAndDueTasks()
155 fakeClock.forwardNanos(20L); in testPendingAndDueTasks()
DReschedulerTest.java49 scheduler.forwardNanos(1); in runs()
61 scheduler.forwardNanos(1); in cancels()
74 scheduler.forwardNanos(1); in cancelPermanently()
90 scheduler.forwardNanos(1); in reschedules()
94 scheduler.forwardNanos(50); in reschedules()
109 scheduler.forwardNanos(1); in reschedulesShortDelay()
DInternalSubchannelTest.java197 fakeClock.forwardNanos(9); in singleAddressReconnect()
204 fakeClock.forwardNanos(1); in singleAddressReconnect()
222 fakeClock.forwardNanos(99); in singleAddressReconnect()
228 fakeClock.forwardNanos(1); in singleAddressReconnect()
311 fakeClock.forwardNanos(9); in twoAddressesReconnect()
316 fakeClock.forwardNanos(1); in twoAddressesReconnect()
343 fakeClock.forwardNanos(99); in twoAddressesReconnect()
348 fakeClock.forwardNanos(1); in twoAddressesReconnect()
395 fakeClock.forwardNanos(9); in twoAddressesReconnect()
400 fakeClock.forwardNanos(1); in twoAddressesReconnect()
[all …]
DManagedChannelImplTest.java674 timer.forwardNanos( in callOptionsExecutor()
693 timer.forwardNanos(RECONNECT_BACKOFF_INTERVAL_NANOS - 1); in nameResolutionFailed()
696 timer.forwardNanos(1); in nameResolutionFailed()
709 timer.forwardNanos(RECONNECT_BACKOFF_INTERVAL_NANOS * 2 - 1); in nameResolutionFailed()
711 timer.forwardNanos(1); in nameResolutionFailed()
717 timer.forwardNanos(RECONNECT_BACKOFF_INTERVAL_NANOS - 1); in nameResolutionFailed()
719 timer.forwardNanos(1); in nameResolutionFailed()
1364 timer.forwardNanos(RECONNECT_BACKOFF_INTERVAL_NANOS); in subtestRefreshNameResolutionWhenConnectionFailed()
1679 timer.forwardNanos(TimeUnit.MILLISECONDS.toNanos(idleTimeoutMillis)); in stateIsIdleOnIdleTimeout()
1718 timer.forwardNanos(TimeUnit.MILLISECONDS.toNanos(idleTimeoutMillis)); in subtestPanic()
[all …]
DFakeClock.java281 public int forwardNanos(long nanos) { in forwardNanos() method in FakeClock
DClientCallImplTest.java799 fakeClock.forwardNanos(TimeUnit.SECONDS.toNanos(1) + 1); in expiredDeadlineCancelsStream_CallOptions()
826 fakeClock.forwardNanos(TimeUnit.SECONDS.toNanos(1) + 1); in expiredDeadlineCancelsStream_Context()
848 fakeClock.forwardNanos(TimeUnit.SECONDS.toNanos(1) + 1); in streamCancelAbortsDeadlineTimer()
/external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/
DMaxConnectionIdleManagerTest.java61 fakeClock.forwardNanos(123L); in maxIdleReached()
73 fakeClock.forwardNanos(100L); in maxIdleNotReachedAndReached()
77 fakeClock.forwardNanos(100L); in maxIdleNotReachedAndReached()
80 fakeClock.forwardNanos(100L); in maxIdleNotReachedAndReached()
86 fakeClock.forwardNanos(123L); in maxIdleNotReachedAndReached()
99 fakeClock.forwardNanos(123L); in shutdownThenMaxIdleReached()
DNettyServerHandlerTest.java577 fakeClock().forwardNanos(keepAliveTimeInNanos); in keepAliveManager_pingSent()
596 fakeClock().forwardNanos(keepAliveTimeInNanos); in keepAliveManager_pingTimeout()
600 fakeClock().forwardNanos(keepAliveTimeoutInNanos); in keepAliveManager_pingTimeout()
705 fakeClock().forwardNanos(maxConnectionIdleInNanos); in maxConnectionIdle_goAwaySent_pingAck()
740 fakeClock().forwardNanos(maxConnectionIdleInNanos); in maxConnectionIdle_goAwaySent_pingTimeout()
770 fakeClock().forwardNanos(maxConnectionIdleInNanos); in maxConnectionIdle_activeThenRst_pingAck()
780 fakeClock().forwardNanos(maxConnectionIdleInNanos); in maxConnectionIdle_activeThenRst_pingAck()
810 fakeClock().forwardNanos(maxConnectionIdleInNanos); in maxConnectionIdle_activeThenRst_pingTimeoutk()
820 fakeClock().forwardNanos(maxConnectionIdleInNanos); in maxConnectionIdle_activeThenRst_pingTimeoutk()
865 fakeClock().forwardNanos(maxConnectionAgeInNanos); in maxConnectionAge_goAwaySent_pingAck()
[all …]
DNettyTransportTest.java84 fakeClock.forwardNanos(unit.toNanos(offset)); in advanceClock()
/external/grpc-grpc-java/okhttp/src/test/java/io/grpc/okhttp/
DOkHttpTransportTest.java89 fakeClock.forwardNanos(unit.toNanos(offset)); in advanceClock()
/external/grpc-grpc-java/grpclb/src/test/java/io/grpc/grpclb/
DGrpclbLoadBalancerTest.java1421 fakeClock.forwardNanos(9); in grpclbBalancerStreamRetry()
1424 fakeClock.forwardNanos(1); in grpclbBalancerStreamRetry()
1440 fakeClock.forwardNanos(100 - 1); in grpclbBalancerStreamRetry()
1443 fakeClock.forwardNanos(1); in grpclbBalancerStreamRetry()
1466 fakeClock.forwardNanos(4); in grpclbBalancerStreamRetry()
1474 fakeClock.forwardNanos(10 - 4 - 1); in grpclbBalancerStreamRetry()
1477 fakeClock.forwardNanos(1); in grpclbBalancerStreamRetry()
/external/grpc-grpc-java/core/src/test/java/io/grpc/
DContextsTest.java220 fakeClock.forwardNanos(100); in statusFromCancelled_TimeoutExceptionShouldMapToDeadlineExceeded()