From 08df4b42de6823bbdf9231aa68d0e974f86be371 Mon Sep 17 00:00:00 2001
From: Minghao Li <castermode@gmail.com>
Date: Wed, 2 Mar 2022 20:08:46 +0800
Subject: [PATCH] sync modify timer

---
 source/libs/sync/inc/syncMessage.h |  4 ++--
 source/libs/sync/src/syncIO.c      | 13 ++-----------
 source/libs/sync/src/syncMain.c    | 11 ++++++++++-
 3 files changed, 14 insertions(+), 14 deletions(-)

diff --git a/source/libs/sync/inc/syncMessage.h b/source/libs/sync/inc/syncMessage.h
index a4ae910608..bb9ec65d3b 100644
--- a/source/libs/sync/inc/syncMessage.h
+++ b/source/libs/sync/inc/syncMessage.h
@@ -30,8 +30,8 @@ extern "C" {
 
 // encode as uint64
 typedef enum ESyncMessageType {
-  SYNC_PING = 100,
-  SYNC_PING_REPLY,
+  SYNC_PING = 101,
+  SYNC_PING_REPLY = 103,
   SYNC_CLIENT_REQUEST,
   SYNC_CLIENT_REQUEST_REPLY,
   SYNC_REQUEST_VOTE,
diff --git a/source/libs/sync/src/syncIO.c b/source/libs/sync/src/syncIO.c
index 85a9459483..590466d1cc 100644
--- a/source/libs/sync/src/syncIO.c
+++ b/source/libs/sync/src/syncIO.c
@@ -216,19 +216,10 @@ static void *syncIOConsumerFunc(void *param) {
           memcpy(&tmpRpcMsg, pRpcMsg, sizeof(SRpcMsg));
           pSyncMsg = syncPingBuild(tmpRpcMsg.contLen);
 
-          // syncPingFromRpcMsg(pRpcMsg, pSyncMsg);
+          syncPingFromRpcMsg(pRpcMsg, pSyncMsg);
 
-          memcpy(pSyncMsg, tmpRpcMsg.pCont, tmpRpcMsg.contLen);
+          // memcpy(pSyncMsg, tmpRpcMsg.pCont, tmpRpcMsg.contLen);
 
-#if 0
-          {
-            cJSON *pJson = syncPing2Json(pSyncMsg);
-            char  *serialized = cJSON_Print(pJson);
-            sTrace("syncIOConsumerFunc syncNodePing pMsg:%s ", serialized);
-            free(serialized);
-            cJSON_Delete(pJson);
-          }
-#endif
           io->FpOnSyncPing(io->pSyncNode, pSyncMsg);
         }
 
diff --git a/source/libs/sync/src/syncMain.c b/source/libs/sync/src/syncMain.c
index 180a2b13a1..ce3dba4c0e 100644
--- a/source/libs/sync/src/syncMain.c
+++ b/source/libs/sync/src/syncMain.c
@@ -230,7 +230,16 @@ static int32_t syncNodeSendMsgByInfo(const SNodeInfo* nodeInfo, SSyncNode* pSync
 
 static int32_t syncNodeOnPingCb(SSyncNode* ths, SyncPing* pMsg) {
   int32_t ret = 0;
-  sTrace("syncNodeOnPingCb ---- =========");
+  sTrace("<-- syncNodeOnPingCb -->");
+
+  {
+    cJSON* pJson = syncPing2Json(pMsg);
+    char*  serialized = cJSON_Print(pJson);
+    sTrace("syncNodeOnPingCb syncNodePing pMsg:%s ", serialized);
+    free(serialized);
+    cJSON_Delete(pJson);
+  }
+
   return ret;
 }