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

rename threads: 15 char limit (#16625)

Browse Source
This commit is contained in:
Jeff Washington (jwash) 2021-04-19 12:16:58 -05:00 committed by GitHub
parent 9dfcb921cf
commit 4aa753ff01
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
core/src/accounts_hash_verifier.rs
View File

@ -43,7 +43,7 @@ impl AccountsHashVerifier {
let exit = exit.clone(); let exit = exit.clone();
let cluster_info = cluster_info.clone(); let cluster_info = cluster_info.clone();
let t_accounts_hash_verifier = Builder::new() let t_accounts_hash_verifier = Builder::new()
.name("solana-accounts-hash".to_string()) .name("solana-hash-accounts".to_string())
.spawn(move || { .spawn(move || {
let mut hashes = vec![]; let mut hashes = vec![];
let mut thread_pool_storage = None; let mut thread_pool_storage = None;

2
runtime/src/accounts_background_service.rs
View File

@ -295,7 +295,7 @@ impl AccountsBackgroundService {
let mut total_remove_slots_time = 0; let mut total_remove_slots_time = 0;
let mut last_expiration_check_time = Instant::now(); let mut last_expiration_check_time = Instant::now();
let t_background = Builder::new() let t_background = Builder::new()
.name("solana-accounts-background".to_string()) .name("solana-bg-accounts".to_string())
.spawn(move || loop { .spawn(move || loop {
if exit.load(Ordering::Relaxed) { if exit.load(Ordering::Relaxed) {
break; break;

6
runtime/src/accounts_db.rs
View File

@ -1116,7 +1116,7 @@ pub fn make_min_priority_thread_pool() -> ThreadPool {
// Use lower thread count to reduce priority. // Use lower thread count to reduce priority.
let num_threads = std::cmp::max(2, num_cpus::get() / 4); let num_threads = std::cmp::max(2, num_cpus::get() / 4);
rayon::ThreadPoolBuilder::new() rayon::ThreadPoolBuilder::new()
.thread_name(|i| format!("solana-accounts-cleanup-{}", i)) .thread_name(|i| format!("solana-cleanup-accounts-{}", i))
.num_threads(num_threads) .num_threads(num_threads)
.build() .build()
.unwrap() .unwrap()
@ -1162,7 +1162,7 @@ impl Default for AccountsDb {
file_size: DEFAULT_FILE_SIZE, file_size: DEFAULT_FILE_SIZE,
thread_pool: rayon::ThreadPoolBuilder::new() thread_pool: rayon::ThreadPoolBuilder::new()
.num_threads(num_threads) .num_threads(num_threads)
.thread_name(|i| format!("solana-accounts-db-{}", i)) .thread_name(|i| format!("solana-db-accounts-{}", i))
.build() .build()
.unwrap(), .unwrap(),
thread_pool_clean: make_min_priority_thread_pool(), thread_pool_clean: make_min_priority_thread_pool(),
@ -1407,7 +1407,7 @@ impl AccountsDb {
fn start_background_hasher(&mut self) { fn start_background_hasher(&mut self) {
let (sender, receiver) = unbounded(); let (sender, receiver) = unbounded();
Builder::new() Builder::new()
.name("solana-accounts-db-store-hasher".to_string()) .name("solana-db-store-hasher-accounts".to_string())
.spawn(move || { .spawn(move || {
Self::background_hasher(receiver); Self::background_hasher(receiver);
}) })