chore: Use `i` over `ix` variable name when naming worker threads (#30206)
This commit is contained in:
parent
1ad69cfc38
commit
d3dab24bbe
|
@ -100,7 +100,7 @@ const MAX_REPAIR_RETRY_LOOP_ATTEMPTS: usize = 10;
|
||||||
lazy_static! {
|
lazy_static! {
|
||||||
static ref PAR_THREAD_POOL: ThreadPool = rayon::ThreadPoolBuilder::new()
|
static ref PAR_THREAD_POOL: ThreadPool = rayon::ThreadPoolBuilder::new()
|
||||||
.num_threads(MAX_CONCURRENT_FORKS_TO_REPLAY)
|
.num_threads(MAX_CONCURRENT_FORKS_TO_REPLAY)
|
||||||
.thread_name(|ix| format!("solReplay{ix:02}"))
|
.thread_name(|i| format!("solReplay{i:02}"))
|
||||||
.build()
|
.build()
|
||||||
.unwrap();
|
.unwrap();
|
||||||
}
|
}
|
||||||
|
|
|
@ -443,7 +443,7 @@ impl Validator {
|
||||||
}
|
}
|
||||||
|
|
||||||
if rayon::ThreadPoolBuilder::new()
|
if rayon::ThreadPoolBuilder::new()
|
||||||
.thread_name(|ix| format!("solRayonGlob{ix:02}"))
|
.thread_name(|i| format!("solRayonGlob{i:02}"))
|
||||||
.build_global()
|
.build_global()
|
||||||
.is_err()
|
.is_err()
|
||||||
{
|
{
|
||||||
|
|
|
@ -47,7 +47,7 @@ use {
|
||||||
lazy_static! {
|
lazy_static! {
|
||||||
static ref PAR_THREAD_POOL: ThreadPool = rayon::ThreadPoolBuilder::new()
|
static ref PAR_THREAD_POOL: ThreadPool = rayon::ThreadPoolBuilder::new()
|
||||||
.num_threads(get_max_thread_count())
|
.num_threads(get_max_thread_count())
|
||||||
.thread_name(|ix| format!("solEntry{ix:02}"))
|
.thread_name(|i| format!("solEntry{i:02}"))
|
||||||
.build()
|
.build()
|
||||||
.unwrap();
|
.unwrap();
|
||||||
}
|
}
|
||||||
|
|
|
@ -92,12 +92,12 @@ pub use {
|
||||||
lazy_static! {
|
lazy_static! {
|
||||||
static ref PAR_THREAD_POOL: ThreadPool = rayon::ThreadPoolBuilder::new()
|
static ref PAR_THREAD_POOL: ThreadPool = rayon::ThreadPoolBuilder::new()
|
||||||
.num_threads(get_max_thread_count())
|
.num_threads(get_max_thread_count())
|
||||||
.thread_name(|ix| format!("solBstore{ix:02}"))
|
.thread_name(|i| format!("solBstore{i:02}"))
|
||||||
.build()
|
.build()
|
||||||
.unwrap();
|
.unwrap();
|
||||||
static ref PAR_THREAD_POOL_ALL_CPUS: ThreadPool = rayon::ThreadPoolBuilder::new()
|
static ref PAR_THREAD_POOL_ALL_CPUS: ThreadPool = rayon::ThreadPoolBuilder::new()
|
||||||
.num_threads(num_cpus::get())
|
.num_threads(num_cpus::get())
|
||||||
.thread_name(|ix| format!("solBstoreAll{ix:02}"))
|
.thread_name(|i| format!("solBstoreAll{i:02}"))
|
||||||
.build()
|
.build()
|
||||||
.unwrap();
|
.unwrap();
|
||||||
}
|
}
|
||||||
|
|
|
@ -79,7 +79,7 @@ struct ReplayEntry {
|
||||||
lazy_static! {
|
lazy_static! {
|
||||||
static ref PAR_THREAD_POOL: ThreadPool = rayon::ThreadPoolBuilder::new()
|
static ref PAR_THREAD_POOL: ThreadPool = rayon::ThreadPoolBuilder::new()
|
||||||
.num_threads(get_max_thread_count())
|
.num_threads(get_max_thread_count())
|
||||||
.thread_name(|ix| format!("solBstoreProc{ix:02}"))
|
.thread_name(|i| format!("solBstoreProc{i:02}"))
|
||||||
.build()
|
.build()
|
||||||
.unwrap();
|
.unwrap();
|
||||||
}
|
}
|
||||||
|
|
|
@ -24,7 +24,7 @@ use {
|
||||||
lazy_static! {
|
lazy_static! {
|
||||||
static ref PAR_THREAD_POOL: ThreadPool = rayon::ThreadPoolBuilder::new()
|
static ref PAR_THREAD_POOL: ThreadPool = rayon::ThreadPoolBuilder::new()
|
||||||
.num_threads(get_thread_count())
|
.num_threads(get_thread_count())
|
||||||
.thread_name(|ix| format!("solShredder{ix:02}"))
|
.thread_name(|i| format!("solShredder{i:02}"))
|
||||||
.build()
|
.build()
|
||||||
.unwrap();
|
.unwrap();
|
||||||
}
|
}
|
||||||
|
|
|
@ -26,7 +26,7 @@ const SIGN_SHRED_GPU_MIN: usize = 256;
|
||||||
lazy_static! {
|
lazy_static! {
|
||||||
static ref SIGVERIFY_THREAD_POOL: ThreadPool = rayon::ThreadPoolBuilder::new()
|
static ref SIGVERIFY_THREAD_POOL: ThreadPool = rayon::ThreadPoolBuilder::new()
|
||||||
.num_threads(get_thread_count())
|
.num_threads(get_thread_count())
|
||||||
.thread_name(|ix| format!("solSvrfyShred{ix:02}"))
|
.thread_name(|i| format!("solSvrfyShred{i:02}"))
|
||||||
.build()
|
.build()
|
||||||
.unwrap();
|
.unwrap();
|
||||||
}
|
}
|
||||||
|
|
|
@ -36,7 +36,7 @@ pub const VERIFY_MIN_PACKETS_PER_THREAD: usize = 128;
|
||||||
lazy_static! {
|
lazy_static! {
|
||||||
static ref PAR_THREAD_POOL: ThreadPool = rayon::ThreadPoolBuilder::new()
|
static ref PAR_THREAD_POOL: ThreadPool = rayon::ThreadPoolBuilder::new()
|
||||||
.num_threads(get_thread_count())
|
.num_threads(get_thread_count())
|
||||||
.thread_name(|ix| format!("solSigVerify{ix:02}"))
|
.thread_name(|i| format!("solSigVerify{i:02}"))
|
||||||
.build()
|
.build()
|
||||||
.unwrap();
|
.unwrap();
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue