提交 aab1ec63 编写于 作者: S Shengliang Guan

fix: heap-use-after-free in syncNodeEqPingTimer

上级 6c0bbe68
...@@ -1842,7 +1842,7 @@ static void syncNodeEqPingTimer(void* param, void* tmrId) { ...@@ -1842,7 +1842,7 @@ static void syncNodeEqPingTimer(void* param, void* tmrId) {
return; return;
} }
sTrace(pNode, "enqueue ping msg"); sTrace("enqueue ping msg");
code = pNode->syncEqMsg(pNode->msgcb, &rpcMsg); code = pNode->syncEqMsg(pNode->msgcb, &rpcMsg);
if (code != 0) { if (code != 0) {
sError("failed to sync enqueue ping msg since %s", terrstr()); sError("failed to sync enqueue ping msg since %s", terrstr());
...@@ -1870,7 +1870,7 @@ static void syncNodeEqElectTimer(void* param, void* tmrId) { ...@@ -1870,7 +1870,7 @@ static void syncNodeEqElectTimer(void* param, void* tmrId) {
} }
SyncTimeout* pTimeout = rpcMsg.pCont; SyncTimeout* pTimeout = rpcMsg.pCont;
sTrace(pNode, "enqueue elect msg lc:%" PRId64, pTimeout->logicClock); sTrace("enqueue elect msg lc:%" PRId64, pTimeout->logicClock);
code = pNode->syncEqMsg(pNode->msgcb, &rpcMsg); code = pNode->syncEqMsg(pNode->msgcb, &rpcMsg);
if (code != 0) { if (code != 0) {
...@@ -1894,7 +1894,7 @@ static void syncNodeEqHeartbeatTimer(void* param, void* tmrId) { ...@@ -1894,7 +1894,7 @@ static void syncNodeEqHeartbeatTimer(void* param, void* tmrId) {
return; return;
} }
sTrace(pNode, "enqueue heartbeat timer"); sTrace("enqueue heartbeat timer");
code = pNode->syncEqMsg(pNode->msgcb, &rpcMsg); code = pNode->syncEqMsg(pNode->msgcb, &rpcMsg);
if (code != 0) { if (code != 0) {
sError("failed to enqueue heartbeat msg since %s", terrstr()); sError("failed to enqueue heartbeat msg since %s", terrstr());
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册