(ignite) branch master updated: IGNITE-26040 Use MessageSerializer for JobStealingRequest (#12251)

[timoninmaxim]

This is an automated email from the ASF dual-hosted git repository.

timoninmaxim pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite.git


The following commit(s) were added to refs/heads/master by this push:
     new 0f50d8eb2fc IGNITE-26040 Use MessageSerializer for JobStealingRequest 
(#12251)
0f50d8eb2fc is described below

commit 0f50d8eb2fcdd4aea7e0817ad1a8759f54ef4c22
Author: Dmitry Werner <grimekil...@gmail.com>
AuthorDate: Tue Aug 12 17:56:30 2025 +0500

    IGNITE-26040 Use MessageSerializer for JobStealingRequest (#12251)
---
 .../communication/GridIoMessageFactory.java        |  3 +-
 .../collision/jobstealing/JobStealingRequest.java  | 55 ++++------------------
 2 files changed, 12 insertions(+), 46 deletions(-)

diff --git 
a/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoMessageFactory.java
 
b/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoMessageFactory.java
index 632168e69d4..be0306c7750 100644
--- 
a/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoMessageFactory.java
+++ 
b/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoMessageFactory.java
@@ -39,6 +39,7 @@ import 
org.apache.ignite.internal.codegen.GridQueryKillRequestSerializer;
 import org.apache.ignite.internal.codegen.GridQueryKillResponseSerializer;
 import org.apache.ignite.internal.codegen.GridTaskResultRequestSerializer;
 import org.apache.ignite.internal.codegen.IgniteTxKeySerializer;
+import org.apache.ignite.internal.codegen.JobStealingRequestSerializer;
 import org.apache.ignite.internal.codegen.LatchAckMessageSerializer;
 import 
org.apache.ignite.internal.codegen.MissingMappingRequestMessageSerializer;
 import 
org.apache.ignite.internal.codegen.MissingMappingResponseMessageSerializer;
@@ -284,7 +285,7 @@ public class GridIoMessageFactory implements 
MessageFactoryProvider {
         factory.register((short)79, MissingMappingResponseMessage::new, new 
MissingMappingResponseMessageSerializer());
         factory.register((short)80, MetadataRequestMessage::new);
         factory.register((short)81, MetadataResponseMessage::new);
-        factory.register((short)82, JobStealingRequest::new);
+        factory.register((short)82, JobStealingRequest::new, new 
JobStealingRequestSerializer());
         factory.register((short)84, GridByteArrayList::new);
         factory.register((short)85, GridLongList::new);
         factory.register((short)86, GridCacheVersion::new, new 
GridCacheVersionSerializer());
diff --git 
a/modules/core/src/main/java/org/apache/ignite/spi/collision/jobstealing/JobStealingRequest.java
 
b/modules/core/src/main/java/org/apache/ignite/spi/collision/jobstealing/JobStealingRequest.java
index b9c68ee0619..5ac290efad2 100644
--- 
a/modules/core/src/main/java/org/apache/ignite/spi/collision/jobstealing/JobStealingRequest.java
+++ 
b/modules/core/src/main/java/org/apache/ignite/spi/collision/jobstealing/JobStealingRequest.java
@@ -17,17 +17,16 @@
 
 package org.apache.ignite.spi.collision.jobstealing;
 
-import java.nio.ByteBuffer;
+import org.apache.ignite.internal.Order;
 import org.apache.ignite.internal.util.typedef.internal.S;
 import org.apache.ignite.plugin.extensions.communication.Message;
-import org.apache.ignite.plugin.extensions.communication.MessageReader;
-import org.apache.ignite.plugin.extensions.communication.MessageWriter;
 
 /**
  * Job stealing request.
  */
 public class JobStealingRequest implements Message {
     /** Delta. */
+    @Order(0)
     private int delta;
 
     /**
@@ -47,54 +46,20 @@ public class JobStealingRequest implements Message {
     /**
      * @return Delta.
      */
-    int delta() {
+    public int delta() {
         return delta;
     }
 
-    /** {@inheritDoc} */
-    @Override public void onAckReceived() {
-        // No-op.
-    }
-
-    /** {@inheritDoc} */
-    @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) {
-        writer.setBuffer(buf);
-
-        if (!writer.isHeaderWritten()) {
-            if (!writer.writeHeader(directType()))
-                return false;
-
-            writer.onHeaderWritten();
-        }
-
-        switch (writer.state()) {
-            case 0:
-                if (!writer.writeInt(delta))
-                    return false;
-
-                writer.incrementState();
-
-        }
-
-        return true;
+    /**
+     * @param delta New delta.
+     */
+    public void delta(int delta) {
+        this.delta = delta;
     }
 
     /** {@inheritDoc} */
-    @Override public boolean readFrom(ByteBuffer buf, MessageReader reader) {
-        reader.setBuffer(buf);
-
-        switch (reader.state()) {
-            case 0:
-                delta = reader.readInt();
-
-                if (!reader.isLastRead())
-                    return false;
-
-                reader.incrementState();
-
-        }
-
-        return true;
+    @Override public void onAckReceived() {
+        // No-op.
     }
 
     /** {@inheritDoc} */