Merge pull request #5626 from taosdata/hotfix/TD-3605
[TD-3605]fix CQ memleak issue
This commit is contained in:
commit
ff2f32ad9f
|
@ -439,6 +439,8 @@ void tscFreeSqlResult(SSqlObj *pSql);
|
||||||
* @param pObj
|
* @param pObj
|
||||||
*/
|
*/
|
||||||
void tscFreeSqlObj(SSqlObj *pSql);
|
void tscFreeSqlObj(SSqlObj *pSql);
|
||||||
|
void tscFreeSubobj(SSqlObj* pSql);
|
||||||
|
|
||||||
void tscFreeRegisteredSqlObj(void *pSql);
|
void tscFreeRegisteredSqlObj(void *pSql);
|
||||||
|
|
||||||
void tscCloseTscObj(void *pObj);
|
void tscCloseTscObj(void *pObj);
|
||||||
|
|
|
@ -2647,7 +2647,6 @@ void tscInitMsgsFp() {
|
||||||
tscProcessMsgRsp[TSDB_SQL_SHOW_CREATE_TABLE] = tscProcessShowCreateRsp;
|
tscProcessMsgRsp[TSDB_SQL_SHOW_CREATE_TABLE] = tscProcessShowCreateRsp;
|
||||||
tscProcessMsgRsp[TSDB_SQL_SHOW_CREATE_DATABASE] = tscProcessShowCreateRsp;
|
tscProcessMsgRsp[TSDB_SQL_SHOW_CREATE_DATABASE] = tscProcessShowCreateRsp;
|
||||||
|
|
||||||
|
|
||||||
tscKeepConn[TSDB_SQL_SHOW] = 1;
|
tscKeepConn[TSDB_SQL_SHOW] = 1;
|
||||||
tscKeepConn[TSDB_SQL_RETRIEVE] = 1;
|
tscKeepConn[TSDB_SQL_RETRIEVE] = 1;
|
||||||
tscKeepConn[TSDB_SQL_SELECT] = 1;
|
tscKeepConn[TSDB_SQL_SELECT] = 1;
|
||||||
|
|
|
@ -299,6 +299,7 @@ static void tscProcessStreamRetrieveResult(void *param, TAOS_RES *res, int numOf
|
||||||
tfree(pTableMetaInfo->pTableMeta);
|
tfree(pTableMetaInfo->pTableMeta);
|
||||||
|
|
||||||
tscFreeSqlResult(pSql);
|
tscFreeSqlResult(pSql);
|
||||||
|
tscFreeSubobj(pSql);
|
||||||
tfree(pSql->pSubs);
|
tfree(pSql->pSubs);
|
||||||
pSql->subState.numOfSub = 0;
|
pSql->subState.numOfSub = 0;
|
||||||
pTableMetaInfo->vgroupList = tscVgroupInfoClear(pTableMetaInfo->vgroupList);
|
pTableMetaInfo->vgroupList = tscVgroupInfoClear(pTableMetaInfo->vgroupList);
|
||||||
|
|
|
@ -447,7 +447,7 @@ void tscFreeSqlResult(SSqlObj* pSql) {
|
||||||
memset(&pSql->res, 0, sizeof(SSqlRes));
|
memset(&pSql->res, 0, sizeof(SSqlRes));
|
||||||
}
|
}
|
||||||
|
|
||||||
static void tscFreeSubobj(SSqlObj* pSql) {
|
void tscFreeSubobj(SSqlObj* pSql) {
|
||||||
if (pSql->subState.numOfSub == 0) {
|
if (pSql->subState.numOfSub == 0) {
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
|
@ -25,7 +25,9 @@ function stopTaosd {
|
||||||
function dohavecore(){
|
function dohavecore(){
|
||||||
corefile=`find $corepath -mmin 1`
|
corefile=`find $corepath -mmin 1`
|
||||||
core_file=`echo $corefile|cut -d " " -f2`
|
core_file=`echo $corefile|cut -d " " -f2`
|
||||||
echo $core_file
|
echo "corefile:$core_file"
|
||||||
|
echo "corepath:$corepath"
|
||||||
|
ls -l $corepath
|
||||||
proc=`echo $corefile|cut -d "_" -f3`
|
proc=`echo $corefile|cut -d "_" -f3`
|
||||||
if [ -n "$corefile" ];then
|
if [ -n "$corefile" ];then
|
||||||
echo 'taosd or taos has generated core'
|
echo 'taosd or taos has generated core'
|
||||||
|
|
Loading…
Reference in New Issue