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

fix: use fseeko

This commit is contained in:
slzhou 2024-02-04 21:12:19 +08:00
parent 18366934c3
commit 247bfae039
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/libs/executor/src/tsort.c
View File

@ -1127,7 +1127,7 @@ static int32_t saveBlockRowToExtRowsMemFile(SSortHandle* pHandle, SSDataBlock* p
pMemFile->currPageOffset = 0; pMemFile->currPageOffset = 0;
} else { } else {
if (pMemFile->currPageOffset + pHandle->extRowBytes >= pMemFile->pageSize) { if (pMemFile->currPageOffset + pHandle->extRowBytes >= pMemFile->pageSize) {
fseek(pMemFile->pTdFile, pMemFile->currPageId * pMemFile->pageSize, SEEK_SET); fseeko(pMemFile->pTdFile, ((int64_t)pMemFile->currPageId) * pMemFile->pageSize, SEEK_SET);
fwrite(pMemFile->pageBuf, pMemFile->currPageOffset + 1, 1, pMemFile->pTdFile); fwrite(pMemFile->pageBuf, pMemFile->currPageOffset + 1, 1, pMemFile->pTdFile);
++pMemFile->currPageId; ++pMemFile->currPageId;
@ -1149,7 +1149,7 @@ static int32_t saveLastPageToExtRowsMemFile(SSortHandle* pHandle) {
if (!pMemFile->bDirty) { if (!pMemFile->bDirty) {
return TSDB_CODE_SUCCESS; return TSDB_CODE_SUCCESS;
} }
fseek(pMemFile->pTdFile, pMemFile->currPageId * pMemFile->pageSize, SEEK_SET); fseeko(pMemFile->pTdFile, ((int64_t)pMemFile->currPageId) * pMemFile->pageSize, SEEK_SET);
fwrite(pMemFile->pageBuf, pMemFile->currPageOffset + 1, 1, pMemFile->pTdFile); fwrite(pMemFile->pageBuf, pMemFile->currPageOffset + 1, 1, pMemFile->pTdFile);
pMemFile->bDirty = false; pMemFile->bDirty = false;
return TSDB_CODE_SUCCESS; return TSDB_CODE_SUCCESS;