From 901f62ec725d1f73ce7c15ca58800f17b8a1d281 Mon Sep 17 00:00:00 2001 From: yihaoDeng Date: Sat, 28 Nov 2020 08:40:48 +0000 Subject: [PATCH] add debug --- src/client/inc/tsclient.h | 1 + src/client/src/tscSql.c | 4 +++- 2 files changed, 4 insertions(+), 1 deletion(-) diff --git a/src/client/inc/tsclient.h b/src/client/inc/tsclient.h index 9cfeffb2d8..6b5c65df85 100644 --- a/src/client/inc/tsclient.h +++ b/src/client/inc/tsclient.h @@ -371,6 +371,7 @@ typedef struct SSqlObj { SSubqueryState subState; struct SSqlObj **pSubs; + int global; struct SSqlObj *prev, *next; int64_t self; } SSqlObj; diff --git a/src/client/src/tscSql.c b/src/client/src/tscSql.c index 654a41fe77..82788eec03 100644 --- a/src/client/src/tscSql.c +++ b/src/client/src/tscSql.c @@ -353,8 +353,10 @@ TAOS_RES* taos_query_c(TAOS *taos, const char *sqlstr, uint32_t sqlLen, TAOS_RES terrno = TSDB_CODE_TSC_OUT_OF_MEMORY; return NULL; } + tscError("curre query count: %ld",atomic_add_fetch_64(&queryIncr, 1)); tsem_init(&pSql->rspSem, 0, 0); + pSql->global = 100; doAsyncQuery(pObj, pSql, waitForQueryRsp, taos, sqlstr, sqlLen); if (res != NULL) { @@ -660,7 +662,7 @@ void taos_free_result(TAOS_RES *res) { tscError("%p already released sqlObj", res); return; } - if (0 == pSql->subState.numOfSub) { + if (100 == pSql->global) { tscError("current query count: %ld", atomic_sub_fetch_64(&queryIncr, 1)); } -- GitLab