opensource/kubo
1
0
Fork 0
mirror of https://github.com/ipfs/kubo.git synced 2025-07-01 10:49:24 +08:00
Code Issues Projects Releases Wiki Activity

style(bitswap) rename

Browse Source
This commit is contained in:
Brian Tiger Chow
2014-12-23 07:01:19 -05:00
committed by Juan Batiz-Benet
parent fb75184c35
commit 4ab4da7e2b
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
exchange/bitswap/bitswap.go
View File

@ -202,7 +202,7 @@ func (bs *bitswap) sendWantlistToProviders(ctx context.Context, wantlist *wantli
message.AddEntry(e.Key, e.Priority) message.AddEntry(e.Key, e.Priority)
} }
ps := pset.New() set := pset.New()
// Get providers for all entries in wantlist (could take a while) // Get providers for all entries in wantlist (could take a while)
wg := sync.WaitGroup{} wg := sync.WaitGroup{}
@ -214,7 +214,7 @@ func (bs *bitswap) sendWantlistToProviders(ctx context.Context, wantlist *wantli
providers := bs.routing.FindProvidersAsync(child, k, maxProvidersPerRequest) providers := bs.routing.FindProvidersAsync(child, k, maxProvidersPerRequest)
for prov := range providers { for prov := range providers {
if ps.TryAdd(prov.ID) { //Do once per peer if set.TryAdd(prov.ID) { //Do once per peer
bs.send(ctx, prov.ID, message) bs.send(ctx, prov.ID, message)
} }
} }