Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
慢慢CG
TDengine
提交
da40c925
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看板
提交
da40c925
编写于
4月 11, 2020
作者:
H
hjxilinx
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
[td-98] fix compiler error
上级
1dd2e59e
变更
4
隐藏空白更改
内联
并排
Showing
4 changed file
with
16 addition
and
22 deletion
+16
-22
src/query/src/queryExecutor.c
src/query/src/queryExecutor.c
+1
-1
src/util/inc/tutil.h
src/util/inc/tutil.h
+1
-7
src/util/src/tglobalcfg.c
src/util/src/tglobalcfg.c
+11
-10
src/util/src/tutil.c
src/util/src/tutil.c
+3
-4
未找到文件。
src/query/src/queryExecutor.c
浏览文件 @
da40c925
...
...
@@ -924,7 +924,7 @@ static void blockwiseApplyAllFunctions(SQueryRuntimeEnv *pRuntimeEnv, SDataStati
STimeWindow
win
=
getActiveTimeWindow
(
pWindowResInfo
,
ts
,
pQuery
);
if
(
setWindowOutputBufByKey
(
pRuntimeEnv
,
pWindowResInfo
,
pDataBlockInfo
->
sid
,
&
win
)
!=
TSDB_CODE_SUCCESS
)
{
return
0
;
return
;
}
TSKEY
ekey
=
reviseWindowEkey
(
pQuery
,
&
win
);
...
...
src/util/inc/tutil.h
浏览文件 @
da40c925
...
...
@@ -121,11 +121,7 @@ int64_t strnatoi(char *num, int32_t len);
char
*
strreplace
(
const
char
*
str
,
const
char
*
pattern
,
const
char
*
rep
);
#define POW2(x) ((x) * (x))
int32_t
strdequote
(
char
*
src
);
char
*
paGetToken
(
char
*
src
,
size_t
maxLen
,
char
**
token
,
int32_t
*
tokenLen
);
char
*
paGetToken
(
char
*
src
,
char
**
token
,
int32_t
*
tokenLen
);
void
taosMsleep
(
int32_t
mseconds
);
...
...
@@ -133,8 +129,6 @@ int32_t taosByteArrayToHexStr(char bytes[], int32_t len, char hexstr[]);
int32_t
taosHexStrToByteArray
(
char
hexstr
[],
char
bytes
[]);
int64_t
str2int64
(
char
*
str
);
int32_t
taosFileRename
(
char
*
fullPath
,
char
*
suffix
,
char
delimiter
,
char
**
dstPath
);
/**
...
...
src/util/src/tglobalcfg.c
浏览文件 @
da40c925
...
...
@@ -874,12 +874,13 @@ void tsReadGlobalLogConfig() {
olen
=
vlen
=
0
;
getline
(
&
line
,
&
len
,
fp
);
paGetToken
(
line
,
len
,
&
option
,
&
olen
);
line
[
len
-
1
]
=
0
;
paGetToken
(
line
,
&
option
,
&
olen
);
if
(
olen
==
0
)
continue
;
option
[
olen
]
=
0
;
paGetToken
(
option
+
olen
+
1
,
len
,
&
value
,
&
vlen
);
paGetToken
(
option
+
olen
+
1
,
&
value
,
&
vlen
);
if
(
vlen
==
0
)
continue
;
value
[
vlen
]
=
0
;
...
...
@@ -911,18 +912,19 @@ bool tsReadGlobalConfig() {
olen
=
vlen
=
0
;
getline
(
&
line
,
&
len
,
fp
);
paGetToken
(
line
,
len
,
&
option
,
&
olen
);
line
[
len
-
1
]
=
0
;
paGetToken
(
line
,
&
option
,
&
olen
);
if
(
olen
==
0
)
continue
;
option
[
olen
]
=
0
;
paGetToken
(
option
+
olen
+
1
,
len
,
&
value
,
&
vlen
);
paGetToken
(
option
+
olen
+
1
,
&
value
,
&
vlen
);
if
(
vlen
==
0
)
continue
;
value
[
vlen
]
=
0
;
// For dataDir, the format is:
// dataDir /mnt/disk1 0
paGetToken
(
value
+
vlen
+
1
,
len
,
&
value1
,
&
vlen1
);
paGetToken
(
value
+
vlen
+
1
,
&
value1
,
&
vlen1
);
tsReadConfigOption
(
option
,
value
);
}
...
...
@@ -1005,11 +1007,10 @@ int tsCfgDynamicOptions(char *msg) {
int
olen
,
vlen
,
code
=
0
;
int
vint
=
0
;
size_t
len
=
120
;
paGetToken
(
msg
,
len
,
&
option
,
&
olen
);
paGetToken
(
msg
,
&
option
,
&
olen
);
if
(
olen
==
0
)
return
TSDB_CODE_INVALID_MSG_CONTENT
;
paGetToken
(
option
+
olen
+
1
,
len
,
&
value
,
&
vlen
);
paGetToken
(
option
+
olen
+
1
,
&
value
,
&
vlen
);
if
(
vlen
==
0
)
vint
=
135
;
else
{
...
...
src/util/src/tutil.c
浏览文件 @
da40c925
...
...
@@ -164,9 +164,8 @@ char* strtolower(char *dst, const char *src) {
return
dst
;
}
char
*
paGetToken
(
char
*
string
,
size_t
maxLen
,
char
**
token
,
int32_t
*
tokenLen
)
{
char
*
paGetToken
(
char
*
string
,
char
**
token
,
int32_t
*
tokenLen
)
{
char
quote
=
0
;
char
*
start
=
string
;
while
(
*
string
!=
0
)
{
if
(
*
string
==
' '
||
*
string
==
'\t'
)
{
...
...
@@ -183,7 +182,7 @@ char *paGetToken(char *string, size_t maxLen, char **token, int32_t *tokenLen) {
*
token
=
string
;
while
(
*
string
!=
0
&&
*
string
!=
'\n'
&&
(
string
-
start
<
maxLen
)
)
{
while
(
*
string
!=
0
)
{
if
(
*
string
==
'@'
&&
quote
)
{
//*string = 0;
++
string
;
...
...
@@ -337,7 +336,7 @@ int32_t taosByteArrayToHexStr(char bytes[], int32_t len, char hexstr[]) {
char
hexval
[
16
]
=
{
'0'
,
'1'
,
'2'
,
'3'
,
'4'
,
'5'
,
'6'
,
'7'
,
'8'
,
'9'
,
'a'
,
'b'
,
'c'
,
'd'
,
'e'
,
'f'
};
for
(
i
=
0
;
i
<
len
;
i
++
)
{
hexstr
[
i
*
2
]
=
hexval
[((
bytes
[
i
]
>>
4
)
&
0xF
)];
hexstr
[
i
*
2
]
=
hexval
[((
bytes
[
i
]
>>
4
u
)
&
0xF
)];
hexstr
[(
i
*
2
)
+
1
]
=
hexval
[(
bytes
[
i
])
&
0x0F
];
}
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录