以太坊源码系列之miner解析(1)

miner用来对worker进行管理，订阅外部事件，控制worker的启动和停止。

type Miner struct {mux      *event.TypeMuxworker   *workercoinbase common.Addresseth      Backendengine   consensus.Engine  //共识exitCh   chan struct{}startCh  chan common.AddressstopCh   chan struct{}
}

//构造, 创建了一个Miner 启动了miner的update goroutine

func New(eth Backend, config *Config, chainConfig *params.ChainConfig, mux *event.TypeMux, engine consensus.Engine, isLocalBlock func(block *types.Block) bool) *Miner {miner := &Miner{eth:     eth,mux:     mux,engine:  engine,exitCh:  make(chan struct{}),startCh: make(chan common.Address),stopCh:  make(chan struct{}),worker:  newWorker(config, chainConfig, engine, eth, mux, isLocalBlock, true),}go miner.update()return miner
}

update订阅了downloader的事件， goroutine是一个一次性的循环，只要接收到一次downloader的downloader.DoneEvent或者 downloader.FailedEvent事件，就会设置canStart为1. 并退出循环，这是为了避免黑客恶意的 DOS攻击，让你不断的处于异常状态

func (miner *Miner) update() {events := miner.mux.Subscribe(downloader.StartEvent{}, downloader.DoneEvent{}, downloader.FailedEvent{})defer func() {if !events.Closed() {events.Unsubscribe()}}()shouldStart := falsecanStart := truedlEventCh := events.Chan()for {select {case ev := <-dlEventCh:if ev == nil {// 取消订阅，停止收听dlEventCh = nilcontinue}switch ev.Data.(type) {case downloader.StartEvent:wasMining := miner.Mining()miner.worker.stop()canStart = falseif wasMining {// 同步完成后继续挖掘shouldStart = truelog.Info("Mining aborted due to sync")}case downloader.FailedEvent:canStart = trueif shouldStart {miner.SetEtherbase(miner.coinbase)miner.worker.start()}case downloader.DoneEvent:canStart = true//启动worker 开始挖矿if shouldStart {miner.SetEtherbase(miner.coinbase)miner.worker.start()}// 停止对同步事件作出反应events.Unsubscribe()}case addr := <-miner.startCh:miner.SetEtherbase(addr)//启动worker 开始挖矿if canStart {miner.worker.start()}shouldStart = truecase <-miner.stopCh:shouldStart = false//worker 停止挖矿miner.worker.stop()case <-miner.exitCh:miner.worker.close()return}}
}

以太坊源码系列之miner解析(1)相关推荐

以太坊源码系列之miner解析(2)
// 工作者是负责将消息应用到新状态的主要对象 type worker struct {config *ConfigchainConfig *params.ChainConfigengine cons ...
以太坊源码分析(2)——以太坊APP对象
前言从这一节开始,我将开始以太坊代码全覆盖讲解,讲解的流程是: 以太坊程序入口基本框架以太坊协议发送一笔交易后发生了什么启动挖矿以太坊共识 p2p 网络阅读本系列文章,将默认读者具备一定 ...
3 v4 中心节点固定_死磕以太坊源码分析之p2p节点发现
死磕以太坊源码分析之p2p节点发现在阅读节点发现源码之前必须要理解kadmilia算法,可以参考:KAD算法详解. 节点发现概述节点发现,使本地节点得知其他节点的信息,进而加入到p2p网络中. 以 ...
以太坊源码学习(一) 正本清源
以太坊源码学习(一)正本清源背景 geth源码一直在不断增加,优化,发展到现在已经非常庞大,第一次看geth源码,会有不小的难度.虽然如此,还是可以从geth仓库的第一个commit开始,这时的代码 ...
以太坊源码阅读2——RLP编码
以太坊源码阅读2--RLP编码 RLP介绍目前网上的资料都是RLP(Recursive Length prefix),叫递归长度前缀编码,但目前源码的doc.go的第20行里面的注释写的是 The ...
以太坊源码阅读5——POW源码分析
以太坊源码阅读5--POW源码分析介绍 POW,proof of work,即工作量证明,是著名公bitcoin所采用的共识算法.简单来说,pow就是一个证明,由矿工使用算力进行计算(挖矿),竞争记 ...
kademlia java_死磕以太坊源码分析之Kademlia算法
死磕以太坊源码分析之Kademlia算法 KAD 算法概述 Kademlia是一种点对点分布式哈希表(DHT),它在容易出错的环境中也具有可证明的一致性和性能.使用一种基于异或指标的拓扑结构来路由查询 ...
以太坊源码学习 -- EVM
以太坊源码学习 – EVM 学习文档链接:here 一.虚拟机外主要功能: 执行前将Transaction类型转化成Message,创建虚拟机(EVM)对象,计算一些Gas消耗,以及执行交易完毕后创 ...
以太坊源码分析-交易
以太坊源码分析-交易机理先说一点区块链转账的基本概念和流程用户输入转账的地址和转入的地址和转出的金额系统通过转出的地址的私钥对转账信息进行签名(用于证明这笔交易确实有本人进行) 系统对交易信 ...

以太坊源码系列之miner解析(1)

以太坊源码系列之miner解析(1)相关推荐

最新文章

热门文章