From f2dc9dd96ef191684fff141ae1851f4773b5ee86 Mon Sep 17 00:00:00 2001 From: "mergify[bot]" <37929162+mergify[bot]@users.noreply.github.com> Date: Fri, 30 Jul 2021 10:52:37 +0900 Subject: [PATCH] Fix unstable retransmit-num_nodes (#18970) (#18974) (cherry picked from commit da480bdb5f306c62e656d51d50809532e8498038) Co-authored-by: Ryo Onodera --- core/src/retransmit_stage.rs | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/core/src/retransmit_stage.rs b/core/src/retransmit_stage.rs index 8f843559cd..50f837e1c1 100644 --- a/core/src/retransmit_stage.rs +++ b/core/src/retransmit_stage.rs @@ -332,7 +332,7 @@ fn retransmit( } } let cluster_nodes = cluster_nodes.read().unwrap(); - let mut peers_len = 0; + let peers_len = cluster_nodes.num_peers(); epoch_cache_update.stop(); let my_id = cluster_info.id(); @@ -385,7 +385,6 @@ fn retransmit( // TODO: Consider forwarding the packet to the root node here. retransmit_tree_mismatch += 1; } - peers_len = peers_len.max(cluster_nodes.num_peers()); compute_turbine_peers.stop(); compute_turbine_peers_total += compute_turbine_peers.as_us();