no need to ping same members that are probed

Signed-off-by: Matt Wrock <[email protected]>
habitat-sh · Nov 6, 2024 · fe1726f · fe1726f
1 parent 5dd4375
commit fe1726f
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/components/butterfly/src/server/outbound.rs b/components/butterfly/src/server/outbound.rs
@@ -128,13 +128,14 @@ fn run_loop(server: &Server, socket: &UdpSocket, rx_inbound: &AckReceiver, timin
                                      .members_write()
                                      .drain()
                                      .collect::<Vec<_>>();
-
+        let mut check_list = server.member_list.check_list_mlr(&server.member_id);
         if !members_to_probe.is_empty() {
             debug!("Probing {} members in the Probe List.",
                    members_to_probe.len());
 
             for member in members_to_probe {
                 trace!("Probing member: {}", member.id);
+                check_list.retain(|mem| mem.id != member.id);
                 let addr = member.swim_socket_address();
                 ping_mlr_smr_rhw(server,
                                  socket,
@@ -154,8 +155,6 @@ fn run_loop(server: &Server, socket: &UdpSocket, rx_inbound: &AckReceiver, timin
             debug!("Zero members in probe_list");
         }
 
-        let check_list = server.member_list.check_list_mlr(&server.member_id);
-
         let probe_iteration_start = Instant::now();
         for member in check_list {
             if server.member_list.pingable_mlr(&member) {