Home
last modified time | relevance | path

Searched refs:newPicker (Results 1 – 23 of 23) sorted by relevance

/external/grpc-grpc-java/core/src/main/java/io/grpc/util/
DGracefulSwitchLoadBalancer.java142 public void updateBalancingState(ConnectivityState newState, SubchannelPicker newPicker) { in switchTo() argument
146 pendingPicker = newPicker; in switchTo()
155 helper.updateBalancingState(newState, newPicker); in switchTo()
DForwardingLoadBalancerHelper.java88 ConnectivityState newState, SubchannelPicker newPicker) { in updateBalancingState() argument
89 delegate().updateBalancingState(newState, newPicker); in updateBalancingState()
DOutlierDetectionLoadBalancer.java235 public void updateBalancingState(ConnectivityState newState, SubchannelPicker newPicker) { in updateBalancingState() argument
236 delegate.updateBalancingState(newState, new OutlierDetectionPicker(newPicker)); in updateBalancingState()
/external/grpc-grpc-java/examples/example-orca/src/main/java/io/grpc/examples/orca/
DCustomBackendMetricsLoadBalancerProvider.java103 …ic void updateBalancingState(ConnectivityState newState, LoadBalancer.SubchannelPicker newPicker) { in updateBalancingState() argument
104 delegate().updateBalancingState(newState, new MayReportLoadPicker(newPicker)); in updateBalancingState()
/external/grpc-grpc-java/interop-testing/src/main/java/io/grpc/testing/integration/
DRpcBehaviorLoadBalancerProvider.java145 @Nonnull SubchannelPicker newPicker) { in updateBalancingState() argument
146 delegateHelper.updateBalancingState(newState, new RpcBehaviorPicker(newPicker, rpcBehavior)); in updateBalancingState()
DCustomBackendMetricsLoadBalancerProvider.java102 public void updateBalancingState(ConnectivityState newState, SubchannelPicker newPicker) { in updateBalancingState() argument
103 delegate().updateBalancingState(newState, new MayReportLoadPicker(newPicker)); in updateBalancingState()
/external/grpc-grpc-java/xds/src/test/java/io/grpc/xds/
DMetadataLoadBalancerProvider.java145 @Nonnull SubchannelPicker newPicker) { in updateBalancingState() argument
147 new MetadataPicker(newPicker, metadataKey, metadataValue)); in updateBalancingState()
DClusterImplLoadBalancerTest.java763 @Nonnull ConnectivityState newState, @Nonnull SubchannelPicker newPicker) { in updateBalancingState() argument
765 currentPicker = newPicker; in updateBalancingState()
/external/grpc-grpc-java/rls/src/main/java/io/grpc/rls/
DLbPolicyConfiguration.java386 public void updateBalancingState(ConnectivityState newState, SubchannelPicker newPicker) { in updateBalancingState() argument
387 picker = newPicker; in updateBalancingState()
389 super.updateBalancingState(newState, newPicker); in updateBalancingState()
DCachingRlsLbClient.java327 public void updateBalancingState(ConnectivityState newState, SubchannelPicker newPicker) { in updateBalancingState() argument
329 picker = newPicker; in updateBalancingState()
330 super.updateBalancingState(newState, newPicker); in updateBalancingState()
/external/grpc-grpc-java/xds/src/main/java/io/grpc/xds/
DWeightedTargetLoadBalancer.java202 final SubchannelPicker newPicker) { in updateBalancingState() argument
204 currentPicker = newPicker; in updateBalancingState()
DClusterImplLoadBalancer.java190 public void updateBalancingState(ConnectivityState newState, SubchannelPicker newPicker) { in updateBalancingState() argument
192 currentPicker = newPicker; in updateBalancingState()
194 new RequestLimitingSubchannelPicker(newPicker, dropPolicies, maxConcurrentRequests); in updateBalancingState()
DClusterManagerLoadBalancer.java260 final SubchannelPicker newPicker) { in updateBalancingState() argument
269 currentPicker = newPicker; in updateBalancingState()
DPriorityLoadBalancer.java318 final SubchannelPicker newPicker) { in updateBalancingState() argument
323 picker = newPicker; in updateBalancingState()
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DManagedChannelImpl.java881 private void updateSubchannelPicker(SubchannelPicker newPicker) {
882 subchannelPicker = newPicker;
883 delayedTransport.reprocess(newPicker);
1455 final ConnectivityState newState, final SubchannelPicker newPicker) {
1458 checkNotNull(newPicker, "newPicker");
1465 updateSubchannelPicker(newPicker);
1470 ChannelLogLevel.INFO, "Entering {0} state with picker: {1}", newState, newPicker);
/external/grpc-grpc-java/api/src/test/java/io/grpc/
DLoadBalancerTest.java345 ConnectivityState newState, LoadBalancer.SubchannelPicker newPicker) {} in updateBalancingState() argument
/external/grpc-grpc-java/api/src/main/java/io/grpc/
DLoadBalancer.java1054 @Nonnull ConnectivityState newState, @Nonnull SubchannelPicker newPicker); in updateBalancingState() argument
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DAutoConfiguredLoadBalancerFactoryTest.java688 public void updateBalancingState(ConnectivityState newState, SubchannelPicker newPicker) { in updateBalancingState() argument
/external/grpc-grpc-java/rls/src/test/java/io/grpc/rls/
DRlsLoadBalancerTest.java545 @Nonnull ConnectivityState newState, @Nonnull SubchannelPicker newPicker) { in updateBalancingState() argument
DCachingRlsLbClientTest.java815 @Nonnull ConnectivityState newState, @Nonnull SubchannelPicker newPicker) {
/external/grpc-grpc-java/xds/src/test/java/io/grpc/xds/orca/
DOrcaOobUtilTest.java926 public void updateBalancingState(ConnectivityState newState, SubchannelPicker newPicker) { in updateBalancingState() argument
/external/grpc-grpc-java/services/src/test/java/io/grpc/protobuf/services/
DHealthCheckingLoadBalancerFactoryTest.java1253 public void updateBalancingState(ConnectivityState newState, SubchannelPicker newPicker) {
/external/grpc-grpc-java/grpclb/src/test/java/io/grpc/grpclb/
DGrpclbLoadBalancerTest.java2935 @Nonnull ConnectivityState newState, @Nonnull SubchannelPicker newPicker) { in updateBalancingState() argument
2936 currentPicker = newPicker; in updateBalancingState()