HomeSort by relevance Sort by last modified time
    Searched refs:channelExecutor (Results 1 - 8 of 8) sorted by null

  /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DelayedClientTransport.java 56 private final ChannelExecutor channelExecutor;
91 * @param channelExecutor all listener callbacks of the delayed transport will be run from this
92 * ChannelExecutor.
94 DelayedClientTransport(Executor defaultAppExecutor, ChannelExecutor channelExecutor) {
96 this.channelExecutor = channelExecutor;
170 channelExecutor.drain();
175 * Caller must call {@code channelExecutor.drain()} outside of lock because this method ma
    [all...]
InternalSubchannel.java 93 private final ChannelExecutor channelExecutor;
130 // Must only be used from channelExecutor
167 Supplier<Stopwatch> stopwatchSupplier, ChannelExecutor channelExecutor, Callback callback,
181 this.channelExecutor = channelExecutor;
213 channelExecutor.drain();
251 channelExecutor.executeLater(runnable);
279 channelExecutor.drain()
    [all...]
ManagedChannelImpl.java 128 private final ChannelExecutor channelExecutor = new ChannelExecutor() {
159 // Only null after channel is terminated. Must be assigned from the channelExecutor.
162 // Must be accessed from the channelExecutor.
165 // null when channel is in idle mode. Must be assigned from channelExecutor.
169 // Must ONLY be assigned from updateSubchannelPicker(), which is called from channelExecutor.
174 // Must be accessed from the channelExecutor
177 // Must be mutated from channelExecutor
182 // Must be mutated from channelExecutor
    [all...]
OobChannel.java 105 ScheduledExecutorService deadlineCancellationExecutor, ChannelExecutor channelExecutor,
113 this.delayedTransport = new DelayedClientTransport(executor, channelExecutor);
  /external/grpc-grpc-java/grpclb/src/test/java/io/grpc/grpclb/
CachedSubchannelPoolTest.java 68 private final SerializingExecutor channelExecutor =
93 channelExecutor.execute(task);
GrpclbLoadBalancerTest.java 165 private final SerializingExecutor channelExecutor =
237 channelExecutor.execute(task);
268 channelExecutor.execute(new Runnable() {
    [all...]
  /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
InternalSubchannelTest.java 85 // For channelExecutor
87 private final ChannelExecutor channelExecutor = new ChannelExecutor();
    [all...]
  /external/grpc-grpc-java/core/
grpc-core-1.14.0.jar 

Completed in 394 milliseconds