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

fix(stream): fix memory leak.

This commit is contained in:
Haojun Liao 2024-07-01 16:53:43 +08:00
parent 6d64d0e081
commit c166c8de70
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
source/libs/stream/src/streamHb.c
View File

@ -145,6 +145,7 @@ int32_t streamMetaSendHbHelper(SStreamMeta* pMeta) {
pMsg->vgId = pMeta->vgId; pMsg->vgId = pMeta->vgId;
pMsg->msgId = pMeta->pHbInfo->hbCount; pMsg->msgId = pMeta->pHbInfo->hbCount;
pMsg->pTaskStatus = taosArrayInit(numOfTasks, sizeof(STaskStatusEntry)); pMsg->pTaskStatus = taosArrayInit(numOfTasks, sizeof(STaskStatusEntry));
pMsg->pUpdateNodes = taosArrayInit(numOfTasks, sizeof(int32_t)); pMsg->pUpdateNodes = taosArrayInit(numOfTasks, sizeof(int32_t));
@ -215,6 +216,8 @@ int32_t streamMetaSendHbHelper(SStreamMeta* pMeta) {
doSendHbMsgInfo(pMsg, pMeta, &epset); doSendHbMsgInfo(pMsg, pMeta, &epset);
} else { } else {
stDebug("vgId:%d no tasks or no mnd epset, not send stream hb to mnode", pMeta->vgId); stDebug("vgId:%d no tasks or no mnd epset, not send stream hb to mnode", pMeta->vgId);
tCleanupStreamHbMsg(&pInfo->hbMsg);
pInfo->msgSendTs = -1;
} }
return TSDB_CODE_SUCCESS; return TSDB_CODE_SUCCESS;
@ -330,8 +333,6 @@ int32_t streamProcessHeartbeatRsp(SStreamMeta* pMeta, SMStreamHbRspMsg* pRsp) {
pInfo->hbCount += 1; pInfo->hbCount += 1;
pInfo->msgSendTs = -1; pInfo->msgSendTs = -1;
tCleanupStreamHbMsg(&pInfo->hbMsg);
} else { } else {
stWarn("vgId:%d recv expired hb rsp, msgId:%d, discarded", pMeta->vgId, pRsp->msgId); stWarn("vgId:%d recv expired hb rsp, msgId:%d, discarded", pMeta->vgId, pRsp->msgId);
} }