|
|
|
@ -24,7 +24,6 @@ import ( |
|
|
|
|
"sync/atomic" |
|
|
|
|
"time" |
|
|
|
|
|
|
|
|
|
"github.com/ethereum/go-ethereum/accounts" |
|
|
|
|
"github.com/ethereum/go-ethereum/common" |
|
|
|
|
"github.com/ethereum/go-ethereum/consensus" |
|
|
|
|
"github.com/ethereum/go-ethereum/consensus/misc" |
|
|
|
@ -109,9 +108,6 @@ type worker struct { |
|
|
|
|
uncleMu sync.Mutex |
|
|
|
|
possibleUncles map[common.Hash]*types.Block |
|
|
|
|
|
|
|
|
|
txQueueMu sync.Mutex |
|
|
|
|
txQueue map[common.Hash]*types.Transaction |
|
|
|
|
|
|
|
|
|
unconfirmed *unconfirmedBlocks // set of locally mined blocks pending canonicalness confirmations
|
|
|
|
|
|
|
|
|
|
// atomic status counters
|
|
|
|
@ -133,9 +129,8 @@ func newWorker(config *params.ChainConfig, engine consensus.Engine, coinbase com |
|
|
|
|
proc: eth.BlockChain().Validator(), |
|
|
|
|
possibleUncles: make(map[common.Hash]*types.Block), |
|
|
|
|
coinbase: coinbase, |
|
|
|
|
txQueue: make(map[common.Hash]*types.Transaction), |
|
|
|
|
agents: make(map[Agent]struct{}), |
|
|
|
|
unconfirmed: newUnconfirmedBlocks(eth.BlockChain(), 5), |
|
|
|
|
unconfirmed: newUnconfirmedBlocks(eth.BlockChain(), miningLogAtDepth), |
|
|
|
|
fullValidation: false, |
|
|
|
|
} |
|
|
|
|
worker.events = worker.mux.Subscribe(core.ChainHeadEvent{}, core.ChainSideEvent{}, core.TxPreEvent{}) |
|
|
|
@ -362,11 +357,7 @@ func (self *worker) makeCurrent(parent *types.Block, header *types.Header) error |
|
|
|
|
work.family.Add(ancestor.Hash()) |
|
|
|
|
work.ancestors.Add(ancestor.Hash()) |
|
|
|
|
} |
|
|
|
|
wallets := self.eth.AccountManager().Wallets() |
|
|
|
|
accounts := make([]accounts.Account, 0, len(wallets)) |
|
|
|
|
for _, wallet := range wallets { |
|
|
|
|
accounts = append(accounts, wallet.Accounts()...) |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
// Keep track of transactions which return errors so they can be removed
|
|
|
|
|
work.tcount = 0 |
|
|
|
|
self.current = work |
|
|
|
|