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

fix: memory leak issue

This commit is contained in:
dapan1121 2023-09-21 09:49:43 +08:00
parent aa86490ed2
commit 7d076d2db9
1 changed files with 2 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -1698,10 +1698,7 @@ void* doAsyncFetchRows(SRequestObj* pRequest, bool setupOneRowPtr, bool convertU
// convert ucs4 to native multi-bytes string // convert ucs4 to native multi-bytes string
pResultInfo->convertUcs4 = convertUcs4; pResultInfo->convertUcs4 = convertUcs4;
SSyncQueryParam* pParam = NULL; SSyncQueryParam* pParam = pRequest->body.param;
if (pRequest->syncQuery) {
pParam = pRequest->body.param;
}
taos_fetch_rows_a(pRequest, syncFetchFn, pParam); taos_fetch_rows_a(pRequest, syncFetchFn, pParam);
tsem_wait(&pParam->sem); tsem_wait(&pParam->sem);
} }
@ -2561,9 +2558,9 @@ void taosAsyncFetchImpl(SRequestObj* pRequest, __taos_async_fn_t fp, void* param
tsem_destroy(&((SSyncQueryParam *)pRequest->body.param)->sem); tsem_destroy(&((SSyncQueryParam *)pRequest->body.param)->sem);
} }
taosMemoryFree(pRequest->body.param); taosMemoryFree(pRequest->body.param);
pRequest->syncQuery = false;
} }
pRequest->syncQuery = false;
pRequest->body.fetchFp = fp; pRequest->body.fetchFp = fp;
pRequest->body.param = param; pRequest->body.param = param;