diff options
| author | metamuffin <metamuffin@disroot.org> | 2026-01-15 02:57:31 +0100 |
|---|---|---|
| committer | metamuffin <metamuffin@disroot.org> | 2026-01-15 02:57:31 +0100 |
| commit | c836b650eaf4ba33b1cfd2b475971b3ccc9f69b7 (patch) | |
| tree | 2ea722aff33252ff2e3662faee63cabb223339c3 /database/src/backends/rocksdb.rs | |
| parent | 8c0ee6d17fe0dbd7748e7b60ff01a0e8f25faa51 (diff) | |
| download | jellything-c836b650eaf4ba33b1cfd2b475971b3ccc9f69b7.tar jellything-c836b650eaf4ba33b1cfd2b475971b3ccc9f69b7.tar.bz2 jellything-c836b650eaf4ba33b1cfd2b475971b3ccc9f69b7.tar.zst | |
new update_node_init
Diffstat (limited to 'database/src/backends/rocksdb.rs')
| -rw-r--r-- | database/src/backends/rocksdb.rs | 12 |
1 files changed, 9 insertions, 3 deletions
diff --git a/database/src/backends/rocksdb.rs b/database/src/backends/rocksdb.rs index 1475dac..056af9e 100644 --- a/database/src/backends/rocksdb.rs +++ b/database/src/backends/rocksdb.rs @@ -4,7 +4,7 @@ Copyright (C) 2026 metamuffin <metamuffin.org> */ -use crate::backends::{Database, ReadTransaction, WriteTransaction, WriteTxnFunction}; +use crate::backends::{Database, ReadTransaction, WriteTransaction}; use anyhow::Result; use rocksdb::{Direction, ErrorKind, IteratorMode, OptimisticTransactionDB}; use std::path::Path; @@ -14,7 +14,10 @@ pub fn new(path: &Path) -> Result<OptimisticTransactionDB> { } impl Database for OptimisticTransactionDB { - fn write_transaction(&self, f: &mut WriteTxnFunction) -> Result<()> { + fn write_transaction( + &self, + f: &mut dyn FnMut(&mut dyn WriteTransaction) -> Result<()>, + ) -> Result<()> { loop { let mut txn = self.transaction(); f(&mut txn)?; @@ -25,7 +28,10 @@ impl Database for OptimisticTransactionDB { } } } - fn read_transaction(&self, f: &mut super::ReadTxnFunction) -> Result<()> { + fn read_transaction( + &self, + f: &mut dyn FnMut(&dyn ReadTransaction) -> Result<()>, + ) -> Result<()> { loop { let txn = self.transaction(); f(&txn)?; |