Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
taosdata
TDengine
提交
f7a7d148
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看板
提交
f7a7d148
编写于
3月 21, 2022
作者:
H
Haojun Liao
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
[td-13039] fix compiler error.
上级
bda9c060
变更
3
隐藏空白更改
内联
并排
Showing
3 changed file
with
24 addition
and
8 deletion
+24
-8
source/client/test/clientTests.cpp
source/client/test/clientTests.cpp
+2
-0
source/dnode/vnode/test/tsdbSmaTest.cpp
source/dnode/vnode/test/tsdbSmaTest.cpp
+3
-1
source/libs/transport/test/transUT.cc
source/libs/transport/test/transUT.cc
+19
-7
未找到文件。
source/client/test/clientTests.cpp
浏览文件 @
f7a7d148
...
...
@@ -271,6 +271,8 @@ TEST(testCase, create_stable_Test) {
}
taos_free_result
(
pRes
);
pRes
=
taos_query
(
pConn
,
"use abc1"
);
pRes
=
taos_query
(
pConn
,
"create table if not exists abc1.st1(ts timestamp, k int) tags(a int)"
);
if
(
taos_errno
(
pRes
)
!=
0
)
{
printf
(
"error in create stable, reason:%s
\n
"
,
taos_errstr
(
pRes
));
...
...
source/dnode/vnode/test/tsdbSmaTest.cpp
浏览文件 @
f7a7d148
...
...
@@ -304,7 +304,9 @@ TEST(testCase, tSma_Data_Insert_Query_Test) {
break
;
}
SDiskCfg
pDisks
=
{.
level
=
0
,
.
primary
=
1
};
SDiskCfg
pDisks
=
{
0
};
pDisks
.
level
=
0
;
pDisks
.
primary
=
1
;
strncpy
(
pDisks
.
dir
,
"/var/lib/taos"
,
TSDB_FILENAME_LEN
);
int32_t
numOfDisks
=
1
;
pTsdb
->
pTfs
=
tfsOpen
(
&
pDisks
,
numOfDisks
);
...
...
source/libs/transport/test/transUT.cc
浏览文件 @
f7a7d148
...
...
@@ -333,7 +333,10 @@ TEST_F(TransEnv, cliPersistHandle) {
SRpcMsg
resp
=
{
0
};
void
*
handle
=
NULL
;
for
(
int
i
=
0
;
i
<
10
;
i
++
)
{
SRpcMsg
req
=
{.
handle
=
resp
.
handle
,
.
persistHandle
=
1
};
SRpcMsg
req
=
{
0
};
req
.
handle
=
resp
.
handle
;
req
.
persistHandle
=
1
;
req
.
msgType
=
1
;
req
.
pCont
=
rpcMallocCont
(
10
);
req
.
contLen
=
10
;
...
...
@@ -366,7 +369,9 @@ TEST_F(TransEnv, srvReleaseHandle) {
// tr->Restart(processReleaseHandleCb);
void
*
handle
=
NULL
;
for
(
int
i
=
0
;
i
<
1
;
i
++
)
{
SRpcMsg
req
=
{.
handle
=
resp
.
handle
,
.
persistHandle
=
1
};
SRpcMsg
req
=
{
0
};
req
.
handle
=
resp
.
handle
;
req
.
persistHandle
=
1
;
req
.
msgType
=
1
;
req
.
pCont
=
rpcMallocCont
(
10
);
req
.
contLen
=
10
;
...
...
@@ -379,7 +384,9 @@ TEST_F(TransEnv, srvReleaseHandle) {
TEST_F
(
TransEnv
,
cliReleaseHandleExcept
)
{
SRpcMsg
resp
=
{
0
};
for
(
int
i
=
0
;
i
<
3
;
i
++
)
{
SRpcMsg
req
=
{.
handle
=
resp
.
handle
,
.
persistHandle
=
1
};
SRpcMsg
req
=
{
0
};
req
.
handle
=
resp
.
handle
;
req
.
persistHandle
=
1
;
req
.
msgType
=
1
;
req
.
pCont
=
rpcMallocCont
(
10
);
req
.
contLen
=
10
;
...
...
@@ -411,7 +418,8 @@ TEST_F(TransEnv, srvPersistHandleExcept) {
// tr->SetCliPersistFp(cliPersistHandle);
SRpcMsg
resp
=
{
0
};
for
(
int
i
=
0
;
i
<
5
;
i
++
)
{
SRpcMsg
req
=
{.
handle
=
resp
.
handle
};
SRpcMsg
req
=
{
0
};
req
.
handle
=
resp
.
handle
;
req
.
msgType
=
1
;
req
.
pCont
=
rpcMallocCont
(
10
);
req
.
contLen
=
10
;
...
...
@@ -429,7 +437,8 @@ TEST_F(TransEnv, cliPersistHandleExcept) {
tr
->
SetSrvContinueSend
(
processContinueSend
);
SRpcMsg
resp
=
{
0
};
for
(
int
i
=
0
;
i
<
5
;
i
++
)
{
SRpcMsg
req
=
{.
handle
=
resp
.
handle
};
SRpcMsg
req
=
{
0
};
req
.
handle
=
resp
.
handle
;
req
.
msgType
=
1
;
req
.
pCont
=
rpcMallocCont
(
10
);
req
.
contLen
=
10
;
...
...
@@ -451,7 +460,9 @@ TEST_F(TransEnv, queryExcept) {
tr
->
SetSrvContinueSend
(
processRegisterFailure
);
SRpcMsg
resp
=
{
0
};
for
(
int
i
=
0
;
i
<
5
;
i
++
)
{
SRpcMsg
req
=
{.
handle
=
resp
.
handle
,
.
persistHandle
=
1
};
SRpcMsg
req
=
{
0
};
req
.
handle
=
resp
.
handle
;
req
.
persistHandle
=
1
;
req
.
msgType
=
1
;
req
.
pCont
=
rpcMallocCont
(
10
);
req
.
contLen
=
10
;
...
...
@@ -467,7 +478,8 @@ TEST_F(TransEnv, queryExcept) {
TEST_F
(
TransEnv
,
noResp
)
{
SRpcMsg
resp
=
{
0
};
for
(
int
i
=
0
;
i
<
5
;
i
++
)
{
SRpcMsg
req
=
{.
noResp
=
1
};
SRpcMsg
req
=
{
0
};
req
.
noResp
=
1
;
req
.
msgType
=
1
;
req
.
pCont
=
rpcMallocCont
(
10
);
req
.
contLen
=
10
;
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录