diff options
author | Alex Auvolat <alex@adnab.me> | 2020-04-17 17:09:57 +0200 |
---|---|---|
committer | Alex Auvolat <alex@adnab.me> | 2020-04-17 17:09:57 +0200 |
commit | 69f1d8fef23149e45189c296e0c0d23e040cbb0e (patch) | |
tree | b213f119ae5eea620ab140cd712362707af28ddb /src/version_table.rs | |
parent | e41ce4d81528388f043c1c5e6608df45347ea70d (diff) | |
download | garage-69f1d8fef23149e45189c296e0c0d23e040cbb0e.tar.gz garage-69f1d8fef23149e45189c296e0c0d23e040cbb0e.zip |
WIP
TODOs:
- ensure sync goes both way
- finish sending blocks to other nodes when they need them before deleting
Diffstat (limited to 'src/version_table.rs')
-rw-r--r-- | src/version_table.rs | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/src/version_table.rs b/src/version_table.rs index 77a7560d..22290fd7 100644 --- a/src/version_table.rs +++ b/src/version_table.rs @@ -62,6 +62,7 @@ impl TableSchema for VersionTable { type P = Hash; type S = EmptySortKey; type E = Version; + type Filter = (); async fn updated(&self, old: Option<Self::E>, new: Option<Self::E>) { let block_ref_table = self.block_ref_table.clone(); @@ -84,4 +85,8 @@ impl TableSchema for VersionTable { }); } } + + fn matches_filter(entry: &Self::E, _filter: &Self::Filter) -> bool { + !entry.deleted + } } |