| /external/grpc-grpc-java/core/src/test/java/io/grpc/util/ |
| D | RoundRobinLoadBalancerTest.java | 147 loadBalancer.handleSubchannelState(readySubchannel, ConnectivityStateInfo.forNonError(READY)); in pickAfterResolved()
230 loadBalancer.handleSubchannelState(removedSubchannel, in pickAfterResolvedUpdatedHosts()
264 loadBalancer.handleSubchannelState(subchannel, in pickAfterStateChange()
272 loadBalancer.handleSubchannelState(subchannel, in pickAfterStateChange()
279 loadBalancer.handleSubchannelState(subchannel, in pickAfterStateChange()
336 loadBalancer.handleSubchannelState(readySubchannel, ConnectivityStateInfo.forNonError(READY)); in nameResolutionErrorWithActiveChannels()
370 loadBalancer.handleSubchannelState(sc1, ConnectivityStateInfo.forNonError(READY)); in subchannelStateIsolation()
371 loadBalancer.handleSubchannelState(sc2, ConnectivityStateInfo.forNonError(READY)); in subchannelStateIsolation()
372 loadBalancer.handleSubchannelState(sc3, ConnectivityStateInfo.forNonError(READY)); in subchannelStateIsolation()
373 loadBalancer.handleSubchannelState(sc2, ConnectivityStateInfo.forNonError(IDLE)); in subchannelStateIsolation()
[all …]
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/ |
| D | PickFirstLoadBalancerTest.java | 156 loadBalancer.handleSubchannelState(mockSubchannel, ConnectivityStateInfo.forNonError(READY)); in stateChangeBeforeResolution()
171 loadBalancer.handleSubchannelState(subchannel, in pickAfterStateChangeAfterResolution()
176 loadBalancer.handleSubchannelState(subchannel, ConnectivityStateInfo.forNonError(IDLE)); in pickAfterStateChangeAfterResolution()
180 loadBalancer.handleSubchannelState(subchannel, ConnectivityStateInfo.forNonError(READY)); in pickAfterStateChangeAfterResolution()
226 loadBalancer.handleSubchannelState(mockSubchannel, in nameResolutionErrorWithStateChanges()
236 loadBalancer.handleSubchannelState(mockSubchannel, ConnectivityStateInfo.forNonError(READY)); in nameResolutionErrorWithStateChanges()
251 loadBalancer.handleSubchannelState(mockSubchannel, ConnectivityStateInfo.forNonError(IDLE)); in requestConnection()
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | AutoConfiguredLoadBalancerFactoryTest.java | 91 public void handleSubchannelState(Subchannel subchannel, ConnectivityStateInfo stateInfo) { in forwardsCalls()
106 lb.handleSubchannelState(null, null); in forwardsCalls()
175 public void handleSubchannelState(Subchannel subchannel, ConnectivityStateInfo stateInfo) { in handleResolvedAddressGroups_shutsDownOldBalancer()
362 public void handleSubchannelState(Subchannel subchannel, ConnectivityStateInfo stateInfo) { in handleSubchannelState() method in AutoConfiguredLoadBalancerFactoryTest.ForwardingLoadBalancer
363 delegate().handleSubchannelState(subchannel, stateInfo); in handleSubchannelState()
|
| D | ManagedChannelImplTest.java | 582 .handleSubchannelState(same(subchannel1), stateInfoCaptor.capture()); in noMoreCallbackAfterLoadBalancerShutdown()
587 .handleSubchannelState(same(subchannel2), stateInfoCaptor.capture()); in noMoreCallbackAfterLoadBalancerShutdown()
856 inOrder.verify(mockLoadBalancer).handleSubchannelState( in firstResolvedServerFailedToConnect()
880 inOrder.verify(mockLoadBalancer).handleSubchannelState( in firstResolvedServerFailedToConnect()
1002 inOrder.verify(mockLoadBalancer).handleSubchannelState( in allServersFailedToConnect()
1023 inOrder.verify(mockLoadBalancer).handleSubchannelState( in allServersFailedToConnect()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | AutoConfiguredLoadBalancerFactory.java | 75 public void handleSubchannelState(Subchannel subchannel, ConnectivityStateInfo stateInfo) {} in handleSubchannelState() method in AutoConfiguredLoadBalancerFactory.NoopLoadBalancer
146 public void handleSubchannelState(Subchannel subchannel, ConnectivityStateInfo stateInfo) { in handleSubchannelState() method in AutoConfiguredLoadBalancerFactory.AutoConfiguredLoadBalancer
147 getDelegate().handleSubchannelState(subchannel, stateInfo); in handleSubchannelState()
|
| D | ManagedChannelImpl.java | 1041 lb.handleSubchannelState(subchannel, newState); in createSubchannel()
|
| /external/grpc-grpc-java/grpclb/src/main/java/io/grpc/grpclb/ |
| D | GrpclbLoadBalancer.java | 80 public void handleSubchannelState(Subchannel subchannel, ConnectivityStateInfo newState) { in handleSubchannelState() method in GrpclbLoadBalancer
83 grpclbState.handleSubchannelState(subchannel, newState); in handleSubchannelState()
|
| D | GrpclbState.java | 165 void handleSubchannelState(Subchannel subchannel, ConnectivityStateInfo newState) { in handleSubchannelState() method in GrpclbState
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/ |
| D | PickFirstBalancerFactory.java | 92 public void handleSubchannelState(Subchannel subchannel, ConnectivityStateInfo stateInfo) { in handleSubchannelState() method in PickFirstBalancerFactory.PickFirstBalancer
|
| D | LoadBalancer.java | 146 public abstract void handleSubchannelState( in handleSubchannelState() method in LoadBalancer
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/util/ |
| D | RoundRobinLoadBalancerFactory.java | 197 public void handleSubchannelState(Subchannel subchannel, ConnectivityStateInfo stateInfo) { in handleSubchannelState() method in RoundRobinLoadBalancerFactory.RoundRobinLoadBalancer
|
| /external/grpc-grpc-java/grpclb/src/test/java/io/grpc/grpclb/ |
| D | GrpclbLoadBalancerTest.java | 1526 balancer.handleSubchannelState(subchannel, newState); in deliverSubchannelState()
|