From 53fbd3fc417e4504cf2220f4fb88ca06abcfc5f8 Mon Sep 17 00:00:00 2001 From: Charles Hall Date: Tue, 21 May 2024 17:25:23 -0700 Subject: [PATCH] store old_cfs as a HashSet This list can't have duplicates. --- src/database/abstraction/rocksdb.rs | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/src/database/abstraction/rocksdb.rs b/src/database/abstraction/rocksdb.rs index f73a4d0f..da797d65 100644 --- a/src/database/abstraction/rocksdb.rs +++ b/src/database/abstraction/rocksdb.rs @@ -1,4 +1,5 @@ use std::{ + collections::HashSet, future::Future, pin::Pin, sync::{Arc, RwLock}, @@ -20,7 +21,7 @@ pub(crate) struct Engine { rocks: DBWithThreadMode, max_open_files: i32, cache: Cache, - old_cfs: Vec, + old_cfs: HashSet, } pub(crate) struct RocksDbEngineTree<'a> { @@ -84,6 +85,7 @@ impl KeyValueDatabaseEngine for Arc { &db_opts, &config.database_path, ) + .map(|x| x.into_iter().collect::>()) .unwrap_or_default(); let db = DBWithThreadMode::::open_cf_descriptors(