backups/grapevine
1
0
Fork 0
mirror of https://gitlab.computer.surgery/matrix/grapevine.git synced 2025-12-17 07:41:23 +01:00
Code Issues Projects Releases Packages Wiki Activity Actions

store old_cfs as a HashSet

Browse source 
This list can't have duplicates.
This commit is contained in:
Charles Hall 2024-05-21 17:25:23 -07:00
parent a60a9551e1
commit 53fbd3fc41
No known key found for this signature in database
GPG key ID: 7B8E0645816E07CF
1 changed files with 3 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

4
src/database/abstraction/rocksdb.rs
View file

@ -1,4 +1,5 @@
use std::{ use std::{
collections::HashSet,
future::Future, future::Future,
pin::Pin, pin::Pin,
sync::{Arc, RwLock}, sync::{Arc, RwLock},
@ -20,7 +21,7 @@ pub(crate) struct Engine {
rocks: DBWithThreadMode<MultiThreaded>, rocks: DBWithThreadMode<MultiThreaded>,
max_open_files: i32, max_open_files: i32,
cache: Cache, cache: Cache,
old_cfs: Vec<String>, old_cfs: HashSet<String>,
} }
pub(crate) struct RocksDbEngineTree<'a> { pub(crate) struct RocksDbEngineTree<'a> {
@ -84,6 +85,7 @@ impl KeyValueDatabaseEngine for Arc<Engine> {
&db_opts, &db_opts,
&config.database_path, &config.database_path,
) )
.map(|x| x.into_iter().collect::<HashSet<_>>())
.unwrap_or_default(); .unwrap_or_default();
let db = DBWithThreadMode::<MultiThreaded>::open_cf_descriptors( let db = DBWithThreadMode::<MultiThreaded>::open_cf_descriptors(