提交 901f62ec 编写于 作者: Y yihaoDeng

add debug

上级 9e5bd3e3
...@@ -371,6 +371,7 @@ typedef struct SSqlObj { ...@@ -371,6 +371,7 @@ typedef struct SSqlObj {
SSubqueryState subState; SSubqueryState subState;
struct SSqlObj **pSubs; struct SSqlObj **pSubs;
int global;
struct SSqlObj *prev, *next; struct SSqlObj *prev, *next;
int64_t self; int64_t self;
} SSqlObj; } SSqlObj;
......
...@@ -353,8 +353,10 @@ TAOS_RES* taos_query_c(TAOS *taos, const char *sqlstr, uint32_t sqlLen, TAOS_RES ...@@ -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; terrno = TSDB_CODE_TSC_OUT_OF_MEMORY;
return NULL; return NULL;
} }
tscError("curre query count: %ld",atomic_add_fetch_64(&queryIncr, 1)); tscError("curre query count: %ld",atomic_add_fetch_64(&queryIncr, 1));
tsem_init(&pSql->rspSem, 0, 0); tsem_init(&pSql->rspSem, 0, 0);
pSql->global = 100;
doAsyncQuery(pObj, pSql, waitForQueryRsp, taos, sqlstr, sqlLen); doAsyncQuery(pObj, pSql, waitForQueryRsp, taos, sqlstr, sqlLen);
if (res != NULL) { if (res != NULL) {
...@@ -660,7 +662,7 @@ void taos_free_result(TAOS_RES *res) { ...@@ -660,7 +662,7 @@ void taos_free_result(TAOS_RES *res) {
tscError("%p already released sqlObj", res); tscError("%p already released sqlObj", res);
return; return;
} }
if (0 == pSql->subState.numOfSub) { if (100 == pSql->global) {
tscError("current query count: %ld", atomic_sub_fetch_64(&queryIncr, 1)); tscError("current query count: %ld", atomic_sub_fetch_64(&queryIncr, 1));
} }
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册