Home
last modified time | relevance | path

Searched refs:channelExecutor (Results 1 – 7 of 7) sorted by relevance

/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DDelayedClientTransport.java56 private final ChannelExecutor channelExecutor; field in DelayedClientTransport
94 DelayedClientTransport(Executor defaultAppExecutor, ChannelExecutor channelExecutor) { in DelayedClientTransport() argument
96 this.channelExecutor = channelExecutor; in DelayedClientTransport()
170 channelExecutor.drain(); in newStream()
183 channelExecutor.executeLater(reportTransportInUse); in createPendingStream()
212 channelExecutor.executeLater(new Runnable() { in shutdown()
219 channelExecutor.executeLater(reportTransportTerminated); in shutdown()
223 channelExecutor.drain(); in shutdown()
247 channelExecutor.executeLater(savedReportTransportTerminated).drain(); in shutdownNow()
330 channelExecutor.executeLater(reportTransportNotInUse); in reprocess()
[all …]
DInternalSubchannel.java93 private final ChannelExecutor channelExecutor; field in InternalSubchannel
167 Supplier<Stopwatch> stopwatchSupplier, ChannelExecutor channelExecutor, Callback callback, in InternalSubchannel() argument
181 this.channelExecutor = channelExecutor; in InternalSubchannel()
213 channelExecutor.drain(); in obtainActiveTransport()
251 channelExecutor.executeLater(runnable); in startNewTransport()
279 channelExecutor.drain(); in scheduleBackoff()
316 channelExecutor.drain(); in resetConnectBackoff()
339 channelExecutor.executeLater(new Runnable() { in gotoState()
378 channelExecutor.drain(); in updateAddresses()
411 channelExecutor.drain(); in shutdown()
[all …]
DManagedChannelImpl.java128 private final ChannelExecutor channelExecutor = new PanicChannelExecutor(); field in ManagedChannelImpl
272 channelExecutor.executeLater(new StatsFetcher()).drain(); in getStats()
438 channelExecutor.executeLater(new ExitIdleModeForTransport()).drain(); in get()
542 this.delayedTransport = new DelayedClientTransport(this.executor, this.channelExecutor); in ManagedChannelImpl()
571 channelExecutor.executeLater(command); in ManagedChannelImpl()
572 channelExecutor.drain(); 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()
[all …]
DOobChannel.java105 ScheduledExecutorService deadlineCancellationExecutor, ChannelExecutor channelExecutor, in OobChannel() argument
113 this.delayedTransport = new DelayedClientTransport(executor, channelExecutor); in OobChannel()
/external/grpc-grpc-java/grpclb/src/test/java/io/grpc/grpclb/
DCachedSubchannelPoolTest.java68 private final SerializingExecutor channelExecutor = field in CachedSubchannelPoolTest
93 channelExecutor.execute(task); in setUp()
DGrpclbLoadBalancerTest.java164 private final SerializingExecutor channelExecutor = field in GrpclbLoadBalancerTest
236 channelExecutor.execute(task); in setUp()
267 channelExecutor.execute(new Runnable() { in tearDown()
1523 channelExecutor.execute(new Runnable() { in deliverSubchannelState()
1532 channelExecutor.execute(new Runnable() { in deliverNameResolutionError()
1542 channelExecutor.execute(new Runnable() { in deliverResolvedAddresses()
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DInternalSubchannelTest.java87 private final ChannelExecutor channelExecutor = new ChannelExecutor(); field in InternalSubchannelTest
1114 fakeClock.getStopwatchSupplier(), channelExecutor, mockInternalSubchannelCallback, in createInternalSubchannel()
1130 assertEquals(0, channelExecutor.numPendingTasks()); in assertExactCallbackInvokes()