(cherry picked from commit 611af87fdb
)
Co-authored-by: Ryo Onodera <ryoqun@gmail.com>
This commit is contained in:
@ -351,7 +351,7 @@ impl StandardBroadcastRun {
|
|||||||
if now - last > BROADCAST_PEER_UPDATE_INTERVAL_MS
|
if now - last > BROADCAST_PEER_UPDATE_INTERVAL_MS
|
||||||
&& self
|
&& self
|
||||||
.last_peer_update
|
.last_peer_update
|
||||||
.compare_and_swap(now, last, Ordering::Relaxed)
|
.compare_and_swap(last, now, Ordering::Relaxed)
|
||||||
== last
|
== last
|
||||||
{
|
{
|
||||||
let mut w_broadcast_peer_cache = self.broadcast_peer_cache.write().unwrap();
|
let mut w_broadcast_peer_cache = self.broadcast_peer_cache.write().unwrap();
|
||||||
|
Reference in New Issue
Block a user