aboutsummaryrefslogtreecommitdiff
path: root/src/table/table.rs
diff options
context:
space:
mode:
authorAlex Auvolat <alex@adnab.me>2021-02-23 20:25:15 +0100
committerAlex Auvolat <alex@adnab.me>2021-02-23 20:25:15 +0100
commitbf25c95fe2fda4ded2e3ca14499e3991e7243532 (patch)
tree889ced32b11186e69caba5af740b26de3e3b0659 /src/table/table.rs
parent28bc967c837c38ba416d9b19fd1ae96cbb292074 (diff)
downloadgarage-bf25c95fe2fda4ded2e3ca14499e3991e7243532.tar.gz
garage-bf25c95fe2fda4ded2e3ca14499e3991e7243532.zip
Make updated() be a sync function that doesn't fail
Diffstat (limited to 'src/table/table.rs')
-rw-r--r--src/table/table.rs6
1 files changed, 3 insertions, 3 deletions
diff --git a/src/table/table.rs b/src/table/table.rs
index 018426c4..737ed589 100644
--- a/src/table/table.rs
+++ b/src/table/table.rs
@@ -414,7 +414,7 @@ where
epidemic_propagate.push(new_entry.clone());
}
- self.instance.updated(old_entry, Some(new_entry)).await?;
+ self.instance.updated(old_entry, Some(new_entry));
syncer.invalidate(&tree_key[..]);
}
}
@@ -429,7 +429,7 @@ where
Ok(())
}
- pub(crate) async fn delete_if_equal(
+ pub(crate) fn delete_if_equal(
self: &Arc<Self>,
k: &[u8],
v: &[u8],
@@ -445,7 +445,7 @@ where
})?;
if removed {
let old_entry = self.decode_entry(v)?;
- self.instance.updated(Some(old_entry), None).await?;
+ self.instance.updated(Some(old_entry), None);
self.syncer.load_full().unwrap().invalidate(k);
}
Ok(removed)