diff options
| author | Jeffrey Wilcke <geffobscura@gmail.com> | 2016-05-10 19:35:01 +0800 |
|---|---|---|
| committer | Jeffrey Wilcke <geffobscura@gmail.com> | 2016-05-10 19:35:01 +0800 |
| commit | a824c3f02f74eb11b4382abbb92aa8babc5d685c (patch) | |
| tree | 36b8d7c9c6cb82fb2656d3f6d8efca216888c7ac /miner | |
| parent | 5782164a35ea8acdb09507a604c45941051fd5f3 (diff) | |
| download | dexon-a824c3f02f74eb11b4382abbb92aa8babc5d685c.tar.gz dexon-a824c3f02f74eb11b4382abbb92aa8babc5d685c.tar.zst dexon-a824c3f02f74eb11b4382abbb92aa8babc5d685c.zip | |
miner: fixed pending state by not shutting down update loop
Diffstat (limited to 'miner')
| -rw-r--r-- | miner/worker.go | 4 |
1 files changed, 0 insertions, 4 deletions
diff --git a/miner/worker.go b/miner/worker.go index 3d1928bf6..fe759560c 100644 --- a/miner/worker.go +++ b/miner/worker.go @@ -145,7 +145,6 @@ func newWorker(config *core.ChainConfig, coinbase common.Address, eth core.Backe fullValidation: false, } worker.events = worker.mux.Subscribe(core.ChainHeadEvent{}, core.ChainSideEvent{}, core.TxPreEvent{}) - worker.wg.Add(1) go worker.update() go worker.wait() @@ -188,8 +187,6 @@ func (self *worker) start() { } func (self *worker) stop() { - // Quit update. - self.events.Unsubscribe() self.wg.Wait() self.mu.Lock() @@ -224,7 +221,6 @@ func (self *worker) unregister(agent Agent) { } func (self *worker) update() { - defer self.wg.Done() for event := range self.events.Chan() { // A real event arrived, process interesting content switch ev := event.Data.(type) { |