diff --git a/build.gradle b/build.gradle index db85a1d3e8903..39d227461a5c6 100644 --- a/build.gradle +++ b/build.gradle @@ -219,8 +219,8 @@ task verifyVersions { * after the backport of the backcompat code is complete. */ -boolean bwc_tests_enabled = false -final String bwc_tests_disabled_issue = "https://github.com/elastic/elasticsearch/pull/52385" /* place a PR link here when committing bwc changes */ +boolean bwc_tests_enabled = true +final String bwc_tests_disabled_issue = "" /* place a PR link here when committing bwc changes */ if (bwc_tests_enabled == false) { if (bwc_tests_disabled_issue.isEmpty()) { throw new GradleException("bwc_tests_disabled_issue must be set when bwc_tests_enabled == false") diff --git a/server/src/main/java/org/elasticsearch/common/util/concurrent/ThreadContext.java b/server/src/main/java/org/elasticsearch/common/util/concurrent/ThreadContext.java index 6421fec0fc45c..edc2c563ae2a3 100644 --- a/server/src/main/java/org/elasticsearch/common/util/concurrent/ThreadContext.java +++ b/server/src/main/java/org/elasticsearch/common/util/concurrent/ThreadContext.java @@ -272,7 +272,7 @@ public static Tuple, Map>> readHeadersFr } public static List readAllowedSystemIndices(StreamInput in) throws IOException { - if (in.getVersion().onOrAfter(Version.V_8_0_0)) { // TODO update version on backport + if (in.getVersion().onOrAfter(Version.V_7_7_0)) { return in.readOptionalStringList(); } else { return emptyList(); @@ -663,7 +663,7 @@ private void writeTo(StreamOutput out, Map defaultHeaders) throw } out.writeMap(responseHeaders, StreamOutput::writeString, StreamOutput::writeStringCollection); - if (out.getVersion().onOrAfter(Version.V_8_0_0)) { // TODO update version on backport + if (out.getVersion().onOrAfter(Version.V_7_7_0)) { out.writeOptionalStringCollection(allowedSystemIndexPatterns); } } diff --git a/test/framework/src/main/java/org/elasticsearch/transport/AbstractSimpleTransportTestCase.java b/test/framework/src/main/java/org/elasticsearch/transport/AbstractSimpleTransportTestCase.java index 71bb3350a4d29..c0fd76d7f753b 100644 --- a/test/framework/src/main/java/org/elasticsearch/transport/AbstractSimpleTransportTestCase.java +++ b/test/framework/src/main/java/org/elasticsearch/transport/AbstractSimpleTransportTestCase.java @@ -2369,15 +2369,15 @@ public String executor() { assertEquals(1, transportStats.getRxCount()); assertEquals(2, transportStats.getTxCount()); assertEquals(25, transportStats.getRxSize().getBytes()); - assertEquals(111, transportStats.getTxSize().getBytes()); + assertEquals(113, transportStats.getTxSize().getBytes()); }); sendResponseLatch.countDown(); responseLatch.await(); stats = serviceC.transport.getStats(); // response has been received assertEquals(2, stats.getRxCount()); assertEquals(2, stats.getTxCount()); - assertEquals(50, stats.getRxSize().getBytes()); - assertEquals(111, stats.getTxSize().getBytes()); + assertEquals(52, stats.getRxSize().getBytes()); + assertEquals(113, stats.getTxSize().getBytes()); } finally { serviceC.close(); } @@ -2484,7 +2484,7 @@ public String executor() { assertEquals(1, transportStats.getRxCount()); assertEquals(2, transportStats.getTxCount()); assertEquals(25, transportStats.getRxSize().getBytes()); - assertEquals(111, transportStats.getTxSize().getBytes()); + assertEquals(113, transportStats.getTxSize().getBytes()); }); sendResponseLatch.countDown(); responseLatch.await(); @@ -2498,8 +2498,8 @@ public String executor() { String failedMessage = "Unexpected read bytes size. The transport exception that was received=" + exception; // 49 bytes are the non-exception message bytes that have been received. It should include the initial // handshake message and the header, version, etc bytes in the exception message. - assertEquals(failedMessage, 53 + streamOutput.bytes().length(), stats.getRxSize().getBytes()); - assertEquals(111, stats.getTxSize().getBytes()); + assertEquals(failedMessage, 55 + streamOutput.bytes().length(), stats.getRxSize().getBytes()); + assertEquals(113, stats.getTxSize().getBytes()); } finally { serviceC.close(); }