diff options
| author | obscuren <geffobscura@gmail.com> | 2014-05-30 19:27:56 +0800 |
|---|---|---|
| committer | obscuren <geffobscura@gmail.com> | 2014-05-30 19:27:56 +0800 |
| commit | e0b6a31613bc48bc5785f2bea655f832848392d8 (patch) | |
| tree | 08a25a1b318dfd25742059208cf1783c67a1a971 /ethminer | |
| parent | f382221b28ab9e886263e37b1eab9c7924a6a0dc (diff) | |
| download | dexon-e0b6a31613bc48bc5785f2bea655f832848392d8.tar.gz dexon-e0b6a31613bc48bc5785f2bea655f832848392d8.tar.zst dexon-e0b6a31613bc48bc5785f2bea655f832848392d8.zip | |
Buffered channel to fix not ready (blocking)
Diffstat (limited to 'ethminer')
| -rw-r--r-- | ethminer/miner.go | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/ethminer/miner.go b/ethminer/miner.go index 9396d33f9..e7237bae2 100644 --- a/ethminer/miner.go +++ b/ethminer/miner.go @@ -25,6 +25,7 @@ func NewDefaultMiner(coinbase []byte, ethereum ethchain.EthManager) Miner { reactChan := make(chan ethutil.React, 1) // This is the channel that receives 'updates' when ever a new transaction or block comes in powChan := make(chan []byte, 1) // This is the channel that receives valid sha hases for a given block powQuitChan := make(chan ethutil.React, 1) // This is the channel that can exit the miner thread + quitChan := make(chan bool, 1) ethereum.Reactor().Subscribe("newBlock", reactChan) ethereum.Reactor().Subscribe("newTx:pre", reactChan) @@ -44,7 +45,7 @@ func NewDefaultMiner(coinbase []byte, ethereum ethchain.EthManager) Miner { reactChan: reactChan, powChan: powChan, powQuitChan: powQuitChan, - quitChan: make(chan bool), + quitChan: quitChan, } // Insert initial TXs in our little miner 'pool' |