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 ChannelExecutor() { field in ManagedChannelImpl
302 channelExecutor.executeLater(new Runnable() { in getStats()
476 channelExecutor.executeLater(new Runnable() {
563 this.delayedTransport = new DelayedClientTransport(this.executor, this.channelExecutor); in ManagedChannelImpl()
592 channelExecutor.executeLater(command); in ManagedChannelImpl()
593 channelExecutor.drain(); in ManagedChannelImpl()
690 channelExecutor.executeLater(new Runnable() { in shutdown()
705 channelExecutor.executeLater(new Runnable() { in shutdown()
725 channelExecutor.executeLater(new Runnable() { in shutdownNow()
859 channelExecutor.executeLater( 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.java165 private final SerializingExecutor channelExecutor = field in GrpclbLoadBalancerTest
237 channelExecutor.execute(task); in setUp()
268 channelExecutor.execute(new Runnable() { in tearDown()
1492 channelExecutor.execute(new Runnable() { in deliverSubchannelState()
1501 channelExecutor.execute(new Runnable() { in deliverNameResolutionError()
1511 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()