Skip to content

Commit 845c5fd

Browse files
authored
[ISSUE apache#1846] Dledger model change into pipeline manner to improve performance (apache#1847)
* enhancement(dledger):implement asyncPutMessage in dledger commitlog * enhancement(dledger):move serialization out of lock * fix(dledger):fix the issue that queueOffset is overwritten * fix(dledger):fix the issue that get wrong queueOffset * test(dledger):add dledgerCommitlog put messages async unit test * chore(dledger): fix the issue that cannot find symbol of variable SCHEDULE_TOPIC
1 parent 3be7033 commit 845c5fd

File tree

3 files changed

+231
-88
lines changed

3 files changed

+231
-88
lines changed

common/src/main/java/org/apache/rocketmq/common/message/MessageDecoder.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -42,6 +42,7 @@ public class MessageDecoder {
4242
public static final char NAME_VALUE_SEPARATOR = 1;
4343
public static final char PROPERTY_SEPARATOR = 2;
4444
public static final int PHY_POS_POSITION = 4 + 4 + 4 + 4 + 4 + 8;
45+
public static final int QUEUE_OFFSET_POSITION = 4 + 4 + 4 + 4 + 4;
4546
public static final int SYSFLAG_POSITION = 4 + 4 + 4 + 4 + 4 + 8 + 8;
4647
// public static final int BODY_SIZE_POSITION = 4 // 1 TOTALSIZE
4748
// + 4 // 2 MAGICCODE

0 commit comments

Comments
 (0)