fluencelabs/rust-libp2p
1
0
Fork 0
mirror of https://github.com/fluencelabs/rust-libp2p synced 2025-06-30 02:01:35 +00:00
Code Issues Projects Releases Wiki Activity

fix closest lgos

Browse Source
This commit is contained in:
folex
2020-03-27 20:18:42 +03:00
parent 816ccac1ff
commit ce86462a05
1 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
protocols/kad/src/kbucket.rs
View File

@ -400,10 +400,11 @@ impl Iterator for ClosestBucketsIter {
Some(i) Some(i)
} }
ClosestBucketsIterState::ZoomIn(i) => { ClosestBucketsIterState::ZoomIn(i) => {
let old_i = i.0;
if let Some(i) = self.next_in(i) { if let Some(i) = self.next_in(i) {
println!( println!(
"ClosestBucketsIter: distance = {}; ZoomIn({}) -> ZoomIn({})", "ClosestBucketsIter: distance = {}; ZoomIn({}) -> ZoomIn({})",
self.distance.0, i.0, i.0 self.distance.0, old_i, i.0
); );
self.state = ClosestBucketsIterState::ZoomIn(i); self.state = ClosestBucketsIterState::ZoomIn(i);
Some(i) Some(i)
@ -418,16 +419,17 @@ impl Iterator for ClosestBucketsIter {
} }
} }
ClosestBucketsIterState::ZoomOut(i) => { ClosestBucketsIterState::ZoomOut(i) => {
let old_i = i.0;
if let Some(i) = self.next_out(i) { if let Some(i) = self.next_out(i) {
println!( println!(
"ClosestBucketsIter: distance = {}; ZoomOut({}) -> ZoomOut({})", "ClosestBucketsIter: distance = {}; ZoomOut({}) -> ZoomOut({})",
self.distance.0, i.0, i.0 self.distance.0, old_i, i.0
); );
self.state = ClosestBucketsIterState::ZoomOut(i); self.state = ClosestBucketsIterState::ZoomOut(i);
Some(i) Some(i)
} else { } else {
println!( println!(
"ClosestBucketsIter: distance = {}; ZoomOut({}) ->Done", "ClosestBucketsIter: distance = {}; ZoomOut({}) -> Done",
self.distance.0, i.0 self.distance.0, i.0
); );
self.state = ClosestBucketsIterState::Done; self.state = ClosestBucketsIterState::Done;