diff options
| author | Alex Auvolat <alex@adnab.me> | 2022-06-03 15:31:07 +0200 |
|---|---|---|
| committer | Alex Auvolat <alex@adnab.me> | 2022-06-03 15:31:07 +0200 |
| commit | 4e72c713f157ae9d5103a461c4c213b2aa6a84b9 (patch) | |
| tree | 50fca54ff6540490846d0aa65be5a3c7bfde0e17 /src/model | |
| parent | 16e0a655d0d01e3871aee81a0a9660102d6df74e (diff) | |
| download | garage-4e72c713f157ae9d5103a461c4c213b2aa6a84b9.tar.gz garage-4e72c713f157ae9d5103a461c4c213b2aa6a84b9.zip | |
Start LMDB adapter, with fixed semantics
Diffstat (limited to 'src/model')
| -rw-r--r-- | src/model/index_counter.rs | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/model/index_counter.rs b/src/model/index_counter.rs index 9e343e5f..d8c1229a 100644 --- a/src/model/index_counter.rs +++ b/src/model/index_counter.rs @@ -179,7 +179,7 @@ impl<T: CounterSchema> IndexCounter<T> { pub fn count(&self, pk: &T::P, sk: &T::S, counts: &[(&str, i64)]) -> Result<(), Error> { let tree_key = self.table.data.tree_key(pk, sk); - let new_entry = self.local_counter.db().transaction(|tx| { + let new_entry = self.local_counter.db().transaction(|mut tx| { let mut entry = match tx.get(&self.local_counter, &tree_key[..])? { Some(old_bytes) => rmp_serde::decode::from_slice::<LocalCounterEntry>(&old_bytes) .map_err(Error::RmpDecode) |