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

Enh(wal):Modify the error message when the wal file is corrupted.

This commit is contained in:
xiao-77 2024-12-26 09:29:55 +08:00
parent 807c0f3274
commit de81bfb00d
1 changed files with 12 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
source/libs/wal/src/walRead.c
View File

@ -437,15 +437,15 @@ int32_t walReadVer(SWalReader *pReader, int64_t ver) {
seeked = true; seeked = true;
continue; continue;
} else { } else {
wError("vgId:%d, failed to read WAL record head, index:%" PRId64 ", from log file since %s",
pReader->pWal->cfg.vgId, ver, terrstr());
TAOS_UNUSED(taosThreadMutexUnlock(&pReader->mutex));
if (contLen < 0) { if (contLen < 0) {
TAOS_RETURN(terrno); code = terrno;
} else { } else {
TAOS_RETURN(TSDB_CODE_WAL_FILE_CORRUPTED); code = TSDB_CODE_WAL_FILE_CORRUPTED;
} }
wError("vgId:%d, failed to read WAL record head, index:%" PRId64 ", from log file since %s",
pReader->pWal->cfg.vgId, ver, tstrerror(code));
TAOS_UNUSED(taosThreadMutexUnlock(&pReader->mutex));
TAOS_RETURN(code);
} }
} }
@ -478,15 +478,15 @@ int32_t walReadVer(SWalReader *pReader, int64_t ver) {
} }
if ((contLen = taosReadFile(pReader->pLogFile, pReader->pHead->head.body, cryptedBodyLen)) != cryptedBodyLen) { if ((contLen = taosReadFile(pReader->pLogFile, pReader->pHead->head.body, cryptedBodyLen)) != cryptedBodyLen) {
wError("vgId:%d, failed to read WAL record body, index:%" PRId64 ", from log file since %s",
pReader->pWal->cfg.vgId, ver, terrstr());
TAOS_UNUSED(taosThreadMutexUnlock(&pReader->mutex));
if (contLen < 0) { if (contLen < 0) {
TAOS_RETURN(terrno); code = terrno;
} else { } else {
TAOS_RETURN(TSDB_CODE_WAL_FILE_CORRUPTED); code = TSDB_CODE_WAL_FILE_CORRUPTED;
} }
wError("vgId:%d, failed to read WAL record body, index:%" PRId64 ", from log file since %s",
pReader->pWal->cfg.vgId, ver, strerror(code));
TAOS_UNUSED(taosThreadMutexUnlock(&pReader->mutex));
TAOS_RETURN(code);
} }
if (pReader->pHead->head.version != ver) { if (pReader->pHead->head.version != ver) {