Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
taosdata
TDengine
提交
95f75a76
T
TDengine
项目概览
taosdata
/
TDengine
1 年多 前同步成功
通知
1185
Star
22016
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看板
未验证
提交
95f75a76
编写于
6月 13, 2022
作者:
S
Shengliang Guan
提交者:
GitHub
6月 13, 2022
浏览文件
操作
浏览文件
下载
差异文件
Merge pull request #13771 from taosdata/fix/mnode
refactor: adjust logs
上级
0166d40c
3d8ebc26
变更
2
显示空白变更内容
内联
并排
Showing
2 changed file
with
9 addition
and
9 deletion
+9
-9
source/dnode/mnode/impl/src/mndTrans.c
source/dnode/mnode/impl/src/mndTrans.c
+7
-7
tests/pytest/util/dnodes.py
tests/pytest/util/dnodes.py
+2
-2
未找到文件。
source/dnode/mnode/impl/src/mndTrans.c
浏览文件 @
95f75a76
...
@@ -968,7 +968,7 @@ static int32_t mndTransSendSingleMsg(SMnode *pMnode, STrans *pTrans, STransActio
...
@@ -968,7 +968,7 @@ static int32_t mndTransSendSingleMsg(SMnode *pMnode, STrans *pTrans, STransActio
static
int32_t
mndTransExecNullMsg
(
SMnode
*
pMnode
,
STrans
*
pTrans
,
STransAction
*
pAction
)
{
static
int32_t
mndTransExecNullMsg
(
SMnode
*
pMnode
,
STrans
*
pTrans
,
STransAction
*
pAction
)
{
pAction
->
rawWritten
=
0
;
pAction
->
rawWritten
=
0
;
pAction
->
errCode
=
0
;
pAction
->
errCode
=
0
;
mDebug
(
"trans:%d, %s:%d
null
action executed"
,
pTrans
->
id
,
mndTransStr
(
pAction
->
stage
),
pAction
->
id
);
mDebug
(
"trans:%d, %s:%d
confirm
action executed"
,
pTrans
->
id
,
mndTransStr
(
pAction
->
stage
),
pAction
->
id
);
pTrans
->
lastAction
=
pAction
->
id
;
pTrans
->
lastAction
=
pAction
->
id
;
pTrans
->
lastMsgType
=
pAction
->
msgType
;
pTrans
->
lastMsgType
=
pAction
->
msgType
;
...
@@ -1025,18 +1025,18 @@ static int32_t mndTransExecuteActions(SMnode *pMnode, STrans *pTrans, SArray *pA
...
@@ -1025,18 +1025,18 @@ static int32_t mndTransExecuteActions(SMnode *pMnode, STrans *pTrans, SArray *pA
if
(
numOfExecuted
==
numOfActions
)
{
if
(
numOfExecuted
==
numOfActions
)
{
if
(
errCode
==
0
)
{
if
(
errCode
==
0
)
{
pTrans
->
lastAction
=
0
;
pTrans
->
lastAction
=
0
;
pTrans
->
lastErrorNo
=
0
;
pTrans
->
lastMsgType
=
0
;
pTrans
->
lastMsgType
=
0
;
memset
(
&
pTrans
->
lastEpset
,
0
,
sizeof
(
pTrans
->
lastEpset
));
memset
(
&
pTrans
->
lastEpset
,
0
,
sizeof
(
pTrans
->
lastEpset
));
pTrans
->
lastErrorNo
=
0
;
mDebug
(
"trans:%d, all %d actions execute successfully"
,
pTrans
->
id
,
numOfActions
);
mDebug
(
"trans:%d, all %d actions execute successfully"
,
pTrans
->
id
,
numOfActions
);
return
0
;
return
0
;
}
else
{
}
else
{
mError
(
"trans:%d, all %d actions executed, code:0x%x"
,
pTrans
->
id
,
numOfActions
,
errCode
&
0XFFFF
);
mError
(
"trans:%d, all %d actions executed, code:0x%x"
,
pTrans
->
id
,
numOfActions
,
errCode
&
0XFFFF
);
if
(
pErrAction
!=
NULL
)
{
if
(
pErrAction
!=
NULL
)
{
pTrans
->
lastMsgType
=
pErrAction
->
msgType
;
pTrans
->
lastAction
=
pErrAction
->
id
;
pTrans
->
lastAction
=
pErrAction
->
id
;
pTrans
->
last
ErrorNo
=
pErrAction
->
errCod
e
;
pTrans
->
last
MsgType
=
pErrAction
->
msgTyp
e
;
pTrans
->
lastEpset
=
pErrAction
->
epSet
;
pTrans
->
lastEpset
=
pErrAction
->
epSet
;
pTrans
->
lastErrorNo
=
pErrAction
->
errCode
;
}
}
mndTransResetActions
(
pMnode
,
pTrans
,
pArray
);
mndTransResetActions
(
pMnode
,
pTrans
,
pArray
);
terrno
=
errCode
;
terrno
=
errCode
;
...
@@ -1103,13 +1103,13 @@ static int32_t mndTransExecuteRedoActionsSerial(SMnode *pMnode, STrans *pTrans)
...
@@ -1103,13 +1103,13 @@ static int32_t mndTransExecuteRedoActionsSerial(SMnode *pMnode, STrans *pTrans)
}
}
if
(
code
==
0
)
{
if
(
code
==
0
)
{
pTrans
->
lastAction
=
0
;
pTrans
->
lastAction
=
action
;
pTrans
->
lastErrorNo
=
0
;
pTrans
->
lastMsgType
=
0
;
pTrans
->
lastMsgType
=
0
;
pTrans
->
lastErrorNo
=
0
;
memset
(
&
pTrans
->
lastEpset
,
0
,
sizeof
(
pTrans
->
lastEpset
));
memset
(
&
pTrans
->
lastEpset
,
0
,
sizeof
(
pTrans
->
lastEpset
));
}
else
{
}
else
{
pTrans
->
lastMsgType
=
pAction
->
msgType
;
pTrans
->
lastAction
=
action
;
pTrans
->
lastAction
=
action
;
pTrans
->
lastMsgType
=
pAction
->
msgType
;
pTrans
->
lastErrorNo
=
code
;
pTrans
->
lastErrorNo
=
code
;
pTrans
->
lastEpset
=
pAction
->
epSet
;
pTrans
->
lastEpset
=
pAction
->
epSet
;
}
}
...
...
tests/pytest/util/dnodes.py
浏览文件 @
95f75a76
...
@@ -133,8 +133,8 @@ class TDDnode:
...
@@ -133,8 +133,8 @@ class TDDnode:
"qDebugFlag"
:
"143"
,
"qDebugFlag"
:
"143"
,
"rpcDebugFlag"
:
"143"
,
"rpcDebugFlag"
:
"143"
,
"tmrDebugFlag"
:
"131"
,
"tmrDebugFlag"
:
"131"
,
"uDebugFlag"
:
"1
43
"
,
"uDebugFlag"
:
"1
31
"
,
"sDebugFlag"
:
"1
35
"
,
"sDebugFlag"
:
"1
43
"
,
"wDebugFlag"
:
"143"
,
"wDebugFlag"
:
"143"
,
"qdebugFlag"
:
"143"
,
"qdebugFlag"
:
"143"
,
"numOfLogLines"
:
"100000000"
,
"numOfLogLines"
:
"100000000"
,
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录