Home
last modified time | relevance | path

Searched refs:runDueTasks (Results 1 – 11 of 11) sorted by relevance

/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DConnectivityStateManagerTest.java72 assertEquals(1, executor.runDueTasks()); in registerCallbackBeforeStateChanged()
92 assertEquals(1, executor.runDueTasks()); in registerCallbackAfterStateChanged()
124 assertEquals(1, executor.runDueTasks()); in callbacksAreOneShot()
141 assertEquals(1, executor.runDueTasks()); in callbacksAreOneShot()
175 assertEquals(1, executor.runDueTasks()); in multipleCallbacks()
183 assertEquals(2, executor.runDueTasks()); in multipleCallbacks()
210 assertEquals(1, executor.runDueTasks());
216 assertEquals(1, executor.runDueTasks());
DServerImplTest.java421 assertEquals(1, executor.runDueTasks()); in methodNotFound()
506 assertEquals(1, executor.runDueTasks()); in basicExchangeHelper()
521 assertEquals(1, executor.runDueTasks()); in basicExchangeHelper()
537 assertEquals(1, executor.runDueTasks()); in basicExchangeHelper()
555 assertEquals(1, executor.runDueTasks()); in basicExchangeHelper()
706 assertEquals(1, executor.runDueTasks()); in interceptors()
758 assertEquals(1, executor.runDueTasks()); in exceptionInStartCallPropagatesToStream()
918 assertEquals(1, executor.runDueTasks()); in testCallContextIsBoundInListenerCallbacks()
923 assertEquals(1, executor.runDueTasks()); in testCallContextIsBoundInListenerCallbacks()
927 assertEquals(1, executor.runDueTasks()); in testCallContextIsBoundInListenerCallbacks()
[all …]
DManagedChannelImplTest.java305 assertEquals(1, executor.runDueTasks()); in immediateDeadlineExceeded()
366 timer.runDueTasks(); in channelzMembership_subchannel()
493 timer.runDueTasks(); in subtestCallsAndShutdown()
494 executor.runDueTasks(); in subtestCallsAndShutdown()
504 executor.runDueTasks(); in subtestCallsAndShutdown()
516 executor.runDueTasks(); in subtestCallsAndShutdown()
655 assertEquals(1, callExecutor.runDueTasks()); in callOptionsExecutor()
665 assertEquals(1, callExecutor.runDueTasks()); in callOptionsExecutor()
754 executor.runDueTasks(); in nameResolutionFailed_delayedTransportShutdownCancelsBackoff()
847 executor.runDueTasks(); in firstResolvedServerFailedToConnect()
[all …]
DDnsNameResolverTest.java213 assertEquals(1, fakeExecutor.runDueTasks()); in resolve_neverCache()
219 assertEquals(1, fakeExecutor.runDueTasks()); in resolve_neverCache()
245 assertEquals(1, fakeExecutor.runDueTasks()); in resolve_cacheForever()
252 assertEquals(1, fakeExecutor.runDueTasks()); in resolve_cacheForever()
279 assertEquals(1, fakeExecutor.runDueTasks()); in resolve_usingCache()
287 assertEquals(1, fakeExecutor.runDueTasks()); in resolve_usingCache()
313 assertEquals(1, fakeExecutor.runDueTasks()); in resolve_cacheExpired()
320 assertEquals(1, fakeExecutor.runDueTasks()); in resolve_cacheExpired()
355 assertEquals(1, fakeExecutor.runDueTasks()); in resolveDefaultValue()
362 assertEquals(1, fakeExecutor.runDueTasks()); in resolveDefaultValue()
[all …]
DDelayedClientTransportTest.java133 assertEquals(1, fakeExecutor.runDueTasks()); in streamStartThenAssignTransport()
151 assertEquals(1, fakeExecutor.runDueTasks()); in newStreamThenAssignTransportThenShutdown()
221 fakeExecutor.runDueTasks(); in newStreamThenShutdownTransportThenAssignTransport()
376 fakeExecutor.runDueTasks(); in reprocessSemantics()
414 fakeExecutor.runDueTasks(); in reprocessSemantics()
423 wfr3Executor.runDueTasks(); in reprocessSemantics()
446 fakeExecutor.runDueTasks(); in reprocessSemantics()
DFakeClockTest.java145 fakeClock.runDueTasks(); in testPendingAndDueTasks()
192 assertEquals(2, fakeClock.runDueTasks()); in testTaskFilter()
DManagedChannelImplIdlenessTest.java224 assertEquals(2, executor.runDueTasks()); in newCallRefreshesIdlenessTimer()
241 assertEquals(1, executor.runDueTasks()); in delayedTransportHoldsOffIdleness()
275 executor.runDueTasks(); in realTransportsHoldsOffIdleness()
354 executor.runDueTasks(); in oobTransportDoesNotAffectIdleness()
DFakeClock.java216 public int runDueTasks() { in runDueTasks() method in FakeClock
273 return runDueTasks(); in forwardTime()
DInternalSubchannelTest.java913 fakeExecutor.runDueTasks(); in transportStartReturnsRunnable()
1125 while (fakeExecutor.runDueTasks() > 0) {} in assertNoCallbackInvoke()
/external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/
DNettyClientTransportTest.java450 clock.runDueTasks(); in failingToConstructChannelShouldFailGracefully()
/external/grpc-grpc-java/grpclb/src/test/java/io/grpc/grpclb/
DGrpclbLoadBalancerTest.java424 assertEquals(0, fakeClock.runDueTasks()); in loadReporting()