Merge pull request #29449 from taosdata/fix/TS-5651-skip-sync-heartbe…

…at-main fix:[TS-5651]skip-sync-heartbeat
taosdata · Jan 6, 2025 · ee89a84 · ee89a84
2 parents b81ade6 + ad4bf2a
commit ee89a84
Showing 1 changed file with 9 additions and 1 deletion.
diff --git 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;