Home
last modified time | relevance | path

Searched refs:fakeExecutor (Results 1 – 3 of 3) sorted by relevance

/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DDelayedClientTransportTest.java101 private final FakeClock fakeExecutor = new FakeClock(); field in DelayedClientTransportTest
104 fakeExecutor.getScheduledExecutorService(), new ChannelExecutor());
119 assertEquals(0, fakeExecutor.numPendingTasks()); in noMorePendingTasks()
129 assertEquals(0, fakeExecutor.numPendingTasks()); in streamStartThenAssignTransport()
133 assertEquals(1, fakeExecutor.runDueTasks()); in streamStartThenAssignTransport()
151 assertEquals(1, fakeExecutor.runDueTasks()); in newStreamThenAssignTransportThenShutdown()
221 fakeExecutor.runDueTasks(); in newStreamThenShutdownTransportThenAssignTransport()
376 fakeExecutor.runDueTasks(); in reprocessSemantics()
377 assertEquals(0, fakeExecutor.numPendingTasks()); in reprocessSemantics()
414 fakeExecutor.runDueTasks(); in reprocessSemantics()
[all …]
DDnsNameResolverTest.java90 private final FakeClock fakeExecutor = new FakeClock(); field in DnsNameResolverTest
96 return fakeExecutor.getScheduledExecutorService();
135 assertEquals(0, fakeExecutor.numPendingTasks()); in noMorePendingTasks()
192 assertEquals(1, fakeExecutor.runDueTasks()); in resolve()
198 assertEquals(1, fakeExecutor.runDueTasks()); in resolve()
356 assertEquals(1, fakeExecutor.runDueTasks()); in doNotResolveWhenProxyDetected()
DInternalSubchannelTest.java86 private final FakeClock fakeExecutor = new FakeClock(); field in InternalSubchannelTest
141 assertEquals(0, fakeExecutor.numPendingTasks()); in noMorePendingTasks()
672 assertEquals(0, fakeExecutor.numPendingTasks()); in connectIsLazy()
913 fakeExecutor.runDueTasks(); in transportStartReturnsRunnable()
1125 while (fakeExecutor.runDueTasks() > 0) {} in assertNoCallbackInvoke()