Annotate

store/src/main/java/org/apache/rocketmq/store/dledger/DLedgerCommitLog.java

@@ -270,6 +270,8 @@ public class DLedgerCommitLog extends CommitLog {
         }
         //Indicate that, it is the first time to load mixed commitlog, need to recover the old commitlog
         isInrecoveringOldCommitlog = true;
+        //TODO only do the normal recover
+        //No need the abnormal recover
         if (lastOk) {
             super.recoverNormally(maxPhyOffsetOfConsumeQueue);
         } else {
@@ -300,6 +302,7 @@ public class DLedgerCommitLog extends CommitLog {
             byteBuffer.putInt(mappedFile.getFileSize() - mappedFile.getWrotePosition());
             byteBuffer.putInt(BLANK_MAGIC_CODE);
             mappedFile.flush(0);
+            //TODO already set
             mappedFile.setWrotePosition(mappedFile.getFileSize());
             mappedFile.setCommittedPosition(mappedFile.getFileSize());
             mappedFile.setFlushedPosition(mappedFile.getFileSize());