WIP

Author: timoninmaxim

modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/messages/TcpDiscoveryCheckFailedMessage.java

@@ -65,7 +65,7 @@ public void error(String err) {
 
     /** {@inheritDoc} */
     @Override public short directType() {
-        return -1000;
+        return 0;
     }
 
     /** {@inheritDoc} */

modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoveryCoordinatorFailureTest.java

@@ -284,6 +284,22 @@ public void awaitDrop() throws InterruptedException, IgniteCheckedException {
                 throw new IgniteCheckedException("Failed to wait for NodeAddFinishedMessage");
         }
 
+        /** {@inheritDoc} */
+        @Override protected void writeToSocket(
+            Socket sock,
+            TcpDiscoveryAbstractMessage msg,
+            byte[] data,
+            long timeout
+        ) throws IOException {
+            if (isDrop(msg)) {
+                // Replace logic routine message with a stub to update last-sent-time to avoid segmentation on
+                // connRecoveryTimeout.
+                msg = new TcpDiscoveryConnectionCheckMessage(locNode);
+            }
+
+            super.writeToSocket(sock, msg, data, timeout);
+        }
+
         /** {@inheritDoc} */
         @Override protected void writeToSocket(
             TcpDiscoveryIoSession ses,