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

fix mem leak

This commit is contained in:
yihaoDeng 2022-11-29 21:59:49 +08:00
parent 6eb032f3e9
commit 9278ed2ab5
2 changed files with 10 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
source/libs/scheduler/inc/schInt.h
View File

@ -214,9 +214,9 @@ typedef struct SSchRedirectCtx {
} SSchRedirectCtx; } SSchRedirectCtx;
typedef struct SSchTimerParam { typedef struct SSchTimerParam {
int64_t rId; int64_t rId;
uint64_t queryId; uint64_t queryId;
uint64_t taskId; uint64_t taskId;
} SSchTimerParam; } SSchTimerParam;
typedef struct SSchTask { typedef struct SSchTask {

7
source/libs/scheduler/src/schTask.c
View File

@ -1152,7 +1152,12 @@ void schHandleTimerEvent(void *param, void *tmrId) {
SSchJob *pJob = NULL; SSchJob *pJob = NULL;
int32_t code = 0; int32_t code = 0;
if (schProcessOnCbBegin(&pJob, &pTask, pTimerParam->queryId, pTimerParam->rId, pTimerParam->taskId)) { int64_t rId = pTimerParam->rId;
uint64_t queryId = pTimerParam->queryId;
uint64_t taskId = pTimerParam->taskId;
taosMemoryFree(pTimerParam);
if (schProcessOnCbBegin(&pJob, &pTask, queryId, rId, taskId)) {
return; return;
} }