rafaelcaricio/relay
1
0
Fork 0
forked from mirrors/relay
Code Pull requests Activity

Add logging around parallelism

Browse source
This commit is contained in:
asonix 2023-07-26 22:51:07 -05:00
parent 5d526c60fe
commit 11d81683e3
1 changed files with 3 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
src/requests.rs
View file

@ -464,11 +464,14 @@ impl Spawner {
pub(crate) fn build() -> std::io::Result<Self> { pub(crate) fn build() -> std::io::Result<Self> {
let threads = std::thread::available_parallelism() let threads = std::thread::available_parallelism()
.map(usize::from) .map(usize::from)
.map_err(|e| tracing::warn!("Failed to get parallelism, {e}"))
.unwrap_or(1); .unwrap_or(1);
let (sender, receiver) = flume::bounded(8); let (sender, receiver) = flume::bounded(8);
let (shutdown, shutdown_rx) = flume::bounded(threads); let (shutdown, shutdown_rx) = flume::bounded(threads);
tracing::warn!("Launching {threads} signature threads");
let threads = (0..threads) let threads = (0..threads)
.map(|i| { .map(|i| {
let receiver = receiver.clone(); let receiver = receiver.clone();