From 151388692a0ead3a90b49bca6ed9baefb7752b89 Mon Sep 17 00:00:00 2001 From: David Schwartz Date: Tue, 1 Apr 2014 09:28:40 -0700 Subject: [PATCH] Add bg_threads and high_threads RocksDB tunables --- .../nodestore/backend/RocksDBFactory.cpp | 13 ++++++++++++- 1 file changed, 12 insertions(+), 1 deletion(-) diff --git a/src/ripple_core/nodestore/backend/RocksDBFactory.cpp b/src/ripple_core/nodestore/backend/RocksDBFactory.cpp index 0dd1d8b69..e9b22a25c 100644 --- a/src/ripple_core/nodestore/backend/RocksDBFactory.cpp +++ b/src/ripple_core/nodestore/backend/RocksDBFactory.cpp @@ -97,6 +97,7 @@ public: rocksdb::Options options; options.create_if_missing = true; + options.env = env; if (keyValues["cache_mb"].isEmpty()) { @@ -134,7 +135,17 @@ public: options.target_file_size_multiplier = keyValues["file_size_mult"].getIntValue(); } - options.env = env; + if (! keyValues["bg_threads"].isEmpty()) + { + options.env->SetBackgroundThreads + (keyValues["bg_threads"].getIntValue(), rocksdb::Env::LOW); + } + + if (! keyValues["high_threads"].isEmpty()) + { + options.env->SetBackgroundThreads + (keyValues["high_threads"].getIntValue(), rocksdb::Env::HIGH); + } rocksdb::DB* db = nullptr; rocksdb::Status status = rocksdb::DB::Open (options, m_name, &db);