Quash 'repair listener error: Err(RecvTimeoutError(Timeout))' log spam

This commit is contained in:
Michael Vines 2020-02-12 08:45:44 -07:00
parent a8028fbb93
commit 1e0f2b2446
1 changed files with 6 additions and 5 deletions

View File

@ -4,7 +4,7 @@ use crate::{
cluster_info::{ClusterInfo, ClusterInfoError},
contact_info::ContactInfo,
packet::Packet,
result::Result,
result::{Error, Result},
};
use bincode::serialize;
use rand::{thread_rng, Rng};
@ -205,19 +205,20 @@ impl ServeRepair {
Builder::new()
.name("solana-repair-listen".to_string())
.spawn(move || loop {
let e = Self::run_listen(
let result = Self::run_listen(
&me,
&recycler,
blockstore.as_ref(),
&requests_receiver,
&response_sender,
);
match result {
Err(Error::RecvTimeoutError(_)) | Ok(_) => {}
Err(err) => info!("repair listener error: {:?}", err),
};
if exit.load(Ordering::Relaxed) {
return;
}
if e.is_err() {
info!("repair listener error: {:?}", e);
}
thread_mem_usage::datapoint("solana-repair-listen");
})
.unwrap()