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;