From ab565474ca8badc6a77f57d0f69ae2bfea6ecf2a Mon Sep 17 00:00:00 2001
From: Brian Tiger Chow <brian.holderchow@gmail.com>
Date: Tue, 2 Dec 2014 21:44:16 -0800
Subject: [PATCH] rm unnecessary concurrency

License: MIT
Signed-off-by: Brian Tiger Chow <brian@perfmode.com>
---
 exchange/bitswap/bitswap.go | 10 ++++------
 1 file changed, 4 insertions(+), 6 deletions(-)

diff --git a/exchange/bitswap/bitswap.go b/exchange/bitswap/bitswap.go
index 4c8b1c160..8dbf05314 100644
--- a/exchange/bitswap/bitswap.go
+++ b/exchange/bitswap/bitswap.go
@@ -284,13 +284,11 @@ func (bs *bitswap) ReceiveMessage(ctx context.Context, p peer.Peer, incoming bsm
 	// and number of bytes transfered.
 	bs.strategy.MessageReceived(p, incoming)
 
-	go func() {
-		for _, block := range incoming.Blocks() {
-			if err := bs.HasBlock(ctx, block); err != nil {
-				log.Error(err)
-			}
+	for _, block := range incoming.Blocks() {
+		if err := bs.HasBlock(ctx, block); err != nil {
+			log.Error(err)
 		}
-	}()
+	}
 
 	for _, key := range incoming.Wantlist() {
 		if bs.strategy.ShouldSendBlockToPeer(key, p) {