Skip to content

Commit 7dc4fc9

Browse files
authored
xds, api: minor cleanup to address linter suggestions (#9116)
1 parent ecf1b37 commit 7dc4fc9

File tree

3 files changed

+14
-26
lines changed

3 files changed

+14
-26
lines changed

api/src/test/java/io/grpc/ManagedChannelRegistryTest.java

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -253,11 +253,6 @@ public NewChannelBuilderResult newChannelBuilder(
253253
throw new AssertionError();
254254
}
255255
});
256-
class MockChannelBuilder extends ForwardingChannelBuilder<MockChannelBuilder> {
257-
@Override public ManagedChannelBuilder<?> delegate() {
258-
throw new UnsupportedOperationException();
259-
}
260-
}
261256

262257
registry.register(new BaseProvider(true, 4) {
263258
@Override

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

Lines changed: 2 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -586,7 +586,7 @@ private final class FakeLoadBalancerProvider extends LoadBalancerProvider {
586586

587587
@Override
588588
public LoadBalancer newLoadBalancer(Helper helper) {
589-
FakeLoadBalancer balancer = new FakeLoadBalancer(policyName, helper);
589+
FakeLoadBalancer balancer = new FakeLoadBalancer(policyName);
590590
childBalancers.add(balancer);
591591
return balancer;
592592
}
@@ -618,14 +618,12 @@ public NameResolver.ConfigOrError parseLoadBalancingPolicyConfig(
618618

619619
private final class FakeLoadBalancer extends LoadBalancer {
620620
private final String name;
621-
private final Helper helper;
622621
private Object config;
623622
private Status upstreamError;
624623
private boolean shutdown;
625624

626-
FakeLoadBalancer(String name, Helper helper) {
625+
FakeLoadBalancer(String name) {
627626
this.name = name;
628-
this.helper = helper;
629627
}
630628

631629
@Override
@@ -643,16 +641,6 @@ public void shutdown() {
643641
shutdown = true;
644642
childBalancers.remove(this);
645643
}
646-
647-
void deliverSubchannelState(final Subchannel subchannel, ConnectivityState state) {
648-
SubchannelPicker picker = new SubchannelPicker() {
649-
@Override
650-
public PickResult pickSubchannel(PickSubchannelArgs args) {
651-
return PickResult.withSubchannel(subchannel);
652-
}
653-
};
654-
helper.updateBalancingState(state, picker);
655-
}
656644
}
657645

658646
private static final class FakeXdsClient extends XdsClient {

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

Lines changed: 12 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -53,10 +53,13 @@ public void roundRobin() throws ResourceInvalidException {
5353

5454
@Test
5555
public void ringHash() throws ResourceInvalidException {
56-
Cluster cluster = Cluster.newBuilder().setLbPolicy(LbPolicy.RING_HASH).setRingHashLbConfig(
57-
RingHashLbConfig.newBuilder()
58-
.setMinimumRingSize(UInt64Value.newBuilder().setValue(1).build())
59-
.setMaximumRingSize(UInt64Value.newBuilder().setValue(2).build()).build()).build();
56+
Cluster cluster = Cluster.newBuilder()
57+
.setLbPolicy(LbPolicy.RING_HASH)
58+
.setRingHashLbConfig(
59+
RingHashLbConfig.newBuilder()
60+
.setMinimumRingSize(UInt64Value.of(1))
61+
.setMaximumRingSize(UInt64Value.of(2)))
62+
.build();
6063

6164
LbConfig lbConfig = ServiceConfigUtil.unwrapLoadBalancingConfig(
6265
LegacyLoadBalancerConfigFactory.newConfig(cluster, true));
@@ -85,9 +88,11 @@ public void ringHash_invalidHash() throws ResourceInvalidException {
8588
public void leastRequest() throws ResourceInvalidException {
8689
System.setProperty("io.grpc.xds.experimentalEnableLeastRequest", "true");
8790

88-
Cluster cluster = Cluster.newBuilder().setLbPolicy(LbPolicy.LEAST_REQUEST)
89-
.setLeastRequestLbConfig(LeastRequestLbConfig.newBuilder()
90-
.setChoiceCount(UInt32Value.newBuilder().setValue(10).build())).build();
91+
Cluster cluster = Cluster.newBuilder()
92+
.setLbPolicy(LbPolicy.LEAST_REQUEST)
93+
.setLeastRequestLbConfig(
94+
LeastRequestLbConfig.newBuilder().setChoiceCount(UInt32Value.of(10)))
95+
.build();
9196

9297
LbConfig lbConfig = ServiceConfigUtil.unwrapLoadBalancingConfig(
9398
LegacyLoadBalancerConfigFactory.newConfig(cluster, true));

0 commit comments

Comments
 (0)