diff options
| author | Alex Auvolat <alex@adnab.me> | 2021-03-05 15:09:18 +0100 |
|---|---|---|
| committer | Alex Auvolat <alex@adnab.me> | 2021-03-05 15:09:18 +0100 |
| commit | 3882d5ba36f48751fdf6e5b82eae0dd990238655 (patch) | |
| tree | dbf412ac4643c27617cd613eea04682da25d6a66 /src/table/table_sharded.rs | |
| parent | d7e148d3027b7092d7de7e561665d2667199e9bc (diff) | |
| download | garage-3882d5ba36f48751fdf6e5b82eae0dd990238655.tar.gz garage-3882d5ba36f48751fdf6e5b82eae0dd990238655.zip | |
Remove epidemic propagation for fully replicated stuff: write directly to all nodes
Diffstat (limited to 'src/table/table_sharded.rs')
| -rw-r--r-- | src/table/table_sharded.rs | 5 |
1 files changed, 1 insertions, 4 deletions
diff --git a/src/table/table_sharded.rs b/src/table/table_sharded.rs index cbb1bc01..47bdfeaf 100644 --- a/src/table/table_sharded.rs +++ b/src/table/table_sharded.rs @@ -31,15 +31,12 @@ impl TableReplication for TableShardedReplication { let ring = system.ring.borrow().clone(); ring.walk_ring(&hash, self.replication_factor) } - fn write_quorum(&self) -> usize { + fn write_quorum(&self, _system: &System) -> usize { self.write_quorum } fn max_write_errors(&self) -> usize { self.replication_factor - self.write_quorum } - fn epidemic_writes(&self) -> bool { - false - } fn replication_nodes(&self, hash: &Hash, ring: &Ring) -> Vec<UUID> { ring.walk_ring(&hash, self.replication_factor) |