From 132d012842a24f7e849876ced22d251d42a1e0af Mon Sep 17 00:00:00 2001 From: "mergify[bot]" <37929162+mergify[bot]@users.noreply.github.com> Date: Wed, 12 Feb 2020 10:29:26 -0800 Subject: [PATCH] Quash 'repair listener error: Err(RecvTimeoutError(Timeout))' log spam (#8238) automerge --- core/src/serve_repair.rs | 11 ++++++----- 1 file changed, 6 insertions(+), 5 deletions(-) diff --git a/core/src/serve_repair.rs b/core/src/serve_repair.rs index 0fee536a2d..535ab554ff 100644 --- a/core/src/serve_repair.rs +++ b/core/src/serve_repair.rs @@ -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()