Skip to content

Commit

Permalink
add log
Browse files Browse the repository at this point in the history
  • Loading branch information
iamgd67 committed Oct 20, 2023
1 parent 8c64872 commit cd0ab8d
Showing 1 changed file with 1 addition and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -322,6 +322,7 @@ public void recoverNormally(long maxPhyOffsetOfConsumeQueue) throws RocksDBExcep
long lastValidMsgPhyOffset = this.getConfirmOffset();
// normal recover doesn't require dispatching
boolean doDispatch = false;
log.info("recover physics file {}", mappedFile.getFileName());
while (true) {
// if not checkcrc not need to read body, so pass checkCRCOnRecover as readBody
DispatchRequest dispatchRequest = this.checkMessageAndReturnSize(byteBuffer, checkCRCOnRecover, checkDupInfo, checkCRCOnRecover);
Expand Down

0 comments on commit cd0ab8d

Please sign in to comment.