Home
last modified time | relevance | path

Searched refs:updateBalancingState (Results 1 – 14 of 14) 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()
DForwardingLoadBalancerHelper.java71 public void updateBalancingState( in updateBalancingState() method in ForwardingLoadBalancerHelper
73 delegate().updateBalancingState(newState, newPicker); 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.java567 public abstract void updateBalancingState( in updateBalancingState() method in LoadBalancer.Helper
/external/grpc-grpc-java/grpclb/src/test/java/io/grpc/grpclb/
DGrpclbLoadBalancerTest.java246 }).when(helper).updateBalancingState( in setUp()
442 .updateBalancingState(eq(READY), pickerCaptor.capture()); in loadReporting()
578 .updateBalancingState(any(ConnectivityState.class), any(SubchannelPicker.class)); in loadReporting()
597 helperInOrder.verify(helper).updateBalancingState(eq(READY), pickerCaptor.capture()); in loadReporting()
720 verify(helper).updateBalancingState(eq(TRANSIENT_FAILURE), pickerCaptor.capture()); in nameResolutionFailsThenRecoverToDelegate()
736 verify(helper).updateBalancingState(eq(TRANSIENT_FAILURE), pickerCaptor.capture()); in nameResolutionFailsThenRecoverToGrpclb()
770 inOrder.verify(helper).updateBalancingState(eq(TRANSIENT_FAILURE), pickerCaptor.capture()); in grpclbThenNameResolutionFails()
864 .updateBalancingState(any(ConnectivityState.class), any(SubchannelPicker.class)); in grpclbWorking()
888 inOrder.verify(helper).updateBalancingState(eq(CONNECTING), pickerCaptor.capture()); in grpclbWorking()
896 inOrder.verify(helper).updateBalancingState(eq(READY), pickerCaptor.capture()); in grpclbWorking()
[all …]
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DAutoConfiguredLoadBalancerFactoryTest.java126 public void updateBalancingState(ConnectivityState newState, SubchannelPicker newPicker) { in handleResolvedAddressGroups_keepOldBalancer()
160 public void updateBalancingState(ConnectivityState newState, SubchannelPicker newPicker) { in handleResolvedAddressGroups_shutsDownOldBalancer()
298 public void updateBalancingState(ConnectivityState newState, SubchannelPicker newPicker) { in channelTracing_lbPolicyChanged()
395 public void updateBalancingState( in updateBalancingState() method in AutoConfiguredLoadBalancerFactoryTest.ForwardingLoadBalancerHelper
397 delegate().updateBalancingState(newState, newPicker); in updateBalancingState()
DManagedChannelImplTest.java456 helper.updateBalancingState(READY, mockPicker); in subtestCallsAndShutdown()
514 helper.updateBalancingState(READY, picker2); in subtestCallsAndShutdown()
651 helper.updateBalancingState(READY, mockPicker); in callOptionsExecutor()
752 helper.updateBalancingState(READY, picker); in nameResolutionFailed_delayedTransportShutdownCancelsBackoff()
885 helper.updateBalancingState(READY, mockPicker); in firstResolvedServerFailedToConnect()
934 helper.updateBalancingState(READY, picker); in subtestFailRpcFromBalancer()
1032 helper.updateBalancingState(TRANSIENT_FAILURE, picker2); in allServersFailedToConnect()
1444 helper.updateBalancingState(READY, mockPicker); in informationPropagatedToNewStreamAndCallCredentials()
1507 helper.updateBalancingState(READY, mockPicker); in pickerReturnsStreamTracer_noDelay()
1545 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.java116 helper.updateBalancingState(ConnectivityState.TRANSIENT_FAILURE, new FailingPicker(s)); in handleResolvedAddressGroups()
124 helper.updateBalancingState(ConnectivityState.CONNECTING, new EmptyPicker()); in handleResolvedAddressGroups()
DManagedChannelImpl.java1107 public void updateBalancingState( in updateBalancingState() method in ManagedChannelImpl.LbHelperImpl
/external/grpc-grpc-java/grpclb/src/main/java/io/grpc/grpclb/
DGrpclbState.java720 helper.updateBalancingState(state, picker); in maybeUpdatePicker()