redo

Signed-off-by: Somtochi Onyekwere <[email protected]>

Author: somtochiama

crates/corro-agent/src/agent/util.rs

@@ -67,7 +67,6 @@ use tracing::{debug, error, info, trace, warn};
 use tripwire::{Outcome, PreemptibleFutureExt, Tripwire};
 
 pub async fn initialise_foca(agent: &Agent, states: Vec<(SocketAddr, Member<Actor>)>) {
-    info!("loaded member states: {:?}", states);
     if !states.is_empty() {
         let mut foca_states = BTreeMap::<SocketAddr, Member<Actor>>::new();
 
@@ -95,7 +94,6 @@ pub async fn initialise_foca(agent: &Agent, states: Vec<(SocketAddr, Member<Acto
             }
         }
 
-        info!("foca states: {:?}", foca_states);
         if let Err(e) = agent
             .tx_foca()
             .send(FocaInput::ApplyMany(foca_states.into_values().collect()))

crates/corro-agent/src/broadcast/mod.rs

@@ -838,8 +838,6 @@ fn diff_member_states(
     let members = agent.members().read();
     let membership_id = agent.config().gossip.membership_id;
 
-    let mut to_delete = vec![];
-
     let to_update = foca_states
         .iter()
         .filter_map(|(id, member)| {
@@ -874,6 +872,8 @@ fn diff_member_states(
         })
         .collect::<Vec<_>>();
 
+    let mut to_delete = vec![];
+
     last_states.retain(|id, _v| {
         let foca_state = foca_states.get(id);
         if foca_state.is_some() && foca_state.unwrap().id().membership_id() == membership_id {