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

Fix review errors.

This commit is contained in:
xiao-77 2024-12-26 15:08:18 +08:00
parent 9fea6fd295
commit 1a753fedc7
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -214,16 +214,16 @@ static int32_t walReadSeekVerImpl(SWalReader *pReader, int64_t ver) {
TAOS_UNUSED(taosThreadRwlockUnlock(&pWal->mutex)); TAOS_UNUSED(taosThreadRwlockUnlock(&pWal->mutex));
TAOS_RETURN(TSDB_CODE_WAL_INVALID_VER); TAOS_RETURN(TSDB_CODE_WAL_INVALID_VER);
} }
SWalFileInfo pRet; SWalFileInfo ret;
TAOS_MEMCPY(&pRet, globalRet, sizeof(SWalFileInfo)); TAOS_MEMCPY(&ret, globalRet, sizeof(SWalFileInfo));
TAOS_UNUSED(taosThreadRwlockUnlock(&pWal->mutex)); TAOS_UNUSED(taosThreadRwlockUnlock(&pWal->mutex));
if (pReader->curFileFirstVer != pRet.firstVer) { if (pReader->curFileFirstVer != ret.firstVer) {
// error code was set inner // error code was set inner
TAOS_CHECK_RETURN(walReadChangeFile(pReader, pRet.firstVer)); TAOS_CHECK_RETURN(walReadChangeFile(pReader, ret.firstVer));
} }
// error code was set inner // error code was set inner
TAOS_CHECK_RETURN(walReadSeekFilePos(pReader, pRet.firstVer, ver)); TAOS_CHECK_RETURN(walReadSeekFilePos(pReader, ret.firstVer, ver));
wDebug("vgId:%d, wal version reset from %" PRId64 " to %" PRId64, pReader->pWal->cfg.vgId, pReader->curVersion, ver); wDebug("vgId:%d, wal version reset from %" PRId64 " to %" PRId64, pReader->pWal->cfg.vgId, pReader->curVersion, ver);
pReader->curVersion = ver; pReader->curVersion = ver;