From ad4bf2a1365908f8b10228f7046c0328c3628a45 Mon Sep 17 00:00:00 2001 From: dmchen Date: Thu, 2 Jan 2025 02:17:29 +0000 Subject: [PATCH] fix/TS-5651-skip-sync-heartbeat --- source/dnode/mgmt/node_mgmt/src/dmTransport.c | 10 +++++++++- 1 file changed, 9 insertions(+), 1 deletion(-) diff --git a/source/dnode/mgmt/node_mgmt/src/dmTransport.c b/source/dnode/mgmt/node_mgmt/src/dmTransport.c index acd95d4b43..6fefd47a6f 100644 --- a/source/dnode/mgmt/node_mgmt/src/dmTransport.c +++ b/source/dnode/mgmt/node_mgmt/src/dmTransport.c @@ -254,7 +254,15 @@ static void dmProcessRpcMsg(SDnode *pDnode, SRpcMsg *pRpc, SEpSet *pEpSet) { pRpc->info.wrapper = pWrapper; - EQItype itype = IsReq(pRpc) ? RPC_QITEM : DEF_QITEM; // rsp msg is not restricted by tsQueueMemoryUsed + EQItype itype = RPC_QITEM; // rsp msg is not restricted by tsQueueMemoryUsed + if (IsReq(pRpc)) { + if (pRpc->msgType == TDMT_SYNC_HEARTBEAT || pRpc->msgType == TDMT_SYNC_HEARTBEAT_REPLY) + itype = DEF_QITEM; + else + itype = RPC_QITEM; + } else { + itype = DEF_QITEM; + } code = taosAllocateQitem(sizeof(SRpcMsg), itype, pRpc->contLen, (void **)&pMsg); if (code) goto _OVER;