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 43d8f027853 IGNITE-26832 Fix buffer size for reading 
RecoveryLastReceivedMessage (#12465)
43d8f027853 is described below

commit 43d8f027853a7ee6fb7c3e1e95209599c74d9205
Author: Maksim Timonin <[email protected]>
AuthorDate: Tue Oct 28 17:24:12 2025 +0300

    IGNITE-26832 Fix buffer size for reading RecoveryLastReceivedMessage 
(#12465)
---
 .../communication/tcp/messages/RecoveryLastReceivedMessage.java  | 9 +++++++--
 1 file changed, 7 insertions(+), 2 deletions(-)

diff --git 
a/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/messages/RecoveryLastReceivedMessage.java
 
b/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/messages/RecoveryLastReceivedMessage.java
index 76c961ed0e1..df260bf10d5 100644
--- 
a/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/messages/RecoveryLastReceivedMessage.java
+++ 
b/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/messages/RecoveryLastReceivedMessage.java
@@ -18,6 +18,7 @@
 package org.apache.ignite.spi.communication.tcp.messages;
 
 import org.apache.ignite.internal.Order;
+import org.apache.ignite.internal.direct.stream.DirectByteBufferStream;
 import org.apache.ignite.internal.util.typedef.internal.S;
 import org.apache.ignite.plugin.extensions.communication.Message;
 import org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi;
@@ -38,8 +39,12 @@ public class RecoveryLastReceivedMessage implements Message {
     /** Initiator node is not in current topogy. */
     public static final long UNKNOWN_NODE = -4;
 
-    /** Message body size in bytes. */
-    private static final int MESSAGE_SIZE = 8;
+    /**
+     * Message body size in bytes. In worst case it uses 10 bytes for 
serialization.
+     *
+     * @see DirectByteBufferStream#writeLong(long).
+     */
+    private static final int MESSAGE_SIZE = 10;
 
     /** Full message size (with message type) in bytes. */
     public static final int MESSAGE_FULL_SIZE = MESSAGE_SIZE + 
DIRECT_TYPE_SIZE;

Reply via email to