Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
taosdata
TDengine
提交
6bf279b6
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看板
提交
6bf279b6
编写于
9月 29, 2021
作者:
S
Shengliang Guan
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
[TD-10430] minor changes
上级
d6976c0f
变更
8
隐藏空白更改
内联
并排
Showing
8 changed file
with
19 addition
and
14 deletion
+19
-14
include/server/vnode/vnode.h
include/server/vnode/vnode.h
+8
-8
source/server/dnode/CMakeLists.txt
source/server/dnode/CMakeLists.txt
+5
-0
source/server/dnode/inc/dnodeCfg.h
source/server/dnode/inc/dnodeCfg.h
+1
-1
source/server/dnode/inc/dnodeCheck.h
source/server/dnode/inc/dnodeCheck.h
+1
-1
source/server/dnode/inc/dnodeEps.h
source/server/dnode/inc/dnodeEps.h
+1
-1
source/server/dnode/src/dnodeCfg.c
source/server/dnode/src/dnodeCfg.c
+1
-1
source/server/dnode/src/dnodeCheck.c
source/server/dnode/src/dnodeCheck.c
+1
-1
source/server/dnode/src/dnodeEps.c
source/server/dnode/src/dnodeEps.c
+1
-1
未找到文件。
include/server/vnode/vnode.h
浏览文件 @
6bf279b6
...
@@ -86,14 +86,6 @@ typedef struct {
...
@@ -86,14 +86,6 @@ typedef struct {
*/
*/
int32_t
vnodeGetStatistics
(
struct
Vnode
*
vnode
,
SVnodeStat
*
stat
);
int32_t
vnodeGetStatistics
(
struct
Vnode
*
vnode
,
SVnodeStat
*
stat
);
/**
* Interface for processing messages.
*
* @param vnode, instance of vnode module.
* @param msg, message to be processed.
*/
void
vnodeProcessMsg
(
struct
Vnode
*
vnode
,
SRpcMsg
*
msg
);
/**
/**
* Get the status of all vnodes.
* Get the status of all vnodes.
*
*
...
@@ -111,6 +103,14 @@ void vnodeGetStatus(struct Vnode *vnode, struct SStatusMsg *status);
...
@@ -111,6 +103,14 @@ void vnodeGetStatus(struct Vnode *vnode, struct SStatusMsg *status);
*/
*/
void
vnodeSetAccess
(
struct
Vnode
*
vnode
,
struct
SVgroupAccess
*
access
,
int32_t
numOfVnodes
);
void
vnodeSetAccess
(
struct
Vnode
*
vnode
,
struct
SVgroupAccess
*
access
,
int32_t
numOfVnodes
);
/**
* Interface for processing messages.
*
* @param vnode, instance of vnode module.
* @param msg, message to be processed.
*/
void
vnodeProcessMsg
(
struct
Vnode
*
vnode
,
SRpcMsg
*
msg
);
#ifdef __cplusplus
#ifdef __cplusplus
}
}
#endif
#endif
...
...
source/server/dnode/CMakeLists.txt
浏览文件 @
6bf279b6
aux_source_directory
(
src DNODE_SRC
)
aux_source_directory
(
src DNODE_SRC
)
add_library
(
dnode
${
DNODE_SRC
}
)
add_library
(
dnode
${
DNODE_SRC
}
)
target_link_libraries
(
dnode
PUBLIC os
PUBLIC cJson
)
target_include_directories
(
target_include_directories
(
dnode
dnode
PUBLIC
"
${
CMAKE_SOURCE_DIR
}
/include/server/dnode"
PUBLIC
"
${
CMAKE_SOURCE_DIR
}
/include/server/dnode"
...
...
source/server/dnode/inc/dnodeCfg.h
浏览文件 @
6bf279b6
...
@@ -31,7 +31,7 @@ typedef struct DnCfg {
...
@@ -31,7 +31,7 @@ typedef struct DnCfg {
}
DnCfg
;
}
DnCfg
;
int32_t
dnodeInitCfg
(
Dnode
*
dnode
,
DnCfg
**
cfg
);
int32_t
dnodeInitCfg
(
Dnode
*
dnode
,
DnCfg
**
cfg
);
void
dnodeCleanupCfg
(
Dn
ode
*
dnode
,
Dn
Cfg
**
cfg
);
void
dnodeCleanupCfg
(
DnCfg
**
cfg
);
void
dnodeUpdateCfg
(
DnCfg
*
cfg
,
SDnodeCfg
*
data
);
void
dnodeUpdateCfg
(
DnCfg
*
cfg
,
SDnodeCfg
*
data
);
int32_t
dnodeGetDnodeId
(
DnCfg
*
cfg
);
int32_t
dnodeGetDnodeId
(
DnCfg
*
cfg
);
void
dnodeGetClusterId
(
DnCfg
*
cfg
,
char
*
clusterId
);
void
dnodeGetClusterId
(
DnCfg
*
cfg
,
char
*
clusterId
);
...
...
source/server/dnode/inc/dnodeCheck.h
浏览文件 @
6bf279b6
...
@@ -26,7 +26,7 @@ typedef struct DnCheck {
...
@@ -26,7 +26,7 @@ typedef struct DnCheck {
}
DnCheck
;
}
DnCheck
;
int32_t
dnodeInitCheck
(
Dnode
*
dnode
,
DnCheck
**
check
);
int32_t
dnodeInitCheck
(
Dnode
*
dnode
,
DnCheck
**
check
);
void
dnodeCleanupCheck
(
Dn
ode
*
dnode
,
Dn
Check
**
check
);
void
dnodeCleanupCheck
(
DnCheck
**
check
);
#ifdef __cplusplus
#ifdef __cplusplus
}
}
...
...
source/server/dnode/inc/dnodeEps.h
浏览文件 @
6bf279b6
...
@@ -33,7 +33,7 @@ typedef struct DnEps {
...
@@ -33,7 +33,7 @@ typedef struct DnEps {
}
DnEps
;
}
DnEps
;
int32_t
dnodeInitEps
(
Dnode
*
dnode
,
DnEps
**
eps
);
int32_t
dnodeInitEps
(
Dnode
*
dnode
,
DnEps
**
eps
);
void
dnodeCleanupEps
(
Dn
ode
*
dnode
,
Dn
Eps
**
eps
);
void
dnodeCleanupEps
(
DnEps
**
eps
);
void
dnodeUpdateEps
(
DnEps
*
eps
,
SDnodeEps
*
data
);
void
dnodeUpdateEps
(
DnEps
*
eps
,
SDnodeEps
*
data
);
bool
dnodeIsDnodeEpChanged
(
DnEps
*
eps
,
int32_t
dnodeId
,
char
*
epstr
);
bool
dnodeIsDnodeEpChanged
(
DnEps
*
eps
,
int32_t
dnodeId
,
char
*
epstr
);
void
dnodeGetDnodeEp
(
Dnode
*
dnode
,
int32_t
dnodeId
,
char
*
epstr
,
char
*
fqdn
,
uint16_t
*
port
);
void
dnodeGetDnodeEp
(
Dnode
*
dnode
,
int32_t
dnodeId
,
char
*
epstr
,
char
*
fqdn
,
uint16_t
*
port
);
...
...
source/server/dnode/src/dnodeCfg.c
浏览文件 @
6bf279b6
...
@@ -128,7 +128,7 @@ int32_t dnodeInitCfg(Dnode *dnode, DnCfg **out) {
...
@@ -128,7 +128,7 @@ int32_t dnodeInitCfg(Dnode *dnode, DnCfg **out) {
return
ret
;
return
ret
;
}
}
void
dnodeCleanupCfg
(
Dn
ode
*
dnode
,
Dn
Cfg
**
out
)
{
void
dnodeCleanupCfg
(
DnCfg
**
out
)
{
DnCfg
*
cfg
=
*
out
;
DnCfg
*
cfg
=
*
out
;
*
out
=
NULL
;
*
out
=
NULL
;
...
...
source/server/dnode/src/dnodeCheck.c
浏览文件 @
6bf279b6
...
@@ -194,7 +194,7 @@ int32_t dnodeInitCheck(Dnode *dnode, DnCheck **out) {
...
@@ -194,7 +194,7 @@ int32_t dnodeInitCheck(Dnode *dnode, DnCheck **out) {
return
0
;
return
0
;
}
}
void
dnodeCleanupCheck
(
Dn
ode
*
dnode
,
Dn
Check
**
out
)
{
void
dnodeCleanupCheck
(
DnCheck
**
out
)
{
DnCheck
*
check
=
*
out
;
DnCheck
*
check
=
*
out
;
*
out
=
NULL
;
*
out
=
NULL
;
...
...
source/server/dnode/src/dnodeEps.c
浏览文件 @
6bf279b6
...
@@ -204,7 +204,7 @@ int32_t dnodeInitEps(Dnode *dnode, DnEps **out) {
...
@@ -204,7 +204,7 @@ int32_t dnodeInitEps(Dnode *dnode, DnEps **out) {
return
ret
;
return
ret
;
}
}
void
dnodeCleanupEps
(
Dn
ode
*
dnode
,
Dn
Eps
**
out
)
{
void
dnodeCleanupEps
(
DnEps
**
out
)
{
DnEps
*
eps
=
*
out
;
DnEps
*
eps
=
*
out
;
*
out
=
NULL
;
*
out
=
NULL
;
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录