OpenGrok
Home
Sort by relevance
Sort by last modified time
Full Search
Definition
Symbol
File Path
History
|
|
Help
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