Skip to content

M
mybee
Commit 5afd52eb authored by istae's avatar istae Committed by GitHub
Browse files
Options

fix: closetpeer skip list (#2374)

parent 1c34e9c9
Show whitespace changes
Inline Side-by-side
Showing with 4 additions and 3 deletions
pkg/topology/kademlia/kademlia.go
View file @ 5afd52eb
...@@ -1023,9 +1023,6 @@ func (k *Kad) ClosestPeer(addr swarm.Address, includeSelf bool, skipPeers ...swa ...@@ -1023,9 +1023,6 @@ func (k *Kad) ClosestPeer(addr swarm.Address, includeSelf bool, skipPeers ...swa
} }
err := k.connectedPeers.EachBinRev(func(peer swarm.Address, po uint8) (bool, bool, error) { err := k.connectedPeers.EachBinRev(func(peer swarm.Address, po uint8) (bool, bool, error) {
if closest.IsZero() {
closest = peer
}
for _, a := range skipPeers { for _, a := range skipPeers {
if a.Equal(peer) { if a.Equal(peer) {
...@@ -1033,6 +1030,10 @@ func (k *Kad) ClosestPeer(addr swarm.Address, includeSelf bool, skipPeers ...swa ...@@ -1033,6 +1030,10 @@ func (k *Kad) ClosestPeer(addr swarm.Address, includeSelf bool, skipPeers ...swa
} }
} }
if closest.IsZero() {
closest = peer
}
// kludge: hotfix for topology peer inconsistencies bug // kludge: hotfix for topology peer inconsistencies bug
if !isIn(peer, peers) { if !isIn(peer, peers) {
a := swarm.NewAddress(peer.Bytes()) a := swarm.NewAddress(peer.Bytes())
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment