diff --git a/core/src/broadcast_stage/standard_broadcast_run.rs b/core/src/broadcast_stage/standard_broadcast_run.rs index 62af0708d7..7bfe5950f4 100644 --- a/core/src/broadcast_stage/standard_broadcast_run.rs +++ b/core/src/broadcast_stage/standard_broadcast_run.rs @@ -344,7 +344,7 @@ impl StandardBroadcastRun { if now - last > BROADCAST_PEER_UPDATE_INTERVAL_MS && self .last_peer_update - .compare_and_swap(now, last, Ordering::Relaxed) + .compare_and_swap(last, now, Ordering::Relaxed) == last { *self.cluster_nodes.write().unwrap() = ClusterNodes::::new(