Home
last modified time | relevance | path

Searched refs:delayedTransport (Results 1 – 3 of 3) sorted by relevance

/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DDelayedClientTransportTest.java103 private final DelayedClientTransport delayedTransport = new DelayedClientTransport( field in DelayedClientTransportTest
115 delayedTransport.start(transportListener); in setUp()
123 assertFalse(delayedTransport.hasPendingStreams()); in streamStartThenAssignTransport()
124 ClientStream stream = delayedTransport.newStream(method, headers, callOptions); in streamStartThenAssignTransport()
126 assertEquals(1, delayedTransport.getPendingStreamsCount()); in streamStartThenAssignTransport()
127 assertTrue(delayedTransport.hasPendingStreams()); in streamStartThenAssignTransport()
130 delayedTransport.reprocess(mockPicker); in streamStartThenAssignTransport()
131 assertEquals(0, delayedTransport.getPendingStreamsCount()); in streamStartThenAssignTransport()
132 assertFalse(delayedTransport.hasPendingStreams()); in streamStartThenAssignTransport()
143 ClientStream stream = delayedTransport.newStream(method, headers, callOptions); in newStreamThenAssignTransportThenShutdown()
[all …]
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DOobChannel.java75 private final DelayedClientTransport delayedTransport; field in OobChannel
93 return delayedTransport;
113 this.delayedTransport = new DelayedClientTransport(executor, channelExecutor); in OobChannel()
115 this.delayedTransport.start(new ManagedClientTransport.Listener() { in OobChannel()
185 delayedTransport.reprocess(subchannelPicker); in setSubchannel()
227 delayedTransport.shutdown(Status.UNAVAILABLE.withDescription("OobChannel.shutdown() called")); in shutdown()
239 delayedTransport.shutdownNow( in shutdownNow()
256 delayedTransport.reprocess(subchannelPicker); in handleSubchannelStateChange()
259 delayedTransport.reprocess(new SubchannelPicker() { in handleSubchannelStateChange()
DManagedChannelImpl.java180 private final DelayedClientTransport delayedTransport; field in ManagedChannelImpl
352 delayedTransport.reprocess(null); in enterIdleMode()
428 return delayedTransport; in get()
439 return delayedTransport; in get()
457 return delayedTransport; in get()
542 this.delayedTransport = new DelayedClientTransport(this.executor, this.channelExecutor); in ManagedChannelImpl()
543 this.delayedTransport.start(delayedTransportListener); in ManagedChannelImpl()
753 delayedTransport.reprocess(newPicker); in updateSubchannelPicker()
946 delayedTransport.shutdown(reason); in onShutdown()
961 delayedTransport.shutdownNow(reason); in onShutdownNow()
[all …]