refactor peerSet

b88f0394 · Jeromy · Juan Batiz-Benet · 211fa238 · b88f0394
Commit b88f0394 authored Dec 16, 2014 by Jeromy Committed by Juan Batiz-Benet Dec 17, 2014
Show whitespace changes
Inline Side-by-side

Showing with 1 addition and 1 deletion

bitswap.go bitswap.go +1 -1

No files found.
--- a/bitswap.go
+++ b/bitswap.go
@@ -222,7 +222,7 @@ func (bs *bitswap) sendWantlistToProviders(ctx context.Context, wantlist *wl.Wan
 			providers := bs.routing.FindProvidersAsync(child, k, maxProvidersPerRequest)
 			for prov := range providers {
-				if ps.AddIfSmallerThan(prov, -1) { //Do once per peer
+				if ps.TryAdd(prov) { //Do once per peer
 					bs.send(ctx, prov, message)
 				}
 			}