Home
last modified time | relevance | path

Searched refs:obtainActiveTransport (Results 1 – 8 of 8) sorted by relevance

/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DInternalSubchannelTest.java160 assertNull(internalSubchannel.obtainActiveTransport()); in eagAttribute_propagatesToTransport()
180 assertNull(internalSubchannel.obtainActiveTransport()); in singleAddressReconnect()
198 assertNull(internalSubchannel.obtainActiveTransport()); in singleAddressReconnect()
223 assertNull(internalSubchannel.obtainActiveTransport()); in singleAddressReconnect()
231 assertNull(internalSubchannel.obtainActiveTransport()); in singleAddressReconnect()
241 ((CallTracingTransport) internalSubchannel.obtainActiveTransport()).delegate()); in singleAddressReconnect()
250 assertNull(internalSubchannel.obtainActiveTransport()); in singleAddressReconnect()
277 assertNull(internalSubchannel.obtainActiveTransport()); in twoAddressesReconnect()
286 assertNull(internalSubchannel.obtainActiveTransport()); in twoAddressesReconnect()
294 assertNull(internalSubchannel.obtainActiveTransport()); in twoAddressesReconnect()
[all …]
DDelayedClientTransportTest.java110 when(mockSubchannel.obtainActiveTransport()).thenReturn(mockRealTransport); in setUp()
299 when(subchannel1.obtainActiveTransport()).thenReturn(mockRealTransport); in reprocessSemantics()
300 when(subchannel2.obtainActiveTransport()).thenReturn(mockRealTransport2); in reprocessSemantics()
301 when(subchannel3.obtainActiveTransport()).thenReturn(null); in reprocessSemantics()
456 when(subchannel.obtainActiveTransport()).thenReturn(mockRealTransport); in reprocess_NoPendingStream()
468 verify(subchannel).obtainActiveTransport(); in reprocess_NoPendingStream()
DManagedChannelImplTest.java2298 subchannel.obtainActiveTransport(); in channelTracing_subchannelStateChangeEvent()
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DOobChannel.java152 ClientTransport obtainActiveTransport() { in setSubchannel()
153 return subchannel.obtainActiveTransport(); in setSubchannel()
163 subchannel.obtainActiveTransport(); in setSubchannel()
DAbstractSubchannel.java35 abstract ClientTransport obtainActiveTransport(); in obtainActiveTransport() method in AbstractSubchannel
DManagedChannelImpl.java1386 ClientTransport obtainActiveTransport() { in obtainActiveTransport() method in ManagedChannelImpl.SubchannelImpl
1387 return subchannel.obtainActiveTransport(); in obtainActiveTransport()
1440 subchannel.obtainActiveTransport(); in requestConnection()
DGrpcUtil.java669 transport = ((AbstractSubchannel) subchannel).obtainActiveTransport(); in getTransportFromPickResult()
DInternalSubchannel.java195 ClientTransport obtainActiveTransport() { in obtainActiveTransport() method in InternalSubchannel