SearchValue will only update k closest peers to have latest record

c7a8d0d2 · Adin Schmahmann · Steven Allen · 85f88e1e · c7a8d0d2
Commit c7a8d0d2 authored Jan 30, 2020 by Adin Schmahmann Committed by Steven Allen Apr 03, 2020
Hide whitespace changes
Inline Side-by-side

Showing with 4 additions and 1 deletion

routing.go routing.go +4 -1

No files found.
--- a/routing.go
+++ b/routing.go
@@ -191,7 +191,10 @@ func (dht *IpfsDHT) SearchValue(ctx context.Context, key string, opts ...routing

 			peers := q[0].globallyQueriedPeers.Peers()
 			peers = kb.SortClosestPeers(peers, kb.ConvertKey(key))
-			for _, p := range peers {
+			for i, p := range peers {
+				if i == dht.bucketSize {
+					break
+				}
 				if _, ok := peersWithBest[p]; !ok {
 					updatePeers = append(updatePeers, p)
 				}