Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
taosdata
TDengine
提交
5ed7b9a2
T
TDengine
项目概览
taosdata
/
TDengine
接近 2 年 前同步成功
通知
1192
Star
22018
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看板
提交
5ed7b9a2
编写于
3月 14, 2022
作者:
H
Hongze Cheng
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
more TDB
上级
bfb11917
变更
2
隐藏空白更改
内联
并排
Showing
2 changed file
with
7 addition
and
7 deletion
+7
-7
source/libs/tdb/src/db/tdbBtree.c
source/libs/tdb/src/db/tdbBtree.c
+3
-3
source/libs/tdb/src/inc/tdbPage.h
source/libs/tdb/src/inc/tdbPage.h
+4
-4
未找到文件。
source/libs/tdb/src/db/tdbBtree.c
浏览文件 @
5ed7b9a2
...
@@ -183,7 +183,7 @@ static int tdbBtCursorMoveTo(SBtCursor *pCur, const void *pKey, int kLen) {
...
@@ -183,7 +183,7 @@ static int tdbBtCursorMoveTo(SBtCursor *pCur, const void *pKey, int kLen) {
// ridx = pBtPage->pHdr->nCells - 1;
// ridx = pBtPage->pHdr->nCells - 1;
// while (lidx <= ridx) {
// while (lidx <= ridx) {
// midx = (lidx + ridx) >> 1;
// midx = (lidx + ridx) >> 1;
// pCell = (void *)(pBtPage->aData + pBtPage->
a
CellIdx[midx]);
// pCell = (void *)(pBtPage->aData + pBtPage->
p
CellIdx[midx]);
// c = tdbCompareKeyAndCell(pKey, kLen, pCell);
// c = tdbCompareKeyAndCell(pKey, kLen, pCell);
// if (c == 0) {
// if (c == 0) {
...
@@ -352,7 +352,7 @@ static int tdbBtreeZeroPage(SPage *pPage, void *arg) {
...
@@ -352,7 +352,7 @@ static int tdbBtreeZeroPage(SPage *pPage, void *arg) {
pBt
=
((
SBtreeZeroPageArg
*
)
arg
)
->
pBt
;
pBt
=
((
SBtreeZeroPageArg
*
)
arg
)
->
pBt
;
pPage
->
pPageHdr
=
pPage
->
pData
;
pPage
->
pPageHdr
=
pPage
->
pData
;
pPage
->
a
CellIdx
=
(
u8
*
)(
&
(
pPage
->
pPageHdr
[
1
]));
pPage
->
p
CellIdx
=
(
u8
*
)(
&
(
pPage
->
pPageHdr
[
1
]));
// Init the page header
// Init the page header
TDB_PAGE_FLAGS_SET
(
pPage
,
flags
);
TDB_PAGE_FLAGS_SET
(
pPage
,
flags
);
...
@@ -386,7 +386,7 @@ static int tdbBtreeInitPage(SPage *pPage, void *arg) {
...
@@ -386,7 +386,7 @@ static int tdbBtreeInitPage(SPage *pPage, void *arg) {
flags
=
TDB_PAGE_FLAGS
(
pPage
);
flags
=
TDB_PAGE_FLAGS
(
pPage
);
pPage
->
pPageHdr
=
pPage
->
pData
;
pPage
->
pPageHdr
=
pPage
->
pData
;
pPage
->
a
CellIdx
=
pPage
->
pPageHdr
+
pPage
->
szPageHdr
;
pPage
->
p
CellIdx
=
pPage
->
pPageHdr
+
pPage
->
szPageHdr
;
TDB_BTREE_ASSERT_FLAG
(
flags
);
TDB_BTREE_ASSERT_FLAG
(
flags
);
...
...
source/libs/tdb/src/inc/tdbPage.h
浏览文件 @
5ed7b9a2
...
@@ -54,8 +54,8 @@ struct SPage {
...
@@ -54,8 +54,8 @@ struct SPage {
pthread_spinlock_t
lock
;
pthread_spinlock_t
lock
;
// Fields below used by pager and am
// Fields below used by pager and am
u8
*
pPageHdr
;
u8
*
pPageHdr
;
u8
*
aCellIdx
;
u8
*
pAmHdr
;
u8
*
pAmHdr
;
u8
*
pCellIdx
;
u8
*
pFreeStart
;
u8
*
pFreeStart
;
u8
*
pFreeEnd
;
u8
*
pFreeEnd
;
SPageFtr
*
pPageFtr
;
SPageFtr
*
pPageFtr
;
...
@@ -80,7 +80,7 @@ struct SPage {
...
@@ -80,7 +80,7 @@ struct SPage {
#define TDB_SPAGE_CCELLS(pPage) (((SPageHdr *)(pPage)->pPageHdr)->cCells)
#define TDB_SPAGE_CCELLS(pPage) (((SPageHdr *)(pPage)->pPageHdr)->cCells)
#define TDB_SPAGE_FCELL(pPage) (((SPageHdr *)(pPage)->pPageHdr)->fCell)
#define TDB_SPAGE_FCELL(pPage) (((SPageHdr *)(pPage)->pPageHdr)->fCell)
#define TDB_SPAGE_NFREE(pPage) (((SPageHdr *)(pPage)->pPageHdr)->nFree)
#define TDB_SPAGE_NFREE(pPage) (((SPageHdr *)(pPage)->pPageHdr)->nFree)
#define TDB_SPAGE_CELL_OFFSET_AT(pPage, idx) ((u16 *)((pPage)->
a
CellIdx))[idx]
#define TDB_SPAGE_CELL_OFFSET_AT(pPage, idx) ((u16 *)((pPage)->
p
CellIdx))[idx]
#define TDB_SPAGE_FLAGS_SET(pPage, FLAGS) TDB_SPAGE_FLAGS(pPage) = (FLAGS)
#define TDB_SPAGE_FLAGS_SET(pPage, FLAGS) TDB_SPAGE_FLAGS(pPage) = (FLAGS)
#define TDB_SPAGE_NCELLS_SET(pPage, NCELLS) TDB_SPAGE_NCELLS(pPage) = (NCELLS)
#define TDB_SPAGE_NCELLS_SET(pPage, NCELLS) TDB_SPAGE_NCELLS(pPage) = (NCELLS)
...
@@ -95,14 +95,14 @@ struct SPage {
...
@@ -95,14 +95,14 @@ struct SPage {
#define TDB_LPAGE_CCELLS(pPage) TDB_GET_U24(((SPageHdrL *)(pPage)->pPageHdr)->cCells)
#define TDB_LPAGE_CCELLS(pPage) TDB_GET_U24(((SPageHdrL *)(pPage)->pPageHdr)->cCells)
#define TDB_LPAGE_FCELL(pPage) TDB_GET_U24(((SPageHdrL *)(pPage)->pPageHdr)->fCell)
#define TDB_LPAGE_FCELL(pPage) TDB_GET_U24(((SPageHdrL *)(pPage)->pPageHdr)->fCell)
#define TDB_LPAGE_NFREE(pPage) TDB_GET_U24(((SPageHdrL *)(pPage)->pPageHdr)->nFree)
#define TDB_LPAGE_NFREE(pPage) TDB_GET_U24(((SPageHdrL *)(pPage)->pPageHdr)->nFree)
#define TDB_LPAGE_CELL_OFFSET_AT(pPage, idx) TDB_GET_U24((pPage)->
a
CellIdx + idx * 3)
#define TDB_LPAGE_CELL_OFFSET_AT(pPage, idx) TDB_GET_U24((pPage)->
p
CellIdx + idx * 3)
#define TDB_LPAGE_FLAGS_SET(pPage, FLAGS) TDB_LPAGE_FLAGS(pPage) = (flags)
#define TDB_LPAGE_FLAGS_SET(pPage, FLAGS) TDB_LPAGE_FLAGS(pPage) = (flags)
#define TDB_LPAGE_NCELLS_SET(pPage, NCELLS) TDB_PUT_U24(((SPageHdrL *)(pPage)->pPageHdr)->nCells, NCELLS)
#define TDB_LPAGE_NCELLS_SET(pPage, NCELLS) TDB_PUT_U24(((SPageHdrL *)(pPage)->pPageHdr)->nCells, NCELLS)
#define TDB_LPAGE_CCELLS_SET(pPage, CCELLS) TDB_PUT_U24(((SPageHdrL *)(pPage)->pPageHdr)->cCells, CCELLS)
#define TDB_LPAGE_CCELLS_SET(pPage, CCELLS) TDB_PUT_U24(((SPageHdrL *)(pPage)->pPageHdr)->cCells, CCELLS)
#define TDB_LPAGE_FCELL_SET(pPage, FCELL) TDB_PUT_U24(((SPageHdrL *)(pPage)->pPageHdr)->fCell, FCELL)
#define TDB_LPAGE_FCELL_SET(pPage, FCELL) TDB_PUT_U24(((SPageHdrL *)(pPage)->pPageHdr)->fCell, FCELL)
#define TDB_LPAGE_NFREE_SET(pPage, NFREE) TDB_PUT_U24(((SPageHdrL *)(pPage)->pPageHdr)->nFree, NFREE)
#define TDB_LPAGE_NFREE_SET(pPage, NFREE) TDB_PUT_U24(((SPageHdrL *)(pPage)->pPageHdr)->nFree, NFREE)
#define TDB_LPAGE_CELL_OFFSET_AT_SET(pPage, idx, OFFSET) TDB_PUT_U24((pPage)->
a
CellIdx + idx * 3, OFFSET)
#define TDB_LPAGE_CELL_OFFSET_AT_SET(pPage, idx, OFFSET) TDB_PUT_U24((pPage)->
p
CellIdx + idx * 3, OFFSET)
/* For page */
/* For page */
#define TDB_PAGE_FLAGS(pPage) (TDB_IS_LARGE_PAGE(pPage) ? TDB_LPAGE_FLAGS(pPage) : TDB_SPAGE_FLAGS(pPage))
#define TDB_PAGE_FLAGS(pPage) (TDB_IS_LARGE_PAGE(pPage) ? TDB_LPAGE_FLAGS(pPage) : TDB_SPAGE_FLAGS(pPage))
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录