diff options
| author | Alex Auvolat <alex@adnab.me> | 2023-11-14 14:28:16 +0100 |
|---|---|---|
| committer | Alex Auvolat <alex@adnab.me> | 2023-11-14 14:28:16 +0100 |
| commit | 3b361d2959e3d577bdae6f8a5ccb0c9d5526b7ea (patch) | |
| tree | f5448d44c7d5705c1e31912ca6d101c5998523ef /src/table/data.rs | |
| parent | 866196750fca74c1911ade2a90611f3663e60046 (diff) | |
| download | garage-3b361d2959e3d577bdae6f8a5ccb0c9d5526b7ea.tar.gz garage-3b361d2959e3d577bdae6f8a5ccb0c9d5526b7ea.zip | |
layout: prepare for write sets
Diffstat (limited to 'src/table/data.rs')
| -rw-r--r-- | src/table/data.rs | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/src/table/data.rs b/src/table/data.rs index bbfdf58b..7f6b7847 100644 --- a/src/table/data.rs +++ b/src/table/data.rs @@ -254,7 +254,8 @@ impl<F: TableSchema, R: TableReplication> TableData<F, R> { // of the GC algorithm, as in all cases GC is suspended if // any node of the partition is unavailable. let pk_hash = Hash::try_from(&tree_key[..32]).unwrap(); - let nodes = self.replication.write_nodes(&pk_hash); + // TODO: this probably breaks when the layout changes + let nodes = self.replication.storage_nodes(&pk_hash); if nodes.first() == Some(&self.system.id) { GcTodoEntry::new(tree_key, new_bytes_hash).save(&self.gc_todo)?; } |