Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
慢慢CG
TDengine
提交
5c915f0d
T
TDengine
项目概览
慢慢CG
/
TDengine
与 Fork 源项目一致
Fork自
taosdata / TDengine
通知
1
Star
0
Fork
0
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
0
列表
看板
标记
里程碑
合并请求
0
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
T
TDengine
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
0
Issue
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
提交
Issue看板
提交
5c915f0d
编写于
4月 05, 2020
作者:
H
hzcheng
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
fix some warning problem
上级
9fa0685a
变更
3
隐藏空白更改
内联
并排
Showing
3 changed file
with
25 addition
and
26 deletion
+25
-26
src/vnode/tsdb/src/tsdbMain.c
src/vnode/tsdb/src/tsdbMain.c
+12
-13
src/vnode/tsdb/src/tsdbMeta.c
src/vnode/tsdb/src/tsdbMeta.c
+4
-4
src/vnode/tsdb/src/tsdbMetaFile.c
src/vnode/tsdb/src/tsdbMetaFile.c
+9
-9
未找到文件。
src/vnode/tsdb/src/tsdbMain.c
浏览文件 @
5c915f0d
...
...
@@ -50,7 +50,7 @@ enum { TSDB_REPO_STATE_ACTIVE, TSDB_REPO_STATE_CLOSED, TSDB_REPO_STATE_CONFIGURI
static
int32_t
tsdbCheckAndSetDefaultCfg
(
STsdbCfg
*
pCfg
);
static
int32_t
tsdbSetRepoEnv
(
STsdbRepo
*
pRepo
);
static
int32_t
tsdbDestroyRepoEnv
(
STsdbRepo
*
pRepo
);
static
int
tsdbOpenMetaFile
(
char
*
tsdbDir
);
//
static int tsdbOpenMetaFile(char *tsdbDir);
static
int32_t
tsdbInsertDataToTable
(
tsdb_repo_t
*
repo
,
SSubmitBlk
*
pBlock
);
static
int32_t
tsdbRestoreCfg
(
STsdbRepo
*
pRepo
,
STsdbCfg
*
pCfg
);
static
int32_t
tsdbGetDataDirName
(
STsdbRepo
*
pRepo
,
char
*
fname
);
...
...
@@ -222,10 +222,10 @@ tsdb_repo_t *tsdbOpenRepo(char *tsdbDir) {
return
(
tsdb_repo_t
*
)
pRepo
;
}
static
int32_t
tsdbFlushCache
(
STsdbRepo
*
pRepo
)
{
// TODO
return
0
;
}
//
static int32_t tsdbFlushCache(STsdbRepo *pRepo) {
//
// TODO
//
return 0;
//
}
/**
* Close a TSDB repository. Only free memory resources, and keep the files.
...
...
@@ -679,10 +679,10 @@ static int32_t tsdbDestroyRepoEnv(STsdbRepo *pRepo) {
return
0
;
}
static
int
tsdbOpenMetaFile
(
char
*
tsdbDir
)
{
// TODO
return
0
;
}
//
static int tsdbOpenMetaFile(char *tsdbDir) {
//
// TODO
//
return 0;
//
}
static
int32_t
tdInsertRowToTable
(
STsdbRepo
*
pRepo
,
SDataRow
row
,
STable
*
pTable
)
{
// TODO
...
...
@@ -937,7 +937,7 @@ static int tsdbCommitToFile(STsdbRepo *pRepo, int fid, SSkipListIterator **iters
TSDB_COMPBLOCK_GET_START_AND_SIZE
(
pCompInfo
,
pTBlock
,
nBlocks
);
SComp
Block
tBlock
;
SComp
Data
tBlock
;
int64_t
toffset
;
int32_t
tlen
;
tsdbLoadDataBlock
(
&
pGroup
->
files
[
TSDB_FILE_TYPE_LAST
],
pTBlock
,
nBlocks
,
pCols
,
&
tBlock
);
...
...
@@ -968,7 +968,7 @@ static int tsdbCommitToFile(STsdbRepo *pRepo, int fid, SSkipListIterator **iters
pCompInfo
->
uid
=
pTable
->
tableId
.
uid
;
// Load SCompBlock part if neccessary
int
isCompBlockLoaded
=
0
;
//
int isCompBlockLoaded = 0;
if
(
0
)
{
// if (pIdx->offset > 0) {
if
(
pIdx
->
hasLast
||
tsdbHasDataInRange
(
pIter
,
minKey
,
pIdx
->
maxKey
))
{
...
...
@@ -976,7 +976,7 @@ static int tsdbCommitToFile(STsdbRepo *pRepo, int fid, SSkipListIterator **iters
pCompInfo
=
(
SCompInfo
*
)
realloc
((
void
*
)
pCompInfo
,
pIdx
->
len
+
sizeof
(
SCompBlock
)
*
100
);
if
(
tsdbLoadCompBlocks
(
pGroup
,
pIdx
,
(
void
*
)
pCompInfo
)
<
0
)
{
/* TODO */
}
if
(
pCompInfo
->
uid
==
pTable
->
tableId
.
uid
)
isCompBlockLoaded
=
1
;
//
if (pCompInfo->uid == pTable->tableId.uid) isCompBlockLoaded = 1;
}
else
{
// TODO: No need to load the SCompBlock part, just sendfile the SCompBlock part
// and write those new blocks to it
...
...
@@ -1023,7 +1023,6 @@ _table_over:
int
bytes
=
tsendfile
(
hFile
.
fd
,
pGroup
->
files
[
TSDB_FILE_TYPE_HEAD
].
fd
,
NULL
,
pIdx
->
len
);
if
(
bytes
<
pIdx
->
len
)
{
printf
(
"Failed to send file, reason: %s
\n
"
,
strerror
(
errno
));
int
d
=
1
;
}
if
(
nNewBlocks
>
0
)
{
write
(
hFile
.
fd
,
(
void
*
)(
pCompInfo
->
blocks
),
sizeof
(
SCompBlock
)
*
nNewBlocks
);
...
...
src/vnode/tsdb/src/tsdbMeta.c
浏览文件 @
5c915f0d
...
...
@@ -374,10 +374,10 @@ static int tsdbAddTableToMeta(STsdbMeta *pMeta, STable *pTable, bool addIdx) {
return
tsdbAddTableIntoMap
(
pMeta
,
pTable
);
}
static
int
tsdbRemoveTableFromMeta
(
STsdbMeta
*
pMeta
,
STable
*
pTable
)
{
// TODO
return
0
;
}
//
static int tsdbRemoveTableFromMeta(STsdbMeta *pMeta, STable *pTable) {
//
// TODO
//
return 0;
//
}
static
int
tsdbAddTableIntoMap
(
STsdbMeta
*
pMeta
,
STable
*
pTable
)
{
// TODO: add the table to the map
...
...
src/vnode/tsdb/src/tsdbMetaFile.c
浏览文件 @
5c915f0d
...
...
@@ -29,7 +29,7 @@ typedef struct {
}
SRecordInfo
;
static
int32_t
tsdbGetMetaFileName
(
char
*
rootDir
,
char
*
fname
);
static
int32_t
tsdbCheckMetaHeader
(
int
fd
);
//
static int32_t tsdbCheckMetaHeader(int fd);
static
int32_t
tsdbWriteMetaHeader
(
int
fd
);
static
int
tsdbCreateMetaFile
(
char
*
fname
);
static
int
tsdbRestoreFromMetaFile
(
char
*
fname
,
SMetaFile
*
mfh
);
...
...
@@ -185,10 +185,10 @@ static int32_t tsdbGetMetaFileName(char *rootDir, char *fname) {
return
0
;
}
static
int32_t
tsdbCheckMetaHeader
(
int
fd
)
{
// TODO: write the meta file header check function
return
0
;
}
//
static int32_t tsdbCheckMetaHeader(int fd) {
//
// TODO: write the meta file header check function
//
return 0;
//
}
static
int32_t
tsdbWriteMetaHeader
(
int
fd
)
{
// TODO: write the meta file header to file
...
...
@@ -199,10 +199,10 @@ static int32_t tsdbWriteMetaHeader(int fd) {
return
0
;
}
static
int32_t
tsdbReadMetaHeader
(
int
fd
)
{
lseek
(
fd
,
TSDB_META_FILE_HEADER_SIZE
,
SEEK_SET
);
return
0
;
}
//
static int32_t tsdbReadMetaHeader(int fd) {
//
lseek(fd, TSDB_META_FILE_HEADER_SIZE, SEEK_SET);
//
return 0;
//
}
static
int
tsdbCreateMetaFile
(
char
*
fname
)
{
int
fd
=
open
(
fname
,
O_RDWR
|
O_CREAT
,
0755
);
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录