diff options
| author | Alex Auvolat <alex@adnab.me> | 2024-03-19 11:04:20 +0100 |
|---|---|---|
| committer | Alex Auvolat <alex@adnab.me> | 2024-03-19 16:20:22 +0100 |
| commit | dc0b78cdb88e9cbfd7dc1a2ee0b15333939be549 (patch) | |
| tree | 20d18c4d8676b455513dd84d560e1748df6fd12b /src/model/garage.rs | |
| parent | 0038ca8a78f147b9c0ec07ef0121773aaf110dc9 (diff) | |
| download | garage-dc0b78cdb88e9cbfd7dc1a2ee0b15333939be549.tar.gz garage-dc0b78cdb88e9cbfd7dc1a2ee0b15333939be549.zip | |
[block-ref-repair] Block refcount recalculation and repair
- We always recalculate the reference count of a block before deleting
it locally, to make sure that it is indeed zero.
- If we had to fetch a remote block but we were not able to get it,
check that refcount is indeed > 0.
- Repair procedure that checks everything
Diffstat (limited to 'src/model/garage.rs')
| -rw-r--r-- | src/model/garage.rs | 8 |
1 files changed, 8 insertions, 0 deletions
diff --git a/src/model/garage.rs b/src/model/garage.rs index 4405d22d..273690db 100644 --- a/src/model/garage.rs +++ b/src/model/garage.rs @@ -247,6 +247,14 @@ impl Garage { #[cfg(feature = "k2v")] let k2v = GarageK2V::new(system.clone(), &db, meta_rep_param); + // ---- setup block refcount recalculation ---- + // this function can be used to fix inconsistencies in the RC table + block_manager.set_recalc_rc(vec![ + block_ref_recount_fn(&block_ref_table), + // other functions could be added here if we had other tables + // that hold references to data blocks + ]); + // -- done -- Ok(Arc::new(Self { config, |