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

fix: fix filter error result

This commit is contained in:
yihaoDeng 2023-02-13 13:47:22 +08:00
parent 5af1faf916
commit 16da9d78a9
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
source/dnode/vnode/src/meta/metaQuery.c
View File

@ -1123,11 +1123,11 @@ int32_t metaFilterCreateTime(SMeta *pMeta, SMetaFltParam *param, SArray *pUids)
if (cmp == 0) if (cmp == 0)
taosArrayPush(pUids, &p->uid); taosArrayPush(pUids, &p->uid);
else { else {
count++;
if (count >= TRY_ERROR_LIMIT) { if (count >= TRY_ERROR_LIMIT) {
break; break;
} }
} }
count++;
valid = param->reverse ? tdbTbcMoveToPrev(pCursor->pCur) : tdbTbcMoveToNext(pCursor->pCur); valid = param->reverse ? tdbTbcMoveToPrev(pCursor->pCur) : tdbTbcMoveToNext(pCursor->pCur);
if (valid < 0) break; if (valid < 0) break;
} while (1); } while (1);
@ -1181,11 +1181,11 @@ int32_t metaFilterTableName(SMeta *pMeta, SMetaFltParam *param, SArray *pUids) {
tb_uid_t tuid = *(tb_uid_t *)pEntryVal; tb_uid_t tuid = *(tb_uid_t *)pEntryVal;
taosArrayPush(pUids, &tuid); taosArrayPush(pUids, &tuid);
} else { } else {
count++;
if (count >= TRY_ERROR_LIMIT) { if (count >= TRY_ERROR_LIMIT) {
break; break;
} }
} }
count++;
valid = param->reverse ? tdbTbcMoveToPrev(pCursor->pCur) : tdbTbcMoveToNext(pCursor->pCur); valid = param->reverse ? tdbTbcMoveToPrev(pCursor->pCur) : tdbTbcMoveToNext(pCursor->pCur);
if (valid < 0) { if (valid < 0) {
break; break;