Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
慢慢CG
TDengine
提交
11e042a1
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看板
提交
11e042a1
编写于
3月 03, 2021
作者:
M
Minglei Jin
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
[TD-3042]<fix>: fix unsigned to signed conversion with serverPort
max(serverPort) changed from 65535 to 65056
上级
535234a1
变更
4
隐藏空白更改
内联
并排
Showing
4 changed file
with
32 addition
and
5 deletion
+32
-5
src/common/src/tglobal.c
src/common/src/tglobal.c
+2
-2
src/dnode/src/dnodeCheck.c
src/dnode/src/dnodeCheck.c
+3
-3
src/util/inc/tconfig.h
src/util/inc/tconfig.h
+1
-0
src/util/src/tconfig.c
src/util/src/tconfig.c
+26
-0
未找到文件。
src/common/src/tglobal.c
浏览文件 @
11e042a1
...
...
@@ -430,10 +430,10 @@ static void doInitGlobalConfig(void) {
// port
cfg
.
option
=
"serverPort"
;
cfg
.
ptr
=
&
tsServerPort
;
cfg
.
valType
=
TAOS_CFG_VTYPE_INT16
;
cfg
.
valType
=
TAOS_CFG_VTYPE_
U
INT16
;
cfg
.
cfgType
=
TSDB_CFG_CTYPE_B_CONFIG
|
TSDB_CFG_CTYPE_B_SHOW
|
TSDB_CFG_CTYPE_B_CLIENT
;
cfg
.
minValue
=
1
;
cfg
.
maxValue
=
65
535
;
cfg
.
maxValue
=
65
056
;
cfg
.
ptrLength
=
0
;
cfg
.
unitType
=
TAOS_CFG_UTYPE_NONE
;
taosInitConfigOption
(
cfg
);
...
...
src/dnode/src/dnodeCheck.c
浏览文件 @
11e042a1
...
...
@@ -29,7 +29,7 @@ typedef struct {
static
SCheckItem
tsCheckItem
[
TSDB_CHECK_ITEM_MAX
]
=
{{
0
}};
int64_t
tsMinFreeMemSizeForStart
=
0
;
static
int32_t
bindTcpPort
(
int16_t
port
)
{
static
int32_t
bindTcpPort
(
u
int16_t
port
)
{
SOCKET
serverSocket
;
struct
sockaddr_in
server_addr
;
...
...
@@ -85,9 +85,9 @@ static int32_t bindUdpPort(int16_t port) {
static
int32_t
dnodeCheckNetwork
()
{
int32_t
ret
;
int16_t
startPort
=
tsServerPort
;
u
int16_t
startPort
=
tsServerPort
;
for
(
int16_t
port
=
startPort
;
port
<
startPort
+
12
;
port
++
)
{
for
(
u
int16_t
port
=
startPort
;
port
<
startPort
+
12
;
port
++
)
{
ret
=
bindTcpPort
(
port
);
if
(
0
!=
ret
)
{
dError
(
"failed to tcp bind port %d, quit"
,
port
);
...
...
src/util/inc/tconfig.h
浏览文件 @
11e042a1
...
...
@@ -44,6 +44,7 @@ enum {
TAOS_CFG_VTYPE_INT8
,
TAOS_CFG_VTYPE_INT16
,
TAOS_CFG_VTYPE_INT32
,
TAOS_CFG_VTYPE_UINT16
,
TAOS_CFG_VTYPE_FLOAT
,
TAOS_CFG_VTYPE_STRING
,
TAOS_CFG_VTYPE_IPSTR
,
...
...
src/util/src/tconfig.c
浏览文件 @
11e042a1
...
...
@@ -95,6 +95,23 @@ static void taosReadInt16Config(SGlobalCfg *cfg, char *input_value) {
}
}
static
void
taosReadUInt16Config
(
SGlobalCfg
*
cfg
,
char
*
input_value
)
{
int32_t
value
=
atoi
(
input_value
);
uint16_t
*
option
=
(
uint16_t
*
)
cfg
->
ptr
;
if
(
value
<
cfg
->
minValue
||
value
>
cfg
->
maxValue
)
{
uError
(
"config option:%s, input value:%s, out of range[%f, %f], use default value:%d"
,
cfg
->
option
,
input_value
,
cfg
->
minValue
,
cfg
->
maxValue
,
*
option
);
}
else
{
if
(
cfg
->
cfgStatus
<=
TAOS_CFG_CSTATUS_FILE
)
{
*
option
=
(
uint16_t
)
value
;
cfg
->
cfgStatus
=
TAOS_CFG_CSTATUS_FILE
;
}
else
{
uWarn
(
"config option:%s, input value:%s, is configured by %s, use %d"
,
cfg
->
option
,
input_value
,
tsCfgStatusStr
[
cfg
->
cfgStatus
],
*
option
);
}
}
}
static
void
taosReadInt8Config
(
SGlobalCfg
*
cfg
,
char
*
input_value
)
{
int32_t
value
=
atoi
(
input_value
);
int8_t
*
option
=
(
int8_t
*
)
cfg
->
ptr
;
...
...
@@ -239,6 +256,9 @@ static void taosReadConfigOption(const char *option, char *value, char *value2,
case
TAOS_CFG_VTYPE_INT32
:
taosReadInt32Config
(
cfg
,
value
);
break
;
case
TAOS_CFG_VTYPE_UINT16
:
taosReadUInt16Config
(
cfg
,
value
);
break
;
case
TAOS_CFG_VTYPE_FLOAT
:
taosReadFloatConfig
(
cfg
,
value
);
break
;
...
...
@@ -422,6 +442,9 @@ void taosPrintGlobalCfg() {
case
TAOS_CFG_VTYPE_INT32
:
uInfo
(
" %s:%s%d%s"
,
cfg
->
option
,
blank
,
*
((
int32_t
*
)
cfg
->
ptr
),
tsGlobalUnit
[
cfg
->
unitType
]);
break
;
case
TAOS_CFG_VTYPE_UINT16
:
uInfo
(
" %s:%s%d%s"
,
cfg
->
option
,
blank
,
*
((
uint16_t
*
)
cfg
->
ptr
),
tsGlobalUnit
[
cfg
->
unitType
]);
break
;
case
TAOS_CFG_VTYPE_FLOAT
:
uInfo
(
" %s:%s%f%s"
,
cfg
->
option
,
blank
,
*
((
float
*
)
cfg
->
ptr
),
tsGlobalUnit
[
cfg
->
unitType
]);
break
;
...
...
@@ -459,6 +482,9 @@ static void taosDumpCfg(SGlobalCfg *cfg) {
case
TAOS_CFG_VTYPE_INT32
:
printf
(
" %s:%s%d%s
\n
"
,
cfg
->
option
,
blank
,
*
((
int32_t
*
)
cfg
->
ptr
),
tsGlobalUnit
[
cfg
->
unitType
]);
break
;
case
TAOS_CFG_VTYPE_UINT16
:
printf
(
" %s:%s%d%s
\n
"
,
cfg
->
option
,
blank
,
*
((
uint16_t
*
)
cfg
->
ptr
),
tsGlobalUnit
[
cfg
->
unitType
]);
break
;
case
TAOS_CFG_VTYPE_FLOAT
:
printf
(
" %s:%s%f%s
\n
"
,
cfg
->
option
,
blank
,
*
((
float
*
)
cfg
->
ptr
),
tsGlobalUnit
[
cfg
->
unitType
]);
break
;
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录