aboutsummaryrefslogtreecommitdiffstats
path: root/miner/worker.go
diff options
context:
space:
mode:
authorobscuren <geffobscura@gmail.com>2015-03-24 01:27:05 +0800
committerobscuren <geffobscura@gmail.com>2015-03-24 01:27:05 +0800
commitc8e9ca048327d7074cfd58137ebf89e065763b71 (patch)
tree1765a19dd55a3cb1ef43ac6f8f957dcf1b6910de /miner/worker.go
parent0330077d76b48934ab024a309000f83c78047d8a (diff)
downloaddexon-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/worker.go')
-rw-r--r--miner/worker.go13
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)