leyoda/rqbit
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

silence DHT timeout error

Browse source
This commit is contained in:
Igor Katson 2023-11-28 10:55:43 +00:00
parent 336bf751e3
commit e9b7103c26
No known key found for this signature in database
GPG key ID: B4EC22B66D61A3F5
1 changed files with 9 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

11
crates/dht/src/dht.rs
View file

@ -95,7 +95,15 @@ impl DhtState {
let this = self.clone(); let this = self.clone();
spawn( spawn(
error_span!(parent: None, "dht_request", addr=addr.to_string(), request=format!("{:?}", request)), 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) => { Err(e) => {
self.inflight.remove(&key); self.inflight.remove(&key);
debug!("error: {:?}", e);
anyhow::bail!("timeout") anyhow::bail!("timeout")
} }
} }