| /external/grpc-grpc-java/core/src/test/java/io/grpc/ |
| D | LoadBalancerTest.java | 23 import io.grpc.LoadBalancer.PickResult;
49 PickResult result = PickResult.withSubchannel(subchannel); in pickResult_withSubchannel()
58 PickResult result = PickResult.withSubchannel(subchannel, tracerFactory); in pickResult_withSubchannelAndTracer()
67 PickResult result = PickResult.withNoResult(); in pickResult_withNoResult()
76 PickResult result = PickResult.withError(status); in pickResult_withError()
85 PickResult result = PickResult.withDrop(status); in pickResult_withDrop()
94 PickResult sc1 = PickResult.withSubchannel(subchannel); in pickResult_equals()
95 PickResult sc2 = PickResult.withSubchannel(subchannel); in pickResult_equals()
96 PickResult sc3 = PickResult.withSubchannel(subchannel, tracerFactory); in pickResult_equals()
97 PickResult sc4 = PickResult.withSubchannel(subchannel2); in pickResult_equals()
[all …]
|
| D | PickFirstLoadBalancerTest.java | 38 import io.grpc.LoadBalancer.PickResult;
192 PickResult pickResult = pickerCaptor.getValue().pickSubchannel(mockArgs); in nameResolutionError()
232 PickResult pickResult = pickerCaptor.getValue().pickSubchannel(mockArgs); in nameResolutionErrorWithStateChanges()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/ |
| D | LoadBalancer.java | 171 public abstract PickResult pickSubchannel(PickSubchannelArgs args); in pickSubchannel()
234 public static final class PickResult { class in LoadBalancer
235 private static final PickResult NO_RESULT = new PickResult(null, null, Status.OK, false);
246 private PickResult( in PickResult() method in LoadBalancer.PickResult
322 public static PickResult withSubchannel( in withSubchannel()
324 return new PickResult( in withSubchannel()
334 public static PickResult withSubchannel(Subchannel subchannel) { in withSubchannel()
346 public static PickResult withError(Status error) { in withError()
348 return new PickResult(null, null, error, false); in withError()
358 public static PickResult withDrop(Status status) { in withDrop()
[all …]
|
| D | PickFirstBalancerFactory.java | 25 import io.grpc.LoadBalancer.PickResult;
73 helper.updateBalancingState(CONNECTING, new Picker(PickResult.withSubchannel(subchannel))); in handleResolvedAddressGroups()
88 helper.updateBalancingState(TRANSIENT_FAILURE, new Picker(PickResult.withError(error))); in handleNameResolutionError()
106 picker = new Picker(PickResult.withNoResult()); in handleSubchannelState()
109 picker = new Picker(PickResult.withSubchannel(subchannel)); in handleSubchannelState()
112 picker = new Picker(PickResult.withError(stateInfo.getStatus())); in handleSubchannelState()
134 private final PickResult result;
136 Picker(PickResult result) { in Picker()
141 public PickResult pickSubchannel(PickSubchannelArgs args) { in pickSubchannel()
155 public PickResult pickSubchannel(PickSubchannelArgs args) { in pickSubchannel()
[all …]
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | DelayedClientTransportTest.java | 38 import io.grpc.LoadBalancer.PickResult;
109 .thenReturn(PickResult.withSubchannel(mockSubchannel)); in setUp()
349 PickResult.withSubchannel(subchannel1), // ff1: proceed in reprocessSemantics()
350 PickResult.withError(Status.UNAVAILABLE), // ff2: fail in reprocessSemantics()
351 PickResult.withSubchannel(subchannel3), // ff3: stay in reprocessSemantics()
352 PickResult.withNoResult(), // ff4: stay in reprocessSemantics()
354 PickResult.withSubchannel(subchannel2), // wfr1: proceed in reprocessSemantics()
355 PickResult.withError(Status.RESOURCE_EXHAUSTED), // wfr2: stay in reprocessSemantics()
356 PickResult.withSubchannel(subchannel3)); // wfr3: stay in reprocessSemantics()
395 PickResult.withSubchannel(subchannel1), // ff3 in reprocessSemantics()
[all …]
|
| D | GrpcUtilTest.java | 31 import io.grpc.LoadBalancer.PickResult;
232 PickResult pickResult = PickResult.withError(status); in getTransportFromPickResult_errorPickResult_waitForReady()
241 PickResult pickResult = PickResult.withError(status); in getTransportFromPickResult_errorPickResult_failFast()
257 PickResult pickResult = PickResult.withDrop(status); in getTransportFromPickResult_dropPickResult_waitForReady()
273 PickResult pickResult = PickResult.withDrop(status); in getTransportFromPickResult_dropPickResult_failFast()
|
| D | ManagedChannelImplTest.java | 78 import io.grpc.LoadBalancer.PickResult;
453 PickResult.withNoResult()); in subtestCallsAndShutdown()
456 PickResult.withSubchannel(subchannel)); in subtestCallsAndShutdown()
514 .thenReturn(PickResult.withSubchannel(subchannel)); in subtestCallsAndShutdown()
650 .thenReturn(PickResult.withSubchannel(subchannel)); in callOptionsExecutor()
752 .thenReturn(PickResult.withDrop(status)); in nameResolutionFailed_delayedTransportShutdownCancelsBackoff()
855 .thenReturn(PickResult.withSubchannel(subchannel)); in firstResolvedServerFailedToConnect()
934 .thenReturn(drop ? PickResult.withDrop(status) : PickResult.withError(status)); in subtestFailRpcFromBalancer()
1000 .thenReturn(PickResult.withSubchannel(subchannel)); in allServersFailedToConnect()
1032 .thenReturn(PickResult.withError(server2Error)); in allServersFailedToConnect()
[all …]
|
| D | ManagedChannelImplIdlenessTest.java | 43 import io.grpc.LoadBalancer.PickResult;
272 .thenReturn(PickResult.withSubchannel(subchannel)); in realTransportsHoldsOffIdleness()
352 .thenReturn(PickResult.withError(Status.UNAVAILABLE)); in oobTransportDoesNotAffectIdleness()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | OobChannel.java | 40 import io.grpc.LoadBalancer.PickResult;
178 final PickResult result = PickResult.withSubchannel(subchannelImpl); in setSubchannel()
181 public PickResult pickSubchannel(PickSubchannelArgs args) { in setSubchannel()
260 final PickResult errorResult = PickResult.withError(newState.getStatus()); in handleSubchannelStateChange()
263 public PickResult pickSubchannel(PickSubchannelArgs args) { in handleSubchannelStateChange()
|
| D | AutoConfiguredLoadBalancerFactory.java | 26 import io.grpc.LoadBalancer.PickResult;
209 public PickResult pickSubchannel(PickSubchannelArgs args) { in pickSubchannel()
210 return PickResult.withNoResult(); in pickSubchannel()
222 public PickResult pickSubchannel(PickSubchannelArgs args) { in pickSubchannel()
223 return PickResult.withError(failure); in pickSubchannel()
|
| D | DelayedClientTransport.java | 26 import io.grpc.LoadBalancer.PickResult;
149 PickResult pickResult = picker.pickSubchannel(args); in newStream()
289 PickResult pickResult = picker.pickSubchannel(stream.args); in reprocess()
|
| D | ManagedChannelImpl.java | 54 import io.grpc.LoadBalancer.PickResult;
494 PickResult pickResult = pickerCopy.pickSubchannel(args);
749 final PickResult panicPickResult = in panic()
750 PickResult.withDrop( in panic()
753 public PickResult pickSubchannel(PickSubchannelArgs args) { in panic()
|
| D | GrpcUtil.java | 36 import io.grpc.LoadBalancer.PickResult;
665 static ClientTransport getTransportFromPickResult(PickResult result, boolean isWaitForReady) { in getTransportFromPickResult()
|
| /external/grpc-grpc-java/grpclb/src/main/java/io/grpc/grpclb/ |
| D | GrpclbState.java | 38 import io.grpc.LoadBalancer.PickResult;
92 static final PickResult DROP_PICK_RESULT =
93 PickResult.withDrop(Status.UNAVAILABLE.withDescription("Dropped as requested by balancer"));
98 public PickResult picked(Metadata headers) {
99 return PickResult.withNoResult();
778 PickResult picked() { in picked()
807 PickResult picked(Metadata headers); in picked()
813 final PickResult result;
823 this.result = PickResult.withSubchannel(subchannel, loadRecorder); in BackendEntry()
832 this.result = PickResult.withSubchannel(subchannel); in BackendEntry()
[all …]
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/util/ |
| D | RoundRobinLoadBalancerFactory.java | 36 import io.grpc.LoadBalancer.PickResult;
428 public PickResult pickSubchannel(PickSubchannelArgs args) { in pickSubchannel()
440 return PickResult.withSubchannel(subchannel != null ? subchannel : nextSubchannel()); in pickSubchannel()
482 public PickResult pickSubchannel(PickSubchannelArgs args) { in pickSubchannel()
483 return status.isOk() ? PickResult.withNoResult() : PickResult.withError(status); in pickSubchannel()
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/util/ |
| D | RoundRobinLoadBalancerTest.java | 55 import io.grpc.LoadBalancer.PickResult;
248 assertEquals(PickResult.withNoResult(), pickerCaptor.getValue().pickSubchannel(mockArgs)); in pickAfterResolvedUpdatedHosts()
326 LoadBalancer.PickResult pickResult = pickerCaptor.getValue().pickSubchannel(mockArgs); in nameResolutionErrorWithNoChannels()
349 LoadBalancer.PickResult pickResult = pickerCaptor.getValue().pickSubchannel(mockArgs); in nameResolutionErrorWithActiveChannels()
353 LoadBalancer.PickResult pickResult2 = pickerCaptor.getValue().pickSubchannel(mockArgs); in nameResolutionErrorWithActiveChannels()
|
| /external/grpc-grpc-java/grpclb/src/test/java/io/grpc/grpclb/ |
| D | GrpclbLoadBalancerTest.java | 58 import io.grpc.LoadBalancer.PickResult;
459 PickResult pick1 = picker.pickSubchannel(args); in loadReporting()
471 PickResult pick2 = picker.pickSubchannel(args); in loadReporting()
488 PickResult pick3 = picker.pickSubchannel(args); in loadReporting()
504 PickResult pick4 = picker.pickSubchannel(args); in loadReporting()
525 PickResult pick5 = picker.pickSubchannel(args); in loadReporting()
583 PickResult pick6 = picker.pickSubchannel(args); in loadReporting()
601 PickResult pick1p = picker.pickSubchannel(args); in loadReporting()
|