asonix/garage
1
0
Fork 0
forked from Deuxfleurs/garage
Code Pull requests Activity

GC object table in a specific case

Browse source
This commit is contained in:
Alex 2021-03-16 16:51:15 +01:00
parent 1bfe9c129e
commit 08bcd51956
2 changed files with 4 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
src/model/block.rs
View file

@ -259,7 +259,7 @@ impl BlockManager {
if let Err(e) = self.resync_iter(&mut must_exit).await { if let Err(e) = self.resync_iter(&mut must_exit).await {
warn!("Error in block resync loop: {}", e); warn!("Error in block resync loop: {}", e);
select! { select! {
_ = tokio::time::sleep(Duration::from_secs(10)).fuse() => (), _ = tokio::time::sleep(Duration::from_secs(1)).fuse() => (),
_ = must_exit.changed().fuse() => (), _ = must_exit.changed().fuse() => (),
} }
} }

3
src/model/object_table.rs
View file

@ -146,6 +146,9 @@ impl Entry<String, String> for Object {
fn sort_key(&self) -> &String { fn sort_key(&self) -> &String {
&self.key &self.key
} }
fn is_tombstone(&self) -> bool {
self.versions.len() == 1 && self.versions[0].state == ObjectVersionState::Complete(ObjectVersionData::DeleteMarker)
}
} }
impl CRDT for Object { impl CRDT for Object {