diff options
| author | Alex Auvolat <alex@adnab.me> | 2020-04-19 15:14:23 +0200 |
|---|---|---|
| committer | Alex Auvolat <alex@adnab.me> | 2020-04-19 15:14:23 +0200 |
| commit | 302502f4c10b4c1cd03d3b098b3e55a3f70054f2 (patch) | |
| tree | 3e32c8751dc5d62b1723bcc2738aa77f12d45123 /src/table_sync.rs | |
| parent | 7131553c53d4414d2da0e9b60e6e3425f1b46ec2 (diff) | |
| download | garage-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.rs | 6 |
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)) { |