grpc
/
grpc-java
mirror of https://github.com/grpc/grpc-java.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

core: OutlierDetectionLoadBalancer to pass child LB config. (#9467)

This commit is contained in:
Terry Wilson 2022-08-22 10:29:57 -07:00 committed by GitHub
parent 9ed5a1bbbf
commit f5670b39c4
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
core/src/main/java/io/grpc/util/OutlierDetectionLoadBalancer.java
View File

@ -139,7 +139,9 @@ public final class OutlierDetectionLoadBalancer extends LoadBalancer {
trackerMap.cancelTracking(); trackerMap.cancelTracking();
} }
switchLb.handleResolvedAddresses(resolvedAddresses); switchLb.handleResolvedAddresses(
resolvedAddresses.toBuilder().setLoadBalancingPolicyConfig(config.childPolicy.getConfig())
.build());
} }
@Override @Override

4
core/src/test/java/io/grpc/util/OutlierDetectionLoadBalancerTest.java
View File

@ -233,7 +233,9 @@ public class OutlierDetectionLoadBalancerTest {
loadBalancer.handleResolvedAddresses(resolvedAddresses); loadBalancer.handleResolvedAddresses(resolvedAddresses);
// Handling of resolved addresses is delegated // Handling of resolved addresses is delegated
verify(mockChildLb).handleResolvedAddresses(resolvedAddresses); verify(mockChildLb).handleResolvedAddresses(
resolvedAddresses.toBuilder().setLoadBalancingPolicyConfig(config.childPolicy.getConfig())
.build());
// There is a single pending task to run the outlier detection algorithm // There is a single pending task to run the outlier detection algorithm
assertThat(fakeClock.getPendingTasks()).hasSize(1); assertThat(fakeClock.getPendingTasks()).hasSize(1);