From 2652d782567d967d75141b77a43e8d7b558f0c55 Mon Sep 17 00:00:00 2001
From: Alex Duan <417921451@qq.com>
Date: Thu, 14 Jul 2022 14:09:17 +0800
Subject: [PATCH] fix(rpc): send probe msg loop move next

---
 src/client/src/tscServer.c | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

diff --git a/src/client/src/tscServer.c b/src/client/src/tscServer.c
index 1f4db1c03e..79f8e94835 100644
--- a/src/client/src/tscServer.c
+++ b/src/client/src/tscServer.c
@@ -343,6 +343,9 @@ void checkBrokenQueries(STscObj *pTscObj) {
         dealConnBroken(pSubSql);
       }
     }
+
+    // move next
+    pSql = pSql->next;
   }
 } 
 
@@ -363,11 +366,11 @@ void tscProcessActivityTimer(void *handle, void *tmrId) {
 
   // check queries already death
   static int activetyTimerCnt = 0;
-  if (++activetyTimerCnt > 10) { // 1.5s * 10 = 15s interval call
+  if (++activetyTimerCnt > 5) { // 1.5s * 10 = 15s interval call
     activetyTimerCnt = 0;
 
     // call check if have query doing
-    if(pObj->sqlList && pObj->sqlList->next) {
+    if(pObj->sqlList) {
       // have queries executing
       checkBrokenQueries(pObj);
     }
-- 
GitLab