Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
taosdata
TDengine
提交
8ac6495d
TDengine
项目概览
taosdata
/
TDengine
12 个月 前同步成功
通知
1180
Star
22014
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看板
体验新版 GitCode,发现更多精彩内容 >>
未验证
提交
8ac6495d
编写于
6月 15, 2022
作者:
H
Hui Li
提交者:
GitHub
6月 15, 2022
浏览文件
操作
浏览文件
下载
差异文件
Merge pull request #13873 from taosdata/test/chr/TD-14699
test:modify testcase of muti-mnode
上级
941cc2b6
4ae574a3
变更
1
隐藏空白更改
内联
并排
Showing
1 changed file
with
20 addition
and
36 deletion
+20
-36
tests/system-test/6-cluster/5dnode3mnodeStopInsert.py
tests/system-test/6-cluster/5dnode3mnodeStopInsert.py
+20
-36
未找到文件。
tests/system-test/6-cluster/5dnode3mnodeStopInsert.py
浏览文件 @
8ac6495d
...
@@ -23,39 +23,6 @@ class MyDnodes(TDDnodes):
...
@@ -23,39 +23,6 @@ class MyDnodes(TDDnodes):
self
.
dnodes
=
dnodes_lists
# dnode must be TDDnode instance
self
.
dnodes
=
dnodes_lists
# dnode must be TDDnode instance
self
.
simDeployed
=
False
self
.
simDeployed
=
False
class
MyThreadFunc
(
object
):
'''
手动终止线程的方法
'''
def
__init__
(
self
,
func
):
self
.
myThread
=
threading
.
Thread
(
target
=
func
)
def
start
(
self
):
print
(
'线程启动'
)
self
.
myThread
.
start
()
def
stop
(
self
):
print
(
'线程终止'
)
try
:
for
i
in
range
(
5
):
self
.
_async_raise
(
self
.
myThread
.
ident
,
SystemExit
)
time
.
sleep
(
1
)
except
Exception
as
e
:
print
(
e
)
def
_async_raise
(
self
,
tid
,
exctype
):
"""raises the exception, performs cleanup if needed"""
tid
=
ctypes
.
c_long
(
tid
)
if
not
inspect
.
isclass
(
exctype
):
exctype
=
type
(
exctype
)
res
=
ctypes
.
pythonapi
.
PyThreadState_SetAsyncExc
(
tid
,
ctypes
.
py_object
(
exctype
))
if
res
==
0
:
raise
ValueError
(
"invalid thread id"
)
elif
res
!=
1
:
# """if it returns a number greater than one, you're in trouble,
# and you should call it again with exc=NULL to revert the effect"""
ctypes
.
pythonapi
.
PyThreadState_SetAsyncExc
(
tid
,
None
)
raise
SystemError
(
"PyThreadState_SetAsyncExc failed"
)
class
TDTestCase
:
class
TDTestCase
:
...
@@ -86,7 +53,24 @@ class TDTestCase:
...
@@ -86,7 +53,24 @@ class TDTestCase:
buildPath
=
root
[:
len
(
root
)
-
len
(
"/build/bin"
)]
buildPath
=
root
[:
len
(
root
)
-
len
(
"/build/bin"
)]
break
break
return
buildPath
return
buildPath
def
_async_raise
(
self
,
tid
,
exctype
):
"""raises the exception, performs cleanup if needed"""
if
not
inspect
.
isclass
(
exctype
):
exctype
=
type
(
exctype
)
res
=
ctypes
.
pythonapi
.
PyThreadState_SetAsyncExc
(
tid
,
ctypes
.
py_object
(
exctype
))
if
res
==
0
:
raise
ValueError
(
"invalid thread id"
)
elif
res
!=
1
:
# """if it returns a number greater than one, you're in trouble,
# and you should call it again with exc=NULL to revert the effect"""
ctypes
.
pythonapi
.
PyThreadState_SetAsyncExc
(
tid
,
None
)
raise
SystemError
(
"PyThreadState_SetAsyncExc failed"
)
def
stop_thread
(
self
,
thread
):
self
.
_async_raise
(
thread
.
ident
,
SystemExit
)
def
insert_data
(
self
,
countstart
,
countstop
):
def
insert_data
(
self
,
countstart
,
countstop
):
# fisrt add data : db\stable\childtable\general table
# fisrt add data : db\stable\childtable\general table
...
@@ -339,13 +323,13 @@ class TDTestCase:
...
@@ -339,13 +323,13 @@ class TDTestCase:
threads
.
start
()
threads
.
start
()
self
.
TDDnodes
.
stoptaosd
(
i
+
1
)
self
.
TDDnodes
.
stoptaosd
(
i
+
1
)
self
.
TDDnodes
.
starttaosd
(
i
+
1
)
self
.
TDDnodes
.
starttaosd
(
i
+
1
)
if
self
.
checkdnodes
(
5
):
if
self
.
checkdnodes
(
5
):
print
(
"123"
)
print
(
"123"
)
threads
.
join
()
threads
.
join
()
else
:
else
:
print
(
"456"
)
print
(
"456"
)
self
.
_is_stopped
=
True
self
.
stop_thread
(
threads
)
assert
1
==
2
,
"some dnode started failed"
assert
1
==
2
,
"some dnode started failed"
return
False
return
False
# self.check3mnode()
# self.check3mnode()
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录