diff options
author | obscuren <geffobscura@gmail.com> | 2015-03-24 01:27:05 +0800 |
---|---|---|
committer | obscuren <geffobscura@gmail.com> | 2015-03-24 01:27:05 +0800 |
commit | c8e9ca048327d7074cfd58137ebf89e065763b71 (patch) | |
tree | 1765a19dd55a3cb1ef43ac6f8f957dcf1b6910de /miner | |
parent | 0330077d76b48934ab024a309000f83c78047d8a (diff) | |
download | dexon-c8e9ca048327d7074cfd58137ebf89e065763b71.tar dexon-c8e9ca048327d7074cfd58137ebf89e065763b71.tar.gz dexon-c8e9ca048327d7074cfd58137ebf89e065763b71.tar.bz2 dexon-c8e9ca048327d7074cfd58137ebf89e065763b71.tar.lz dexon-c8e9ca048327d7074cfd58137ebf89e065763b71.tar.xz dexon-c8e9ca048327d7074cfd58137ebf89e065763b71.tar.zst dexon-c8e9ca048327d7074cfd58137ebf89e065763b71.zip |
fixed bad uncles
Diffstat (limited to 'miner')
-rw-r--r-- | miner/worker.go | 13 |
1 files changed, 11 insertions, 2 deletions
diff --git a/miner/worker.go b/miner/worker.go index e21765f9d..d96da9829 100644 --- a/miner/worker.go +++ b/miner/worker.go @@ -9,11 +9,11 @@ import ( "github.com/ethereum/go-ethereum/common" "github.com/ethereum/go-ethereum/core" + "github.com/ethereum/go-ethereum/core/state" "github.com/ethereum/go-ethereum/core/types" "github.com/ethereum/go-ethereum/event" "github.com/ethereum/go-ethereum/logger" "github.com/ethereum/go-ethereum/pow" - "github.com/ethereum/go-ethereum/core/state" "gopkg.in/fatih/set.v0" ) @@ -199,6 +199,8 @@ func (self *worker) push() { func (self *worker) commitNewWork() { self.mu.Lock() defer self.mu.Unlock() + self.uncleMu.Lock() + defer self.uncleMu.Unlock() block := self.chain.NewBlock(self.coinbase) @@ -241,7 +243,10 @@ gasLimit: } self.eth.TxPool().RemoveSet(remove) - var uncles []*types.Header + var ( + uncles []*types.Header + badUncles []common.Hash + ) for hash, uncle := range self.possibleUncles { if len(uncles) == 2 { break @@ -250,12 +255,16 @@ gasLimit: if err := self.commitUncle(uncle.Header()); err != nil { minerlogger.Infof("Bad uncle found and will be removed (%x)\n", hash[:4]) minerlogger.Debugln(uncle) + badUncles = append(badUncles, hash) } else { minerlogger.Infof("commiting %x as uncle\n", hash[:4]) uncles = append(uncles, uncle.Header()) } } minerlogger.Infof("commit new work with %d txs & %d uncles\n", tcount, len(uncles)) + for _, hash := range badUncles { + delete(self.possibleUncles, hash) + } self.current.block.SetUncles(uncles) |