From 9e5bd3e33ac7a236400620187f717b4dd21fe87e Mon Sep 17 00:00:00 2001
From: yihaoDeng <luomoxyz@126.com>
Date: Mon, 30 Nov 2020 14:07:06 +0000
Subject: [PATCH] add debug info

---
 src/client/src/tscSql.c | 10 ++++++++--
 1 file changed, 8 insertions(+), 2 deletions(-)

diff --git a/src/client/src/tscSql.c b/src/client/src/tscSql.c
index addb65a0a8..654a41fe77 100644
--- a/src/client/src/tscSql.c
+++ b/src/client/src/tscSql.c
@@ -43,6 +43,9 @@ static bool validImpl(const char* str, size_t maxsize) {
   return true;
 }
 
+static int64_t queryIncr = 0;
+//static int64_t queryDec = 0; 
+
 static bool validUserName(const char* user) {
   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
     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);
   doAsyncQuery(pObj, pSql, waitForQueryRsp, taos, sqlstr, sqlLen);
 
@@ -657,7 +660,10 @@ void taos_free_result(TAOS_RES *res) {
     tscError("%p already released sqlObj", res);
     return;
   }
-
+  if (0 == pSql->subState.numOfSub) {
+    tscError("current query count: %ld", atomic_sub_fetch_64(&queryIncr, 1));
+  }
+    
   bool freeNow = tscKillQueryInDnode(pSql);
   if (freeNow) {
     tscDebug("%p free sqlObj in cache", pSql);
-- 
GitLab