summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorTimo Kösters <timo@koesters.xyz>2023-05-21 11:51:36 +0200
committerTimo Kösters <timo@koesters.xyz>2023-05-21 13:41:51 +0200
commit49b5af6d454f27f543ca080a605ab56bbeeeac37 (patch)
treef4c7a8f59aa946f500fd33fdcc7404b2dcb8eb1b /src
parent1f1444da8c41aab6b0014987cac24c8f63a63ba1 (diff)
downloadconduit-49b5af6d454f27f543ca080a605ab56bbeeeac37.zip
chore: bump rocksdb
Diffstat (limited to 'src')
-rw-r--r--src/database/abstraction/rocksdb.rs8
1 files changed, 4 insertions, 4 deletions
diff --git a/src/database/abstraction/rocksdb.rs b/src/database/abstraction/rocksdb.rs
index 34d91d2..3e64e8b 100644
--- a/src/database/abstraction/rocksdb.rs
+++ b/src/database/abstraction/rocksdb.rs
@@ -54,7 +54,7 @@ fn db_options(max_open_files: i32, rocksdb_cache: &rocksdb::Cache) -> rocksdb::O
impl KeyValueDatabaseEngine for Arc<Engine> {
fn open(config: &Config) -> Result<Self> {
let cache_capacity_bytes = (config.db_cache_capacity_mb * 1024.0 * 1024.0) as usize;
- let rocksdb_cache = rocksdb::Cache::new_lru_cache(cache_capacity_bytes).unwrap();
+ let rocksdb_cache = rocksdb::Cache::new_lru_cache(cache_capacity_bytes);
let db_opts = db_options(config.rocksdb_max_open_files, &rocksdb_cache);
@@ -161,7 +161,7 @@ impl KvTree for RocksDbEngineTree<'_> {
self.db
.rocks
.iterator_cf(&self.cf(), rocksdb::IteratorMode::Start)
- //.map(|r| r.unwrap())
+ .map(|r| r.unwrap())
.map(|(k, v)| (Vec::from(k), Vec::from(v))),
)
}
@@ -185,7 +185,7 @@ impl KvTree for RocksDbEngineTree<'_> {
},
),
)
- //.map(|r| r.unwrap())
+ .map(|r| r.unwrap())
.map(|(k, v)| (Vec::from(k), Vec::from(v))),
)
}
@@ -226,7 +226,7 @@ impl KvTree for RocksDbEngineTree<'_> {
&self.cf(),
rocksdb::IteratorMode::From(&prefix, rocksdb::Direction::Forward),
)
- //.map(|r| r.unwrap())
+ .map(|r| r.unwrap())
.map(|(k, v)| (Vec::from(k), Vec::from(v)))
.take_while(move |(k, _)| k.starts_with(&prefix)),
)