-
Notifications
You must be signed in to change notification settings - Fork 395
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
This PR ports joint quorum. It rename ProgressSet to ProgressTracker and keep both name and field layout just like etcd. In addition, the PR fixes a performance issue discovered earlier that campaign prints too much logs. Signed-off-by: Jay Lee <BusyJayLee@gmail.com>
- Loading branch information
Showing
13 changed files
with
418 additions
and
215 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,83 @@ | ||
| // Copyright 2020 TiKV Project Authors. Licensed under Apache-2.0. | ||
|
|
||
| use super::{AckedIndexer, VoteResult}; | ||
| use crate::util::Union; | ||
| use crate::HashSet; | ||
| use crate::MajorityConfig; | ||
| use std::cmp; | ||
|
|
||
| /// A configuration of two groups of (possibly overlapping) majority configurations. | ||
| /// Decisions require the support of both majorities. | ||
| #[derive(Clone, Debug, Default, PartialEq)] | ||
| pub struct Configuration { | ||
| pub(crate) incoming: MajorityConfig, | ||
| pub(crate) outgoing: MajorityConfig, | ||
| } | ||
|
|
||
| impl Configuration { | ||
| /// Creates a new configuration using the given IDs. | ||
| pub fn new(voters: HashSet<u64>) -> Configuration { | ||
| Configuration { | ||
| incoming: MajorityConfig::new(voters), | ||
| outgoing: MajorityConfig::default(), | ||
| } | ||
| } | ||
|
|
||
| /// Creates an empty configuration with given capacity. | ||
| pub fn with_capacity(cap: usize) -> Configuration { | ||
| Configuration { | ||
| incoming: MajorityConfig::with_capacity(cap), | ||
| outgoing: MajorityConfig::default(), | ||
| } | ||
| } | ||
|
|
||
| /// Returns the largest committed index for the given joint quorum. An index is | ||
| /// jointly committed if it is committed in both constituent majorities. | ||
| /// | ||
| /// The bool flag indicates whether the index is computed by group commit algorithm | ||
| /// successfully. It's true only when both majorities use group commit. | ||
| pub fn committed_index(&self, use_group_commit: bool, l: &impl AckedIndexer) -> (u64, bool) { | ||
| let (i_idx, i_use_gc) = self.incoming.committed_index(use_group_commit, l); | ||
| let (o_idx, o_use_gc) = self.outgoing.committed_index(use_group_commit, l); | ||
| (cmp::min(i_idx, o_idx), i_use_gc && o_use_gc) | ||
| } | ||
|
|
||
| /// Takes a mapping of voters to yes/no (true/false) votes and returns a result | ||
| /// indicating whether the vote is pending, lost, or won. A joint quorum requires | ||
| /// both majority quorums to vote in favor. | ||
| pub fn vote_result(&self, check: impl Fn(u64) -> Option<bool>) -> VoteResult { | ||
| let i = self.incoming.vote_result(&check); | ||
| let o = self.outgoing.vote_result(check); | ||
| match (i, o) { | ||
| // It won if won in both. | ||
| (VoteResult::Won, VoteResult::Won) => VoteResult::Won, | ||
| // It lost if lost in either. | ||
| (VoteResult::Lost, _) | (_, VoteResult::Lost) => VoteResult::Lost, | ||
| // It remains pending if pending in both or just won in one side. | ||
| _ => VoteResult::Pending, | ||
| } | ||
| } | ||
|
|
||
| /// Clears all IDs. | ||
| pub fn clear(&mut self) { | ||
| self.incoming.clear(); | ||
| self.outgoing.clear(); | ||
| } | ||
|
|
||
| /// Returns true if (and only if) there is only one voting member | ||
| /// (i.e. the leader) in the current configuration. | ||
| pub fn is_singleton(&self) -> bool { | ||
| self.outgoing.voters.is_empty() && self.incoming.voters.len() == 1 | ||
| } | ||
|
|
||
| /// Returns an iterator over two hash set without cloning. | ||
| pub fn ids(&self) -> Union<'_> { | ||
| Union::new(&self.incoming.voters, &self.outgoing.voters) | ||
| } | ||
|
|
||
| /// Check if an id is a voter. | ||
| #[inline] | ||
| pub fn contains(&self, id: u64) -> bool { | ||
| self.incoming.voters.contains(&id) || self.outgoing.voters.contains(&id) | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.