xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

fix:dead lock

This commit is contained in:
wangmm0220 2023-05-16 17:58:31 +08:00
parent e6e0ac7603
commit a52939127f
1 changed files with 0 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
source/dnode/vnode/src/tq/tq.c
View File

@ -384,9 +384,7 @@ int32_t tqProcessPollReq(STQ* pTq, SRpcMsg* pMsg) {
consumerId, req.epoch, pHandle->subKey, vgId, buf, req.reqId); consumerId, req.epoch, pHandle->subKey, vgId, buf, req.reqId);
int code = tqExtractDataForMq(pTq, pHandle, &req, pMsg); int code = tqExtractDataForMq(pTq, pHandle, &req, pMsg);
taosWLockLatch(&pTq->lock);
tqSetHandleIdle(pHandle); tqSetHandleIdle(pHandle);
taosWUnLockLatch(&pTq->lock);
return code; return code;
} }