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-16 03:07:40 +00:00
parent ec3cb6fd9c
commit 5cdfc49ba0
2 changed files with 9 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -233,10 +233,13 @@ static int tdbBtCursorMoveTo(SBtCursor *pCur, const void *pKey, int kLen, int *p
c = pBt->kcmpr(pKey, kLen, cd.pKey, cd.kLen); c = pBt->kcmpr(pKey, kLen, cd.pKey, cd.kLen);
if (c < 0) { if (c < 0) {
/* TODO */ /* TODO */
ASSERT(0);
} else if (c > 0) { } else if (c > 0) {
/* TODO */ /* TODO */
ASSERT(0);
} else { } else {
/* TODO */ /* TODO */
ASSERT(0);
} }
} }
} }
@ -797,9 +800,7 @@ static int tdbBtreeDecodePayload(SPage *pPage, const u8 *pPayload, SCellDecoder
if (!pDecoder->pVal) { if (!pDecoder->pVal) {
pDecoder->pVal = (void *)(pPayload + pDecoder->kLen); pDecoder->pVal = (void *)(pPayload + pDecoder->kLen);
} }
} } else {
{
// TODO: handle overflow case // TODO: handle overflow case
ASSERT(0); ASSERT(0);
} }

9
source/libs/tdb/src/inc/tdbUtil.h
View File

@ -62,19 +62,20 @@ static inline int tdbGetVarInt(const u8 *p, int *v) {
int tv = 0; int tv = 0;
for (;;) { for (;;) {
if (p[n] & 0x80 == 0) { if (p[n] <= 0x7f) {
tv = (tv << 7) & p[n]; tv = (tv << 7) | p[n];
n++; n++;
break; break;
} }
tv = (tv << 7) & (p[n] & 0x7f); tv = (tv << 7) | (p[n] & 0x7f);
n++; n++;
} }
ASSERT(n < 6); ASSERT(n < 6);
return 0; *v = tv;
return n;
} }
#ifdef __cplusplus #ifdef __cplusplus