make wantlist updates to connected peers happen async, dramatically improves performance between connected nodes
Jeromy committed
Feb 26, 2015 at 10:12 UTC
9c66f65410afa87a44d4bd2a455dd246ab626760
1 file changed
+6
-4
exchange/bitswap/bitswap.go
+6
-4
@@ -369,10 +369,12 @@ func (bs *bitswap) wantNewBlocks(ctx context.Context, bkeys []u.Key) {
369
message.AddEntry(k, kMaxPriority-i)
370
}
371
for _, p := range bs.engine.Peers() {
372
- err := bs.send(ctx, p, message)
373
- if err != nil {
374
- log.Debugf("Error sending message: %s", err)
375
- }
372
+ go func(p peer.ID) {
373
+ err := bs.send(ctx, p, message)
374
+ if err != nil {
375
+ log.Debugf("Error sending message: %s", err)
376
+ }
377
+ }(p)
378
}
379
}
380