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

refact

This commit is contained in:
Hongze Cheng 2022-03-01 06:46:50 +00:00
parent 3902294f01
commit 8bd4beec94
4 changed files with 22 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -117,23 +117,27 @@ static int tdbBtCursorMoveTo(SBtCursor *pCur, const void *pKey, int kLen) {
return -1;
}
for (;;) {
int lidx, ridx, midx, c;
if (pCur->pPage->pHdr->nCells == 0) {
// Tree is empty
} else {
for (;;) {
int lidx, ridx, midx, c;
pBtPage = pCur->pPage;
lidx = 0;
ridx = pBtPage->pHdr->nCells - 1;
while (lidx <= ridx) {
midx = (lidx + ridx) >> 1;
pCell = (void *)(pBtPage->aData + pBtPage->aCellIdx[midx]);
pBtPage = pCur->pPage;
lidx = 0;
ridx = pBtPage->pHdr->nCells - 1;
while (lidx <= ridx) {
midx = (lidx + ridx) >> 1;
pCell = (void *)(pBtPage->aData + pBtPage->aCellIdx[midx]);
c = tdbCompareKeyAndCell(pKey, kLen, pCell);
if (c == 0) {
break;
} else if (c < 0) {
lidx = lidx + 1;
} else {
ridx = ridx - 1;
c = tdbCompareKeyAndCell(pKey, kLen, pCell);
if (c == 0) {
break;
} else if (c < 0) {
lidx = lidx + 1;
} else {
ridx = ridx - 1;
}
}
}

2
source/libs/tdb/src/db/tdbDb.c
View File

@ -38,7 +38,7 @@ int tdbDbOpen(const char *fname, int keyLen, int valLen, FKeyComparator keyCmprF
// pDb->pEnv
pDb->pEnv = pEnv;
pFile = tdbEnvGetPFile(pEnv, fname);
pFile = tdbEnvGetPager(pEnv, fname);
if (pFile == NULL) {
snprintf(fFullName, TDB_FILENAME_LEN, "%s/%s", pEnv->rootDir, fname);
ret = tdbPagerOpen(pEnv->pCache, fFullName, &pFile);

2
source/libs/tdb/src/db/tdbEnv.c
View File

@ -64,7 +64,7 @@ int tdbEnvClose(STEnv *pEnv) {
return 0;
}
SPager *tdbEnvGetPFile(STEnv *pEnv, const char *fname) {
SPager *tdbEnvGetPager(STEnv *pEnv, const char *fname) {
// TODO
return NULL;
}

2
source/libs/tdb/src/inc/tdbEnv.h
View File

@ -30,7 +30,7 @@ typedef struct STEnv {
int tdbEnvOpen(const char *rootDir, int pageSize, int cacheSize, STEnv **ppEnv);
int tdbEnvClose(STEnv *pEnv);
SPager *tdbEnvGetPFile(STEnv *pEnv, const char *fname);
SPager *tdbEnvGetPager(STEnv *pEnv, const char *fname);
#ifdef __cplusplus
}