fix memory leak

This commit is contained in:
Hongze Cheng 2022-07-22 01:40:02 +00:00
parent 63627172c6
commit b27272d784
1 changed files with 5 additions and 1 deletions

View File

@ -3275,7 +3275,7 @@ int32_t tsdbTakeReadSnap(STsdb* pTsdb, STsdbReadSnap** ppSnap) {
tsdbRefMemTable((*ppSnap)->pIMem); tsdbRefMemTable((*ppSnap)->pIMem);
} }
// fs (todo) // fs
code = tsdbFSRef(pTsdb, &(*ppSnap)->fs); code = tsdbFSRef(pTsdb, &(*ppSnap)->fs);
if (code) { if (code) {
taosThreadRwlockUnlock(&pTsdb->rwLock); taosThreadRwlockUnlock(&pTsdb->rwLock);
@ -3289,6 +3289,7 @@ int32_t tsdbTakeReadSnap(STsdb* pTsdb, STsdbReadSnap** ppSnap) {
goto _exit; goto _exit;
} }
tsdbTrace("vgId:%d take read snapshot", TD_VID(pTsdb->pVnode));
_exit: _exit:
return code; return code;
} }
@ -3304,5 +3305,8 @@ void tsdbUntakeReadSnap(STsdb* pTsdb, STsdbReadSnap* pSnap) {
} }
tsdbFSUnref(pTsdb, &pSnap->fs); tsdbFSUnref(pTsdb, &pSnap->fs);
taosMemoryFree(pSnap);
} }
tsdbTrace("vgId:%d untake read snapshot", TD_VID(pTsdb->pVnode));
} }