From 09fca89ac55511c92b86733787cdf9d5f5154bcc Mon Sep 17 00:00:00 2001 From: strawberry Date: Fri, 10 May 2024 19:32:11 -0400 Subject: [PATCH] Revert "rocksdb: enable async_io if using io_uring feature" This reverts commit 6266e0ab5e7db05cb1f5aa4a72b9874ff5ab57e5. --- src/database/rocksdb/kvtree.rs | 9 --------- 1 file changed, 9 deletions(-) diff --git a/src/database/rocksdb/kvtree.rs b/src/database/rocksdb/kvtree.rs index a6026baa..4761624b 100644 --- a/src/database/rocksdb/kvtree.rs +++ b/src/database/rocksdb/kvtree.rs @@ -19,7 +19,6 @@ impl KvTree for RocksDbEngineTree<'_> { fn get(&self, key: &[u8]) -> Result>> { let mut readoptions = rust_rocksdb::ReadOptions::default(); readoptions.set_total_order_seek(true); - readoptions.set_async_io(cfg!(feature = "io_uring")); Ok(self.db.rocks.get_cf_opt(&self.cf(), key, &readoptions)?) } @@ -27,7 +26,6 @@ impl KvTree for RocksDbEngineTree<'_> { fn multi_get(&self, keys: &[&[u8]]) -> Result>>> { let mut readoptions = rust_rocksdb::ReadOptions::default(); readoptions.set_total_order_seek(true); - readoptions.set_async_io(cfg!(feature = "io_uring")); // Optimization can be `true` if key vector is pre-sorted **by the column // comparator**. @@ -115,7 +113,6 @@ impl KvTree for RocksDbEngineTree<'_> { fn iter<'a>(&'a self) -> Box, Vec)> + 'a> { let mut readoptions = rust_rocksdb::ReadOptions::default(); readoptions.set_total_order_seek(true); - readoptions.set_async_io(cfg!(feature = "io_uring")); Box::new( self.db @@ -129,7 +126,6 @@ impl KvTree for RocksDbEngineTree<'_> { fn iter_from<'a>(&'a self, from: &[u8], backwards: bool) -> Box, Vec)> + 'a> { let mut readoptions = rust_rocksdb::ReadOptions::default(); readoptions.set_total_order_seek(true); - readoptions.set_async_io(cfg!(feature = "io_uring")); Box::new( self.db @@ -154,8 +150,6 @@ impl KvTree for RocksDbEngineTree<'_> { fn increment(&self, key: &[u8]) -> Result> { let mut readoptions = rust_rocksdb::ReadOptions::default(); readoptions.set_total_order_seek(true); - readoptions.set_async_io(cfg!(feature = "io_uring")); - let writeoptions = rust_rocksdb::WriteOptions::default(); let old = self.db.rocks.get_cf_opt(&self.cf(), key, &readoptions)?; @@ -174,8 +168,6 @@ impl KvTree for RocksDbEngineTree<'_> { fn increment_batch(&self, iter: &mut dyn Iterator>) -> Result<()> { let mut readoptions = rust_rocksdb::ReadOptions::default(); readoptions.set_total_order_seek(true); - readoptions.set_async_io(cfg!(feature = "io_uring")); - let writeoptions = rust_rocksdb::WriteOptions::default(); let mut batch = WriteBatchWithTransaction::::default(); @@ -198,7 +190,6 @@ impl KvTree for RocksDbEngineTree<'_> { fn scan_prefix<'a>(&'a self, prefix: Vec) -> Box, Vec)> + 'a> { let mut readoptions = rust_rocksdb::ReadOptions::default(); readoptions.set_total_order_seek(true); - readoptions.set_async_io(cfg!(feature = "io_uring")); Box::new( self.db