未验证 提交 2e1a5815 编写于 作者: S Shengliang Guan 提交者: GitHub

Merge pull request #5906 from taosdata/fix/TD-3850

[TD-3850]<fix>: fix vnode write enqueue flowctrl UAF & no response
...@@ -347,9 +347,11 @@ static void vnodeFlowCtrlMsgToWQueue(void *param, void *tmrId) { ...@@ -347,9 +347,11 @@ static void vnodeFlowCtrlMsgToWQueue(void *param, void *tmrId) {
vDebug("vgId:%d, msg:%p, write into vwqueue after flowctrl, retry:%d", pVnode->vgId, pWrite, vDebug("vgId:%d, msg:%p, write into vwqueue after flowctrl, retry:%d", pVnode->vgId, pWrite,
pWrite->processedCount); pWrite->processedCount);
pWrite->processedCount = 0; pWrite->processedCount = 0;
void *handle = pWrite->rpcMsg.handle;
code = vnodeWriteToWQueueImp(pWrite); code = vnodeWriteToWQueueImp(pWrite);
if (code != 0) { if (code != TSDB_CODE_SUCCESS) {
dnodeSendRpcVWriteRsp(pWrite->pVnode, pWrite, code); SRpcMsg rpcRsp = {.handle = handle, .code = code};
rpcSendResponse(&rpcRsp);
} }
} }
} }
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册