diff --git a/node/bft/src/bft.rs b/node/bft/src/bft.rs index ef87edcc8f..348b1de7c5 100644 --- a/node/bft/src/bft.rs +++ b/node/bft/src/bft.rs @@ -1708,7 +1708,7 @@ mod tests { assert!(!bootup_bft.dag.read().contains_certificate_in_round(certificate_round, certificate_id)); } - // Check that that the bootup BFT has committed the subdag stemming from the second leader certificate in consensus. + // Check that the bootup BFT has committed the subdag stemming from the second leader certificate in consensus. for certificate in committed_certificates_bootup.clone() { let certificate_round = certificate.round(); let certificate_id = certificate.id(); diff --git a/node/bft/src/helpers/cache.rs b/node/bft/src/helpers/cache.rs index 377bdc724e..ac6a5c8cd4 100644 --- a/node/bft/src/helpers/cache.rs +++ b/node/bft/src/helpers/cache.rs @@ -136,7 +136,7 @@ impl Cache { Self::decrement_counter(&self.seen_outbound_validators_requests, peer_ip) } - /// Clears the the IP's number of validator requests. + /// Clears the IP's number of validator requests. pub fn clear_outbound_validators_requests(&self, peer_ip: SocketAddr) { self.seen_outbound_validators_requests.write().remove(&peer_ip); } diff --git a/node/bft/src/helpers/channels.rs b/node/bft/src/helpers/channels.rs index aeb210cde4..b6c9c9d3d7 100644 --- a/node/bft/src/helpers/channels.rs +++ b/node/bft/src/helpers/channels.rs @@ -60,6 +60,7 @@ pub fn init_consensus_channels() -> (ConsensusSender, ConsensusRe (sender, receiver) } +/// Outbound channels that the `primary` uses to communicate with the BFT. #[derive(Clone, Debug)] pub struct BFTSender { pub tx_primary_round: mpsc::Sender<(u64, oneshot::Sender)>,