Documentation ¶
Index ¶
- type Processor
- func (p *Processor) Init()
- func (p *Processor) PreStartABCI()
- func (p *Processor) ReceiveSyncHeader(header *wire.BlockHeader)
- func (p *Processor) RegisterCEListener(listener iconsensus.CEShardStateListener)
- func (p *Processor) SetStartConsensusAtRound(round int)
- func (p *Processor) Start(isIntegrationTest bool)
- func (p *Processor) StartABCI(prevReshardheader *wire.BlockHeader)
- func (p *Processor) StopABCI()
- func (p *Processor) StopConsensusAtRound(round int)
- func (p *Processor) String() string
- func (p *Processor) UpdateMinerProof(proof []byte)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Processor ¶
type Processor struct {
// contains filtered or unexported fields
}
Processor is used to manage the miner node.
func NewProcessor ¶
func NewProcessor(blockChain iblockchain.BlockChain, params *consensus.Params, shardIndex shard.Index, selector iconsensus.Sortitionor, dPool idepositpool.DepositPool, pubSubMgr *message.PubSubManager) *Processor
func (*Processor) PreStartABCI ¶
func (p *Processor) PreStartABCI()
func (*Processor) ReceiveSyncHeader ¶
func (p *Processor) ReceiveSyncHeader(header *wire.BlockHeader)
ReceiveSyncHeader receives the block head and use abci to handle it.
func (*Processor) RegisterCEListener ¶
func (p *Processor) RegisterCEListener(listener iconsensus.CEShardStateListener)
RegisterCEListener adds a listener to shardStateListeners.
func (*Processor) SetStartConsensusAtRound ¶
SetStartConsensusAtRound means set the consensus start at the round.
func (*Processor) StartABCI ¶
func (p *Processor) StartABCI(prevReshardheader *wire.BlockHeader)
StartABCI starts abci and records the preReshardHeader.
func (*Processor) StopABCI ¶
func (p *Processor) StopABCI()
StopABCI stop to handleAbciMsg and fetch tx, change the stoping state of abci to true.
func (*Processor) StopConsensusAtRound ¶
StopConsensusAtRound means stop the consensus at the round.
func (*Processor) UpdateMinerProof ¶
UpdateMinerProof is used to update miner's proof.
Click to show internal directories.
Click to hide internal directories.