OpenGrok
Home
Sort by relevance
Sort by last modified time
Full Search
Definition
Symbol
File Path
History
|
|
Help
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