Home
last modified time | relevance | path

Searched refs:updateBalancingState (Results 1 – 13 of 13) sorted by relevance

/external/grpc-grpc-java/core/src/test/java/io/grpc/
DPickFirstLoadBalancerTest.java106 verify(mockHelper).updateBalancingState(eq(CONNECTING), pickerCaptor.capture()); in pickAfterResolved()
125 .updateBalancingState(isA(ConnectivityState.class), isA(SubchannelPicker.class)); in pickAfterResolvedAndUnchanged()
143 inOrder.verify(mockHelper).updateBalancingState(eq(CONNECTING), pickerCaptor.capture()); in pickAfterResolvedAndChanged()
164 verify(mockHelper).updateBalancingState(eq(CONNECTING), pickerCaptor.capture()); in pickAfterStateChangeAfterResolution()
173 inOrder.verify(mockHelper).updateBalancingState(eq(TRANSIENT_FAILURE), pickerCaptor.capture()); in pickAfterStateChangeAfterResolution()
177 inOrder.verify(mockHelper).updateBalancingState(eq(IDLE), pickerCaptor.capture()); in pickAfterStateChangeAfterResolution()
181 inOrder.verify(mockHelper).updateBalancingState(eq(READY), pickerCaptor.capture()); in pickAfterStateChangeAfterResolution()
191 verify(mockHelper).updateBalancingState(eq(TRANSIENT_FAILURE), pickerCaptor.capture()); in nameResolutionError()
205 .updateBalancingState(any(ConnectivityState.class), any(SubchannelPicker.class)); in nameResolutionSuccessAfterError()
210 inOrder.verify(mockHelper).updateBalancingState(eq(CONNECTING), pickerCaptor.capture()); in nameResolutionSuccessAfterError()
[all …]
DLoadBalancerTest.java209 public void updateBalancingState( in updateBalancingState() method in LoadBalancerTest.NoopHelper
/external/grpc-grpc-java/core/src/test/java/io/grpc/util/
DRoundRobinLoadBalancerTest.java159 .updateBalancingState(stateCaptor.capture(), pickerCaptor.capture()); in pickAfterResolved()
206 inOrder.verify(mockHelper).updateBalancingState(eq(READY), pickerCaptor.capture()); in pickAfterResolvedUpdatedHosts()
238 inOrder.verify(mockHelper).updateBalancingState(eq(READY), pickerCaptor.capture()); in pickAfterResolvedUpdatedHosts()
247 inOrder.verify(mockHelper).updateBalancingState(eq(TRANSIENT_FAILURE), pickerCaptor.capture()); in pickAfterResolvedUpdatedHosts()
261 inOrder.verify(mockHelper).updateBalancingState(eq(CONNECTING), isA(EmptyPicker.class)); in pickAfterStateChange()
266 inOrder.verify(mockHelper).updateBalancingState(eq(READY), pickerCaptor.capture()); in pickAfterStateChange()
276 inOrder.verify(mockHelper).updateBalancingState(eq(CONNECTING), pickerCaptor.capture()); in pickAfterStateChange()
325 verify(mockHelper).updateBalancingState(eq(TRANSIENT_FAILURE), pickerCaptor.capture()); in nameResolutionErrorWithNoChannels()
342 .updateBalancingState(stateCaptor.capture(), pickerCaptor.capture()); in nameResolutionErrorWithActiveChannels()
378 .updateBalancingState(stateCaptor.capture(), pickerCaptor.capture()); in subchannelStateIsolation()
[all …]
/external/grpc-grpc-java/core/src/main/java/io/grpc/util/
DRoundRobinLoadBalancerFactory.java186 updateBalancingState(); in handleResolvedAddressGroups()
192 updateBalancingState(TRANSIENT_FAILURE, in handleNameResolutionError()
208 updateBalancingState(); in handleSubchannelState()
233 private void updateBalancingState() { in updateBalancingState() method in RoundRobinLoadBalancerFactory.RoundRobinLoadBalancer
251 updateBalancingState(isConnecting ? CONNECTING : TRANSIENT_FAILURE, in updateBalancingState()
259 updateBalancingState(READY, new ReadyPicker(activeList, startIndex, stickinessState)); in updateBalancingState()
263 private void updateBalancingState(ConnectivityState state, RoundRobinPicker picker) { in updateBalancingState() method in RoundRobinLoadBalancerFactory.RoundRobinLoadBalancer
265 helper.updateBalancingState(state, picker); in updateBalancingState()
/external/grpc-grpc-java/core/src/main/java/io/grpc/
DPickFirstBalancerFactory.java73 helper.updateBalancingState(CONNECTING, new Picker(PickResult.withSubchannel(subchannel))); in handleResolvedAddressGroups()
88 helper.updateBalancingState(TRANSIENT_FAILURE, new Picker(PickResult.withError(error))); in handleNameResolutionError()
118 helper.updateBalancingState(currentState, picker); in handleSubchannelState()
DLoadBalancer.java561 public abstract void updateBalancingState( in updateBalancingState() method in LoadBalancer.Helper
/external/grpc-grpc-java/grpclb/src/test/java/io/grpc/grpclb/
DGrpclbLoadBalancerTest.java247 }).when(helper).updateBalancingState( in setUp()
443 .updateBalancingState(eq(READY), pickerCaptor.capture()); in loadReporting()
579 .updateBalancingState(any(ConnectivityState.class), any(SubchannelPicker.class)); in loadReporting()
598 helperInOrder.verify(helper).updateBalancingState(eq(READY), pickerCaptor.capture()); in loadReporting()
721 verify(helper).updateBalancingState(eq(TRANSIENT_FAILURE), pickerCaptor.capture()); in nameResolutionFailsThenRecoverToDelegate()
737 verify(helper).updateBalancingState(eq(TRANSIENT_FAILURE), pickerCaptor.capture()); in nameResolutionFailsThenRecoverToGrpclb()
771 inOrder.verify(helper).updateBalancingState(eq(TRANSIENT_FAILURE), pickerCaptor.capture()); in grpclbThenNameResolutionFails()
865 .updateBalancingState(any(ConnectivityState.class), any(SubchannelPicker.class)); in grpclbWorking()
889 inOrder.verify(helper).updateBalancingState(eq(CONNECTING), pickerCaptor.capture()); in grpclbWorking()
897 inOrder.verify(helper).updateBalancingState(eq(READY), pickerCaptor.capture()); in grpclbWorking()
[all …]
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DAutoConfiguredLoadBalancerFactoryTest.java122 public void updateBalancingState(ConnectivityState newState, SubchannelPicker newPicker) { in handleResolvedAddressGroups_keepOldBalancer()
156 public void updateBalancingState(ConnectivityState newState, SubchannelPicker newPicker) { in handleResolvedAddressGroups_shutsDownOldBalancer()
317 public void updateBalancingState( in updateBalancingState() method in AutoConfiguredLoadBalancerFactoryTest.ForwardingLoadBalancerHelper
319 delegate().updateBalancingState(newState, newPicker); in updateBalancingState()
DManagedChannelImplTest.java457 helper.updateBalancingState(READY, mockPicker); in subtestCallsAndShutdown()
515 helper.updateBalancingState(READY, picker2); in subtestCallsAndShutdown()
652 helper.updateBalancingState(READY, mockPicker); in callOptionsExecutor()
753 helper.updateBalancingState(READY, picker); in nameResolutionFailed_delayedTransportShutdownCancelsBackoff()
886 helper.updateBalancingState(READY, mockPicker); in firstResolvedServerFailedToConnect()
935 helper.updateBalancingState(READY, picker); in subtestFailRpcFromBalancer()
1033 helper.updateBalancingState(TRANSIENT_FAILURE, picker2); in allServersFailedToConnect()
1444 helper.updateBalancingState(READY, mockPicker); in informationPropagatedToNewStreamAndCallCredentials()
1506 helper.updateBalancingState(READY, mockPicker); in pickerReturnsStreamTracer_noDelay()
1544 helper.updateBalancingState(READY, mockPicker); in pickerReturnsStreamTracer_delayed()
[all …]
DManagedChannelImplIdlenessTest.java273 helper.updateBalancingState(READY, mockPicker); in realTransportsHoldsOffIdleness()
353 helper.updateBalancingState(TRANSIENT_FAILURE, failingPicker); in oobTransportDoesNotAffectIdleness()
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DAutoConfiguredLoadBalancerFactory.java93 helper.updateBalancingState(ConnectivityState.TRANSIENT_FAILURE, new FailingPicker(s)); in handleResolvedAddressGroups()
101 helper.updateBalancingState(ConnectivityState.CONNECTING, new EmptyPicker()); in handleResolvedAddressGroups()
DManagedChannelImpl.java1112 public void updateBalancingState( in updateBalancingState() method in ManagedChannelImpl.LbHelperImpl
/external/grpc-grpc-java/grpclb/src/main/java/io/grpc/grpclb/
DGrpclbState.java726 helper.updateBalancingState(state, picker); in maybeUpdatePicker()