agent.go 2.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107
  1. package miner
  2. import (
  3. "sync"
  4. "github.com/ethereum/go-ethereum/common"
  5. "github.com/ethereum/go-ethereum/core/types"
  6. "github.com/ethereum/go-ethereum/logger"
  7. "github.com/ethereum/go-ethereum/logger/glog"
  8. "github.com/ethereum/go-ethereum/pow"
  9. )
  10. type CpuAgent struct {
  11. mu sync.Mutex
  12. workCh chan *types.Block
  13. quit chan struct{}
  14. quitCurrentOp chan struct{}
  15. returnCh chan<- *types.Block
  16. index int
  17. pow pow.PoW
  18. }
  19. func NewCpuAgent(index int, pow pow.PoW) *CpuAgent {
  20. miner := &CpuAgent{
  21. pow: pow,
  22. index: index,
  23. }
  24. return miner
  25. }
  26. func (self *CpuAgent) Work() chan<- *types.Block { return self.workCh }
  27. func (self *CpuAgent) Pow() pow.PoW { return self.pow }
  28. func (self *CpuAgent) SetReturnCh(ch chan<- *types.Block) { self.returnCh = ch }
  29. func (self *CpuAgent) Stop() {
  30. self.mu.Lock()
  31. defer self.mu.Unlock()
  32. close(self.quit)
  33. }
  34. func (self *CpuAgent) Start() {
  35. self.mu.Lock()
  36. defer self.mu.Unlock()
  37. self.quit = make(chan struct{})
  38. // creating current op ch makes sure we're not closing a nil ch
  39. // later on
  40. self.workCh = make(chan *types.Block, 1)
  41. go self.update()
  42. }
  43. func (self *CpuAgent) update() {
  44. out:
  45. for {
  46. select {
  47. case block := <-self.workCh:
  48. self.mu.Lock()
  49. if self.quitCurrentOp != nil {
  50. close(self.quitCurrentOp)
  51. }
  52. self.quitCurrentOp = make(chan struct{})
  53. go self.mine(block, self.quitCurrentOp)
  54. self.mu.Unlock()
  55. case <-self.quit:
  56. self.mu.Lock()
  57. if self.quitCurrentOp != nil {
  58. close(self.quitCurrentOp)
  59. self.quitCurrentOp = nil
  60. }
  61. self.mu.Unlock()
  62. break out
  63. }
  64. }
  65. done:
  66. // Empty work channel
  67. for {
  68. select {
  69. case <-self.workCh:
  70. default:
  71. close(self.workCh)
  72. break done
  73. }
  74. }
  75. }
  76. func (self *CpuAgent) mine(block *types.Block, stop <-chan struct{}) {
  77. glog.V(logger.Debug).Infof("(re)started agent[%d]. mining...\n", self.index)
  78. // Mine
  79. nonce, mixDigest := self.pow.Search(block, stop)
  80. if nonce != 0 {
  81. self.returnCh <- block.WithMiningResult(nonce, common.BytesToHash(mixDigest))
  82. } else {
  83. self.returnCh <- nil
  84. }
  85. }
  86. func (self *CpuAgent) GetHashRate() int64 {
  87. return self.pow.GetHashrate()
  88. }