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

fix: notify when there are no memory pre fileset

This commit is contained in:
slzhou 2023-12-01 15:11:43 +08:00
parent 4d755562af
commit 82629c2658
1 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
source/dnode/vnode/src/tsdb/tsdbRead2.c
View File

@ -2514,6 +2514,15 @@ static void prepareDurationForNextFileSet(STsdbReader* pReader) {
if (pReader->status.bProcMemPreFileset) { if (pReader->status.bProcMemPreFileset) {
resetTableListIndex(&pReader->status); resetTableListIndex(&pReader->status);
} }
if (!pReader->status.bProcMemFirstFileset) {
if (pReader->notifyFn) {
STsdReaderNotifyInfo info = {0};
info.duration.fileSetId = fid;
pReader->notifyFn(TSD_READER_NOTIFY_DURATION_START, &info, pReader->notifyParam);
}
}
pReader->status.prevFilesetStartKey = winFid.skey; pReader->status.prevFilesetStartKey = winFid.skey;
pReader->status.prevFilesetEndKey = winFid.ekey; pReader->status.prevFilesetEndKey = winFid.ekey;
} }