From a52939127f0d1293849e71c7beb9132323321da5 Mon Sep 17 00:00:00 2001 From: wangmm0220 Date: Tue, 16 May 2023 17:58:31 +0800 Subject: [PATCH] fix:dead lock --- source/dnode/vnode/src/tq/tq.c | 2 -- 1 file changed, 2 deletions(-) diff --git a/source/dnode/vnode/src/tq/tq.c b/source/dnode/vnode/src/tq/tq.c index 74ccd33d4c..9dfd54db14 100644 --- a/source/dnode/vnode/src/tq/tq.c +++ b/source/dnode/vnode/src/tq/tq.c @@ -384,9 +384,7 @@ int32_t tqProcessPollReq(STQ* pTq, SRpcMsg* pMsg) { consumerId, req.epoch, pHandle->subKey, vgId, buf, req.reqId); int code = tqExtractDataForMq(pTq, pHandle, &req, pMsg); - taosWLockLatch(&pTq->lock); tqSetHandleIdle(pHandle); - taosWUnLockLatch(&pTq->lock); return code; }