From 6cf9bb57f5128479d73b817df8dfb84054bf5b2b Mon Sep 17 00:00:00 2001
From: Minghao Li <castermode@gmail.com>
Date: Wed, 23 Feb 2022 17:17:02 +0800
Subject: [PATCH] add timer

---
 source/libs/sync/src/syncIO.c | 20 ++++++++++----------
 1 file changed, 10 insertions(+), 10 deletions(-)

diff --git a/source/libs/sync/src/syncIO.c b/source/libs/sync/src/syncIO.c
index 20c0f8038c..8dadd1e492 100644
--- a/source/libs/sync/src/syncIO.c
+++ b/source/libs/sync/src/syncIO.c
@@ -28,7 +28,7 @@ static void syncTick(void *param, void *tmrId) {
   rpcMsg.pCont = rpcMallocCont(10);
   snprintf(rpcMsg.pCont, 10, "TICK");
   rpcMsg.contLen = 10;
-  rpcMsg.handle = io;
+  rpcMsg.handle = NULL;
   rpcMsg.msgType = 2;
 
   SRpcMsg *pTemp;
@@ -65,15 +65,15 @@ void *syncConsumer(void *param) {
       taosGetQitem(qall, (void **)&pRpcMsg);
       rpcFreeCont(pRpcMsg->pCont);
 
-      /*
-          int msgSize = 128;
-          memset(&rpcMsg, 0, sizeof(rpcMsg));
-          rpcMsg.pCont = rpcMallocCont(msgSize);
-          rpcMsg.contLen = msgSize;
-          rpcMsg.handle = pRpcMsg->handle;
-          rpcMsg.code = 0;
-          rpcSendResponse(&rpcMsg);
-      */
+      if (pRpcMsg->handle != NULL) {
+        int msgSize = 128;
+        memset(&rpcMsg, 0, sizeof(rpcMsg));
+        rpcMsg.pCont = rpcMallocCont(msgSize);
+        rpcMsg.contLen = msgSize;
+        rpcMsg.handle = pRpcMsg->handle;
+        rpcMsg.code = 0;
+        rpcSendResponse(&rpcMsg);
+      }
 
       taosFreeQitem(pRpcMsg);
     }
-- 
GitLab