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()
DLoadBalancer.java181 public void requestConnection() {} in requestConnection() method in LoadBalancer.SubchannelPicker
616 public abstract void requestConnection(); in requestConnection() method in LoadBalancer.Subchannel
DManagedChannel.java84 public ConnectivityState getState(boolean requestConnection) { in getState() argument
/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.java856 public ConnectivityState getState(boolean requestConnection) { in getState() argument
858 if (requestConnection && savedChannelState == IDLE) { in getState()
865 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.java208 private boolean requestConnection = true; field in ManagedChannelImplTest
228 if (requestConnection) { in createChannel()
353 subchannel.requestConnection(); in channelzMembership_subchannel()
390 oob.getSubchannel().requestConnection(); in channelzMembership_oob()
439 subchannel.requestConnection(); in subtestCallsAndShutdown()
573 subchannel1.requestConnection(); in noMoreCallbackAfterLoadBalancerShutdown()
574 subchannel2.requestConnection(); in noMoreCallbackAfterLoadBalancerShutdown()
640 subchannel.requestConnection(); in callOptionsExecutor()
856 subchannel.requestConnection(); in firstResolvedServerFailedToConnect()
1001 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.java364 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.java878 verify(subchannel1).requestConnection(); in grpclbWorking()
879 verify(subchannel2).requestConnection(); in grpclbWorking()
914 verify(subchannel1).requestConnection(); in grpclbWorking()
916 verify(subchannel1, times(2)).requestConnection(); in grpclbWorking()
932 verify(subchannel2).requestConnection(); in grpclbWorking()
934 verify(subchannel2, times(2)).requestConnection(); in grpclbWorking()
964 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()
365 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.txt1642 …method @Deprecated public org.apache.http.conn.ClientConnectionRequest requestConnection(org.apach…
2804 …method @Deprecated public final org.apache.http.conn.ClientConnectionRequest requestConnection(org…
2962 …method @Deprecated public org.apache.http.conn.ClientConnectionRequest requestConnection(org.apach…