fix(sync) add trace log

28b32682 · Shengliang Guan · 62f21b52 · 28b32682 · 28b32682
隐藏空白更改
内联并排

Showing with 6 addition and 6 deletion

source/libs/sync/src/syncMain.c source/libs/sync/src/syncMain.c +4 -4

source/libs/sync/src/syncSnapshot.c source/libs/sync/src/syncSnapshot.c +2 -2

未找到文件。
--- a/source/libs/sync/src/syncMain.c
+++ b/source/libs/sync/src/syncMain.c
@@ -2197,8 +2197,8 @@ static int32_t syncNodeConfigChange(SSyncNode* ths, SRpcMsg* pRpcMsg, SSyncRaftE
      char* newStr = syncCfg2Str(&newSyncCfg);
      syncUtilJson2Line(oldStr);
      syncUtilJson2Line(newStr);
-      snprintf(tmpbuf, sizeof(tmpbuf), "config change from %d to %d, %s  -->  %s", oldSyncCfg.replicaNum,
-               newSyncCfg.replicaNum, oldStr, newStr);
+      snprintf(tmpbuf, sizeof(tmpbuf), "config change from %d to %d, index:%ld, %s  -->  %s", oldSyncCfg.replicaNum,
+          newSyncCfg.replicaNum, pEntry->index, oldStr, newStr);
      taosMemoryFree(oldStr);
      taosMemoryFree(newStr);

@@ -2214,8 +2214,8 @@ static int32_t syncNodeConfigChange(SSyncNode* ths, SRpcMsg* pRpcMsg, SSyncRaftE
    char* newStr = syncCfg2Str(&newSyncCfg);
    syncUtilJson2Line(oldStr);
    syncUtilJson2Line(newStr);
-    snprintf(tmpbuf, sizeof(tmpbuf), "config change2 from %d to %d, %s  -->  %s", oldSyncCfg.replicaNum,
-             newSyncCfg.replicaNum, oldStr, newStr);
+    snprintf(tmpbuf, sizeof(tmpbuf), "config change2 from %d to %d, index:%ld, %s  -->  %s", oldSyncCfg.replicaNum,
+         newSyncCfg.replicaNum, pEntry->index, oldStr, newStr);
    taosMemoryFree(oldStr);
    taosMemoryFree(newStr);


--- a/source/libs/sync/src/syncSnapshot.c
+++ b/source/libs/sync/src/syncSnapshot.c
@@ -671,8 +671,8 @@ int32_t syncNodeOnSnapshotSendCb(SSyncNode *pSyncNode, SyncSnapshotSend *pMsg) {
            char *newStr = syncCfg2Str(&newSyncCfg);
            syncUtilJson2Line(oldStr);
            syncUtilJson2Line(newStr);
-            snprintf(tmpbuf, sizeof(tmpbuf), "config change3 from %d to %d, %s  -->  %s", oldSyncCfg.replicaNum,
-                     newSyncCfg.replicaNum, oldStr, newStr);
+            snprintf(tmpbuf, sizeof(tmpbuf), "config change3 from %d to %d, index:%ld, %s  -->  %s",
+                     oldSyncCfg.replicaNum, newSyncCfg.replicaNum, pMsg->lastConfigIndex, oldStr, newStr);
            taosMemoryFree(oldStr);
            taosMemoryFree(newStr);