diff --git a/mempool/src/shared_mempool/coordinator.rs b/mempool/src/shared_mempool/coordinator.rs index 07b6f7154d9a6..9d91116c6d82b 100644 --- a/mempool/src/shared_mempool/coordinator.rs +++ b/mempool/src/shared_mempool/coordinator.rs @@ -358,6 +358,7 @@ async fn handle_update_peers( .write() .update_peers(&connected_peers); let (newly_added_upstream, disabled) = smp.network_interface.update_peers(&connected_peers); + // TODO: anything that is old, filter out of newly_add_upstream and add to disabled if !newly_added_upstream.is_empty() || !disabled.is_empty() { counters::shared_mempool_event_inc("peer_update"); notify_subscribers(SharedMempoolNotification::PeerStateChange, &smp.subscribers);