From 8f330dca306e3250d7efb8492045a1fb5a85b7ba Mon Sep 17 00:00:00 2001 From: wpan Date: Wed, 1 Sep 2021 19:04:42 +0800 Subject: [PATCH] add debug info --- src/client/src/tscSubquery.c | 1 + src/client/src/tscUtil.c | 4 ++++ 2 files changed, 5 insertions(+) diff --git a/src/client/src/tscSubquery.c b/src/client/src/tscSubquery.c index 8e579ad221..018a2964b2 100644 --- a/src/client/src/tscSubquery.c +++ b/src/client/src/tscSubquery.c @@ -1716,6 +1716,7 @@ void tscFetchDatablockForSubquery(SSqlObj* pSql) { STableMetaInfo* pTableMetaInfo = tscGetMetaInfo(pQueryInfo, 0); if (pRes1->row >= pRes1->numOfRows) { + assert(pSql1->cmd.msgType == TSDB_MSG_TYPE_FETCH); tscDebug("0x%"PRIx64" subquery:0x%"PRIx64" retrieve data from vnode, subquery:%d, vgroupIndex:%d", pSql->self, pSql1->self, pSupporter->subqueryIndex, pTableMetaInfo->vgroupIndex); diff --git a/src/client/src/tscUtil.c b/src/client/src/tscUtil.c index 0e414e36c8..a71ed588db 100644 --- a/src/client/src/tscUtil.c +++ b/src/client/src/tscUtil.c @@ -1516,6 +1516,8 @@ void tscFreeSqlObj(SSqlObj* pSql) { return; } + int64_t sid = pSql->self; + tscDebug("0x%"PRIx64" start to free sqlObj", pSql->self); pSql->res.code = TSDB_CODE_TSC_QUERY_CANCELLED; @@ -1547,6 +1549,8 @@ void tscFreeSqlObj(SSqlObj* pSql) { tfree(pCmd->payload); pCmd->allocSize = 0; + tscDebug("0x%"PRIx64" addr:%p free completed", sid, pSql); + tsem_destroy(&pSql->rspSem); memset(pSql, 0, sizeof(*pSql)); free(pSql); -- GitLab