Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
taosdata
TDengine
提交
b5ebd55b
T
TDengine
项目概览
taosdata
/
TDengine
12 个月 前同步成功
通知
1180
Star
22014
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看板
体验新版 GitCode,发现更多精彩内容 >>
提交
b5ebd55b
编写于
7月 28, 2022
作者:
M
Minghao Li
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
refactor(sync): add test case
上级
e0f0e926
变更
2
隐藏空白更改
内联
并排
Showing
2 changed file
with
141 addition
and
6 deletion
+141
-6
source/libs/sync/test/sh/a.sh
source/libs/sync/test/sh/a.sh
+6
-6
tests/script/tsim/sync/vnodeLogAnalyzeTest.sim
tests/script/tsim/sync/vnodeLogAnalyzeTest.sim
+135
-0
未找到文件。
source/libs/sync/test/sh/a.sh
浏览文件 @
b5ebd55b
...
...
@@ -22,25 +22,25 @@ done
echo
""
echo
"generate vgId ..."
cat
${
logpath
}
/log.dnode
*
|
grep
"vgId:"
|
grep
-v
ERROR |
awk
'{print $5}'
|
sort
|
uniq
>
${
logpath
}
/log.vgIds.tmp
cat
${
logpath
}
/log.dnode
*
|
grep
"vgId:"
|
grep
-v
ERROR |
awk
'{print $5}'
|
awk
-F
,
'{print $1}'
|
sort
-T
.
|
uniq
|
awk
-F
:
'{print $2, $0}'
|
sort
-T
.
-k1
-n
|
awk
'{print $2}'
>
${
logpath
}
/log.vgIds.tmp
echo
"all vgIds:"
>
${
logpath
}
/log.vgIds
cat
${
logpath
}
/log.dnode
*
|
grep
"vgId:"
|
grep
-v
ERROR |
awk
'{print $5}'
|
awk
-F
,
'{print $1}'
|
sort
|
uniq
>>
${
logpath
}
/log.vgIds
cat
${
logpath
}
/log.dnode
*
|
grep
"vgId:"
|
grep
-v
ERROR |
awk
'{print $5}'
|
awk
-F
,
'{print $1}'
|
sort
-T
.
|
uniq
|
awk
-F
:
'{print $2, $0}'
|
sort
-T
.
-k1
-n
|
awk
'{print $2}'
>>
${
logpath
}
/log.vgIds
for
dnode
in
`
ls
${
logpath
}
|
grep
dnode |
grep
-v
log
`
;
do
echo
""
>>
${
logpath
}
/log.vgIds
echo
""
>>
${
logpath
}
/log.vgIds
echo
"
${
dnode
}
:"
>>
${
logpath
}
/log.vgIds
cat
${
logpath
}
/
${
dnode
}
/log/taosdlog.
*
|
grep
SYN |
grep
"vgId:"
|
grep
-v
ERROR |
awk
'{print $5}'
|
awk
-F
,
'{print $1}'
|
sort
|
uniq
>>
${
logpath
}
/log.vgIds
cat
${
logpath
}
/
${
dnode
}
/log/taosdlog.
*
|
grep
SYN |
grep
"vgId:"
|
grep
-v
ERROR |
awk
'{print $5}'
|
awk
-F
,
'{print $1}'
|
sort
-T
.
|
uniq
|
awk
-F
:
'{print $2, $0}'
|
sort
-T
.
-k1
-n
|
awk
'{print $2}'
>>
${
logpath
}
/log.vgIds
done
echo
""
echo
"generate log.dnode.vgId ..."
for
logdnode
in
`
ls
${
logpath
}
/log.dnode
*
`
;
do
for
vgId
in
`
cat
${
logpath
}
/log.vgIds.tmp
`
;
do
rowNum
=
`
cat
${
logdnode
}
|
grep
"
${
vgId
}
"
|
awk
'BEGIN{rowNum=0}{rowNum++}END{print rowNum}'
`
rowNum
=
`
cat
${
logdnode
}
|
grep
"
${
vgId
}
,
"
|
awk
'BEGIN{rowNum=0}{rowNum++}END{print rowNum}'
`
#echo "-----${rowNum}"
if
[
$rowNum
-gt
0
]
;
then
echo
"generate
${
logdnode
}
.
${
vgId
}
"
cat
${
logdnode
}
|
grep
"
${
vgId
}
"
>
${
logdnode
}
.
${
vgId
}
cat
${
logdnode
}
|
grep
"
${
vgId
}
,
"
>
${
logdnode
}
.
${
vgId
}
fi
done
done
...
...
@@ -54,7 +54,7 @@ done
echo
""
echo
"generate log.leader.term ..."
cat
${
logpath
}
/
*
.main |
grep
"become leader"
|
grep
-v
"config change"
|
awk
'{print $5,$0}'
|
awk
-F
,
'{print $4"_"$0}'
|
sort
-k1
>
${
logpath
}
/log.leader.term
cat
${
logpath
}
/
*
.main |
grep
"become leader"
|
grep
-v
"config change"
|
awk
'{print $5,$0}'
|
awk
-F
,
'{print $4"_"$0}'
|
sort
-
T
.
-
k1
>
${
logpath
}
/log.leader.term
echo
""
echo
"generate log.index, log.snapshot, log.records, log.actions ..."
...
...
tests/script/tsim/sync/vnodeLogAnalyzeTest.sim
0 → 100644
浏览文件 @
b5ebd55b
system sh/stop_dnodes.sh
system sh/deploy.sh -n dnode1 -i 1
system sh/deploy.sh -n dnode2 -i 2
system sh/deploy.sh -n dnode3 -i 3
system sh/deploy.sh -n dnode4 -i 4
system sh/cfg.sh -n dnode1 -c supportVnodes -v 0
system sh/exec.sh -n dnode1 -s start
system sh/exec.sh -n dnode2 -s start
system sh/exec.sh -n dnode3 -s start
system sh/exec.sh -n dnode4 -s start
sql connect
sql create dnode $hostname port 7200
sql create dnode $hostname port 7300
sql create dnode $hostname port 7400
$x = 0
step1:
$x = $x + 1
sleep 1000
if $x == 10 then
print ====> dnode not ready!
return -1
endi
sql show dnodes
print ===> $data00 $data01 $data02 $data03 $data04 $data05
print ===> $data10 $data11 $data12 $data13 $data14 $data15
print ===> $data20 $data21 $data22 $data23 $data24 $data25
print ===> $data30 $data31 $data32 $data33 $data34 $data35
if $rows != 4 then
return -1
endi
if $data(1)[4] != ready then
goto step1
endi
if $data(2)[4] != ready then
goto step1
endi
if $data(3)[4] != ready then
goto step1
endi
if $data(4)[4] != ready then
goto step1
endi
$replica = 3
$vgroups = 30
print ============= create database
sql create database db replica $replica vgroups $vgroups
$loop_cnt = 0
check_db_ready:
$loop_cnt = $loop_cnt + 1
sleep 200
if $loop_cnt == 100 then
print ====> db not ready!
return -1
endi
sql show databases
print ===> rows: $rows
print $data[2][0] $data[2][1] $data[2][2] $data[2][3] $data[2][4] $data[2][5] $data[2][6] $data[2][7] $data[2][8] $data[2][9] $data[2][6] $data[2][11] $data[2][12] $data[2][13] $data[2][14] $data[2][15] $data[2][16] $data[2][17] $data[2][18] $data[2][19]
if $rows != 3 then
return -1
endi
if $data[2][15] != ready then
goto check_db_ready
endi
sql use db
$loop_cnt = 0
check_vg_ready:
$loop_cnt = $loop_cnt + 1
sleep 200
if $loop_cnt == 300 then
print ====> vgroups not ready!
return -1
endi
sql show vgroups
print ===> rows: $rows
print $data[0][0] $data[0][1] $data[0][2] $data[0][3] $data[0][4] $data[0][5] $data[0][6] $data[0][7] $data[0][8] $data[0][9] $data[0][10] $data[0][11]
if $rows != $vgroups then
return -1
endi
if $data[0][4] == leader then
if $data[0][6] == follower then
if $data[0][8] == follower then
print ---- vgroup $data[0][0] leader locate on dnode $data[0][3]
endi
endi
elif $data[0][6] == leader then
if $data[0][4] == follower then
if $data[0][8] == follower then
print ---- vgroup $data[0][0] leader locate on dnode $data[0][5]
endi
endi
elif $data[0][8] == leader then
if $data[0][4] == follower then
if $data[0][6] == follower then
print ---- vgroup $data[0][0] leader locate on dnode $data[0][7]
endi
endi
else
goto check_vg_ready
endi
vg_ready:
print ====> create stable/child table
sql create table stb (ts timestamp, c1 int, c2 float, c3 double) tags (t1 int)
sql show stables
if $rows != 1 then
return -1
endi
sql create table ct1 using stb tags(1000)
print ===> write 1000 records
$N = 10000
$count = 0
while $count < $N
$ms = 1591200000000 + $count
sql insert into ct1 values( $ms , $count , 2.1, 3.1)
$count = $count + 1
endw
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录