Skip to content

Commit 29d21b2

Browse files
authored
IGNITE-24102 Remove VERSION_SINCE_CLIENT_COULD_WAIT_TO_CONNECT (#11821)
1 parent 5f15d9b commit 29d21b2

File tree

1 file changed

+1
-9
lines changed

1 file changed

+1
-9
lines changed

modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/internal/InboundConnectionHandler.java

Lines changed: 1 addition & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -46,7 +46,6 @@
4646
import org.apache.ignite.internal.util.typedef.internal.LT;
4747
import org.apache.ignite.internal.util.typedef.internal.U;
4848
import org.apache.ignite.lang.IgniteInClosure;
49-
import org.apache.ignite.lang.IgniteProductVersion;
5049
import org.apache.ignite.lang.IgniteRunnable;
5150
import org.apache.ignite.plugin.extensions.communication.Message;
5251
import org.apache.ignite.spi.communication.CommunicationListener;
@@ -76,12 +75,6 @@
7675
* This class implement NioListener which process handshake stage, and transmit messages to session.
7776
*/
7877
public class InboundConnectionHandler extends GridNioServerListenerAdapter<Message> {
79-
/**
80-
* Version when client is ready to wait to connect to server (could be needed when client tries to open connection
81-
* before it starts being visible for server)
82-
*/
83-
private static final IgniteProductVersion VERSION_SINCE_CLIENT_COULD_WAIT_TO_CONNECT = IgniteProductVersion.fromString("2.1.4");
84-
8578
/** Message tracker meta for session. */
8679
private static final int TRACKER_META = GridNioSessionMetaKey.nextUniqueKey();
8780

@@ -505,8 +498,7 @@ private void onFirstMessage(final GridNioSession ses, Message msg) {
505498
if (node0 != null) {
506499
assert node0.isClient() : node0;
507500

508-
if (node0.version().compareTo(VERSION_SINCE_CLIENT_COULD_WAIT_TO_CONNECT) >= 0)
509-
unknownNode = false;
501+
unknownNode = false;
510502
}
511503
}
512504
else if (discoverySpi instanceof IgniteDiscoverySpi)

0 commit comments

Comments
 (0)