From b27272d784848b707b1971c05d60c8f4fce0c9cd Mon Sep 17 00:00:00 2001 From: Hongze Cheng Date: Fri, 22 Jul 2022 01:40:02 +0000 Subject: [PATCH] fix memory leak --- source/dnode/vnode/src/tsdb/tsdbRead.c | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/source/dnode/vnode/src/tsdb/tsdbRead.c b/source/dnode/vnode/src/tsdb/tsdbRead.c index 23763bd16c..cd8abe4020 100644 --- a/source/dnode/vnode/src/tsdb/tsdbRead.c +++ b/source/dnode/vnode/src/tsdb/tsdbRead.c @@ -3275,7 +3275,7 @@ int32_t tsdbTakeReadSnap(STsdb* pTsdb, STsdbReadSnap** ppSnap) { tsdbRefMemTable((*ppSnap)->pIMem); } - // fs (todo) + // fs code = tsdbFSRef(pTsdb, &(*ppSnap)->fs); if (code) { taosThreadRwlockUnlock(&pTsdb->rwLock); @@ -3289,6 +3289,7 @@ int32_t tsdbTakeReadSnap(STsdb* pTsdb, STsdbReadSnap** ppSnap) { goto _exit; } + tsdbTrace("vgId:%d take read snapshot", TD_VID(pTsdb->pVnode)); _exit: return code; } @@ -3304,5 +3305,8 @@ void tsdbUntakeReadSnap(STsdb* pTsdb, STsdbReadSnap* pSnap) { } tsdbFSUnref(pTsdb, &pSnap->fs); + taosMemoryFree(pSnap); } + + tsdbTrace("vgId:%d untake read snapshot", TD_VID(pTsdb->pVnode)); }