提交 9e5bd3e3 编写于 作者: dengyihao's avatar dengyihao

add debug info

上级 7e035dcb
...@@ -43,6 +43,9 @@ static bool validImpl(const char* str, size_t maxsize) { ...@@ -43,6 +43,9 @@ static bool validImpl(const char* str, size_t maxsize) {
return true; return true;
} }
static int64_t queryIncr = 0;
//static int64_t queryDec = 0;
static bool validUserName(const char* user) { static bool validUserName(const char* user) {
return validImpl(user, TSDB_USER_LEN - 1); return validImpl(user, TSDB_USER_LEN - 1);
} }
...@@ -350,7 +353,7 @@ TAOS_RES* taos_query_c(TAOS *taos, const char *sqlstr, uint32_t sqlLen, TAOS_RES ...@@ -350,7 +353,7 @@ 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));
tsem_init(&pSql->rspSem, 0, 0); tsem_init(&pSql->rspSem, 0, 0);
doAsyncQuery(pObj, pSql, waitForQueryRsp, taos, sqlstr, sqlLen); doAsyncQuery(pObj, pSql, waitForQueryRsp, taos, sqlstr, sqlLen);
...@@ -657,6 +660,9 @@ void taos_free_result(TAOS_RES *res) { ...@@ -657,6 +660,9 @@ 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) {
tscError("current query count: %ld", atomic_sub_fetch_64(&queryIncr, 1));
}
bool freeNow = tscKillQueryInDnode(pSql); bool freeNow = tscKillQueryInDnode(pSql);
if (freeNow) { if (freeNow) {
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册