Home
last modified time | relevance | path

Searched refs:executeLater (Results 1 – 5 of 5) sorted by relevance

/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DChannelExecutorTest.java73 executor.executeLater(task1); in singleThread()
74 executor.executeLater(task2); in singleThread()
81 executor.executeLater(task3); in singleThread()
123 executor.executeLater(task1); in multiThread()
132 executor.executeLater(task2); in multiThread()
159 executor.executeLater(task1); in taskThrows()
160 executor.executeLater(task2); in taskThrows()
161 executor.executeLater(task3); in taskThrows()
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DDelayedClientTransport.java183 channelExecutor.executeLater(reportTransportInUse); in createPendingStream()
212 channelExecutor.executeLater(new Runnable() { in shutdown()
219 channelExecutor.executeLater(reportTransportTerminated); in shutdown()
247 channelExecutor.executeLater(savedReportTransportTerminated).drain(); in shutdownNow()
330 channelExecutor.executeLater(reportTransportNotInUse); in reprocess()
332 channelExecutor.executeLater(reportTransportTerminated); in reprocess()
373 channelExecutor.executeLater(reportTransportNotInUse); in cancel()
375 channelExecutor.executeLater(reportTransportTerminated); in cancel()
DManagedChannelImpl.java272 channelExecutor.executeLater(new StatsFetcher()).drain(); in getStats()
438 channelExecutor.executeLater(new ExitIdleModeForTransport()).drain(); in get()
571 channelExecutor.executeLater(command); in ManagedChannelImpl()
677 channelExecutor.executeLater(new Shutdown()); in shutdown()
687 channelExecutor.executeLater(new CancelIdleTimer()).drain(); in shutdown()
713 channelExecutor.executeLater(new ShutdownNow()).drain(); in shutdownNow()
857 channelExecutor.executeLater(new RequestConnection()).drain(); in getState()
871 channelExecutor.executeLater(new NotifyStateChanged()).drain(); in notifyWhenStateChanged()
896 channelExecutor.executeLater(new ResetConnectBackoff()).drain(); in resetConnectBackoff()
912 channelExecutor.executeLater(new PrepareToLoseNetworkRunnable()).drain(); in enterIdle()
[all …]
DInternalSubchannel.java251 channelExecutor.executeLater(runnable); in startNewTransport()
339 channelExecutor.executeLater(new Runnable() { in gotoState()
437 channelExecutor.executeLater(new Runnable() { in handleTermination()
447 channelExecutor.executeLater(new Runnable() { in handleTransportInUseState()
DChannelExecutor.java85 final ChannelExecutor executeLater(Runnable runnable) { in executeLater() method in ChannelExecutor