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

more TDB

This commit is contained in:
Hongze Cheng 2022-03-23 09:35:25 +00:00
parent 33e119e9c0
commit 48306365ae
1 changed files with 14 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
source/libs/tdb/src/db/tdbBtree.c
View File

@ -563,10 +563,10 @@ static int tdbBtreeBalanceNonRoot(SBTree *pBt, SPage *pParent, int idx) {
int nNews = 0; int nNews = 0;
struct { struct {
int cnt; int cnt;
int size; int size;
SPage *pPage; int iPage;
int oIdx; int oIdx;
} infoNews[5] = {0}; } infoNews[5] = {0};
{ // Get how many new pages are needed and the new distribution { // Get how many new pages are needed and the new distribution
@ -596,7 +596,7 @@ static int tdbBtreeBalanceNonRoot(SBTree *pBt, SPage *pParent, int idx) {
} }
infoNews[nNews].cnt++; infoNews[nNews].cnt++;
infoNews[nNews].size += cellBytes; infoNews[nNews].size += cellBytes;
infoNews[nNews].pPage = pPage; infoNews[nNews].iPage = oPage;
infoNews[nNews].oIdx = oIdx; infoNews[nNews].oIdx = oIdx;
} }
} }
@ -609,21 +609,23 @@ static int tdbBtreeBalanceNonRoot(SBTree *pBt, SPage *pParent, int idx) {
int szLCell, szRCell; int szLCell, szRCell;
for (;;) { for (;;) {
pCell = tdbPageGetCell(infoNews[iNew - 1].pPage, infoNews[iNew - 1].oIdx); pCell = tdbPageGetCell(pOlds[infoNews[iNew - 1].iPage], infoNews[iNew - 1].oIdx);
if (childNotLeaf) { if (childNotLeaf) {
szLCell = szRCell = tdbBtreeCellSize(infoNews[iNew - 1].pPage, pCell); szLCell = szRCell = tdbBtreeCellSize(pOlds[infoNews[iNew - 1].iPage], pCell);
} else { } else {
szLCell = tdbBtreeCellSize(infoNews[iNew - 1].pPage, pCell); szLCell = tdbBtreeCellSize(pOlds[infoNews[iNew - 1].iPage], pCell);
SPage *pPage = infoNews[iNew - 1].pPage; int iPage = infoNews[iNew - 1].iPage;
int oIdx = infoNews[iNew - 1].oIdx + 1; int oIdx = infoNews[iNew - 1].oIdx + 1;
SPage *pPage;
for (;;) { for (;;) {
pPage = pOlds[iPage];
if (oIdx < TDB_PAGE_TOTAL_CELLS(pPage)) { if (oIdx < TDB_PAGE_TOTAL_CELLS(pPage)) {
break; break;
} }
pPage++; iPage++;
oIdx = 0; oIdx = 0;
} }
@ -646,8 +648,8 @@ static int tdbBtreeBalanceNonRoot(SBTree *pBt, SPage *pParent, int idx) {
break; break;
} }
infoNews[iNew - 1].pPage--; infoNews[iNew - 1].iPage--;
infoNews[iNew - 1].oIdx = TDB_PAGE_TOTAL_CELLS(infoNews[iNew - 1].pPage) - 1; infoNews[iNew - 1].oIdx = TDB_PAGE_TOTAL_CELLS(pOlds[infoNews[iNew - 1].iPage]) - 1;
} }
infoNews[iNew].cnt++; infoNews[iNew].cnt++;