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

tsdb/reader-writer: fix pgno iteration with cache setting

This commit is contained in:
Minglei Jin 2023-11-24 09:06:43 +08:00
parent 3c3763a774
commit b1841ee97b
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
source/dnode/vnode/src/tsdb/tsdbReaderWriter.c
View File

@ -341,7 +341,7 @@ static int32_t tsdbReadFileS3(STsdbFD *pFD, int64_t offset, uint8_t *pBuf, int64
memcpy(pBuf + n, pFD->pBuf + bOffset, nRead); memcpy(pBuf + n, pFD->pBuf + bOffset, nRead);
n += nRead; n += nRead;
pgno++; ++pgno;
bOffset = 0; bOffset = 0;
} }
@ -367,6 +367,7 @@ static int32_t tsdbReadFileS3(STsdbFD *pFD, int64_t offset, uint8_t *pBuf, int64
tsdbCacheSetPageS3(pFD->pTsdb->pgCache, pFD, pgno, pBlock + i * pFD->szPage); tsdbCacheSetPageS3(pFD->pTsdb->pgCache, pFD, pgno, pBlock + i * pFD->szPage);
if (szHint > 0 && n >= size) { if (szHint > 0 && n >= size) {
++pgno;
continue; continue;
} }
memcpy(pFD->pBuf, pBlock + i * pFD->szPage, pFD->szPage); memcpy(pFD->pBuf, pBlock + i * pFD->szPage, pFD->szPage);
@ -383,7 +384,7 @@ static int32_t tsdbReadFileS3(STsdbFD *pFD, int64_t offset, uint8_t *pBuf, int64
memcpy(pBuf + n, pFD->pBuf + bOffset, nRead); memcpy(pBuf + n, pFD->pBuf + bOffset, nRead);
n += nRead; n += nRead;
pgno++; ++pgno;
bOffset = 0; bOffset = 0;
} }