IGNITE-26773 Use MessageSerializer for GridDhtAtomicSingleUpdateRequest (#12436)

Author: w3ll1ngt

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

@@ -55,6 +55,7 @@
 import org.apache.ignite.internal.codegen.GridDhtAffinityAssignmentRequestSerializer;
 import org.apache.ignite.internal.codegen.GridDhtAtomicDeferredUpdateResponseSerializer;
 import org.apache.ignite.internal.codegen.GridDhtAtomicNearResponseSerializer;
+import org.apache.ignite.internal.codegen.GridDhtAtomicSingleUpdateRequestSerializer;
 import org.apache.ignite.internal.codegen.GridDhtAtomicUpdateResponseSerializer;
 import org.apache.ignite.internal.codegen.GridDhtForceKeysRequestSerializer;
 import org.apache.ignite.internal.codegen.GridDhtForceKeysResponseSerializer;
@@ -307,7 +308,7 @@ public class GridIoMessageFactory implements MessageFactoryProvider {
         factory.register((short)-48, GridDhtAtomicNearResponse::new, new GridDhtAtomicNearResponseSerializer());
         factory.register((short)-45, GridChangeGlobalStateMessageResponse::new, new GridChangeGlobalStateMessageResponseSerializer());
         factory.register((short)-43, IgniteIoTestMessage::new);
-        factory.register((short)-36, GridDhtAtomicSingleUpdateRequest::new);
+        factory.register((short)-36, GridDhtAtomicSingleUpdateRequest::new, new GridDhtAtomicSingleUpdateRequestSerializer());
         factory.register((short)-27, GridDhtTxOnePhaseCommitAckRequest::new, new GridDhtTxOnePhaseCommitAckRequestSerializer());
         factory.register((short)-26, TxLockList::new, new TxLockListSerializer());
         factory.register((short)-25, TxLock::new, new TxLockSerializer());

modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicAbstractUpdateFuture.java

@@ -26,7 +26,6 @@
 import javax.cache.processor.EntryProcessor;
 import org.apache.ignite.IgniteCheckedException;
 import org.apache.ignite.IgniteLogger;
-import org.apache.ignite.cache.CacheWriteSynchronizationMode;
 import org.apache.ignite.cluster.ClusterNode;
 import org.apache.ignite.internal.IgniteInternalFuture;
 import org.apache.ignite.internal.cluster.ClusterTopologyCheckedException;
@@ -171,8 +170,6 @@ final void addWriteEntry(
         if (log.isDebugEnabled())
             log.debug("Mapping entry to DHT nodes [nodes=" + nodeIds(dhtNodes) + ", entry=" + entry + ']');
 
-        CacheWriteSynchronizationMode syncMode = updateReq.writeSynchronizationMode();
-
         addDhtKey(entry.key(), dhtNodes);
 
         for (int i = 0; i < dhtNodes.size(); i++) {
@@ -188,7 +185,6 @@ final void addWriteEntry(
                         node.id(),
                         futId,
                         writeVer,
-                        syncMode,
                         topVer,
                         ttl,
                         conflictExpireTime,
@@ -245,8 +241,6 @@ final void addNearWriteEntries(
         boolean readRepairRecovery) {
         assert readers != null;
 
-        CacheWriteSynchronizationMode syncMode = updateReq.writeSynchronizationMode();
-
         addNearKey(entry.key(), readers);
 
         AffinityTopologyVersion topVer = updateReq.topologyVersion();
@@ -278,7 +272,6 @@ final void addNearWriteEntries(
                     node.id(),
                     futId,
                     writeVer,
-                    syncMode,
                     topVer,
                     ttl,
                     expireTime,
@@ -435,7 +428,7 @@ private void initMapping(GridNearAtomicUpdateResponse updateRes) {
 
     /**
      * @param nearNode Near node.
-     * @param sndRes {@code True} if allow to send result from DHT nodes.
+     * @param sndRes {@code True} if allow sending result from DHT nodes.
      * @param ret Return value.
      */
     private void sendDhtRequests(ClusterNode nearNode, GridCacheReturn ret, boolean sndRes) {
@@ -513,7 +506,6 @@ final void onDhtResponse(UUID nodeId, GridDhtAtomicUpdateResponse res) {
      * @param nodeId Node ID.
      * @param futId Future ID.
      * @param writeVer Update version.
-     * @param syncMode Write synchronization mode.
      * @param topVer Topology version.
      * @param ttl TTL.
      * @param conflictExpireTime Conflict expire time.
@@ -525,7 +517,6 @@ protected abstract GridDhtAtomicAbstractUpdateRequest createRequest(
         UUID nodeId,
         long futId,
         GridCacheVersion writeVer,
-        CacheWriteSynchronizationMode syncMode,
         @NotNull AffinityTopologyVersion topVer,
         long ttl,
         long conflictExpireTime,