refactor: do some internal refactor.

This commit is contained in:
Haojun Liao 2023-04-30 16:37:09 +08:00
parent d8e0d02e6e
commit 9cc4721e2a
1 changed files with 3 additions and 2 deletions

View File

@ -3529,8 +3529,9 @@ static int32_t buildBlockFromFiles(STsdbReader* pReader) {
SSDataBlock* pResBlock = pReader->resBlockInfo.pResBlock; SSDataBlock* pResBlock = pReader->resBlockInfo.pResBlock;
if (pBlockIter->numOfBlocks == 0) { if (pBlockIter->numOfBlocks == 0) {
// let's try to extract data from stt files.
ERetrieveType type = doReadDataFromLastFiles(pReader); ERetrieveType type = doReadDataFromLastFiles(pReader);
if (type != TSDB_READ_RETURN) { if (type == TSDB_READ_RETURN) {
return terrno; return terrno;
} }
@ -3571,7 +3572,7 @@ static int32_t buildBlockFromFiles(STsdbReader* pReader) {
resetTableListIndex(&pReader->status); resetTableListIndex(&pReader->status);
ERetrieveType type = doReadDataFromLastFiles(pReader); ERetrieveType type = doReadDataFromLastFiles(pReader);
if (type != TSDB_READ_RETURN) { if (type == TSDB_READ_RETURN) {
return terrno; return terrno;
} }
} }