Home
last modified time | relevance | path

Searched refs:forwardTime (Results 1 – 13 of 13) sorted by relevance

/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DRetriableStreamTest.java258 fakeClock.forwardTime((long) (INITIAL_BACKOFF_IN_SECONDS * FAKE_RANDOM) - 1L, TimeUnit.SECONDS); in retry_everythingDrained()
261 fakeClock.forwardTime(1L, TimeUnit.SECONDS); in retry_everythingDrained()
303 fakeClock.forwardTime( in retry_everythingDrained()
308 fakeClock.forwardTime(1L, TimeUnit.SECONDS); in retry_everythingDrained()
379 fakeClock.forwardTime((long) (INITIAL_BACKOFF_IN_SECONDS * FAKE_RANDOM), TimeUnit.SECONDS); in retry_headersRead_cancel()
437 fakeClock.forwardTime((long) (INITIAL_BACKOFF_IN_SECONDS * FAKE_RANDOM), TimeUnit.SECONDS); in retry_headersRead_closed()
502 fakeClock.forwardTime((long) (INITIAL_BACKOFF_IN_SECONDS * FAKE_RANDOM), TimeUnit.SECONDS); in retry_cancel_closed()
566 fakeClock.forwardTime((long) (INITIAL_BACKOFF_IN_SECONDS * FAKE_RANDOM), TimeUnit.SECONDS); in retry_unretriableClosed_cancel()
683 fakeClock.forwardTime((long) (INITIAL_BACKOFF_IN_SECONDS * FAKE_RANDOM), TimeUnit.SECONDS); in operationsWhileDraining()
798 fakeClock.forwardTime((long) (INITIAL_BACKOFF_IN_SECONDS * FAKE_RANDOM), TimeUnit.SECONDS); in isReady_whileDraining()
[all …]
DManagedChannelImplIdlenessTest.java202 timer.forwardTime(IDLE_TIMEOUT_SECONDS - 1, TimeUnit.SECONDS); in newCallRefreshesIdlenessTimer()
213 timer.forwardTime(IDLE_TIMEOUT_SECONDS - 1, TimeUnit.SECONDS); in newCallRefreshesIdlenessTimer()
218 timer.forwardTime(1, TimeUnit.SECONDS); in newCallRefreshesIdlenessTimer()
235 timer.forwardTime(IDLE_TIMEOUT_SECONDS * 2, TimeUnit.SECONDS); in delayedTransportHoldsOffIdleness()
244 timer.forwardTime(IDLE_TIMEOUT_SECONDS - 1, TimeUnit.SECONDS); in delayedTransportHoldsOffIdleness()
246 timer.forwardTime(1, TimeUnit.SECONDS); in delayedTransportHoldsOffIdleness()
285 timer.forwardTime(IDLE_TIMEOUT_SECONDS * 2, TimeUnit.SECONDS); in realTransportsHoldsOffIdleness()
291 timer.forwardTime(IDLE_TIMEOUT_SECONDS - 1, TimeUnit.SECONDS); in realTransportsHoldsOffIdleness()
293 timer.forwardTime(1, TimeUnit.SECONDS); in realTransportsHoldsOffIdleness()
383 timer.forwardTime(IDLE_TIMEOUT_SECONDS, TimeUnit.SECONDS); in oobTransportDoesNotAffectIdleness()
DCensusModulesTest.java375 fakeClock.forwardTime(30, MILLISECONDS); in subtestClientBasicStatsDefaultContext()
378 fakeClock.forwardTime(100, MILLISECONDS); in subtestClientBasicStatsDefaultContext()
383 fakeClock.forwardTime(16, MILLISECONDS); in subtestClientBasicStatsDefaultContext()
391 fakeClock.forwardTime(24, MILLISECONDS); in subtestClientBasicStatsDefaultContext()
488 fakeClock.forwardTime(3000, MILLISECONDS); in clientStreamNeverCreatedStillRecordStats()
839 fakeClock.forwardTime(100, MILLISECONDS); in subtestServerBasicStatsNoHeaders()
844 fakeClock.forwardTime(16, MILLISECONDS); in subtestServerBasicStatsNoHeaders()
852 fakeClock.forwardTime(24, MILLISECONDS); in subtestServerBasicStatsNoHeaders()
DFakeClock.java271 public int forwardTime(long value, TimeUnit unit) { in forwardTime() method in FakeClock
282 return forwardTime(nanos, TimeUnit.NANOSECONDS); in forwardNanos()
DClientCallImplTest.java657 fakeClock.forwardTime(System.nanoTime(), TimeUnit.NANOSECONDS); in deadlineExceededBeforeCallStarted()
785 fakeClock.forwardTime(System.nanoTime(), TimeUnit.NANOSECONDS); in expiredDeadlineCancelsStream_CallOptions()
807 fakeClock.forwardTime(System.nanoTime(), TimeUnit.NANOSECONDS); in expiredDeadlineCancelsStream_Context()
834 fakeClock.forwardTime(System.nanoTime(), TimeUnit.NANOSECONDS); in streamCancelAbortsDeadlineTimer()
DFakeClockTest.java111 fakeClock.forwardTime(10L, TimeUnit.MINUTES); in testStopWatch()
DManagedChannelImplTest.java365 timer.forwardTime(ManagedChannelImpl.SUBCHANNEL_SHUTDOWN_DELAY_SECONDS, TimeUnit.SECONDS); in channelzMembership_subchannel()
1084 timer.forwardTime(ManagedChannelImpl.SUBCHANNEL_SHUTDOWN_DELAY_SECONDS - 1, TimeUnit.SECONDS); in subchannels()
1087 timer.forwardTime(1, TimeUnit.SECONDS); in subchannels()
1104 timer.forwardTime(ManagedChannelImpl.SUBCHANNEL_SHUTDOWN_DELAY_SECONDS, TimeUnit.SECONDS); in subchannels()
2668 timer.forwardTime(5, TimeUnit.SECONDS); in retryBackoffThenChannelShutdown_retryShouldStillHappen_newCallShouldFail()
2687 timer.forwardTime(5, TimeUnit.SECONDS); in retryBackoffThenChannelShutdown_retryShouldStillHappen_newCallShouldFail()
2791 timer.forwardTime(1234, TimeUnit.SECONDS); in badServiceConfigIsRecoverable()
DServerImplTest.java399 timer.forwardTime(59, TimeUnit.SECONDS); in transportHandshakeTimeout_expired()
402 timer.forwardTime(2, TimeUnit.SECONDS); in transportHandshakeTimeout_expired()
/external/grpc-grpc-java/grpclb/src/test/java/io/grpc/grpclb/
DCachedSubchannelPoolTest.java122 clock.forwardTime(SHUTDOWN_TIMEOUT_MS - 1, MILLISECONDS); in subchannelExpireAfterReturned()
128 clock.forwardTime(1, MILLISECONDS); in subchannelExpireAfterReturned()
132 clock.forwardTime(SHUTDOWN_TIMEOUT_MS - 1, MILLISECONDS); in subchannelExpireAfterReturned()
153 clock.forwardTime(SHUTDOWN_TIMEOUT_MS - 1, MILLISECONDS); in subchannelReused()
162 clock.forwardTime(SHUTDOWN_TIMEOUT_MS - 1, MILLISECONDS); in subchannelReused()
164 clock.forwardTime(1, MILLISECONDS); in subchannelReused()
174 clock.forwardTime(SHUTDOWN_TIMEOUT_MS - 1, MILLISECONDS); in subchannelReused()
176 clock.forwardTime(1, MILLISECONDS); in subchannelReused()
DGrpclbLoadBalancerTest.java694 assertEquals(0, fakeClock.forwardTime(loadReportIntervalMillis - 1, TimeUnit.MILLISECONDS)); in assertNextReport()
696 assertEquals(1, fakeClock.forwardTime(1, TimeUnit.MILLISECONDS)); in assertNextReport()
1077 fakeClock.forwardTime(GrpclbState.FALLBACK_TIMEOUT_MS - 1, TimeUnit.MILLISECONDS); in subtestGrpclbFallbackInitialTimeout()
1107 fakeClock.forwardTime(1, TimeUnit.MILLISECONDS); in subtestGrpclbFallbackInitialTimeout()
/external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/
DNettyServerHandlerTest.java583 fakeClock().forwardTime(10L, TimeUnit.MILLISECONDS); in keepAliveManager_pingSent()
690 fakeClock().forwardTime(20, TimeUnit.MINUTES); in noGoAwaySentBeforeMaxConnectionIdleReached()
754 fakeClock().forwardTime(10, TimeUnit.SECONDS); in maxConnectionIdle_goAwaySent_pingTimeout()
794 fakeClock().forwardTime(10, TimeUnit.SECONDS); in maxConnectionIdle_activeThenRst_pingAck()
849 fakeClock().forwardTime(20, TimeUnit.MINUTES); in noGoAwaySentBeforeMaxConnectionAgeReached()
915 fakeClock().forwardTime(10, TimeUnit.SECONDS); in maxConnectionAge_goAwaySent_pingTimeout()
945 fakeClock().forwardTime(20, TimeUnit.MINUTES); in maxConnectionAgeGrace_channelStillOpenDuringGracePeriod()
987 fakeClock().forwardTime(2, TimeUnit.MILLISECONDS); in maxConnectionAgeGrace_channelClosedAfterGracePeriod_withPingTimeout()
1015 fakeClock().forwardTime(pingRoundTripMillis, TimeUnit.MILLISECONDS); in maxConnectionAgeGrace_channelClosedAfterGracePeriod_withPingAck()
1027 fakeClock().forwardTime(2, TimeUnit.MILLISECONDS); in maxConnectionAgeGrace_channelClosedAfterGracePeriod_withPingAck()
/external/grpc-grpc-java/testing/src/test/java/io/grpc/testing/
DGrpcCleanupRuleTest.java434 fakeClock.forwardTime(cleanupNanos, TimeUnit.NANOSECONDS); in cleanUp()
443 fakeClock.forwardTime(awaitReleaseNanos, TimeUnit.NANOSECONDS); in awaitReleased()
/external/grpc-grpc-java/core/src/test/java/io/grpc/
DContextsTest.java219 fakeClock.forwardTime(System.nanoTime(), TimeUnit.NANOSECONDS); in statusFromCancelled_TimeoutExceptionShouldMapToDeadlineExceeded()