diff options
| author | Alex Auvolat <alex@adnab.me> | 2023-09-21 15:32:25 +0200 |
|---|---|---|
| committer | Alex Auvolat <alex@adnab.me> | 2023-09-21 15:35:31 +0200 |
| commit | f97168f80567f43e15cf236092703e6ae5d8dc2e (patch) | |
| tree | ca9b06fa1d9bf3af9b33c5db0a8c09a53b403fa9 /src/table/merkle.rs | |
| parent | fd7d8fec59c617b40e480ff855894cf35fdcfb40 (diff) | |
| download | garage-f97168f80567f43e15cf236092703e6ae5d8dc2e.tar.gz garage-f97168f80567f43e15cf236092703e6ae5d8dc2e.zip | |
garage_db: refactor transactions and add on_commit mechanism
Diffstat (limited to 'src/table/merkle.rs')
| -rw-r--r-- | src/table/merkle.rs | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/table/merkle.rs b/src/table/merkle.rs index e86d0251..4577f872 100644 --- a/src/table/merkle.rs +++ b/src/table/merkle.rs @@ -108,9 +108,9 @@ impl<F: TableSchema, R: TableReplication> MerkleUpdater<F, R> { self.data .merkle_tree .db() - .transaction(|mut tx| self.update_item_rec(&mut tx, k, &khash, &key, new_vhash))?; + .transaction(|tx| self.update_item_rec(tx, k, &khash, &key, new_vhash))?; - let deleted = self.data.merkle_todo.db().transaction(|mut tx| { + let deleted = self.data.merkle_todo.db().transaction(|tx| { let remove = matches!(tx.get(&self.data.merkle_todo, k)?, Some(ov) if ov == vhash_by); if remove { tx.remove(&self.data.merkle_todo, k)?; |