OpenGrok
Home
Sort by relevance
Sort by last modified time
Full Search
Definition
Symbol
File Path
History
|
|
Help
Searched
refs:delayedTransport
(Results
1 - 4
of
4
) sorted by null
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DelayedClientTransportTest.java
103
private final DelayedClientTransport
delayedTransport
= new DelayedClientTransport(
115
delayedTransport
.start(transportListener);
123
assertFalse(
delayedTransport
.hasPendingStreams());
124
ClientStream stream =
delayedTransport
.newStream(method, headers, callOptions);
126
assertEquals(1,
delayedTransport
.getPendingStreamsCount());
127
assertTrue(
delayedTransport
.hasPendingStreams());
130
delayedTransport
.reprocess(mockPicker);
131
assertEquals(0,
delayedTransport
.getPendingStreamsCount());
132
assertFalse(
delayedTransport
.hasPendingStreams());
143
ClientStream stream =
delayedTransport
.newStream(method, headers, callOptions)
[
all
...]
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
OobChannel.java
75
private final DelayedClientTransport
delayedTransport
;
93
return
delayedTransport
;
113
this.
delayedTransport
= new DelayedClientTransport(executor, channelExecutor);
115
this.
delayedTransport
.start(new ManagedClientTransport.Listener() {
185
delayedTransport
.reprocess(subchannelPicker);
227
delayedTransport
.shutdown(Status.UNAVAILABLE.withDescription("OobChannel.shutdown() called"));
239
delayedTransport
.shutdownNow(
256
delayedTransport
.reprocess(subchannelPicker);
259
delayedTransport
.reprocess(new SubchannelPicker() {
276
// When
delayedTransport
is terminated, it shuts down subchannel. Therefore, at this poin
[
all
...]
ManagedChannelImpl.java
186
private final DelayedClientTransport
delayedTransport
;
196
// 1c
delayedTransport
.shutdown()
197
// 2.
delayedTransport
terminated: stop stream-creation functionality
252
inUseStateAggregator.updateObjectInUse(
delayedTransport
, inUse);
397
delayedTransport
.reprocess(null);
471
// If channel is shut down,
delayedTransport
is also shut down which will fail the stream
473
return
delayedTransport
;
482
return
delayedTransport
;
500
return
delayedTransport
;
563
this.
delayedTransport
= new DelayedClientTransport(this.executor, this.channelExecutor)
[
all
...]
/external/grpc-grpc-java/core/
grpc-core-1.14.0.jar
Completed in 1583 milliseconds