From a0cad9d598bc4d1b6c8626bbcee8a5c1b56b700f Mon Sep 17 00:00:00 2001 From: kamilsa Date: Sun, 16 Mar 2025 18:18:32 +0500 Subject: [PATCH] Protect config column families by mutex --- core/storage/rocksdb/rocksdb.cpp | 20 +++++++++++++------- 1 file changed, 13 insertions(+), 7 deletions(-) diff --git a/core/storage/rocksdb/rocksdb.cpp b/core/storage/rocksdb/rocksdb.cpp index 259d5c36b9..8fc00ef945 100644 --- a/core/storage/rocksdb/rocksdb.cpp +++ b/core/storage/rocksdb/rocksdb.cpp @@ -129,13 +129,19 @@ namespace kagome::storage { std::vector column_family_descriptors; std::vector ttls; - configureColumnFamilies(column_family_descriptors, - ttls, - all_families, - column_ttl, - trie_space_cache_size, - other_spaces_cache_size, - log); + + { + static std::mutex config_mutex; + std::lock_guard lock(config_mutex); + + configureColumnFamilies(column_family_descriptors, + ttls, + all_families, + column_ttl, + trie_space_cache_size, + other_spaces_cache_size, + log); + } options.create_missing_column_families = true; auto rocks_db = std::shared_ptr(new RocksDb);