cleanup wal level 0 before ref removing

This commit is contained in:
Minglei Jin 2024-06-17 08:57:53 +08:00
parent d47fe255ae
commit 930c5d2adf
1 changed files with 2 additions and 2 deletions

View File

@ -232,13 +232,13 @@ void walClose(SWal *pWal) {
pWal->pRefHash = NULL;
taosThreadMutexUnlock(&pWal->mutex);
taosRemoveRef(tsWal.refSetId, pWal->refId);
if (pWal->cfg.level == TAOS_WAL_SKIP) {
wInfo("vgId:%d, remove all wals, path:%s", pWal->cfg.vgId, pWal->path);
taosRemoveDir(pWal->path);
taosMkDir(pWal->path);
}
taosRemoveRef(tsWal.refSetId, pWal->refId);
}
static void walFreeObj(void *wal) {