Abstract database behind generic interface and implement alternative drivers #322
2 changed files with 2 additions and 2 deletions
|
@ -243,7 +243,7 @@ where
|
|||
|
||||
pub(crate) fn delete_if_equal(self: &Arc<Self>, k: &[u8], v: &[u8]) -> Result<bool, Error> {
|
||||
let removed = self.store.db().transaction(|mut tx| {
|
||||
let remove = matches!(tx.get(&self.store, k)?, Some(cur_v) if cur_v == v => true);
|
||||
let remove = matches!(tx.get(&self.store, k)?, Some(cur_v) if cur_v == v);
|
||||
if remove {
|
||||
tx.remove(&self.store, k)?;
|
||||
tx.insert(&self.merkle_todo, k, vec![])?;
|
||||
|
|
|
@ -384,7 +384,7 @@ impl GcTodoEntry {
|
|||
let key = self.todo_table_key();
|
||||
gc_todo_tree.db().transaction(|mut tx| {
|
||||
let remove =
|
||||
matches!(tx.get(gc_todo_tree, &key)? Some(ov) if ov == self.value_hash.as_slice());
|
||||
matches!(tx.get(gc_todo_tree, &key)?, Some(ov) if ov == self.value_hash.as_slice());
|
||||
if remove {
|
||||
tx.remove(gc_todo_tree, &key)?;
|
||||
}
|
||||
|
|
Loading…
Reference in a new issue