提交 439796f7 编写于 作者: H huangyiming 提交者: von gosling

[ISSUE #375] Replace the message_magic_code and blank_magic_code value

上级 3f7dda3c
...@@ -38,7 +38,7 @@ public class MessageDecoder { ...@@ -38,7 +38,7 @@ public class MessageDecoder {
public final static int MESSAGE_FLAG_POSTION = 16; public final static int MESSAGE_FLAG_POSTION = 16;
public final static int MESSAGE_PHYSIC_OFFSET_POSTION = 28; public final static int MESSAGE_PHYSIC_OFFSET_POSTION = 28;
public final static int MESSAGE_STORE_TIMESTAMP_POSTION = 56; public final static int MESSAGE_STORE_TIMESTAMP_POSTION = 56;
public final static int MESSAGE_MAGIC_CODE = 0xAABBCCDD ^ 1880681586 + 8; public final static int MESSAGE_MAGIC_CODE = -626843481;
public static final char NAME_VALUE_SEPARATOR = 1; public static final char NAME_VALUE_SEPARATOR = 1;
public static final char PROPERTY_SEPARATOR = 2; public static final char PROPERTY_SEPARATOR = 2;
public static final int BODY_SIZE_POSITION = 4 // 1 TOTALSIZE public static final int BODY_SIZE_POSITION = 4 // 1 TOTALSIZE
......
...@@ -44,10 +44,10 @@ import org.apache.rocketmq.store.schedule.ScheduleMessageService; ...@@ -44,10 +44,10 @@ import org.apache.rocketmq.store.schedule.ScheduleMessageService;
*/ */
public class CommitLog { public class CommitLog {
// Message's MAGIC CODE daa320a7 // Message's MAGIC CODE daa320a7
public final static int MESSAGE_MAGIC_CODE = 0xAABBCCDD ^ 1880681586 + 8; public final static int MESSAGE_MAGIC_CODE = -626843481;
private static final InternalLogger log = InternalLoggerFactory.getLogger(LoggerName.STORE_LOGGER_NAME); private static final InternalLogger log = InternalLoggerFactory.getLogger(LoggerName.STORE_LOGGER_NAME);
// End of file empty MAGIC CODE cbd43194 // End of file empty MAGIC CODE cbd43194
private final static int BLANK_MAGIC_CODE = 0xBBCCDDEE ^ 1880681586 + 8; private final static int BLANK_MAGIC_CODE = -875286124;
private final MappedFileQueue mappedFileQueue; private final MappedFileQueue mappedFileQueue;
private final DefaultMessageStore defaultMessageStore; private final DefaultMessageStore defaultMessageStore;
private final FlushCommitLogService flushCommitLogService; private final FlushCommitLogService flushCommitLogService;
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册