From 625a9fd9326ac9b240dec520c156a03b1b7515b7 Mon Sep 17 00:00:00 2001 From: "mergify[bot]" <37929162+mergify[bot]@users.noreply.github.com> Date: Mon, 9 Dec 2019 01:03:35 -0800 Subject: [PATCH] Properly set parallelism (#7370) (#7372) automerge --- ledger/src/blocktree_db.rs | 7 ++----- 1 file changed, 2 insertions(+), 5 deletions(-) diff --git a/ledger/src/blocktree_db.rs b/ledger/src/blocktree_db.rs index 67bac239d1..a140f34bb3 100644 --- a/ledger/src/blocktree_db.rs +++ b/ledger/src/blocktree_db.rs @@ -13,8 +13,6 @@ use solana_client::rpc_request::RpcTransactionStatus; use solana_sdk::{clock::Slot, signature::Signature}; use std::{collections::HashMap, fs, marker::PhantomData, path::Path, sync::Arc}; -// A good value for this is the number of cores on the machine -const TOTAL_THREADS: i32 = 8; const MAX_WRITE_BUFFER_SIZE: u64 = 256 * 1024 * 1024; // 256MB // Column family for metadata about a leader slot @@ -727,8 +725,7 @@ fn get_db_options() -> Options { let mut options = Options::default(); options.create_if_missing(true); options.create_missing_column_families(true); - options.increase_parallelism(TOTAL_THREADS); - options.set_max_background_flushes(4); - options.set_max_background_compactions(4); + // A good value for this is the number of cores on the machine + options.increase_parallelism(sys_info::cpu_num().unwrap() as i32); options }