Removed goroutine from "Run"

This commit is contained in:
obscuren 2014-12-15 17:09:06 +01:00
parent db89c3e1a3
commit 455241debb
1 changed files with 8 additions and 8 deletions

View File

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