[ISSUE #9654] Optimize the bufferLocal size of the TimerMessageStore (#9655)

2026-08-28 20:09:14 +08:00 · 2026-08-03 11:24:22 +08:00
parent a06836dd56
commit 89166af997
1 changed files with 4 additions and 1 deletions
@@ -223,7 +223,10 @@ public class TimerMessageStore {
        bufferLocal = new ThreadLocal<ByteBuffer>() {
            @Override
            protected ByteBuffer initialValue() {
-                return ByteBuffer.allocateDirect(storeConfig.getMaxMessageSize() + 100);
+                int maxMessageBodySize = storeConfig.getMaxMessageSize();
+                int maxMessageSize = Integer.MAX_VALUE - maxMessageBodySize >= 64 * 1024 ?
+                        maxMessageBodySize + 64 * 1024 : Integer.MAX_VALUE;
+                return ByteBuffer.allocateDirect(maxMessageSize);
            }
        };