Home
last modified time | relevance | path

Searched refs:PickResult (Results 1 – 25 of 27) sorted by relevance

12

/external/grpc-grpc-java/core/src/test/java/io/grpc/
DLoadBalancerTest.java23 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 …]
DPickFirstLoadBalancerTest.java38 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/
DLoadBalancer.java177 public abstract PickResult pickSubchannel(PickSubchannelArgs args); in pickSubchannel()
240 public static final class PickResult { class in LoadBalancer
241 private static final PickResult NO_RESULT = new PickResult(null, null, Status.OK, false);
252 private PickResult( in PickResult() method in LoadBalancer.PickResult
328 public static PickResult withSubchannel( in withSubchannel()
330 return new PickResult( in withSubchannel()
340 public static PickResult withSubchannel(Subchannel subchannel) { in withSubchannel()
352 public static PickResult withError(Status error) { in withError()
354 return new PickResult(null, null, error, false); in withError()
364 public static PickResult withDrop(Status status) { in withDrop()
[all …]
DPickFirstBalancerFactory.java25 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/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/
Dlb_policy.cc95 LoadBalancingPolicy::PickResult LoadBalancingPolicy::QueuePicker::Pick( in Pick()
125 PickResult result; in Pick()
126 result.type = PickResult::PICK_QUEUE; in Pick()
134 LoadBalancingPolicy::PickResult
136 PickResult result; in Pick()
137 result.type = PickResult::PICK_FAILED; in Pick()
Dlb_policy.h206 struct PickResult { struct
269 virtual PickResult Pick(PickArgs args) = 0; argument
380 PickResult Pick(PickArgs args) override;
393 PickResult Pick(PickArgs args) override;
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DDelayedClientTransportTest.java38 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 …]
DGrpcUtilTest.java31 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()
DManagedChannelImplTest.java77 import io.grpc.LoadBalancer.PickResult;
452 PickResult.withNoResult()); in subtestCallsAndShutdown()
455 PickResult.withSubchannel(subchannel)); in subtestCallsAndShutdown()
513 .thenReturn(PickResult.withSubchannel(subchannel)); in subtestCallsAndShutdown()
649 .thenReturn(PickResult.withSubchannel(subchannel)); in callOptionsExecutor()
751 .thenReturn(PickResult.withDrop(status)); in nameResolutionFailed_delayedTransportShutdownCancelsBackoff()
854 .thenReturn(PickResult.withSubchannel(subchannel)); in firstResolvedServerFailedToConnect()
933 .thenReturn(drop ? PickResult.withDrop(status) : PickResult.withError(status)); in subtestFailRpcFromBalancer()
999 .thenReturn(PickResult.withSubchannel(subchannel)); in allServersFailedToConnect()
1031 .thenReturn(PickResult.withError(server2Error)); in allServersFailedToConnect()
[all …]
DManagedChannelImplIdlenessTest.java43 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/
DOobChannel.java40 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()
DAutoConfiguredLoadBalancerFactory.java29 import io.grpc.LoadBalancer.PickResult;
240 public PickResult pickSubchannel(PickSubchannelArgs args) { in pickSubchannel()
241 return PickResult.withNoResult(); in pickSubchannel()
253 public PickResult pickSubchannel(PickSubchannelArgs args) { in pickSubchannel()
254 return PickResult.withError(failure); in pickSubchannel()
DDelayedClientTransport.java26 import io.grpc.LoadBalancer.PickResult;
149 PickResult pickResult = picker.pickSubchannel(args); in newStream()
289 PickResult pickResult = picker.pickSubchannel(stream.args); in reprocess()
DManagedChannelImpl.java54 import io.grpc.LoadBalancer.PickResult;
451 PickResult pickResult = pickerCopy.pickSubchannel(args); in get()
728 private final PickResult panicPickResult = in panic()
729 PickResult.withDrop( in panic()
733 public PickResult pickSubchannel(PickSubchannelArgs args) { in panic()
DGrpcUtil.java36 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/
DGrpclbState.java38 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();
772 PickResult picked() { in picked()
801 PickResult picked(Metadata headers); in picked()
807 final PickResult result;
817 this.result = PickResult.withSubchannel(subchannel, loadRecorder); in BackendEntry()
826 this.result = PickResult.withSubchannel(subchannel); in BackendEntry()
[all …]
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/xds/
Dxds_cluster_impl.cc197 PickResult Pick(PickArgs args) { return picker_->Pick(args); } in Pick()
209 PickResult Pick(PickArgs args) override;
294 LoadBalancingPolicy::PickResult XdsClusterImplLb::Picker::Pick( in Pick()
300 PickResult result; in Pick()
301 result.type = PickResult::PICK_COMPLETE; in Pick()
311 PickResult result; in Pick()
312 result.type = PickResult::PICK_COMPLETE; in Pick()
318 PickResult result; in Pick()
319 result.type = PickResult::PICK_FAILED; in Pick()
328 PickResult result = picker_->Pick(args); in Pick()
Dxds_cluster_manager.cc87 PickResult Pick(PickArgs args) { return picker_->Pick(args); } in Pick()
109 PickResult Pick(PickArgs args) override;
207 XdsClusterManagerLb::PickResult XdsClusterManagerLb::ClusterPicker::Pick( in Pick()
215 PickResult result; in Pick()
216 result.type = PickResult::PICK_FAILED; in Pick()
/external/grpc-grpc-java/core/src/main/java/io/grpc/util/
DRoundRobinLoadBalancerFactory.java36 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/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/round_robin/
Dround_robin.cc157 PickResult Pick(PickArgs args) override;
208 RoundRobin::PickResult RoundRobin::Picker::Pick(PickArgs /*args*/) { in Pick()
216 PickResult result; in Pick()
217 result.type = PickResult::PICK_COMPLETE; in Pick()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/pick_first/
Dpick_first.cc116 PickResult Pick(PickArgs /*args*/) override { in Pick()
117 PickResult result; in Pick()
118 result.type = PickResult::PICK_COMPLETE; in Pick()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/weighted_target/
Dweighted_target.cc90 PickResult Pick(PickArgs args) { return picker_->Pick(args); } in Pick()
110 PickResult Pick(PickArgs args) override;
211 WeightedTargetLb::PickResult WeightedTargetLb::WeightedPicker::Pick( in Pick()
/external/grpc-grpc-java/core/src/test/java/io/grpc/util/
DRoundRobinLoadBalancerTest.java55 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/
DGrpclbLoadBalancerTest.java57 import io.grpc.LoadBalancer.PickResult;
458 PickResult pick1 = picker.pickSubchannel(args); in loadReporting()
470 PickResult pick2 = picker.pickSubchannel(args); in loadReporting()
487 PickResult pick3 = picker.pickSubchannel(args); in loadReporting()
503 PickResult pick4 = picker.pickSubchannel(args); in loadReporting()
524 PickResult pick5 = picker.pickSubchannel(args); in loadReporting()
582 PickResult pick6 = picker.pickSubchannel(args); in loadReporting()
600 PickResult pick1p = picker.pickSubchannel(args); in loadReporting()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/grpclb/
Dgrpclb.cc340 PickResult Pick(PickArgs args) override;
608 GrpcLb::PickResult GrpcLb::Picker::Pick(PickArgs args) { in Pick()
609 PickResult result; in Pick()
622 result.type = PickResult::PICK_COMPLETE; in Pick()
628 if (result.type == PickResult::PICK_COMPLETE && in Pick()

12