aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--src/table/replication/fullcopy.rs9
1 files changed, 3 insertions, 6 deletions
diff --git a/src/table/replication/fullcopy.rs b/src/table/replication/fullcopy.rs
index 1e52bb47..39e29580 100644
--- a/src/table/replication/fullcopy.rs
+++ b/src/table/replication/fullcopy.rs
@@ -43,13 +43,10 @@ impl TableReplication for TableFullReplication {
}
fn write_quorum(&self) -> usize {
let nmembers = self.system.cluster_layout().current().all_nodes().len();
-
- let max_faults = if nmembers > 1 { 1 } else { 0 };
-
- if nmembers > max_faults {
- nmembers - max_faults
- } else {
+ if nmembers < 3 {
1
+ } else {
+ nmembers.div_euclid(2) + 1
}
}