mirror of
https://github.com/apache/rocketmq.git
synced 2026-08-30 18:10:44 +08:00
This commit is contained in:
@@ -162,7 +162,12 @@ public class DLedgerCommitLog extends CommitLog {
|
||||
if (!mappedFileQueue.getMappedFiles().isEmpty()) {
|
||||
return mappedFileQueue.getMinOffset();
|
||||
}
|
||||
return dLedgerFileList.getMinOffset();
|
||||
for (MmapFile file : dLedgerFileList.getMappedFiles()) {
|
||||
if (file.isAvailable()) {
|
||||
return file.getFileFromOffset() + file.getStartPosition();
|
||||
}
|
||||
}
|
||||
return 0;
|
||||
}
|
||||
|
||||
@Override
|
||||
|
||||
Reference in New Issue
Block a user