opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-08-28 20:09:14 +08:00
Code Issues Packages Projects Releases Wiki Activity

[ISSUE #10819] Correct misleading CommitLog buffer comment (#10820)

Browse Source 
* [ISSUE #10819] Correct misleading CommitLog buffer comment

* [ISSUE #10819] Refine CommitLog comment wording
This commit is contained in:
fuyou001
2026-08-06 16:33:59 +08:00
committed by GitHub
parent 2daf0e2ca9
commit cbebac2e66
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
store/src/main/java/org/apache/rocketmq/store/CommitLog.java
+1 -1
View File
@@ -2092,7 +2092,7 @@ public class CommitLog implements Swappable {
final long beginTimeMills = CommitLog.this.defaultMessageStore.now();
CommitLog.this.getMessageStore().getPerfCounter().startTick("WRITE_MEMORY_TIME_MS");
// Write messages to the queue buffer
// Append the encoded message to the current CommitLog buffer
byteBuffer.put(preEncodeBuffer);
CommitLog.this.getMessageStore().getPerfCounter().endTick("WRITE_MEMORY_TIME_MS");
msgInner.setEncodedBuff(null);