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

refact some code

This commit is contained in:
Hongze Cheng 2022-08-30 11:31:35 +08:00
parent 4c847cde6b
commit e73b4a68bb
1 changed files with 14 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
source/dnode/vnode/src/tsdb/tsdbMergeTree.c
View File

@ -84,32 +84,29 @@ void tLDataIterNextBlock(SLDataIter *pIter) {
int32_t tLDataIterNextRow(SLDataIter *pIter) {
int32_t code = 0;
int32_t iBlockL = pIter->iBlockL;
if (pIter->backward) {
pIter->iRow--;
if (pIter->iRow < 0) {
pIter->iBlockL--;
if (pIter->iBlockL >= 0) {
code = tsdbReadLastBlockEx(pIter->pReader, pIter->iLast, taosArrayGet(pIter->aBlockL, pIter->iBlockL),
&pIter->bData);
if (code) goto _exit;
} else {
// TODO: no more data here
}
tLDataIterNextBlock(pIter);
}
} else {
pIter->iRow++;
if (pIter->iRow >= pIter->bData.nRow) {
pIter->iBlockL++;
if (pIter->iBlockL < taosArrayGetSize(pIter->aBlockL)) {
code = tsdbReadLastBlockEx(pIter->pReader, pIter->iLast, taosArrayGet(pIter->aBlockL, pIter->iBlockL),
&pIter->bData);
if (code) goto _exit;
} else {
// TODO: not more data
goto _exit;
tLDataIterNextBlock(pIter);
}
}
if (iBlockL != pIter->iBlockL) {
if (pIter->pBlockL) {
code = tsdbReadLastBlockEx(pIter->pReader, pIter->iLast, pIter->pBlockL, &pIter->bData);
if (code) goto _exit;
pIter->iRow = 0;
} else {
// no more data
goto _exit;
}
}
pIter->rInfo.suid = pIter->bData.suid;