diff options
| author | obscuren <geffobscura@gmail.com> | 2014-12-16 00:09:06 +0800 |
|---|---|---|
| committer | obscuren <geffobscura@gmail.com> | 2014-12-16 00:09:06 +0800 |
| commit | 455241debb6fa11053bd3a5429cdd9890bb607dc (patch) | |
| tree | 5805a5c16690b3c1f094dc68ee054ca149df96d0 /eth | |
| parent | db89c3e1a34459a0f65d7b86e696df4afc9518b6 (diff) | |
| download | dexon-455241debb6fa11053bd3a5429cdd9890bb607dc.tar dexon-455241debb6fa11053bd3a5429cdd9890bb607dc.tar.gz dexon-455241debb6fa11053bd3a5429cdd9890bb607dc.tar.bz2 dexon-455241debb6fa11053bd3a5429cdd9890bb607dc.tar.lz dexon-455241debb6fa11053bd3a5429cdd9890bb607dc.tar.xz dexon-455241debb6fa11053bd3a5429cdd9890bb607dc.tar.zst dexon-455241debb6fa11053bd3a5429cdd9890bb607dc.zip | |
Removed goroutine from "Run"
Diffstat (limited to 'eth')
| -rw-r--r-- | eth/protocol.go | 16 |
1 files changed, 8 insertions, 8 deletions
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 } |