Skip to content

Commit d56f10b

Browse files
committed
Address review comments.
1 parent 2f5bf11 commit d56f10b

File tree

2 files changed

+16
-17
lines changed

2 files changed

+16
-17
lines changed

xds/src/main/java/io/grpc/xds/ClusterResolverLoadBalancer.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -693,7 +693,7 @@ public Status onResult2(final ResolutionResult resolutionResult) {
693693
resolved = true;
694694
result = new ClusterResolutionResult(addresses, priorityName, priorityChildConfig);
695695
handleEndpointResourceUpdate();
696-
return status;
696+
return Status.OK;
697697
} else {
698698
handleErrorInSyncContext(addressesOrError.getStatus());
699699
return addressesOrError.getStatus();

xds/src/test/java/io/grpc/xds/ClusterResolverLoadBalancerTest.java

Lines changed: 15 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -828,19 +828,17 @@ public void handleEdsResource_noHealthyEndpoint() {
828828

829829
@Test
830830
public void onlyLogicalDnsCluster_endpointsResolved() {
831-
do_onlyLogicalDnsCluster_endpointsResolved(false);
831+
do_onlyLogicalDnsCluster_endpointsResolved();
832832
}
833833

834834
@Test
835835
public void oldListenerCallback_onlyLogicalDnsCluster_endpointsResolved() {
836-
do_onlyLogicalDnsCluster_endpointsResolved(true);
836+
nsRegistry.deregister(fakeNameResolverProvider);
837+
nsRegistry.register(new FakeNameResolverProvider(true));
838+
do_onlyLogicalDnsCluster_endpointsResolved();
837839
}
838840

839-
void do_onlyLogicalDnsCluster_endpointsResolved(boolean useOldListenerCallback) {
840-
if (useOldListenerCallback) {
841-
nsRegistry.deregister(fakeNameResolverProvider);
842-
nsRegistry.register(new FakeNameResolverProvider(true));
843-
}
841+
void do_onlyLogicalDnsCluster_endpointsResolved() {
844842
ClusterResolverConfig config = new ClusterResolverConfig(
845843
Collections.singletonList(logicalDnsDiscoveryMechanism), roundRobin, false);
846844
deliverLbConfig(config);
@@ -889,19 +887,17 @@ public void onlyLogicalDnsCluster_handleRefreshNameResolution() {
889887

890888
@Test
891889
public void resolutionError_backoffAndRefresh() {
892-
do_onlyLogicalDnsCluster_resolutionError_backoffAndRefresh(false);
890+
do_onlyLogicalDnsCluster_resolutionError_backoffAndRefresh();
893891
}
894892

895893
@Test
896894
public void oldListenerCallback_resolutionError_backoffAndRefresh() {
897-
do_onlyLogicalDnsCluster_resolutionError_backoffAndRefresh(true);
895+
nsRegistry.deregister(fakeNameResolverProvider);
896+
nsRegistry.register(new FakeNameResolverProvider(true));
897+
do_onlyLogicalDnsCluster_resolutionError_backoffAndRefresh();
898898
}
899899

900-
void do_onlyLogicalDnsCluster_resolutionError_backoffAndRefresh(boolean useOldListenerCallback) {
901-
if (useOldListenerCallback) {
902-
nsRegistry.deregister(fakeNameResolverProvider);
903-
nsRegistry.register(new FakeNameResolverProvider(true));
904-
}
900+
void do_onlyLogicalDnsCluster_resolutionError_backoffAndRefresh() {
905901
InOrder inOrder = Mockito.inOrder(helper, backoffPolicyProvider,
906902
backoffPolicy1, backoffPolicy2);
907903
ClusterResolverConfig config = new ClusterResolverConfig(
@@ -1409,8 +1405,11 @@ public void shutdown() {
14091405
}
14101406

14111407
protected void deliverEndpointAddresses(List<EquivalentAddressGroup> addresses) {
1412-
syncContext.execute(() -> listener.onResult2(ResolutionResult.newBuilder()
1413-
.setAddressesOrError(StatusOr.fromValue(addresses)).build()) );
1408+
syncContext.execute(() -> {
1409+
Status ret = listener.onResult2(ResolutionResult.newBuilder()
1410+
.setAddressesOrError(StatusOr.fromValue(addresses)).build());
1411+
assertThat(ret.getCode()).isEqualTo(Status.Code.OK);
1412+
});
14141413
}
14151414

14161415
protected void deliverError(Status error) {

0 commit comments

Comments
 (0)