xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

Fix logic error.

This commit is contained in:
xiao-77 2024-12-27 17:50:52 +08:00
parent 5c192cbcb5
commit fd7204b04b
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
source/libs/wal/src/walMeta.c
View File

@ -192,6 +192,10 @@ FORCE_INLINE int32_t walScanLogGetLastVer(SWal* pWal, int32_t fileIdx, int64_t*
if (forwardStage && (terrno != TSDB_CODE_SUCCESS || end == fileSize)) break; if (forwardStage && (terrno != TSDB_CODE_SUCCESS || end == fileSize)) break;
} }
if (retVer < 0) {
code = TSDB_CODE_WAL_LOG_NOT_EXIST;
}
// truncate file // truncate file
if (lastEntryEndOffset != fileSize) { if (lastEntryEndOffset != fileSize) {
wWarn("vgId:%d, repair meta truncate file %s to %" PRId64 ", orig size %" PRId64, pWal->cfg.vgId, fnameStr, wWarn("vgId:%d, repair meta truncate file %s to %" PRId64 ", orig size %" PRId64, pWal->cfg.vgId, fnameStr,
@ -211,8 +215,8 @@ FORCE_INLINE int32_t walScanLogGetLastVer(SWal* pWal, int32_t fileIdx, int64_t*
pFileInfo->fileSize = lastEntryEndOffset; pFileInfo->fileSize = lastEntryEndOffset;
_err: _err:
if (retVer < 0) { if (code != 0) {
code = TSDB_CODE_WAL_LOG_NOT_EXIST; wError("vgId:%d, failed to scan log file due to %s, file:%s", pWal->cfg.vgId, strerror(errno), fnameStr);
} }
taosCloseFile(&pFile); taosCloseFile(&pFile);
taosMemoryFree(buf); taosMemoryFree(buf);