Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
taosdata
TDengine
提交
7661798c
TDengine
项目概览
taosdata
/
TDengine
1 年多 前同步成功
通知
1185
Star
22016
Fork
4786
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
1
列表
看板
标记
里程碑
合并请求
0
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
TDengine
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
1
Issue
1
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
提交
Issue看板
提交
7661798c
编写于
11月 15, 2021
作者:
Z
zhaoyanggh
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
fix win compile
上级
0d7e8302
变更
1
隐藏空白更改
内联
并排
Showing
1 changed file
with
11 addition
and
9 deletion
+11
-9
src/kit/taosdemo/src/demoInsert.c
src/kit/taosdemo/src/demoInsert.c
+11
-9
未找到文件。
src/kit/taosdemo/src/demoInsert.c
浏览文件 @
7661798c
...
...
@@ -2144,7 +2144,8 @@ static void *syncWriteInterlaceSml(threadInfo *pThreadInfo,
if
(
stbInfo
->
lineProtocol
==
TSDB_SML_JSON_PROTOCOL
)
{
cJSON
*
tag
=
cJSON_Duplicate
(
cJSON_GetArrayItem
(
tagsList
,
tableSeq
-
pThreadInfo
->
start_table_from
),
tagsList
,
(
int
)(
tableSeq
-
pThreadInfo
->
start_table_from
)),
true
);
code
=
generateSmlJsonCols
(
jsonArray
,
tag
,
stbInfo
,
pThreadInfo
,
timestamp
);
...
...
@@ -2188,7 +2189,7 @@ static void *syncWriteInterlaceSml(threadInfo *pThreadInfo,
int64_t
remainRows
=
insertRows
-
generatedRecPerTbl
;
if
((
remainRows
>
0
)
&&
(
batchPerTbl
>
remainRows
))
{
batchPerTbl
=
remainRows
;
batchPerTbl
=
(
uint32_t
)
remainRows
;
}
if
(
pThreadInfo
->
ntables
*
batchPerTbl
<
g_args
.
reqPerReq
)
{
...
...
@@ -2261,7 +2262,8 @@ static void *syncWriteInterlaceSml(threadInfo *pThreadInfo,
pThreadInfo
->
totalAffectedRows
+=
affectedRows
;
int
currentPercent
=
pThreadInfo
->
totalAffectedRows
*
100
/
totalRows
;
int
currentPercent
=
(
int
)(
pThreadInfo
->
totalAffectedRows
*
100
/
totalRows
);
if
(
currentPercent
>
percentComplete
)
{
printf
(
"[%d]:%d%%
\n
"
,
pThreadInfo
->
threadID
,
currentPercent
);
percentComplete
=
currentPercent
;
...
...
@@ -2283,7 +2285,7 @@ static void *syncWriteInterlaceSml(threadInfo *pThreadInfo,
performancePrint
(
"%s() LN%d sleep: %"
PRId64
" ms for insert interval
\n
"
,
__func__
,
__LINE__
,
sleepTime
);
taosMsleep
(
sleepTime
);
// ms
taosMsleep
(
(
int32_t
)
sleepTime
);
// ms
sleepTimeTotal
+=
insert_interval
;
}
}
...
...
@@ -2626,7 +2628,7 @@ void *syncWriteProgressiveSml(threadInfo *pThreadInfo) {
cJSON
*
jsonArray
;
if
(
insertRows
<
g_args
.
reqPerReq
)
{
g_args
.
reqPerReq
=
insertRows
;
g_args
.
reqPerReq
=
(
uint32_t
)
insertRows
;
}
if
(
stbInfo
->
lineProtocol
==
TSDB_SML_LINE_PROTOCOL
||
...
...
@@ -2686,8 +2688,8 @@ void *syncWriteProgressiveSml(threadInfo *pThreadInfo) {
for
(
uint64_t
j
=
0
;
j
<
insertRows
;)
{
for
(
int
k
=
0
;
k
<
g_args
.
reqPerReq
;
k
++
)
{
if
(
stbInfo
->
lineProtocol
==
TSDB_SML_JSON_PROTOCOL
)
{
cJSON
*
tag
=
cJSON_
Duplicate
(
cJSON_GetArrayItem
(
tagsList
,
i
),
true
);
cJSON
*
tag
=
cJSON_Duplicate
(
cJSON_
GetArrayItem
(
tagsList
,
(
int
)
i
),
true
);
code
=
generateSmlJsonCols
(
jsonArray
,
tag
,
stbInfo
,
pThreadInfo
,
timestamp
);
if
(
code
)
{
...
...
@@ -2737,8 +2739,8 @@ void *syncWriteProgressiveSml(threadInfo *pThreadInfo) {
pThreadInfo
->
totalAffectedRows
+=
affectedRows
;
pThreadInfo
->
totalInsertRows
+=
g_args
.
reqPerReq
;
currentPercent
=
pThreadInfo
->
totalAffectedRows
*
100
/
(
insertRows
*
pThreadInfo
->
ntables
);
currentPercent
=
(
int
)(
pThreadInfo
->
totalAffectedRows
*
100
/
(
insertRows
*
pThreadInfo
->
ntables
)
);
if
(
currentPercent
>
percentComplete
)
{
printf
(
"[%d]:%d%%
\n
"
,
pThreadInfo
->
threadID
,
currentPercent
);
percentComplete
=
currentPercent
;
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录