diff options
| author | Alex <alex@adnab.me> | 2023-09-21 14:03:35 +0000 |
|---|---|---|
| committer | Alex <alex@adnab.me> | 2023-09-21 14:03:35 +0000 |
| commit | 1d986bd889a5f5fe1bdc75e7d4b34acc2cfbe09f (patch) | |
| tree | 5b5f8d66637c4a10866b00e07a45081c93cf75cf /src/table/queue.rs | |
| parent | fd7d8fec59c617b40e480ff855894cf35fdcfb40 (diff) | |
| parent | 0635250b2bdcce4156704128de154f9052d34e9e (diff) | |
| download | garage-1d986bd889a5f5fe1bdc75e7d4b34acc2cfbe09f.tar.gz garage-1d986bd889a5f5fe1bdc75e7d4b34acc2cfbe09f.zip | |
Merge pull request 'Refactor db transactions and add on_commit for table.queue_insert' (#637) from k2v-indices-lmdb into next
Reviewed-on: https://git.deuxfleurs.fr/Deuxfleurs/garage/pulls/637
Diffstat (limited to 'src/table/queue.rs')
| -rw-r--r-- | src/table/queue.rs | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/table/queue.rs b/src/table/queue.rs index 096ac8b4..ffe0a4a7 100644 --- a/src/table/queue.rs +++ b/src/table/queue.rs @@ -53,7 +53,7 @@ impl<F: TableSchema, R: TableReplication> Worker for InsertQueueWorker<F, R> { self.0.insert_many(values).await?; - self.0.data.insert_queue.db().transaction(|mut tx| { + self.0.data.insert_queue.db().transaction(|tx| { for (k, v) in kv_pairs.iter() { if let Some(v2) = tx.get(&self.0.data.insert_queue, k)? { if &v2 == v { |