rm unnecessary concurrency
License: MIT Signed-off-by: Brian Tiger Chow <brian@perfmode.com>
Brian Tiger Chow committed
Dec 2, 2014 at 21:44 UTC
ab565474ca8badc6a77f57d0f69ae2bfea6ecf2a
1 file changed
+4
-6
exchange/bitswap/bitswap.go
+4
-6
@@ -284,13 +284,11 @@ func (bs *bitswap) ReceiveMessage(ctx context.Context, p peer.Peer, incoming bsm
284
// and number of bytes transfered.
285
bs.strategy.MessageReceived(p, incoming)
286
287
- go func() {
288
- for _, block := range incoming.Blocks() {
289
- if err := bs.HasBlock(ctx, block); err != nil {
290
- log.Error(err)
291
- }
287
+ for _, block := range incoming.Blocks() {
288
+ if err := bs.HasBlock(ctx, block); err != nil {
289
+ log.Error(err)
290
}
293
- }()
291
+ }
292
293
for _, key := range incoming.Wantlist() {
294
if bs.strategy.ShouldSendBlockToPeer(key, p) {