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-15 08:40:46 +00:00
parent be09ef45f2
commit d0f60b98d5
1 changed files with 1 additions and 45 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -54,8 +54,6 @@ static int tdbDefaultKeyCmprFn(const void *pKey1, int keyLen1, const void *pKey2
static int tdbBtreeOpenImpl(SBTree *pBt); static int tdbBtreeOpenImpl(SBTree *pBt);
static int tdbBtreeZeroPage(SPage *pPage, void *arg); static int tdbBtreeZeroPage(SPage *pPage, void *arg);
static int tdbBtreeInitPage(SPage *pPage, void *arg); static int tdbBtreeInitPage(SPage *pPage, void *arg);
static int tdbEncodeKeyValue(const void *pKey, int kLen, int kLenG, const void *pVal, int vLen, int vLenG, void *pBuf,
int *bLen);
int tdbBtreeOpen(int keyLen, int valLen, SPager *pPager, FKeyComparator kcmpr, SBTree **ppBt) { int tdbBtreeOpen(int keyLen, int valLen, SPager *pPager, FKeyComparator kcmpr, SBTree **ppBt) {
SBTree *pBt; SBTree *pBt;
@ -147,8 +145,7 @@ int tdbBtCursorInsert(SBtCursor *pCur, const void *pKey, int kLen, const void *p
} }
} }
// Encode the key-value pairs // Encode the cell
ret = tdbEncodeKeyValue(pKey, kLen, pCur->pPage->kLen, pVal, vLen, pCur->pPage->vLen, pCell, &szCell);
// Insert the cell to the index // Insert the cell to the index
ret = tdbPageInsertCell(pCur->pPage, idx, pCell, szCell); ret = tdbPageInsertCell(pCur->pPage, idx, pCell, szCell);
@ -230,47 +227,6 @@ static int tdbBtCursorMoveTo(SBtCursor *pCur, const void *pKey, int kLen, int *p
return 0; return 0;
} }
static int tdbEncodeKeyValue(const void *pKey, int kLen, int kLenG, const void *pVal, int vLen, int vLenG, void *pBuf,
int *bLen) {
u8 *pPtr;
ASSERT(kLen > 0 && vLen > 0);
ASSERT(kLenG == TDB_VARIANT_LEN || kLenG == kLen);
ASSERT(vLenG == TDB_VARIANT_LEN || vLenG == vLen);
pPtr = (u8 *)pBuf;
if (kLenG == TDB_VARIANT_LEN) {
pPtr += tdbEncodeLength(pPtr, kLen);
}
if (vLenG == TDB_VARIANT_LEN) {
pPtr += tdbEncodeLength(pPtr, vLen);
}
memcpy(pPtr, pKey, kLen);
pPtr += kLen;
memcpy(pPtr, pVal, vLen);
pPtr += vLen;
*bLen = pPtr - (u8 *)pBuf;
return 0;
}
static int tdbDecodeKeyValue(const void *pBuf, void *pKey, int *kLen, void *pVal, int *vLen) {
if (*kLen == TDB_VARIANT_LEN) {
// Decode the key length
}
if (*vLen == TDB_VARIANT_LEN) {
// Decode the value length
}
// TODO: decode the key and value
return 0;
}
static int tdbEncodeLength(u8 *pBuf, uint32_t len) { static int tdbEncodeLength(u8 *pBuf, uint32_t len) {
int iCount = 0; int iCount = 0;