aboutsummaryrefslogtreecommitdiffstats
path: root/ethminer/miner.go
diff options
context:
space:
mode:
authorzelig <viktor.tron@gmail.com>2014-07-05 02:38:44 +0800
committerzelig <viktor.tron@gmail.com>2014-07-05 02:38:44 +0800
commit584d1c61ec93df3417f2ce8ece041b81a5ec63a6 (patch)
tree2e1ea3d9ef4f81b3d29174022f334f35d06e4623 /ethminer/miner.go
parentaf2726414078840aae32aa4c982d3a8c5cf66ef5 (diff)
downloadgo-tangerine-584d1c61ec93df3417f2ce8ece041b81a5ec63a6.tar
go-tangerine-584d1c61ec93df3417f2ce8ece041b81a5ec63a6.tar.gz
go-tangerine-584d1c61ec93df3417f2ce8ece041b81a5ec63a6.tar.bz2
go-tangerine-584d1c61ec93df3417f2ce8ece041b81a5ec63a6.tar.lz
go-tangerine-584d1c61ec93df3417f2ce8ece041b81a5ec63a6.tar.xz
go-tangerine-584d1c61ec93df3417f2ce8ece041b81a5ec63a6.tar.zst
go-tangerine-584d1c61ec93df3417f2ce8ece041b81a5ec63a6.zip
use ethreact.Event and ethreact.ReactorEngine
Diffstat (limited to 'ethminer/miner.go')
-rw-r--r--ethminer/miner.go12
1 files changed, 6 insertions, 6 deletions
diff --git a/ethminer/miner.go b/ethminer/miner.go
index 71d4b2428..8224c5441 100644
--- a/ethminer/miner.go
+++ b/ethminer/miner.go
@@ -4,7 +4,7 @@ import (
"bytes"
"github.com/ethereum/eth-go/ethchain"
"github.com/ethereum/eth-go/ethlog"
- "github.com/ethereum/eth-go/ethutil"
+ "github.com/ethereum/eth-go/ethreact"
"github.com/ethereum/eth-go/ethwire"
"sort"
)
@@ -15,19 +15,19 @@ type Miner struct {
pow ethchain.PoW
ethereum ethchain.EthManager
coinbase []byte
- reactChan chan ethutil.React
+ reactChan chan ethreact.Event
txs ethchain.Transactions
uncles []*ethchain.Block
block *ethchain.Block
powChan chan []byte
- powQuitChan chan ethutil.React
+ powQuitChan chan ethreact.Event
quitChan chan bool
}
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
+ reactChan := make(chan ethreact.Event, 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 ethreact.Event, 1) // This is the channel that can exit the miner thread
quitChan := make(chan bool, 1)
ethereum.Reactor().Subscribe("newBlock", reactChan)