verify the peer address.

rmqtt · Jun 25, 2023 · db96b11 · db96b11
1 parent 10c8d95
commit db96b11
Showing 1 changed file with 6 additions and 4 deletions.
diff --git a/rmqtt-plugins/rmqtt-cluster-raft/src/lib.rs b/rmqtt-plugins/rmqtt-cluster-raft/src/lib.rs
@@ -147,10 +147,12 @@ impl ClusterPlugin {
         let raft = Raft::new(raft_laddr, router, logger, cfg.read().raft.to_raft_config());
         let mailbox = raft.mailbox();
 
-        let peer_addrs = raft_peer_addrs
-            .iter()
-            .filter_map(|peer| if peer.id != id { Some(peer.addr.to_string()) } else { None })
-            .collect::<Vec<String>>();
+        let mut peer_addrs = Vec::new();
+        for peer in raft_peer_addrs.iter() {
+            if peer.id != id {
+                peer_addrs.push(parse_addr(&peer.addr.to_string()).await?.to_string())
+            }
+        }
         log::info!("peer_addrs: {:?}", peer_addrs);
 
         let leader_info =