xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

fix: add ahandle release log (#30395)

This commit is contained in:
Pan Wei 2025-03-24 13:26:49 +08:00 committed by GitHub
parent cfcdfdd2e7
commit c5841939d8
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
3 changed files with 12 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
source/client/src/clientImpl.c
View File

@ -1853,6 +1853,9 @@ int32_t doProcessMsgFromServer(void* param) {
void processMsgFromServer(void* parent, SRpcMsg* pMsg, SEpSet* pEpSet) { void processMsgFromServer(void* parent, SRpcMsg* pMsg, SEpSet* pEpSet) {
int32_t code = 0; int32_t code = 0;
SEpSet* tEpSet = NULL; SEpSet* tEpSet = NULL;
tscDebug("msg callback, ahandle %p", pMsg->info.ahandle);
if (pEpSet != NULL) { if (pEpSet != NULL) {
tEpSet = taosMemoryCalloc(1, sizeof(SEpSet)); tEpSet = taosMemoryCalloc(1, sizeof(SEpSet));
if (NULL == tEpSet) { if (NULL == tEpSet) {
@ -1894,6 +1897,7 @@ void processMsgFromServer(void* parent, SRpcMsg* pMsg, SEpSet* pEpSet) {
goto _exit; goto _exit;
} }
return; return;
_exit: _exit:
tscError("failed to sched msg to tsc since %s", tstrerror(code)); tscError("failed to sched msg to tsc since %s", tstrerror(code));
code = doProcessMsgFromServerImpl(pMsg, tEpSet); code = doProcessMsgFromServerImpl(pMsg, tEpSet);

3
source/libs/qcom/src/queryUtil.c
View File

@ -219,6 +219,9 @@ void destroySendMsgInfo(SMsgSendInfo* pMsgBody) {
return; return;
} }
qDebug("ahandle %p freed, QID:0x%" PRIx64, pMsgBody, pMsgBody->requestId);
taosMemoryFreeClear(pMsgBody->target.dbFName); taosMemoryFreeClear(pMsgBody->target.dbFName);
taosMemoryFreeClear(pMsgBody->msgInfo.pData); taosMemoryFreeClear(pMsgBody->msgInfo.pData);
if (pMsgBody->paramFreeFp) { if (pMsgBody->paramFreeFp) {

6
source/libs/scheduler/src/schRemote.c
View File

@ -660,7 +660,7 @@ int32_t schGenerateCallBackInfo(SSchJob *pJob, SSchTask *pTask, void *msg, uint3
int32_t code = 0; int32_t code = 0;
SMsgSendInfo *msgSendInfo = taosMemoryCalloc(1, sizeof(SMsgSendInfo)); SMsgSendInfo *msgSendInfo = taosMemoryCalloc(1, sizeof(SMsgSendInfo));
if (NULL == msgSendInfo) { 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); SCH_ERR_JRET(terrno);
} }
@ -672,8 +672,12 @@ int32_t schGenerateCallBackInfo(SSchJob *pJob, SSchTask *pTask, void *msg, uint3
if (pJob) { if (pJob) {
msgSendInfo->requestId = pJob->conn.requestId; msgSendInfo->requestId = pJob->conn.requestId;
msgSendInfo->requestObjRefId = pJob->conn.requestObjRefId; 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) { if (TDMT_SCH_LINK_BROKEN != msgType) {
msgSendInfo->msgInfo.pData = msg; msgSendInfo->msgInfo.pData = msg;
msgSendInfo->msgInfo.len = msgSize; msgSendInfo->msgInfo.len = msgSize;