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-21 10:23:34 +00:00
parent 1075c230ed
commit b5b522d666
2 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -690,7 +690,6 @@ static int tdbBtreeBalanceNonRoot(SBTree *pBt, SPage *pParent, int idx) {
int nNews = 0; int nNews = 0;
int cntNews[5] = {0}; // TODO: maybe 5 is not enough int cntNews[5] = {0}; // TODO: maybe 5 is not enough
int szNews[5] = {0}; int szNews[5] = {0};
int maxPageCapacity; // TODO
{ // Get how many new pages are needed and the new distribution { // Get how many new pages are needed and the new distribution
@ -699,11 +698,12 @@ static int tdbBtreeBalanceNonRoot(SBTree *pBt, SPage *pParent, int idx) {
SPage *pPage = pOlds[i]; SPage *pPage = pOlds[i];
SCell *pCell; SCell *pCell;
int cellBytes; int cellBytes;
for (int cIdx = 0; cIdx < TDB_PAGE_TOTAL_CELLS(pPage); cIdx++) { for (int cIdx = 0; cIdx < TDB_PAGE_TOTAL_CELLS(pPage); cIdx++) {
pCell = tdbPageGetCell(pPage, cIdx); pCell = tdbPageGetCell(pPage, cIdx);
cellBytes = TDB_BYTES_CELL_TAKEN(pPage, pCell); cellBytes = TDB_BYTES_CELL_TAKEN(pPage, pCell);
if (szNews[nNews] + cellBytes > maxPageCapacity) { if (szNews[nNews] + cellBytes > TDB_PAGE_USABLE_SIZE(pPage)) {
nNews++; nNews++;
} }
cntNews[nNews]++; cntNews[nNews]++;

1
source/libs/tdb/src/inc/tdbPage.h
View File

@ -99,6 +99,7 @@ struct SPage {
// APIs // APIs
#define TDB_PAGE_TOTAL_CELLS(pPage) ((pPage)->nOverflow + (pPage)->pPageMethods->getCellNum(pPage)) #define TDB_PAGE_TOTAL_CELLS(pPage) ((pPage)->nOverflow + (pPage)->pPageMethods->getCellNum(pPage))
#define TDB_PAGE_USABLE_SIZE(pPage) ((u8 *)(pPage)->pPageFtr - (pPage)->pCellIdx)
#define TDB_BYTES_CELL_TAKEN(pPage, pCell) ((*(pPage)->xCellSize)(pPage, pCell) + (pPage)->pPageMethods->szOffset) #define TDB_BYTES_CELL_TAKEN(pPage, pCell) ((*(pPage)->xCellSize)(pPage, pCell) + (pPage)->pPageMethods->szOffset)
int tdbPageCreate(int pageSize, SPage **ppPage, void *(*xMalloc)(void *, size_t), void *arg); int tdbPageCreate(int pageSize, SPage **ppPage, void *(*xMalloc)(void *, size_t), void *arg);