aboutsummaryrefslogtreecommitdiffstats
path: root/xeth
diff options
context:
space:
mode:
authorTaylor Gerring <taylor.gerring@gmail.com>2015-03-23 16:35:42 +0800
committerTaylor Gerring <taylor.gerring@gmail.com>2015-03-23 16:35:42 +0800
commitab6311c1bd38c2c90fb353bbf512f12777fd15f4 (patch)
tree67789a411277b767109f4fbc84e84d6f36f21adf /xeth
parentd76e8cb1f126bf1f899507b6a43e4ecb4a798e54 (diff)
downloadgo-tangerine-ab6311c1bd38c2c90fb353bbf512f12777fd15f4.tar.gz
go-tangerine-ab6311c1bd38c2c90fb353bbf512f12777fd15f4.tar.zst
go-tangerine-ab6311c1bd38c2c90fb353bbf512f12777fd15f4.zip
Move remote mining agent to XEth
Diffstat (limited to 'xeth')
-rw-r--r--xeth/miner_agent.go81
-rw-r--r--xeth/xeth.go8
2 files changed, 89 insertions, 0 deletions
diff --git a/xeth/miner_agent.go b/xeth/miner_agent.go
new file mode 100644
index 000000000..181ab950a
--- /dev/null
+++ b/xeth/miner_agent.go
@@ -0,0 +1,81 @@
+package xeth
+
+import (
+ "github.com/ethereum/go-ethereum/common"
+ "github.com/ethereum/go-ethereum/core/types"
+ "github.com/ethereum/go-ethereum/miner"
+)
+
+type Agent struct {
+ work *types.Block
+ currentWork *types.Block
+
+ quit chan struct{}
+ workCh chan *types.Block
+ returnCh chan<- miner.Work
+}
+
+func NewAgent() *Agent {
+ agent := &Agent{}
+ go agent.run()
+
+ return agent
+}
+
+func (a *Agent) Work() chan<- *types.Block {
+ return a.workCh
+}
+
+func (a *Agent) SetWorkCh(returnCh chan<- miner.Work) {
+ a.returnCh = returnCh
+}
+
+func (a *Agent) Start() {
+ a.quit = make(chan struct{})
+ a.workCh = make(chan *types.Block, 1)
+}
+
+func (a *Agent) Stop() {
+ close(a.quit)
+ close(a.workCh)
+}
+
+func (a *Agent) GetHashRate() int64 { return 0 }
+
+func (a *Agent) run() {
+out:
+ for {
+ select {
+ case <-a.quit:
+ break out
+ case work := <-a.workCh:
+ a.work = work
+ }
+ }
+}
+
+func (a *Agent) GetWork() [3]string {
+ // TODO return HashNoNonce, DAGSeedHash, Difficulty
+ var res [3]string
+
+ // XXX Wait here untill work != nil ?.
+ if a.work != nil {
+ res[0] = a.work.HashNoNonce().Hex() // Header Hash No Nonce
+ res[1] = common.Hash{}.Hex() // DAG Seed
+ res[2] = common.Hash{}.Hex() // Difficulty
+ }
+
+ return res
+}
+
+func (a *Agent) SubmitWork(nonce uint64, mixDigest, seedHash common.Hash) bool {
+ // Return true or false, but does not indicate if the PoW was correct
+
+ // Make sure the external miner was working on the right hash
+ if a.currentWork != nil && a.work != nil && a.currentWork.Hash() == a.work.Hash() {
+ a.returnCh <- miner.Work{a.currentWork.Number().Uint64(), nonce, mixDigest.Bytes(), seedHash.Bytes()}
+ return true
+ }
+
+ return false
+}
diff --git a/xeth/xeth.go b/xeth/xeth.go
index d3c3131d4..fba61230f 100644
--- a/xeth/xeth.go
+++ b/xeth/xeth.go
@@ -100,6 +100,9 @@ type XEth struct {
// regmut sync.Mutex
// register map[string][]*interface{} // TODO improve return type
+
+ // Miner agent
+ agent *Agent
}
// New creates an XEth that uses the given frontend.
@@ -117,7 +120,10 @@ func New(eth Backend, frontend Frontend) *XEth {
frontend: frontend,
logs: make(map[int]*logFilter),
messages: make(map[int]*whisperFilter),
+ agent: NewAgent(),
}
+ eth.Miner().Register(xeth.agent)
+
if frontend == nil {
xeth.frontend = dummyFrontend{}
}
@@ -164,6 +170,8 @@ func (self *XEth) stop() {
func (self *XEth) DefaultGas() *big.Int { return defaultGas }
func (self *XEth) DefaultGasPrice() *big.Int { return defaultGasPrice }
+func (self *XEth) RemoteMining() *Agent { return self.agent }
+
func (self *XEth) AtStateNum(num int64) *XEth {
chain := self.Backend().ChainManager()
var block *types.Block