gaspersic/solana
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Dial down gossip threadpool (#10540)

Browse Source
This commit is contained in:
sakridge
2020-06-13 22:48:32 -07:00
committed by GitHub
parent a528e966e6
commit f016ccdbb5
1 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
core/src/cluster_info.rs
View File

@ -1728,8 +1728,8 @@ impl ClusterInfo {
let now = timestamp(); let now = timestamp();
const INTERVAL_MS: u64 = 100; const INTERVAL_MS: u64 = 100;
// allow 50kBps per staked validator, epoch slots + votes ~= 1.5kB/slot ~= 4kB/s // allow 30kBps per staked validator, epoch slots + votes ~= 1.5kB/slot ~= 4kB/s
const BYTES_PER_INTERVAL: usize = 5000; const BYTES_PER_INTERVAL: usize = 3000;
const MAX_BUDGET_MULTIPLE: usize = 5; // allow budget build-up to 5x the interval default const MAX_BUDGET_MULTIPLE: usize = 5; // allow budget build-up to 5x the interval default
if now - w_outbound_budget.last_timestamp_ms > INTERVAL_MS { if now - w_outbound_budget.last_timestamp_ms > INTERVAL_MS {
@ -2255,7 +2255,8 @@ impl ClusterInfo {
.name("solana-listen".to_string()) .name("solana-listen".to_string())
.spawn(move || { .spawn(move || {
let thread_pool = rayon::ThreadPoolBuilder::new() let thread_pool = rayon::ThreadPoolBuilder::new()
.num_threads(get_thread_count()) .num_threads(get_thread_count() / 2)
.thread_name(|ix| format!("gos_work_{}", ix))
.build() .build()
.unwrap(); .unwrap();
let mut last_print = Instant::now(); let mut last_print = Instant::now();