BlockStorage/repertory
1
0
Fork 0
Code Issues 7 Pull Requests Releases 6 Wiki Activity

refactor create rocksdb

Browse Source
This commit is contained in:
Scott E. Graves 2024-12-18 12:38:25 -06:00
parent bb983594d5
commit 9961cb700e
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
repertory/librepertory/src/db/impl/rdb_file_db.cpp
View File

@ -43,16 +43,16 @@ void rdb_file_db::create_or_open(bool clear) {
auto families = std::vector<rocksdb::ColumnFamilyDescriptor>(); auto families = std::vector<rocksdb::ColumnFamilyDescriptor>();
families.emplace_back(rocksdb::kDefaultColumnFamilyName, families.emplace_back(rocksdb::kDefaultColumnFamilyName,
rocksdb::ColumnFamilyOptions()); rocksdb::ColumnFamilyOptions());
families.emplace_back("directory", rocksdb::ColumnFamilyOptions());
families.emplace_back("file", rocksdb::ColumnFamilyOptions()); families.emplace_back("file", rocksdb::ColumnFamilyOptions());
families.emplace_back("source", rocksdb::ColumnFamilyOptions());
auto handles = std::vector<rocksdb::ColumnFamilyHandle *>(); auto handles = std::vector<rocksdb::ColumnFamilyHandle *>();
db_ = utils::create_rocksdb(cfg_, "file", families, handles, clear); db_ = utils::create_rocksdb(cfg_, "file", families, handles, clear);
std::size_t idx{}; std::size_t idx{};
source_family_ = handles.at(idx++);
directory_family_ = handles.at(idx++); directory_family_ = handles.at(idx++);
file_family_ = handles.at(idx++); file_family_ = handles.at(idx++);
source_family_ = handles.at(idx++);
} }
auto rdb_file_db::add_directory(const std::string &api_path, auto rdb_file_db::add_directory(const std::string &api_path,