diff --git a/eth/protocol.go b/eth/protocol.go
index 8cbf6d309..3b6f95d44 100644
--- a/eth/protocol.go
+++ b/eth/protocol.go
@@ -2,6 +2,7 @@ package eth
 
 import (
 	"bytes"
+	"fmt"
 	"math"
 	"math/big"
 
@@ -98,15 +99,14 @@ func runEthProtocol(txPool txPool, chainManager chainManager, blockPool blockPoo
 	}
 	err = self.handleStatus()
 	if err == nil {
-		go func() {
-			for {
-				err = self.handle()
-				if err != nil {
-					self.blockPool.RemovePeer(self.id)
-					break
-				}
+		for {
+			err = self.handle()
+			if err != nil {
+				fmt.Println(err)
+				self.blockPool.RemovePeer(self.id)
+				break
 			}
-		}()
+		}
 	}
 	return
 }