From 3772f02569fcc5a3e59e6b9e0dc901fd5e171add Mon Sep 17 00:00:00 2001 From: Taylor Gerring Date: Mon, 23 Mar 2015 08:29:41 +0100 Subject: Rename for filename typo --- rpc/miner_agent.go | 77 ++++++++++++++++++++++++++++++++++++++++++++++++++++++ rpc/miner_agest.go | 77 ------------------------------------------------------ 2 files changed, 77 insertions(+), 77 deletions(-) create mode 100644 rpc/miner_agent.go delete mode 100644 rpc/miner_agest.go diff --git a/rpc/miner_agent.go b/rpc/miner_agent.go new file mode 100644 index 000000000..46fb87207 --- /dev/null +++ b/rpc/miner_agent.go @@ -0,0 +1,77 @@ +package rpc + +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() common.Hash { + // TODO return HashNoNonce, DAGSeedHash, Difficulty + + // XXX Wait here untill work != nil ?. + if a.work != nil { + return a.work.HashNoNonce() + } + return common.Hash{} +} + +func (a *Agent) SetResult(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/rpc/miner_agest.go b/rpc/miner_agest.go deleted file mode 100644 index 46fb87207..000000000 --- a/rpc/miner_agest.go +++ /dev/null @@ -1,77 +0,0 @@ -package rpc - -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() common.Hash { - // TODO return HashNoNonce, DAGSeedHash, Difficulty - - // XXX Wait here untill work != nil ?. - if a.work != nil { - return a.work.HashNoNonce() - } - return common.Hash{} -} - -func (a *Agent) SetResult(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 -} -- cgit