Skip to content

Commit f3daf93

Browse files
committed
Revert "xds: Disable LOGICAL_DNS in XdsDepMan until used"
This reverts commit d374b26 as part of reverting 297ab05.
1 parent 2ecbd43 commit f3daf93

File tree

2 files changed

+4
-21
lines changed

2 files changed

+4
-21
lines changed

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

Lines changed: 4 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -82,9 +82,6 @@ private enum TrackedWatcherTypeEnum {
8282
private static final Locality LOGICAL_DNS_CLUSTER_LOCALITY = Locality.create("", "", "");
8383

8484
private static final int MAX_CLUSTER_RECURSION_DEPTH = 16; // Specified by gRFC A37
85-
86-
static boolean enableLogicalDns = false;
87-
8885
private final String listenerName;
8986
private final XdsClient xdsClient;
9087
private final SynchronizationContext syncContext;
@@ -366,14 +363,9 @@ private static void addConfigForCluster(
366363
}
367364
break;
368365
case LOGICAL_DNS:
369-
if (enableLogicalDns) {
370-
TrackedWatcher<List<EquivalentAddressGroup>> dnsWatcher =
371-
tracer.getWatcher(DNS_TYPE, cdsUpdate.dnsHostName());
372-
child = new EndpointConfig(dnsToEdsUpdate(dnsWatcher.getData(), cdsUpdate.dnsHostName()));
373-
} else {
374-
child = new EndpointConfig(StatusOr.fromStatus(
375-
Status.INTERNAL.withDescription("Logical DNS in dependency manager unsupported")));
376-
}
366+
TrackedWatcher<List<EquivalentAddressGroup>> dnsWatcher =
367+
tracer.getWatcher(DNS_TYPE, cdsUpdate.dnsHostName());
368+
child = new EndpointConfig(dnsToEdsUpdate(dnsWatcher.getData(), cdsUpdate.dnsHostName()));
377369
break;
378370
default:
379371
child = new EndpointConfig(StatusOr.fromStatus(Status.UNAVAILABLE.withDescription(
@@ -814,9 +806,7 @@ public void subscribeToChildren(XdsClusterResource.CdsUpdate update) {
814806
addEdsWatcher(getEdsServiceName());
815807
break;
816808
case LOGICAL_DNS:
817-
if (enableLogicalDns) {
818-
addDnsWatcher(update.dnsHostName());
819-
}
809+
addDnsWatcher(update.dnsHostName());
820810
break;
821811
case AGGREGATE:
822812
update.prioritizedClusterNames()

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

Lines changed: 0 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -152,7 +152,6 @@ public class XdsDependencyManagerTest {
152152

153153
private XdsDependencyManager xdsDependencyManager = new XdsDependencyManager(
154154
xdsClient, syncContext, serverName, serverName, nameResolverArgs);
155-
private boolean savedEnableLogicalDns;
156155

157156
@Before
158157
public void setUp() throws Exception {
@@ -169,8 +168,6 @@ public void setUp() throws Exception {
169168
testWatcher = new TestWatcher();
170169
xdsConfigWatcher = mock(TestWatcher.class, delegatesTo(testWatcher));
171170
defaultXdsConfig = XdsTestUtils.getDefaultXdsConfig(serverName);
172-
173-
savedEnableLogicalDns = XdsDependencyManager.enableLogicalDns;
174171
}
175172

176173
@After
@@ -183,8 +180,6 @@ public void tearDown() throws InterruptedException {
183180
assertThat(adsEnded.get()).isTrue();
184181
assertThat(lrsEnded.get()).isTrue();
185182
assertThat(fakeClock.getPendingTasks()).isEmpty();
186-
187-
XdsDependencyManager.enableLogicalDns = savedEnableLogicalDns;
188183
}
189184

190185
@Test
@@ -754,7 +749,6 @@ public void testChangeAggCluster() {
754749

755750
@Test
756751
public void testLogicalDns_success() {
757-
XdsDependencyManager.enableLogicalDns = true;
758752
FakeSocketAddress fakeAddress = new FakeSocketAddress();
759753
nameResolverRegistry.register(new FakeNameResolverProvider(
760754
"dns:///dns.example.com:1111", fakeAddress));
@@ -795,7 +789,6 @@ public void testLogicalDns_success() {
795789

796790
@Test
797791
public void testLogicalDns_noDnsNr() {
798-
XdsDependencyManager.enableLogicalDns = true;
799792
Cluster cluster = Cluster.newBuilder()
800793
.setName(CLUSTER_NAME)
801794
.setType(Cluster.DiscoveryType.LOGICAL_DNS)

0 commit comments

Comments
 (0)