Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
慢慢CG
TDengine
提交
95ef01bf
T
TDengine
项目概览
慢慢CG
/
TDengine
与 Fork 源项目一致
Fork自
taosdata / TDengine
通知
1
Star
0
Fork
0
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
0
列表
看板
标记
里程碑
合并请求
0
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
T
TDengine
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
0
Issue
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
提交
Issue看板
提交
95ef01bf
编写于
2月 18, 2021
作者:
S
Steven Li
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
Committing crash_gen tool to replicate 0x700 (invalid handle) problem, reasonably easily
上级
ac85dc15
变更
1
隐藏空白更改
内联
并排
Showing
1 changed file
with
5 addition
and
2 deletion
+5
-2
tests/pytest/crash_gen/crash_gen_main.py
tests/pytest/crash_gen/crash_gen_main.py
+5
-2
未找到文件。
tests/pytest/crash_gen/crash_gen_main.py
浏览文件 @
95ef01bf
...
@@ -354,10 +354,11 @@ class ThreadCoordinator:
...
@@ -354,10 +354,11 @@ class ThreadCoordinator:
# end, and maybe signal them to stop
# end, and maybe signal them to stop
if
isinstance
(
err
,
CrashGenError
):
# our own transition failure
if
isinstance
(
err
,
CrashGenError
):
# our own transition failure
Logging
.
info
(
"State transition error"
)
Logging
.
info
(
"State transition error"
)
# TODO: saw an error here once, let's print out stack info for err?
traceback
.
print_stack
()
traceback
.
print_stack
()
transitionFailed
=
True
transitionFailed
=
True
self
.
_te
=
None
# Not running any more
self
.
_te
=
None
# Not running any more
self
.
_execStats
.
registerFailure
(
"State transition error
"
)
self
.
_execStats
.
registerFailure
(
"State transition error
: {}"
.
format
(
err
)
)
else
:
else
:
raise
raise
# return transitionFailed # Why did we have this??!!
# return transitionFailed # Why did we have this??!!
...
@@ -955,6 +956,8 @@ class StateMechine:
...
@@ -955,6 +956,8 @@ class StateMechine:
# We transition the system to a new state by examining the current state itself
# We transition the system to a new state by examining the current state itself
def
transition
(
self
,
tasks
,
dbc
:
DbConn
):
def
transition
(
self
,
tasks
,
dbc
:
DbConn
):
global
gSvcMgr
if
(
len
(
tasks
)
==
0
):
# before 1st step, or otherwise empty
if
(
len
(
tasks
)
==
0
):
# before 1st step, or otherwise empty
Logging
.
debug
(
"[STT] Starting State: {}"
.
format
(
self
.
_curState
))
Logging
.
debug
(
"[STT] Starting State: {}"
.
format
(
self
.
_curState
))
return
# do nothing
return
# do nothing
...
@@ -2374,7 +2377,7 @@ class MainExec:
...
@@ -2374,7 +2377,7 @@ class MainExec:
'-n'
,
'-n'
,
'--dynamic-db-table-names'
,
'--dynamic-db-table-names'
,
action
=
'store_true'
,
action
=
'store_true'
,
help
=
'Use non-fixed names for dbs/tables, useful for multi-instance executions (default: false)'
)
help
=
'Use non-fixed names for dbs/tables,
for -b,
useful for multi-instance executions (default: false)'
)
parser
.
add_argument
(
parser
.
add_argument
(
'-o'
,
'-o'
,
'--num-dnodes'
,
'--num-dnodes'
,
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录