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

fix: first pass

This commit is contained in:
slzhou 2024-02-04 17:51:29 +08:00
parent 8e0f578dba
commit 23bd2aa525
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

@ -1024,8 +1024,6 @@ static int32_t getPageFromExtMemFile(SSortHandle* pHandle, int32_t pageId, char*
} }
pEntry->prev->next = pEntry->next; pEntry->prev->next = pEntry->next;
pEntry->next->prev = pEntry->prev; pEntry->next->prev = pEntry->prev;
taosLSeekFile(pMemFile->pTdFile, pageId * pMemFile->pageSize, SEEK_SET);
taosReadFile(pMemFile->pTdFile, pEntry->data, pMemFile->pageSize);
pEntry->active = false; pEntry->active = false;
} else if (pMemFile->numMemPages < pMemFile->totalMemPages) { } else if (pMemFile->numMemPages < pMemFile->totalMemPages) {
pEntry = taosMemoryCalloc(1, sizeof(SSortMemPageEntry)); pEntry = taosMemoryCalloc(1, sizeof(SSortMemPageEntry));
@ -1033,6 +1031,8 @@ static int32_t getPageFromExtMemFile(SSortHandle* pHandle, int32_t pageId, char*
++pMemFile->numMemPages; ++pMemFile->numMemPages;
} }
{ {
taosLSeekFile(pMemFile->pTdFile, pageId * pMemFile->pageSize, SEEK_SET);
taosReadFile(pMemFile->pTdFile, pEntry->data, pMemFile->pageSize);
SSortMemPageEntry* tail = pMemFile->pagesTail; SSortMemPageEntry* tail = pMemFile->pagesTail;
tail->next = pEntry; tail->next = pEntry;
pEntry->next = NULL; pEntry->next = NULL;