From 5d4f0cbc717c3bec17d3086264f8d30a55026174 Mon Sep 17 00:00:00 2001 From: dmchen Date: Wed, 2 Aug 2023 16:36:07 +0800 Subject: [PATCH] myindex --- source/libs/sync/src/syncMain.c | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/source/libs/sync/src/syncMain.c b/source/libs/sync/src/syncMain.c index 617b141fef..f200212538 100644 --- a/source/libs/sync/src/syncMain.c +++ b/source/libs/sync/src/syncMain.c @@ -2458,6 +2458,10 @@ int32_t syncNodeRebuildPeerAndCfg(SSyncNode* ths, SSyncCfg *cfg){ tstrncpy(ths->raftCfg.cfg.nodeInfo[i].nodeFqdn, cfg->nodeInfo[j].nodeFqdn, TSDB_FQDN_LEN); ths->raftCfg.cfg.nodeInfo[i].nodeId = cfg->nodeInfo[j].nodeId; ths->raftCfg.cfg.nodeInfo[i].nodePort = cfg->nodeInfo[j].nodePort; + if((strcmp(ths->myNodeInfo.nodeFqdn, cfg->nodeInfo[j].nodeFqdn) == 0 + && ths->myNodeInfo.nodePort == cfg->nodeInfo[j].nodePort)){ + ths->raftCfg.cfg.myIndex = i; + } i++; } ths->raftCfg.cfg.totalReplicaNum = i;