HomeSort by relevance Sort by last modified time
    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