HomeSort by relevance Sort by last modified time
    Searched refs:updateBalancingState (Results 1 - 14 of 14) sorted by null

  /external/grpc-grpc-java/core/src/test/java/io/grpc/
PickFirstLoadBalancerTest.java 106 verify(mockHelper).updateBalancingState(eq(CONNECTING), pickerCaptor.capture());
125 .updateBalancingState(isA(ConnectivityState.class), isA(SubchannelPicker.class));
143 inOrder.verify(mockHelper).updateBalancingState(eq(CONNECTING), pickerCaptor.capture());
164 verify(mockHelper).updateBalancingState(eq(CONNECTING), pickerCaptor.capture());
173 inOrder.verify(mockHelper).updateBalancingState(eq(TRANSIENT_FAILURE), pickerCaptor.capture());
177 inOrder.verify(mockHelper).updateBalancingState(eq(IDLE), pickerCaptor.capture());
181 inOrder.verify(mockHelper).updateBalancingState(eq(READY), pickerCaptor.capture());
191 verify(mockHelper).updateBalancingState(eq(TRANSIENT_FAILURE), pickerCaptor.capture());
205 .updateBalancingState(any(ConnectivityState.class), any(SubchannelPicker.class));
210 inOrder.verify(mockHelper).updateBalancingState(eq(CONNECTING), pickerCaptor.capture())
    [all...]
LoadBalancerTest.java 209 public void updateBalancingState(
  /external/grpc-grpc-java/core/src/main/java/io/grpc/
PickFirstBalancerFactory.java 73 helper.updateBalancingState(CONNECTING, new Picker(PickResult.withSubchannel(subchannel)));
88 helper.updateBalancingState(TRANSIENT_FAILURE, new Picker(PickResult.withError(error)));
118 helper.updateBalancingState(currentState, picker);
LoadBalancer.java 131 * Helper#updateBalancingState Helper.updateBalancingState()}. Failing to do so may result in
227 * picker is provided via {@link Helper#updateBalancingState Helper.updateBalancingState()},
271 * Helper#updateBalancingState Helper.updateBalancingState()}, which will trigger a new picking
310 * <li>Always create a new picker and call {@link Helper#updateBalancingState
311 * Helper.updateBalancingState()} whenever {@link #handleSubchannelState
547 * <p>When a new picker is provided via {@code updateBalancingState()}, the channel will apply
552 * updateBalancingState()} is called again and a new picker replaces the old one. If {@cod
    [all...]
  /external/grpc-grpc-java/core/src/main/java/io/grpc/util/
RoundRobinLoadBalancerFactory.java 186 updateBalancingState();
192 updateBalancingState(TRANSIENT_FAILURE,
208 updateBalancingState();
233 private void updateBalancingState() {
251 updateBalancingState(isConnecting ? CONNECTING : TRANSIENT_FAILURE,
259 updateBalancingState(READY, new ReadyPicker(activeList, startIndex, stickinessState));
263 private void updateBalancingState(ConnectivityState state, RoundRobinPicker picker) {
265 helper.updateBalancingState(state, picker);
  /external/grpc-grpc-java/core/src/test/java/io/grpc/util/
RoundRobinLoadBalancerTest.java 159 .updateBalancingState(stateCaptor.capture(), pickerCaptor.capture());
206 inOrder.verify(mockHelper).updateBalancingState(eq(READY), pickerCaptor.capture());
238 inOrder.verify(mockHelper).updateBalancingState(eq(READY), pickerCaptor.capture());
247 inOrder.verify(mockHelper).updateBalancingState(eq(TRANSIENT_FAILURE), pickerCaptor.capture());
261 inOrder.verify(mockHelper).updateBalancingState(eq(CONNECTING), isA(EmptyPicker.class));
266 inOrder.verify(mockHelper).updateBalancingState(eq(READY), pickerCaptor.capture());
276 inOrder.verify(mockHelper).updateBalancingState(eq(CONNECTING), pickerCaptor.capture());
325 verify(mockHelper).updateBalancingState(eq(TRANSIENT_FAILURE), pickerCaptor.capture());
342 .updateBalancingState(stateCaptor.capture(), pickerCaptor.capture());
378 .updateBalancingState(stateCaptor.capture(), pickerCaptor.capture())
    [all...]
  /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
AutoConfiguredLoadBalancerFactoryTest.java 122 public void updateBalancingState(ConnectivityState newState, SubchannelPicker newPicker) {
156 public void updateBalancingState(ConnectivityState newState, SubchannelPicker newPicker) {
317 public void updateBalancingState(
319 delegate().updateBalancingState(newState, newPicker);
ManagedChannelImplTest.java 457 helper.updateBalancingState(READY, mockPicker);
515 helper.updateBalancingState(READY, picker2);
652 helper.updateBalancingState(READY, mockPicker);
753 helper.updateBalancingState(READY, picker);
    [all...]
ManagedChannelImplIdlenessTest.java 273 helper.updateBalancingState(READY, mockPicker);
353 helper.updateBalancingState(TRANSIENT_FAILURE, failingPicker);
  /external/grpc-grpc-java/grpclb/src/test/java/io/grpc/grpclb/
GrpclbLoadBalancerTest.java 247 }).when(helper).updateBalancingState(
443 .updateBalancingState(eq(READY), pickerCaptor.capture());
579 .updateBalancingState(any(ConnectivityState.class), any(SubchannelPicker.class));
598 helperInOrder.verify(helper).updateBalancingState(eq(READY), pickerCaptor.capture());
721 verify(helper).updateBalancingState(eq(TRANSIENT_FAILURE), pickerCaptor.capture());
737 verify(helper).updateBalancingState(eq(TRANSIENT_FAILURE), pickerCaptor.capture());
    [all...]
  /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
AutoConfiguredLoadBalancerFactory.java 93 helper.updateBalancingState(ConnectivityState.TRANSIENT_FAILURE, new FailingPicker(s));
101 helper.updateBalancingState(ConnectivityState.CONNECTING, new EmptyPicker());
ManagedChannelImpl.java     [all...]
  /external/grpc-grpc-java/grpclb/src/main/java/io/grpc/grpclb/
GrpclbState.java 726 helper.updateBalancingState(state, picker);
  /external/grpc-grpc-java/core/
grpc-core-1.14.0.jar 

Completed in 777 milliseconds