Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
冷面1992
TDengine
提交
24dc1ce1
TDengine
项目概览
冷面1992
/
TDengine
与 Fork 源项目一致
Fork自
taosdata / TDengine
通知
1
Star
0
Fork
0
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
0
列表
看板
标记
里程碑
合并请求
0
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
TDengine
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
0
Issue
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
提交
Issue看板
体验新版 GitCode,发现更多精彩内容 >>
提交
24dc1ce1
编写于
12月 25, 2020
作者:
H
Hui Li
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
[TD-2551]
上级
5daeac0f
变更
1
隐藏空白更改
内联
并排
Showing
1 changed file
with
87 addition
and
9 deletion
+87
-9
src/kit/taosdemo/taosdemo.c
src/kit/taosdemo/taosdemo.c
+87
-9
未找到文件。
src/kit/taosdemo/taosdemo.c
浏览文件 @
24dc1ce1
...
...
@@ -95,7 +95,7 @@ typedef struct DemoArguments {
{
0
,
'P'
,
"password"
,
0
,
"The password to use when connecting to the server. Default is 'taosdata'."
,
3
},
#endif
{
0
,
'd'
,
"database"
,
0
,
"Destination database. Default is 'test'."
,
3
},
{
0
,
'a'
,
"replica"
,
0
,
"Set the replica parameters of the database, Default 1, min: 1, max: 3."
,
3
},
{
0
,
'a'
,
"replica"
,
0
,
"Set the replica parameters of the database, Default 1, min: 1, max: 3."
,
3
},
{
0
,
'm'
,
"table_prefix"
,
0
,
"Table prefix name. Default is 't'."
,
3
},
{
0
,
's'
,
"sql file"
,
0
,
"The select sql file."
,
3
},
{
0
,
'M'
,
0
,
0
,
"Use metric flag."
,
13
},
...
...
@@ -205,10 +205,10 @@ typedef struct DemoArguments {
arguments
->
tb_prefix
=
arg
;
break
;
case
'M'
:
arguments
->
use_metric
=
fals
e
;
arguments
->
use_metric
=
tru
e
;
break
;
case
'x'
:
arguments
->
insert_only
=
fals
e
;
arguments
->
insert_only
=
tru
e
;
break
;
case
'c'
:
if
(
wordexp
(
arg
,
&
full_path
,
0
)
!=
0
)
{
...
...
@@ -406,9 +406,9 @@ typedef struct DemoArguments {
}
else
if
(
strcmp
(
argv
[
i
],
"-m"
)
==
0
)
{
arguments
->
tb_prefix
=
argv
[
++
i
];
}
else
if
(
strcmp
(
argv
[
i
],
"-M"
)
==
0
)
{
arguments
->
use_metric
=
fals
e
;
arguments
->
use_metric
=
tru
e
;
}
else
if
(
strcmp
(
argv
[
i
],
"-x"
)
==
0
)
{
arguments
->
insert_only
=
fals
e
;
arguments
->
insert_only
=
tru
e
;
}
else
if
(
strcmp
(
argv
[
i
],
"-c"
)
==
0
)
{
strcpy
(
configDir
,
argv
[
++
i
]);
}
else
if
(
strcmp
(
argv
[
i
],
"-O"
)
==
0
)
{
...
...
@@ -476,6 +476,14 @@ typedef struct {
int
notFinished
;
tsem_t
lock_sem
;
int
counter
;
// insert delay statitics
int64_t
cntDelay
;
int64_t
totalDelay
;
int64_t
avgDelay
;
int64_t
maxDelay
;
int64_t
minDelay
;
}
info
;
typedef
struct
{
...
...
@@ -575,7 +583,7 @@ int main(int argc, char *argv[]) {
arguments
.
num_of_DPT
=
100000
;
arguments
.
num_of_RPR
=
1000
;
arguments
.
use_metric
=
true
;
arguments
.
insert_only
=
tru
e
;
arguments
.
insert_only
=
fals
e
;
// end change
parse_args
(
argc
,
argv
,
&
arguments
);
...
...
@@ -739,6 +747,9 @@ int main(int argc, char *argv[]) {
printf
(
"Inserting data......
\n
"
);
pthread_t
*
pids
=
malloc
(
threads
*
sizeof
(
pthread_t
));
info
*
infos
=
malloc
(
threads
*
sizeof
(
info
));
memset
(
pids
,
0
,
threads
*
sizeof
(
pthread_t
));
memset
(
infos
,
0
,
threads
*
sizeof
(
info
));
int
a
=
ntables
/
threads
;
if
(
a
<
1
)
{
...
...
@@ -768,6 +779,7 @@ int main(int argc, char *argv[]) {
t_info
->
end_table_id
=
i
<
b
?
last
+
a
:
last
+
a
-
1
;
last
=
t_info
->
end_table_id
+
1
;
t_info
->
counter
=
0
;
t_info
->
minDelay
=
INT16_MAX
;
tsem_init
(
&
(
t_info
->
mutex_sem
),
0
,
1
);
t_info
->
notFinished
=
t_info
->
end_table_id
-
t_info
->
start_table_id
+
1
;
...
...
@@ -799,12 +811,29 @@ int main(int argc, char *argv[]) {
t
,
(
int64_t
)
ntables
*
nrecords_per_table
,
nrecords_per_request
,
(
int64_t
)
ntables
*
nrecords_per_table
/
t
);
int64_t
totalDelay
=
0
;
int64_t
maxDelay
=
0
;
int64_t
minDelay
=
INT16_MAX
;
int64_t
cntDelay
=
0
;
double
avgDelay
=
0
;
for
(
int
i
=
0
;
i
<
threads
;
i
++
)
{
info
*
t_info
=
infos
+
i
;
taos_close
(
t_info
->
taos
);
tsem_destroy
(
&
(
t_info
->
mutex_sem
));
tsem_destroy
(
&
(
t_info
->
lock_sem
));
totalDelay
+=
t_info
->
totalDelay
;
cntDelay
+=
t_info
->
cntDelay
;
if
(
t_info
->
maxDelay
>
maxDelay
)
maxDelay
=
t_info
->
maxDelay
;
if
(
t_info
->
minDelay
<
minDelay
)
minDelay
=
t_info
->
minDelay
;
}
avgDelay
=
(
double
)
totalDelay
/
cntDelay
;
fprintf
(
fp
,
"insert delay, avg:%10.6fms, max: %10.6fms, min: %10.6fms
\n\n
"
,
avgDelay
/
1000
.
0
,
(
double
)
maxDelay
/
1000
.
0
,
(
double
)
minDelay
/
1000
.
0
);
printf
(
"insert delay, avg: %10.6fms, max: %10.6fms, min: %10.6fms
\n\n
"
,
avgDelay
/
1000
.
0
,
(
double
)
maxDelay
/
1000
.
0
,
(
double
)
minDelay
/
1000
.
0
);
free
(
pids
);
free
(
infos
);
...
...
@@ -859,7 +888,7 @@ int main(int argc, char *argv[]) {
}
if
(
!
insert_only
)
{
if
(
false
==
insert_only
)
{
// query data
pthread_t
read_id
;
info
*
rInfo
=
malloc
(
sizeof
(
info
));
...
...
@@ -998,7 +1027,7 @@ void * createTable(void *sarg)
/* Create all the tables; */
printf
(
"Creating table from %d to %d
\n
"
,
winfo
->
start_table_id
,
winfo
->
end_table_id
);
for
(
int
i
=
winfo
->
start_table_id
;
i
<=
winfo
->
end_table_id
;
i
++
)
{
snprintf
(
command
,
BUFFER_SIZE
,
"create table if not exists %s.%s%d (ts timestamp%s;"
,
winfo
->
db_name
,
winfo
->
tb_prefix
,
i
,
winfo
->
cols
);
snprintf
(
command
,
BUFFER_SIZE
,
"create table if not exists %s.%s%d (ts timestamp%s
)
;"
,
winfo
->
db_name
,
winfo
->
tb_prefix
,
i
,
winfo
->
cols
);
queryDB
(
winfo
->
taos
,
command
);
}
}
else
{
...
...
@@ -1204,6 +1233,41 @@ void *readMetric(void *sarg) {
return
NULL
;
}
static
int
queryDbExec
(
TAOS
*
taos
,
char
*
command
,
int
type
)
{
int
i
;
TAOS_RES
*
res
=
NULL
;
int32_t
code
=
-
1
;
for
(
i
=
0
;
i
<
5
;
i
++
)
{
if
(
NULL
!=
res
)
{
taos_free_result
(
res
);
res
=
NULL
;
}
res
=
taos_query
(
taos
,
command
);
code
=
taos_errno
(
res
);
if
(
0
==
code
)
{
break
;
}
}
if
(
code
!=
0
)
{
fprintf
(
stderr
,
"Failed to run %s, reason: %s
\n
"
,
command
,
taos_errstr
(
res
));
taos_free_result
(
res
);
//taos_close(taos);
return
-
1
;
}
if
(
1
==
type
)
{
int
affectedRows
=
taos_affected_rows
(
res
);
taos_free_result
(
res
);
return
affectedRows
;
}
taos_free_result
(
res
);
return
0
;
}
void
queryDB
(
TAOS
*
taos
,
char
*
command
)
{
int
i
;
TAOS_RES
*
pSql
=
NULL
;
...
...
@@ -1273,7 +1337,21 @@ void *syncWrite(void *sarg) {
}
/* puts(buffer); */
queryDB
(
winfo
->
taos
,
buffer
);
int64_t
startTs
;
int64_t
endTs
;
startTs
=
taosGetTimestampUs
();
//queryDB(winfo->taos, buffer);
int
affectedRows
=
queryDbExec
(
winfo
->
taos
,
buffer
,
1
);
if
(
0
<=
affectedRows
){
endTs
=
taosGetTimestampUs
();
int64_t
delay
=
endTs
-
startTs
;
if
(
delay
>
winfo
->
maxDelay
)
winfo
->
maxDelay
=
delay
;
if
(
delay
<
winfo
->
minDelay
)
winfo
->
minDelay
=
delay
;
winfo
->
cntDelay
++
;
winfo
->
totalDelay
+=
delay
;
//winfo->avgDelay = (double)winfo->totalDelay / winfo->cntDelay;
}
if
(
tID
==
winfo
->
end_table_id
)
{
i
=
inserted
;
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录