|
@@ -156,27 +156,29 @@ public class TcpTransportTests extends ESTestCase {
|
|
|
TcpTransport.ensureVersionCompatibility(VersionUtils.randomVersionBetween(random(), Version.CURRENT.minimumCompatibilityVersion(),
|
|
|
Version.CURRENT), Version.CURRENT, randomBoolean());
|
|
|
|
|
|
- TcpTransport.ensureVersionCompatibility(Version.fromString("6.0.0"), Version.fromString("7.0.0"), true);
|
|
|
+ final Version version = Version.fromString("7.0.0");
|
|
|
+ TcpTransport.ensureVersionCompatibility(Version.fromString("6.0.0"), version, true);
|
|
|
IllegalStateException ise = expectThrows(IllegalStateException.class, () ->
|
|
|
- TcpTransport.ensureVersionCompatibility(Version.fromString("6.0.0"), Version.fromString("7.0.0"), false));
|
|
|
- assertEquals("Received message from unsupported version: [6.0.0] minimal compatible version is: [6.5.0]", ise.getMessage());
|
|
|
+ TcpTransport.ensureVersionCompatibility(Version.fromString("6.0.0"), version, false));
|
|
|
+ assertEquals("Received message from unsupported version: [6.0.0] minimal compatible version is: ["
|
|
|
+ + version.minimumCompatibilityVersion() + "]", ise.getMessage());
|
|
|
|
|
|
// For handshake we are compatible with N-2
|
|
|
- TcpTransport.ensureVersionCompatibility(Version.fromString("5.6.0"), Version.fromString("7.0.0"), true);
|
|
|
+ TcpTransport.ensureVersionCompatibility(Version.fromString("5.6.0"), version, true);
|
|
|
ise = expectThrows(IllegalStateException.class, () ->
|
|
|
- TcpTransport.ensureVersionCompatibility(Version.fromString("5.6.0"), Version.fromString("7.0.0"), false));
|
|
|
- assertEquals("Received message from unsupported version: [5.6.0] minimal compatible version is: [6.5.0]",
|
|
|
- ise.getMessage());
|
|
|
+ TcpTransport.ensureVersionCompatibility(Version.fromString("5.6.0"), version, false));
|
|
|
+ assertEquals("Received message from unsupported version: [5.6.0] minimal compatible version is: ["
|
|
|
+ + version.minimumCompatibilityVersion() + "]", ise.getMessage());
|
|
|
|
|
|
ise = expectThrows(IllegalStateException.class, () ->
|
|
|
- TcpTransport.ensureVersionCompatibility(Version.fromString("2.3.0"), Version.fromString("7.0.0"), true));
|
|
|
- assertEquals("Received handshake message from unsupported version: [2.3.0] minimal compatible version is: [6.5.0]",
|
|
|
- ise.getMessage());
|
|
|
+ TcpTransport.ensureVersionCompatibility(Version.fromString("2.3.0"), version, true));
|
|
|
+ assertEquals("Received handshake message from unsupported version: [2.3.0] minimal compatible version is: ["
|
|
|
+ + version.minimumCompatibilityVersion() + "]", ise.getMessage());
|
|
|
|
|
|
ise = expectThrows(IllegalStateException.class, () ->
|
|
|
- TcpTransport.ensureVersionCompatibility(Version.fromString("2.3.0"), Version.fromString("7.0.0"), false));
|
|
|
- assertEquals("Received message from unsupported version: [2.3.0] minimal compatible version is: [6.5.0]",
|
|
|
- ise.getMessage());
|
|
|
+ TcpTransport.ensureVersionCompatibility(Version.fromString("2.3.0"), version, false));
|
|
|
+ assertEquals("Received message from unsupported version: [2.3.0] minimal compatible version is: ["
|
|
|
+ + version.minimumCompatibilityVersion() + "]", ise.getMessage());
|
|
|
}
|
|
|
|
|
|
public void testCompressRequest() throws IOException {
|