From 8c742423915832d9f38596d8861988229ad026b7 Mon Sep 17 00:00:00 2001 From: dmchen Date: Wed, 8 Jan 2025 01:56:55 +0000 Subject: [PATCH] fix/TS-5651-refactor --- source/dnode/mgmt/node_mgmt/src/dmTransport.c | 10 ++-------- 1 file changed, 2 insertions(+), 8 deletions(-) diff --git a/source/dnode/mgmt/node_mgmt/src/dmTransport.c b/source/dnode/mgmt/node_mgmt/src/dmTransport.c index 6fefd47a6f..43231c7283 100644 --- a/source/dnode/mgmt/node_mgmt/src/dmTransport.c +++ b/source/dnode/mgmt/node_mgmt/src/dmTransport.c @@ -255,14 +255,8 @@ static void dmProcessRpcMsg(SDnode *pDnode, SRpcMsg *pRpc, SEpSet *pEpSet) { pRpc->info.wrapper = pWrapper; 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; - } + if (IsReq(pRpc) && pRpc->msgType != TDMT_SYNC_HEARTBEAT && pRpc->msgType != TDMT_SYNC_HEARTBEAT_REPLY) + itype = RPC_QITEM; code = taosAllocateQitem(sizeof(SRpcMsg), itype, pRpc->contLen, (void **)&pMsg); if (code) goto _OVER;