cache: remove nFileset from fs state
This commit is contained in:
parent
7ad628417a
commit
a593e887fa
|
@ -1840,7 +1840,6 @@ typedef struct SFSNextRowIter {
|
||||||
STSchema *pTSchema; // [input]
|
STSchema *pTSchema; // [input]
|
||||||
tb_uid_t suid;
|
tb_uid_t suid;
|
||||||
tb_uid_t uid;
|
tb_uid_t uid;
|
||||||
int32_t nFileSet;
|
|
||||||
int32_t iFileSet;
|
int32_t iFileSet;
|
||||||
STFileSet *pFileSet;
|
STFileSet *pFileSet;
|
||||||
TFileSetArray *aDFileSet;
|
TFileSetArray *aDFileSet;
|
||||||
|
@ -1874,8 +1873,7 @@ static int32_t getNextRowFromFS(void *iter, TSDBROW **ppRow, bool *pIgnoreEarlie
|
||||||
STsdb *pTsdb = state->pr->pTsdb;
|
STsdb *pTsdb = state->pr->pTsdb;
|
||||||
|
|
||||||
if (SFSNEXTROW_FS == state->state) {
|
if (SFSNEXTROW_FS == state->state) {
|
||||||
state->nFileSet = TARRAY2_SIZE(state->aDFileSet);
|
state->iFileSet = TARRAY2_SIZE(state->aDFileSet);
|
||||||
state->iFileSet = state->nFileSet;
|
|
||||||
|
|
||||||
state->state = SFSNEXTROW_FILESET;
|
state->state = SFSNEXTROW_FILESET;
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue