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.java304 assertEquals(1, executor.runDueTasks()); in immediateDeadlineExceeded()
365 timer.runDueTasks(); in channelzMembership_subchannel()
492 timer.runDueTasks(); in subtestCallsAndShutdown()
493 executor.runDueTasks(); in subtestCallsAndShutdown()
503 executor.runDueTasks(); in subtestCallsAndShutdown()
515 executor.runDueTasks(); in subtestCallsAndShutdown()
654 assertEquals(1, callExecutor.runDueTasks()); in callOptionsExecutor()
664 assertEquals(1, callExecutor.runDueTasks()); in callOptionsExecutor()
753 executor.runDueTasks(); in nameResolutionFailed_delayedTransportShutdownCancelsBackoff()
846 executor.runDueTasks(); in firstResolvedServerFailedToConnect()
[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()
DFakeClock.java216 public int runDueTasks() { in runDueTasks() method in FakeClock
273 return runDueTasks(); in forwardTime()
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()
DDnsNameResolverTest.java192 assertEquals(1, fakeExecutor.runDueTasks()); in resolve()
198 assertEquals(1, fakeExecutor.runDueTasks()); in resolve()
356 assertEquals(1, fakeExecutor.runDueTasks()); in doNotResolveWhenProxyDetected()
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.java456 clock.runDueTasks(); in failingToConstructChannelShouldFailGracefully()
/external/grpc-grpc-java/grpclb/src/test/java/io/grpc/grpclb/
DGrpclbLoadBalancerTest.java423 assertEquals(0, fakeClock.runDueTasks()); in loadReporting()