Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
taosdata
TDengine
提交
b8ac2d30
T
TDengine
项目概览
taosdata
/
TDengine
1 年多 前同步成功
通知
1185
Star
22016
Fork
4786
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
1
列表
看板
标记
里程碑
合并请求
0
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
T
TDengine
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
1
Issue
1
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
提交
Issue看板
提交
b8ac2d30
编写于
3月 25, 2022
作者:
H
Hongze Cheng
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
refact
上级
488d44a5
变更
3
显示空白变更内容
内联
并排
Showing
3 changed file
with
21 addition
and
16 deletion
+21
-16
source/libs/tdb/src/db/tdbBtree.c
source/libs/tdb/src/db/tdbBtree.c
+8
-8
source/libs/tdb/src/db/tdbDb.c
source/libs/tdb/src/db/tdbDb.c
+3
-3
source/libs/tdb/src/inc/tdbBtree.h
source/libs/tdb/src/inc/tdbBtree.h
+10
-5
未找到文件。
source/libs/tdb/src/db/tdbBtree.c
浏览文件 @
b8ac2d30
...
@@ -67,7 +67,7 @@ typedef struct {
...
@@ -67,7 +67,7 @@ typedef struct {
u8
*
pTmpSpace
;
u8
*
pTmpSpace
;
}
SCellDecoder
;
}
SCellDecoder
;
static
int
tdbBtCursorMoveTo
(
SB
tCursor
*
pCur
,
const
void
*
pKey
,
int
kLen
,
int
*
pCRst
);
static
int
tdbBtCursorMoveTo
(
SB
TC
*
pCur
,
const
void
*
pKey
,
int
kLen
,
int
*
pCRst
);
static
int
tdbDefaultKeyCmprFn
(
const
void
*
pKey1
,
int
keyLen1
,
const
void
*
pKey2
,
int
keyLen2
);
static
int
tdbDefaultKeyCmprFn
(
const
void
*
pKey1
,
int
keyLen1
,
const
void
*
pKey2
,
int
keyLen2
);
static
int
tdbBtreeOpenImpl
(
SBTree
*
pBt
);
static
int
tdbBtreeOpenImpl
(
SBTree
*
pBt
);
static
int
tdbBtreeZeroPage
(
SPage
*
pPage
,
void
*
arg
);
static
int
tdbBtreeZeroPage
(
SPage
*
pPage
,
void
*
arg
);
...
@@ -75,7 +75,7 @@ static int tdbBtreeInitPage(SPage *pPage, void *arg);
...
@@ -75,7 +75,7 @@ static int tdbBtreeInitPage(SPage *pPage, void *arg);
static
int
tdbBtreeEncodeCell
(
SPage
*
pPage
,
const
void
*
pKey
,
int
kLen
,
const
void
*
pVal
,
int
vLen
,
SCell
*
pCell
,
static
int
tdbBtreeEncodeCell
(
SPage
*
pPage
,
const
void
*
pKey
,
int
kLen
,
const
void
*
pVal
,
int
vLen
,
SCell
*
pCell
,
int
*
szCell
);
int
*
szCell
);
static
int
tdbBtreeDecodeCell
(
SPage
*
pPage
,
const
SCell
*
pCell
,
SCellDecoder
*
pDecoder
);
static
int
tdbBtreeDecodeCell
(
SPage
*
pPage
,
const
SCell
*
pCell
,
SCellDecoder
*
pDecoder
);
static
int
tdbBtreeBalance
(
SB
tCursor
*
pCur
);
static
int
tdbBtreeBalance
(
SB
TC
*
pCur
);
static
int
tdbBtreeCellSize
(
const
SPage
*
pPage
,
SCell
*
pCell
);
static
int
tdbBtreeCellSize
(
const
SPage
*
pPage
,
SCell
*
pCell
);
int
tdbBtreeOpen
(
int
keyLen
,
int
valLen
,
SPager
*
pPager
,
FKeyComparator
kcmpr
,
SBTree
**
ppBt
)
{
int
tdbBtreeOpen
(
int
keyLen
,
int
valLen
,
SPager
*
pPager
,
FKeyComparator
kcmpr
,
SBTree
**
ppBt
)
{
...
@@ -131,7 +131,7 @@ int tdbBtreeClose(SBTree *pBt) {
...
@@ -131,7 +131,7 @@ int tdbBtreeClose(SBTree *pBt) {
return
0
;
return
0
;
}
}
int
tdbBtreeCursor
(
SB
tCursor
*
pCur
,
SBTree
*
pBt
)
{
int
tdbBtreeCursor
(
SB
TC
*
pCur
,
SBTree
*
pBt
)
{
pCur
->
pBt
=
pBt
;
pCur
->
pBt
=
pBt
;
pCur
->
iPage
=
-
1
;
pCur
->
iPage
=
-
1
;
pCur
->
pPage
=
NULL
;
pCur
->
pPage
=
NULL
;
...
@@ -140,7 +140,7 @@ int tdbBtreeCursor(SBtCursor *pCur, SBTree *pBt) {
...
@@ -140,7 +140,7 @@ int tdbBtreeCursor(SBtCursor *pCur, SBTree *pBt) {
return
0
;
return
0
;
}
}
int
tdbBtCursorInsert
(
SB
tCursor
*
pCur
,
const
void
*
pKey
,
int
kLen
,
const
void
*
pVal
,
int
vLen
)
{
int
tdbBtCursorInsert
(
SB
TC
*
pCur
,
const
void
*
pKey
,
int
kLen
,
const
void
*
pVal
,
int
vLen
)
{
int
ret
;
int
ret
;
int
idx
;
int
idx
;
SPager
*
pPager
;
SPager
*
pPager
;
...
@@ -204,7 +204,7 @@ int tdbBtCursorInsert(SBtCursor *pCur, const void *pKey, int kLen, const void *p
...
@@ -204,7 +204,7 @@ int tdbBtCursorInsert(SBtCursor *pCur, const void *pKey, int kLen, const void *p
}
}
int
tdbBtreeGet
(
SBTree
*
pBt
,
const
void
*
pKey
,
int
kLen
,
void
**
ppVal
,
int
*
vLen
)
{
int
tdbBtreeGet
(
SBTree
*
pBt
,
const
void
*
pKey
,
int
kLen
,
void
**
ppVal
,
int
*
vLen
)
{
SB
tCursor
btc
;
SB
TC
btc
;
SCell
*
pCell
;
SCell
*
pCell
;
int
cret
;
int
cret
;
SCellDecoder
cd
;
SCellDecoder
cd
;
...
@@ -231,7 +231,7 @@ int tdbBtreeGet(SBTree *pBt, const void *pKey, int kLen, void **ppVal, int *vLen
...
@@ -231,7 +231,7 @@ int tdbBtreeGet(SBTree *pBt, const void *pKey, int kLen, void **ppVal, int *vLen
return
0
;
return
0
;
}
}
static
int
tdbBtCursorMoveToChild
(
SB
tCursor
*
pCur
,
SPgno
pgno
)
{
static
int
tdbBtCursorMoveToChild
(
SB
TC
*
pCur
,
SPgno
pgno
)
{
int
ret
;
int
ret
;
pCur
->
pgStack
[
pCur
->
iPage
]
=
pCur
->
pPage
;
pCur
->
pgStack
[
pCur
->
iPage
]
=
pCur
->
pPage
;
...
@@ -248,7 +248,7 @@ static int tdbBtCursorMoveToChild(SBtCursor *pCur, SPgno pgno) {
...
@@ -248,7 +248,7 @@ static int tdbBtCursorMoveToChild(SBtCursor *pCur, SPgno pgno) {
return
0
;
return
0
;
}
}
static
int
tdbBtCursorMoveTo
(
SB
tCursor
*
pCur
,
const
void
*
pKey
,
int
kLen
,
int
*
pCRst
)
{
static
int
tdbBtCursorMoveTo
(
SB
TC
*
pCur
,
const
void
*
pKey
,
int
kLen
,
int
*
pCRst
)
{
int
ret
;
int
ret
;
SBTree
*
pBt
;
SBTree
*
pBt
;
SPager
*
pPager
;
SPager
*
pPager
;
...
@@ -827,7 +827,7 @@ static int tdbBtreeBalanceNonRoot(SBTree *pBt, SPage *pParent, int idx) {
...
@@ -827,7 +827,7 @@ static int tdbBtreeBalanceNonRoot(SBTree *pBt, SPage *pParent, int idx) {
return
0
;
return
0
;
}
}
static
int
tdbBtreeBalance
(
SB
tCursor
*
pCur
)
{
static
int
tdbBtreeBalance
(
SB
TC
*
pCur
)
{
int
iPage
;
int
iPage
;
SPage
*
pParent
;
SPage
*
pParent
;
SPage
*
pPage
;
SPage
*
pPage
;
...
...
source/libs/tdb/src/db/tdbDb.c
浏览文件 @
b8ac2d30
...
@@ -70,8 +70,8 @@ int tdbDbDrop(STDb *pDb) {
...
@@ -70,8 +70,8 @@ int tdbDbDrop(STDb *pDb) {
}
}
int
tdbDbInsert
(
STDb
*
pDb
,
const
void
*
pKey
,
int
keyLen
,
const
void
*
pVal
,
int
valLen
)
{
int
tdbDbInsert
(
STDb
*
pDb
,
const
void
*
pKey
,
int
keyLen
,
const
void
*
pVal
,
int
valLen
)
{
SB
tCursor
btc
;
SB
TC
btc
;
SB
tCursor
*
pCur
;
SB
TC
*
pCur
;
int
ret
;
int
ret
;
pCur
=
&
btc
;
pCur
=
&
btc
;
...
...
source/libs/tdb/src/inc/tdbBtree.h
浏览文件 @
b8ac2d30
...
@@ -21,9 +21,14 @@ extern "C" {
...
@@ -21,9 +21,14 @@ extern "C" {
#endif
#endif
typedef
struct
SBTree
SBTree
;
typedef
struct
SBTree
SBTree
;
typedef
struct
SBtCursor
SBtCursor
;
typedef
struct
SBTC
SBTC
;
typedef
struct
SBtInfo
{
SPgno
root
;
int
nLevel
;
int
nData
;
}
SBtInfo
;
struct
SB
tCursor
{
struct
SB
TC
{
SBTree
*
pBt
;
SBTree
*
pBt
;
i8
iPage
;
i8
iPage
;
SPage
*
pPage
;
SPage
*
pPage
;
...
@@ -35,8 +40,8 @@ struct SBtCursor {
...
@@ -35,8 +40,8 @@ struct SBtCursor {
int
tdbBtreeOpen
(
int
keyLen
,
int
valLen
,
SPager
*
pFile
,
FKeyComparator
kcmpr
,
SBTree
**
ppBt
);
int
tdbBtreeOpen
(
int
keyLen
,
int
valLen
,
SPager
*
pFile
,
FKeyComparator
kcmpr
,
SBTree
**
ppBt
);
int
tdbBtreeClose
(
SBTree
*
pBt
);
int
tdbBtreeClose
(
SBTree
*
pBt
);
int
tdbBtreeCursor
(
SB
tCursor
*
pCur
,
SBTree
*
pBt
);
int
tdbBtreeCursor
(
SB
TC
*
pCur
,
SBTree
*
pBt
);
int
tdbBtCursorInsert
(
SB
tCursor
*
pCur
,
const
void
*
pKey
,
int
kLen
,
const
void
*
pVal
,
int
vLen
);
int
tdbBtCursorInsert
(
SB
TC
*
pCur
,
const
void
*
pKey
,
int
kLen
,
const
void
*
pVal
,
int
vLen
);
int
tdbBtreeGet
(
SBTree
*
pBt
,
const
void
*
pKey
,
int
kLen
,
void
**
ppVal
,
int
*
vLen
);
int
tdbBtreeGet
(
SBTree
*
pBt
,
const
void
*
pKey
,
int
kLen
,
void
**
ppVal
,
int
*
vLen
);
#ifdef __cplusplus
#ifdef __cplusplus
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录