Skip to content
Closed
Show file tree
Hide file tree
Changes from 4 commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion node/bft/src/bft.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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();
Expand Down
2 changes: 1 addition & 1 deletion node/bft/src/helpers/cache.rs
Original file line number Diff line number Diff line change
Expand Up @@ -136,7 +136,7 @@ impl<N: Network> Cache<N> {
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);
}
Expand Down
1 change: 1 addition & 0 deletions node/bft/src/helpers/channels.rs
Original file line number Diff line number Diff line change
Expand Up @@ -60,6 +60,7 @@ pub fn init_consensus_channels<N: Network>() -> (ConsensusSender<N>, ConsensusRe
(sender, receiver)
}

/// "Interface" that enables, for example, sending data from storage to the BFT logic.
Comment thread
zeroprooff marked this conversation as resolved.
Outdated
#[derive(Clone, Debug)]
pub struct BFTSender<N: Network> {
pub tx_primary_round: mpsc::Sender<(u64, oneshot::Sender<bool>)>,
Expand Down