diff --git a/src/client/src/tscAsync.c b/src/client/src/tscAsync.c index 9a85fbf8f65193d6239c6b58bf0c6577d77a6250..34ecc25c59507f836078164130440f89627e86e7 100644 --- a/src/client/src/tscAsync.c +++ b/src/client/src/tscAsync.c @@ -347,8 +347,8 @@ void tscProcessAsyncRes(SSchedMsg *pMsg) { (*pSql->fp)(pSql->param, taosres, code); if (shouldFree) { - tscFreeSqlObj(pSql); tscTrace("%p Async sql is automatically freed in async res", pSql); + tscFreeSqlObj(pSql); } } diff --git a/src/client/src/tscProfile.c b/src/client/src/tscProfile.c index a7a774b3a8ce71a608d15ec9a71f931a7a59a06a..ab214384ad816950db30a7708e7bb332a9cb21b6 100644 --- a/src/client/src/tscProfile.c +++ b/src/client/src/tscProfile.c @@ -292,7 +292,7 @@ void tscKillConnection(STscObj *pObj) { pthread_mutex_unlock(&pObj->mutex); - taos_close(pObj); - tscTrace("connection:%p is killed", pObj); + + taos_close(pObj); } diff --git a/src/client/src/tscServer.c b/src/client/src/tscServer.c index e977d57241a007e239428cff43dd85e3704cf1c8..94fba04b3e613ac380ff2d3ad1e62afbe24c1ee2 100644 --- a/src/client/src/tscServer.c +++ b/src/client/src/tscServer.c @@ -600,8 +600,8 @@ void *tscProcessMsgFromServer(char *msg, void *ahandle, void *thandle) { taos_close(pObj); tscTrace("%p Async sql close failed connection", pSql); } else { - tscFreeSqlObj(pSql); tscTrace("%p Async sql is automatically freed", pSql); + tscFreeSqlObj(pSql); } } } diff --git a/src/client/src/tscSql.c b/src/client/src/tscSql.c index 99bc9632deeff8bf98c8090e0fac7604104f84c9..a0089379a9c71434ed1a7aa7547724145241b89f 100644 --- a/src/client/src/tscSql.c +++ b/src/client/src/tscSql.c @@ -796,8 +796,8 @@ void taos_free_result_imp(TAOS_RES *res, int keepCmd) { tscTrace("%p qhandle is null, abort free, fp:%p", pSql, pSql->fp); if (pSql->fp != NULL) { pSql->thandle = NULL; - tscFreeSqlObj(pSql); tscTrace("%p Async SqlObj is freed by app", pSql); + tscFreeSqlObj(pSql); } else if (keepCmd) { tscFreeSqlResult(pSql); } else { diff --git a/src/client/src/tscStream.c b/src/client/src/tscStream.c index 8dc8ad49b5b134c9cc3f5bd3987ae61c5273f33c..94fb35d52231746da27d21a755cad823c806321f 100644 --- a/src/client/src/tscStream.c +++ b/src/client/src/tscStream.c @@ -582,10 +582,10 @@ void taos_close_stream(TAOS_STREAM *handle) { tscRemoveFromStreamList(pStream, pSql); taosTmrStopA(&(pStream->pTimer)); + tscTrace("%p stream:%p is closed", pSql, pStream); tscFreeSqlObj(pSql); pStream->pSql = NULL; - tscTrace("%p stream:%p is closed", pSql, pStream); tfree(pStream); } }