Skip to content

R
Rocketmq

Kwan的解忧杂货铺@新空间代码工作室 / Rocketmq
与 Fork 源项目一致

Fork自 Apache RocketMQ / Rocketmq

通知 1
Star 0
Fork 0
R
Rocketmq
提交 b31c17f9 编写于 作者: D dongeforever
浏览文件
操作

Load and recover for dledger commitlog

上级 77b252bd
隐藏空白更改
内联 并排
Showing with 4 addition and 0 deletion
store/src/main/java/org/apache/rocketmq/store/dledger/DLedgerCommitLog.java
浏览文件 @ b31c17f9
...@@ -263,6 +263,8 @@ public class DLedgerCommitLog extends CommitLog { ...@@ -263,6 +263,8 @@ public class DLedgerCommitLog extends CommitLog {
@Override @Override
public void recoverAbnormally(long maxPhyOffsetOfConsumeQueue) { public void recoverAbnormally(long maxPhyOffsetOfConsumeQueue) {
dLedgerFileStore.load();
dLedgerFileStore.recover();
if (dLedgerFileList.getMappedFiles().isEmpty()) { if (dLedgerFileList.getMappedFiles().isEmpty()) {
super.recoverAbnormally(maxPhyOffsetOfConsumeQueue); super.recoverAbnormally(maxPhyOffsetOfConsumeQueue);
} }
...@@ -270,6 +272,8 @@ public class DLedgerCommitLog extends CommitLog { ...@@ -270,6 +272,8 @@ public class DLedgerCommitLog extends CommitLog {
@Override @Override
public void recoverNormally(long maxPhyOffsetOfConsumeQueue) { public void recoverNormally(long maxPhyOffsetOfConsumeQueue) {
dLedgerFileStore.load();
dLedgerFileStore.recover();
if (dLedgerFileList.getMappedFiles().isEmpty()) { if (dLedgerFileList.getMappedFiles().isEmpty()) {
super.recoverNormally(maxPhyOffsetOfConsumeQueue); super.recoverNormally(maxPhyOffsetOfConsumeQueue);
} }
......
Markdown is supported
0% 或 .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑！
想要评论请 注册 或