aboutsummaryrefslogtreecommitdiff
path: root/src/table_sync.rs
diff options
context:
space:
mode:
authorAlex Auvolat <alex@adnab.me>2020-04-19 15:14:23 +0200
committerAlex Auvolat <alex@adnab.me>2020-04-19 15:14:23 +0200
commit302502f4c10b4c1cd03d3b098b3e55a3f70054f2 (patch)
tree3e32c8751dc5d62b1723bcc2738aa77f12d45123 /src/table_sync.rs
parent7131553c53d4414d2da0e9b60e6e3425f1b46ec2 (diff)
downloadgarage-302502f4c10b4c1cd03d3b098b3e55a3f70054f2.tar.gz
garage-302502f4c10b4c1cd03d3b098b3e55a3f70054f2.zip
Add support for fully replicated tables with epidemic dissemination of updates
Diffstat (limited to 'src/table_sync.rs')
-rw-r--r--src/table_sync.rs6
1 files changed, 3 insertions, 3 deletions
diff --git a/src/table_sync.rs b/src/table_sync.rs
index b4555a77..550ad0f0 100644
--- a/src/table_sync.rs
+++ b/src/table_sync.rs
@@ -604,7 +604,7 @@ impl SyncTodo {
for i in 0..split_points.len() - 1 {
let begin = split_points[i].clone();
let end = split_points[i + 1].clone();
- let nodes = table.replication.write_nodes_from_ring(&begin, &ring);
+ let nodes = table.replication.replication_nodes(&begin, &ring);
let retain = nodes.contains(&my_id);
if !retain {
@@ -650,11 +650,11 @@ impl SyncTodo {
let end = all_points[i + 1].clone();
let was_ours = table
.replication
- .write_nodes_from_ring(&begin, &old_ring)
+ .replication_nodes(&begin, &old_ring)
.contains(&my_id);
let is_ours = table
.replication
- .write_nodes_from_ring(&begin, &new_ring)
+ .replication_nodes(&begin, &new_ring)
.contains(&my_id);
let was_todo = match old_todo.binary_search_by(|x| x.begin.cmp(&begin)) {