refactor(sync): modify leader transfer

1fc79e28 · Minghao Li · 10296908 · 1fc79e28
隐藏空白更改
内联并排

Showing with 6 addition and 2 deletion

source/libs/sync/src/syncMain.c source/libs/sync/src/syncMain.c +6 -2

未找到文件。
--- a/source/libs/sync/src/syncMain.c
+++ b/source/libs/sync/src/syncMain.c
@@ -444,8 +444,12 @@ int32_t syncNodeLeaderTransfer(SSyncNode* pSyncNode) {
    return -1;
  }

-  SNodeInfo newLeader = (pSyncNode->peersNodeInfo)[0];
-  int32_t   ret = syncNodeLeaderTransferTo(pSyncNode, newLeader);
+  int32_t ret = 0;
+  if (pSyncNode->state == TAOS_SYNC_STATE_LEADER) {
+    SNodeInfo newLeader = (pSyncNode->peersNodeInfo)[0];
+    ret = syncNodeLeaderTransferTo(pSyncNode, newLeader);
+  }
+
  return ret;
 }