fluencelabs/rust-libp2p
1
0
Fork 0
mirror of https://github.com/fluencelabs/rust-libp2p synced 2025-04-25 03:02:12 +00:00
Code Issues Projects Releases Wiki Activity

add debug on query timeout

Browse Source
This commit is contained in:
folex 2020-12-10 14:32:02 +03:00
parent 8ea09b93ef
commit a23d8060c5
2 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
protocols/kad/src/query.rs
View File

@ -212,6 +212,7 @@ impl<TInner> QueryPool<TInner> {
} }
PeersIterState::Waiting(None) | PeersIterState::WaitingAtCapacity => { PeersIterState::Waiting(None) | PeersIterState::WaitingAtCapacity => {
let elapsed = now - query.stats.start.unwrap_or(now); let elapsed = now - query.stats.start.unwrap_or(now);
log::debug!("Query {} timed out after {} of {} has passed", elapsed, self.config.timeout);
if elapsed >= self.config.timeout { if elapsed >= self.config.timeout {
timeout = Some(query_id); timeout = Some(query_id);
break break

5
protocols/kad/src/query/peers/closest.rs
View File

@ -335,9 +335,10 @@ impl ClosestPeersIter {
// closest peers, the iterator is done. // closest peers, the iterator is done.
if *cnt >= self.config.num_results.get() { if *cnt >= self.config.num_results.get() {
trace!( trace!(
"ClosestPeerIter: target = {}; {} peers responded, finished.", "ClosestPeerIter: target = {}; {}/ХЪ peers responded, finished.",
bs58::encode(&self.target).into_string(), bs58::encode(&self.target).into_string(),
*cnt *cnt,
self.config.num_results.get()
); );
self.state = State::Finished; self.state = State::Finished;
return PeersIterState::Finished return PeersIterState::Finished