diff --git a/server/src/main/java/org/elasticsearch/http/HttpInfo.java b/server/src/main/java/org/elasticsearch/http/HttpInfo.java index f3457495294a8..e792647f4a70d 100644 --- a/server/src/main/java/org/elasticsearch/http/HttpInfo.java +++ b/server/src/main/java/org/elasticsearch/http/HttpInfo.java @@ -33,32 +33,23 @@ import java.io.IOException; -import static org.elasticsearch.common.Booleans.parseBoolean; - public class HttpInfo implements Writeable, ToXContentFragment { private static final DeprecationLogger deprecationLogger = new DeprecationLogger(LogManager.getLogger(HttpInfo.class)); - /** Whether to add hostname to publish host field when serializing. */ - private static final boolean CNAME_IN_PUBLISH_HOST = - parseBoolean(System.getProperty("es.http.cname_in_publish_address"), true); + /** Deprecated property, just here for deprecation logging in 7.x. */ + private static final boolean CNAME_IN_PUBLISH_HOST = System.getProperty("es.http.cname_in_publish_address") != null; private final BoundTransportAddress address; private final long maxContentLength; - private final boolean cnameInPublishHostProperty; public HttpInfo(StreamInput in) throws IOException { - this(new BoundTransportAddress(in), in.readLong(), CNAME_IN_PUBLISH_HOST); + this(new BoundTransportAddress(in), in.readLong()); } public HttpInfo(BoundTransportAddress address, long maxContentLength) { - this(address, maxContentLength, CNAME_IN_PUBLISH_HOST); - } - - HttpInfo(BoundTransportAddress address, long maxContentLength, boolean cnameInPublishHostProperty) { this.address = address; this.maxContentLength = maxContentLength; - this.cnameInPublishHostProperty = cnameInPublishHostProperty; } @Override @@ -82,14 +73,14 @@ public XContentBuilder toXContent(XContentBuilder builder, Params params) throws TransportAddress publishAddress = address.publishAddress(); String publishAddressString = publishAddress.toString(); String hostString = publishAddress.address().getHostString(); + if (CNAME_IN_PUBLISH_HOST) { + deprecationLogger.deprecated( + "es.http.cname_in_publish_address system property is deprecated and no longer affects http.publish_address " + + "formatting. Remove this property to get rid of this deprecation warning." + ); + } if (InetAddresses.isInetAddress(hostString) == false) { publishAddressString = hostString + '/' + publishAddress.toString(); - if (cnameInPublishHostProperty) { - deprecationLogger.deprecated( - "es.http.cname_in_publish_address system property is deprecated and no longer affects http.publish_address " + - "formatting. Remove this property to get rid of this deprecation warning." - ); - } } builder.field(Fields.PUBLISH_ADDRESS, publishAddressString); builder.humanReadableField(Fields.MAX_CONTENT_LENGTH_IN_BYTES, Fields.MAX_CONTENT_LENGTH, maxContentLength()); diff --git a/server/src/test/java/org/elasticsearch/http/HttpInfoTests.java b/server/src/test/java/org/elasticsearch/http/HttpInfoTests.java index cd0cf7e189429..89abe0b8f980e 100644 --- a/server/src/test/java/org/elasticsearch/http/HttpInfoTests.java +++ b/server/src/test/java/org/elasticsearch/http/HttpInfoTests.java @@ -40,26 +40,11 @@ public void testCorrectlyDisplayPublishedCname() throws Exception { new BoundTransportAddress( new TransportAddress[]{new TransportAddress(localhost, port)}, new TransportAddress(localhost, port) - ), 0L, false + ), 0L ), "localhost/" + NetworkAddress.format(localhost) + ':' + port ); } - public void testDeprecatedWarningIfPropertySpecified() throws Exception { - InetAddress localhost = InetAddress.getByName("localhost"); - int port = 9200; - assertPublishAddress( - new HttpInfo( - new BoundTransportAddress( - new TransportAddress[]{new TransportAddress(localhost, port)}, - new TransportAddress(localhost, port) - ), 0L, true - ), "localhost/" + NetworkAddress.format(localhost) + ':' + port - ); - assertWarnings( - "es.http.cname_in_publish_address system property is deprecated and no longer affects http.publish_address " + - "formatting. Remove this property to get rid of this deprecation warning."); - } public void testCorrectDisplayPublishedIp() throws Exception { InetAddress localhost = InetAddress.getByName(NetworkAddress.format(InetAddress.getByName("localhost"))); @@ -69,7 +54,7 @@ public void testCorrectDisplayPublishedIp() throws Exception { new BoundTransportAddress( new TransportAddress[]{new TransportAddress(localhost, port)}, new TransportAddress(localhost, port) - ), 0L, false + ), 0L ), NetworkAddress.format(localhost) + ':' + port ); } @@ -80,7 +65,7 @@ public void testCorrectDisplayPublishedIpv6() throws Exception { new TransportAddress(InetAddress.getByName(NetworkAddress.format(InetAddress.getByName("0:0:0:0:0:0:0:1"))), port); assertPublishAddress( new HttpInfo( - new BoundTransportAddress(new TransportAddress[]{localhost}, localhost), 0L, false + new BoundTransportAddress(new TransportAddress[]{localhost}, localhost), 0L ), localhost.toString() ); }