IGNITE-21093 remove MvccMessage (#11144)

modules/core/src/main/java/org/apache/ignite/internal/GridTopic.java

@@ -139,9 +139,6 @@ public enum GridTopic {
     /** */
     TOPIC_EXCHANGE,
 
-    /** */
-    TOPIC_CACHE_COORDINATOR,
-
     /** */
     TOPIC_GEN_ENC_KEY,
 

modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoManager.java

@@ -93,7 +93,6 @@
 import org.apache.ignite.internal.managers.discovery.CustomEventListener;
 import org.apache.ignite.internal.managers.eventstorage.GridEventStorageManager;
 import org.apache.ignite.internal.managers.eventstorage.GridLocalEventListener;
-import org.apache.ignite.internal.processors.cache.mvcc.msg.MvccMessage;
 import org.apache.ignite.internal.processors.cache.persistence.file.FileIO;
 import org.apache.ignite.internal.processors.cache.persistence.file.FileIOFactory;
 import org.apache.ignite.internal.processors.cache.persistence.file.RandomAccessFileIO;
@@ -147,7 +146,6 @@
 import static org.apache.ignite.events.EventType.EVT_NODE_FAILED;
 import static org.apache.ignite.events.EventType.EVT_NODE_JOINED;
 import static org.apache.ignite.events.EventType.EVT_NODE_LEFT;
-import static org.apache.ignite.internal.GridTopic.TOPIC_CACHE_COORDINATOR;
 import static org.apache.ignite.internal.GridTopic.TOPIC_COMM_SYSTEM;
 import static org.apache.ignite.internal.GridTopic.TOPIC_COMM_USER;
 import static org.apache.ignite.internal.GridTopic.TOPIC_IO_TEST;
@@ -1443,17 +1441,6 @@ private void processRegularMessage(
 
             return;
         }
-        if (msg.topicOrdinal() == TOPIC_CACHE_COORDINATOR.ordinal()) {
-            MvccMessage msg0 = (MvccMessage)msg.message();
-
-            // see IGNITE-8609
-            /*if (msg0.processedFromNioThread())
-                c.run();
-            else*/
-            ctx.pools().getStripedExecutorService().execute(-1, c);
-
-            return;
-        }
 
         final int part = msg.partition(); // Store partition to avoid possible recalculation.
 

modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoMessageFactory.java

@@ -123,17 +123,6 @@
 import org.apache.ignite.internal.processors.cache.distributed.near.GridNearUnlockRequest;
 import org.apache.ignite.internal.processors.cache.mvcc.MvccSnapshotWithoutTxs;
 import org.apache.ignite.internal.processors.cache.mvcc.MvccVersionImpl;
-import org.apache.ignite.internal.processors.cache.mvcc.msg.MvccAckRequestQueryCntr;
-import org.apache.ignite.internal.processors.cache.mvcc.msg.MvccAckRequestQueryId;
-import org.apache.ignite.internal.processors.cache.mvcc.msg.MvccAckRequestTx;
-import org.apache.ignite.internal.processors.cache.mvcc.msg.MvccAckRequestTxAndQueryCntr;
-import org.apache.ignite.internal.processors.cache.mvcc.msg.MvccAckRequestTxAndQueryId;
-import org.apache.ignite.internal.processors.cache.mvcc.msg.MvccActiveQueriesMessage;
-import org.apache.ignite.internal.processors.cache.mvcc.msg.MvccFutureResponse;
-import org.apache.ignite.internal.processors.cache.mvcc.msg.MvccQuerySnapshotRequest;
-import org.apache.ignite.internal.processors.cache.mvcc.msg.MvccRecoveryFinishedMessage;
-import org.apache.ignite.internal.processors.cache.mvcc.msg.MvccSnapshotResponse;
-import org.apache.ignite.internal.processors.cache.mvcc.msg.MvccTxSnapshotRequest;
 import org.apache.ignite.internal.processors.cache.persistence.snapshot.IncrementalSnapshotAwareMessage;
 import org.apache.ignite.internal.processors.cache.persistence.snapshot.SnapshotFilesFailureMessage;
 import org.apache.ignite.internal.processors.cache.persistence.snapshot.SnapshotFilesRequestMessage;
@@ -339,19 +328,9 @@ public class GridIoMessageFactory implements MessageFactoryProvider {
         factory.register((short)133, ClusterMetricsUpdateMessage::new);
         factory.register((short)134, ContinuousRoutineStartResultMessage::new);
         factory.register((short)135, LatchAckMessage::new);
-        factory.register((short)136, MvccTxSnapshotRequest::new);
-        factory.register((short)137, MvccAckRequestTx::new);
-        factory.register((short)138, MvccFutureResponse::new);
-        factory.register((short)139, MvccQuerySnapshotRequest::new);
-        factory.register((short)140, MvccAckRequestQueryCntr::new);
-        factory.register((short)141, MvccSnapshotResponse::new);
         factory.register((short)143, GridCacheMvccEntryInfo::new);
         factory.register((short)144, GridDhtTxQueryEnlistResponse::new);
-        factory.register((short)145, MvccAckRequestQueryId::new);
-        factory.register((short)146, MvccAckRequestTxAndQueryCntr::new);
-        factory.register((short)147, MvccAckRequestTxAndQueryId::new);
         factory.register((short)148, MvccVersionImpl::new);
-        factory.register((short)149, MvccActiveQueriesMessage::new);
         factory.register((short)150, MvccSnapshotWithoutTxs::new);
         factory.register((short)151, GridNearTxQueryEnlistRequest::new);
         factory.register((short)152, GridNearTxQueryEnlistResponse::new);
@@ -366,7 +345,6 @@ public class GridIoMessageFactory implements MessageFactoryProvider {
         factory.register((short)161, GridInvokeValue::new);
         factory.register((short)162, GenerateEncryptionKeyRequest::new);
         factory.register((short)163, GenerateEncryptionKeyResponse::new);
-        factory.register((short)164, MvccRecoveryFinishedMessage::new);
         factory.register((short)167, ServiceDeploymentProcessId::new);
         factory.register((short)168, ServiceSingleNodeDeploymentResultBatch::new);
         factory.register((short)169, ServiceSingleNodeDeploymentResult::new);