Home
last modified time | relevance | path

Searched refs:requestConnection (Results 1 – 23 of 23) sorted by relevance

/external/grpc-grpc-java/core/src/test/java/io/grpc/
DPickFirstLoadBalancerTest.java107 verify(mockSubchannel).requestConnection(); in pickAfterResolved()
118 verify(mockSubchannel).requestConnection(); in pickAfterResolvedAndUnchanged()
144 verify(mockSubchannel).requestConnection(); in pickAfterResolvedAndChanged()
195 verify(mockSubchannel, never()).requestConnection(); in nameResolutionError()
206 verify(mockSubchannel, never()).requestConnection(); in nameResolutionSuccessAfterError()
211 verify(mockSubchannel).requestConnection(); in nameResolutionSuccessAfterError()
249 public void requestConnection() { in requestConnection() method in PickFirstLoadBalancerTest
255 verify(mockSubchannel).requestConnection(); in requestConnection()
256 picker.requestConnection(); in requestConnection()
257 verify(mockSubchannel, times(2)).requestConnection(); in requestConnection()
DLoadBalancerTest.java226 @Override public void requestConnection() {} in requestConnection() method in LoadBalancerTest.EmptySubchannel
/external/grpc-grpc-java/core/src/main/java/io/grpc/
DPickFirstBalancerFactory.java74 subchannel.requestConnection(); in handleResolvedAddressGroups()
156 subchannel.requestConnection(); in pickSubchannel()
161 public void requestConnection() { in requestConnection() method in PickFirstBalancerFactory.RequestConnectionPicker
162 subchannel.requestConnection(); in requestConnection()
DManagedChannel.java84 public ConnectivityState getState(boolean requestConnection) { in getState() argument
DLoadBalancer.java187 public void requestConnection() {} in requestConnection() method in LoadBalancer.SubchannelPicker
622 public abstract void requestConnection(); in requestConnection() method in LoadBalancer.Subchannel
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DForwardingManagedChannel.java72 public ConnectivityState getState(boolean requestConnection) { in getState() argument
73 return delegate.getState(requestConnection); in getState()
DManagedChannelImpl.java844 public ConnectivityState getState(boolean requestConnection) { in getState() argument
846 if (requestConnection && savedChannelState == IDLE) { in getState()
852 subchannelPicker.requestConnection(); in getState()
1439 public void requestConnection() { in requestConnection() method in ManagedChannelImpl.SubchannelImpl
DOobChannel.java162 public void requestConnection() { in setSubchannel()
/external/grpc-grpc-java/core/src/test/java/io/grpc/util/
DRoundRobinLoadBalancerTest.java154 verify(subchannel).requestConnection(); in pickAfterResolved()
210 verify(removedSubchannel, times(1)).requestConnection(); in pickAfterResolvedUpdatedHosts()
211 verify(oldSubchannel, times(1)).requestConnection(); in pickAfterResolvedUpdatedHosts()
227 verify(newSubchannel, times(1)).requestConnection(); in pickAfterResolvedUpdatedHosts()
284 verify(subchannel, times(2)).requestConnection(); in pickAfterStateChange()
366 verify(sc1, times(1)).requestConnection(); in subchannelStateIsolation()
367 verify(sc2, times(1)).requestConnection(); in subchannelStateIsolation()
368 verify(sc3, times(1)).requestConnection(); in subchannelStateIsolation()
393 verify(sc2, times(2)).requestConnection(); in subchannelStateIsolation()
397 verify(sc3, times(1)).requestConnection(); in subchannelStateIsolation()
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DManagedChannelImplTest.java207 private boolean requestConnection = true; field in ManagedChannelImplTest
227 if (requestConnection) { in createChannel()
352 subchannel.requestConnection(); in channelzMembership_subchannel()
389 oob.getSubchannel().requestConnection(); in channelzMembership_oob()
438 subchannel.requestConnection(); in subtestCallsAndShutdown()
572 subchannel1.requestConnection(); in noMoreCallbackAfterLoadBalancerShutdown()
573 subchannel2.requestConnection(); in noMoreCallbackAfterLoadBalancerShutdown()
639 subchannel.requestConnection(); in callOptionsExecutor()
855 subchannel.requestConnection(); in firstResolvedServerFailedToConnect()
1000 subchannel.requestConnection(); in allServersFailedToConnect()
[all …]
DManagedChannelImplIdlenessTest.java266 subchannel.requestConnection(); in realTransportsHoldsOffIdleness()
306 subchannel.requestConnection(); in updateSubchannelAddresses_newAddressConnects()
312 subchannel.requestConnection(); in updateSubchannelAddresses_newAddressConnects()
326 subchannel.requestConnection(); in updateSubchannelAddresses_existingAddressDoesNotConnect()
334 subchannel.requestConnection(); in updateSubchannelAddresses_existingAddressDoesNotConnect()
DAutoConfiguredLoadBalancerFactoryTest.java442 public void requestConnection() { in requestConnection() method in AutoConfiguredLoadBalancerFactoryTest.TestSubchannel
/external/apache-http/src/org/apache/http/conn/
DClientConnectionManager.java75 ClientConnectionRequest requestConnection(HttpRoute route, Object state) in requestConnection() method
/external/grpc-grpc-java/android/src/main/java/io/grpc/android/
DAndroidChannelBuilder.java297 public ConnectivityState getState(boolean requestConnection) { in getState() argument
298 return delegate.getState(requestConnection); in getState()
/external/apache-http/src/org/apache/http/impl/conn/tsccm/
DThreadSafeClientConnManager.java156 public ClientConnectionRequest requestConnection( in requestConnection() method in ThreadSafeClientConnManager
/external/grpc-grpc-java/core/src/main/java/io/grpc/util/
DRoundRobinLoadBalancerFactory.java177 subchannel.requestConnection(); in handleResolvedAddressGroups()
205 subchannel.requestConnection(); in handleSubchannelState()
/external/grpc-grpc-java/grpclb/src/test/java/io/grpc/grpclb/
DGrpclbLoadBalancerTest.java877 verify(subchannel1).requestConnection(); in grpclbWorking()
878 verify(subchannel2).requestConnection(); in grpclbWorking()
913 verify(subchannel1).requestConnection(); in grpclbWorking()
915 verify(subchannel1, times(2)).requestConnection(); in grpclbWorking()
931 verify(subchannel2).requestConnection(); in grpclbWorking()
933 verify(subchannel2, times(2)).requestConnection(); in grpclbWorking()
963 verify(subchannel3).requestConnection(); in grpclbWorking()
/external/apache-http/src/org/apache/http/impl/conn/
DSingleClientConnManager.java183 public final ClientConnectionRequest requestConnection( in requestConnection() method in SingleClientConnManager
/external/grpc-grpc-java/grpclb/src/main/java/io/grpc/grpclb/
DGrpclbState.java170 subchannel.requestConnection(); in handleSubchannelState()
362 subchannel.requestConnection(); in useRoundRobinLists()
/external/apache-http/src/org/apache/http/impl/client/
DDefaultRequestDirector.java325 ClientConnectionRequest connRequest = connManager.requestConnection( in execute()
/external/robolectric-shadows/shadows/httpclient/src/main/java/org/robolectric/shadows/httpclient/
DDefaultRequestDirector.java386 ClientConnectionRequest connRequest = connManager.requestConnection( in execute()
/external/apache-http/
Dart-profile441 HPLorg/apache/http/impl/conn/tsccm/ThreadSafeClientConnManager;->requestConnection(Lorg/apache/http…
866 HSPLorg/apache/http/conn/ClientConnectionManager;->requestConnection(Lorg/apache/http/conn/routing/…
/external/apache-http/api/
Dcurrent.txt1648 …method @Deprecated public org.apache.http.conn.ClientConnectionRequest requestConnection(org.apach…
2810 …method @Deprecated public final org.apache.http.conn.ClientConnectionRequest requestConnection(org…
2968 …method @Deprecated public org.apache.http.conn.ClientConnectionRequest requestConnection(org.apach…