aboutsummaryrefslogtreecommitdiff
path: root/src/table/replication/fullcopy.rs
diff options
context:
space:
mode:
authorAlex <alex@adnab.me>2024-03-05 21:56:17 +0000
committerAlex <alex@adnab.me>2024-03-05 21:56:17 +0000
commit603604cdfc76d9ae86c02f25d49b7c845d138262 (patch)
tree6cfad4bd68493aa2038b60f7f2005ec91bcc0509 /src/table/replication/fullcopy.rs
parentbbde9bc91225ac41ea6e8def61c5b7044bb186a0 (diff)
parent6760895926c23112583dfc53a01ecbcfad02a276 (diff)
downloadgarage-603604cdfc76d9ae86c02f25d49b7c845d138262.tar.gz
garage-603604cdfc76d9ae86c02f25d49b7c845d138262.zip
Merge pull request 'refactor: remove max_write_errors and max_faults' (#760) from yuka/garage:remove-max-write-errors into next-0.10
Reviewed-on: https://git.deuxfleurs.fr/Deuxfleurs/garage/pulls/760
Diffstat (limited to 'src/table/replication/fullcopy.rs')
-rw-r--r--src/table/replication/fullcopy.rs12
1 files changed, 5 insertions, 7 deletions
diff --git a/src/table/replication/fullcopy.rs b/src/table/replication/fullcopy.rs
index 30122f39..1e52bb47 100644
--- a/src/table/replication/fullcopy.rs
+++ b/src/table/replication/fullcopy.rs
@@ -21,8 +21,6 @@ use crate::replication::*;
pub struct TableFullReplication {
/// The membership manager of this node
pub system: Arc<System>,
- /// Max number of faults allowed while replicating a record
- pub max_faults: usize,
}
impl TableReplication for TableFullReplication {
@@ -45,15 +43,15 @@ impl TableReplication for TableFullReplication {
}
fn write_quorum(&self) -> usize {
let nmembers = self.system.cluster_layout().current().all_nodes().len();
- if nmembers > self.max_faults {
- nmembers - self.max_faults
+
+ let max_faults = if nmembers > 1 { 1 } else { 0 };
+
+ if nmembers > max_faults {
+ nmembers - max_faults
} else {
1
}
}
- fn max_write_errors(&self) -> usize {
- self.max_faults
- }
fn partition_of(&self, _hash: &Hash) -> Partition {
0u16