Merge branch 'hotfix/0.3.1'
This commit is contained in:
commit
ceada15290
|
@ -295,7 +295,7 @@ func (s *Ethereum) Stop() {
|
||||||
s.TxPool.Stop()
|
s.TxPool.Stop()
|
||||||
s.BlockManager.Stop()
|
s.BlockManager.Stop()
|
||||||
|
|
||||||
s.shutdownChan <- true
|
close(s.shutdownChan)
|
||||||
}
|
}
|
||||||
|
|
||||||
// This function will wait for a shutdown and resumes main thread execution
|
// This function will wait for a shutdown and resumes main thread execution
|
||||||
|
|
|
@ -46,7 +46,7 @@ func ReadConfig(base string) *config {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
Config = &config{ExecPath: path, Debug: true, Ver: "0.3.0"}
|
Config = &config{ExecPath: path, Debug: true, Ver: "0.3.1"}
|
||||||
Config.Log = NewLogger(LogFile|LogStd, LogLevelDebug)
|
Config.Log = NewLogger(LogFile|LogStd, LogLevelDebug)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
5
peer.go
5
peer.go
|
@ -511,9 +511,8 @@ func (p *Peer) handleHandshake(msg *ethwire.Msg) {
|
||||||
p.port = uint16(c.Get(4).Uint())
|
p.port = uint16(c.Get(4).Uint())
|
||||||
|
|
||||||
// Self connect detection
|
// Self connect detection
|
||||||
data, _ := ethutil.Config.Db.Get([]byte("KeyRing"))
|
key := ethutil.Config.Db.GetKeys()[0]
|
||||||
pubkey := ethutil.NewValueFromBytes(data).Get(2).Bytes()
|
if bytes.Compare(key.PublicKey, p.pubkey) == 0 {
|
||||||
if bytes.Compare(pubkey, p.pubkey) == 0 {
|
|
||||||
p.Stop()
|
p.Stop()
|
||||||
|
|
||||||
return
|
return
|
||||||
|
|
Loading…
Reference in New Issue