From c5841939d8ce0cd8eb0bf6436251e06fea9ecc8f Mon Sep 17 00:00:00 2001
From: Pan Wei <72057773+dapan1121@users.noreply.github.com>
Date: Mon, 24 Mar 2025 13:26:49 +0800
Subject: [PATCH] fix: add ahandle release log (#30395)

---
 source/client/src/clientImpl.c        | 4 ++++
 source/libs/qcom/src/queryUtil.c      | 3 +++
 source/libs/scheduler/src/schRemote.c | 6 +++++-
 3 files changed, 12 insertions(+), 1 deletion(-)

diff --git a/source/client/src/clientImpl.c b/source/client/src/clientImpl.c
index 7e2454bf6f..20958d12ac 100644
--- a/source/client/src/clientImpl.c
+++ b/source/client/src/clientImpl.c
@@ -1853,6 +1853,9 @@ int32_t doProcessMsgFromServer(void* param) {
 void processMsgFromServer(void* parent, SRpcMsg* pMsg, SEpSet* pEpSet) {
   int32_t code = 0;
   SEpSet* tEpSet = NULL;
+
+  tscDebug("msg callback, ahandle %p", pMsg->info.ahandle);
+
   if (pEpSet != NULL) {
     tEpSet = taosMemoryCalloc(1, sizeof(SEpSet));
     if (NULL == tEpSet) {
@@ -1894,6 +1897,7 @@ void processMsgFromServer(void* parent, SRpcMsg* pMsg, SEpSet* pEpSet) {
     goto _exit;
   }
   return;
+  
 _exit:
   tscError("failed to sched msg to tsc since %s", tstrerror(code));
   code = doProcessMsgFromServerImpl(pMsg, tEpSet);
diff --git a/source/libs/qcom/src/queryUtil.c b/source/libs/qcom/src/queryUtil.c
index 098868e907..b6df56d0a8 100644
--- a/source/libs/qcom/src/queryUtil.c
+++ b/source/libs/qcom/src/queryUtil.c
@@ -219,6 +219,9 @@ void destroySendMsgInfo(SMsgSendInfo* pMsgBody) {
     return;
   }
 
+  
+  qDebug("ahandle %p freed, QID:0x%" PRIx64, pMsgBody, pMsgBody->requestId);
+  
   taosMemoryFreeClear(pMsgBody->target.dbFName);
   taosMemoryFreeClear(pMsgBody->msgInfo.pData);
   if (pMsgBody->paramFreeFp) {
diff --git a/source/libs/scheduler/src/schRemote.c b/source/libs/scheduler/src/schRemote.c
index d7c5eb0c84..5b4bd788ea 100644
--- a/source/libs/scheduler/src/schRemote.c
+++ b/source/libs/scheduler/src/schRemote.c
@@ -660,7 +660,7 @@ int32_t schGenerateCallBackInfo(SSchJob *pJob, SSchTask *pTask, void *msg, uint3
   int32_t       code = 0;
   SMsgSendInfo *msgSendInfo = taosMemoryCalloc(1, sizeof(SMsgSendInfo));
   if (NULL == msgSendInfo) {
-    SCH_TASK_ELOG("calloc %d failed", (int32_t)sizeof(SMsgSendInfo));
+    qError("calloc SMsgSendInfo size %d failed", (int32_t)sizeof(SMsgSendInfo));
     SCH_ERR_JRET(terrno);
   }
 
@@ -672,8 +672,12 @@ int32_t schGenerateCallBackInfo(SSchJob *pJob, SSchTask *pTask, void *msg, uint3
   if (pJob) {
     msgSendInfo->requestId = pJob->conn.requestId;
     msgSendInfo->requestObjRefId = pJob->conn.requestObjRefId;
+  } else {
+    SCH_ERR_JRET(taosGetSystemUUIDU64(&msgSendInfo->requestId));
   }
 
+  qDebug("ahandle %p alloced, QID:0x%" PRIx64, msgSendInfo, msgSendInfo->requestId);
+
   if (TDMT_SCH_LINK_BROKEN != msgType) {
     msgSendInfo->msgInfo.pData = msg;
     msgSendInfo->msgInfo.len = msgSize;