From e9b7103c261cfb1f409921dacfc436c5d30dbe49 Mon Sep 17 00:00:00 2001 From: Igor Katson Date: Tue, 28 Nov 2023 10:55:43 +0000 Subject: [PATCH] silence DHT timeout error --- crates/dht/src/dht.rs | 11 +++++++++-- 1 file changed, 9 insertions(+), 2 deletions(-) diff --git a/crates/dht/src/dht.rs b/crates/dht/src/dht.rs index f15df9d..58c3e01 100644 --- a/crates/dht/src/dht.rs +++ b/crates/dht/src/dht.rs @@ -95,7 +95,15 @@ impl DhtState { let this = self.clone(); spawn( error_span!(parent: None, "dht_request", addr=addr.to_string(), request=format!("{:?}", request)), - async move { this.send_request_and_handle_response(request, addr).await }, + async move { + match this.send_request_and_handle_response(request, addr).await { + Ok(_) => {} + Err(e) => { + debug!("error: {:?}", e); + } + }; + Ok(()) + }, ); } @@ -134,7 +142,6 @@ impl DhtState { } Err(e) => { self.inflight.remove(&key); - debug!("error: {:?}", e); anyhow::bail!("timeout") } }