mirror of
https://github.com/ethereum/go-ethereum.git
synced 2026-07-17 18:30:45 +00:00
parent
5c326961ce
commit
3ac908be8d
2 changed files with 5 additions and 1 deletions
|
|
@ -728,7 +728,7 @@ func (f *Fetcher) insert(peer string, block *types.Block) {
|
||||||
}
|
}
|
||||||
err = f.handleProposedBlock(block.Header())
|
err = f.handleProposedBlock(block.Header())
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Error("[insert] Unable to handle new proposed block", "err", err)
|
log.Error("[insert] Unable to handle new proposed block", "err", err, "number", block.Number(), "hash", block.Hash())
|
||||||
}
|
}
|
||||||
// TODO: (XIN-101) Add propose block handler
|
// TODO: (XIN-101) Add propose block handler
|
||||||
// If import succeeded, broadcast the block
|
// If import succeeded, broadcast the block
|
||||||
|
|
|
||||||
|
|
@ -397,6 +397,10 @@ func (self *worker) wait() {
|
||||||
|
|
||||||
if self.config.XDPoS != nil {
|
if self.config.XDPoS != nil {
|
||||||
c := self.engine.(*XDPoS.XDPoS)
|
c := self.engine.(*XDPoS.XDPoS)
|
||||||
|
err = c.HandleProposedBlock(self.chain, block.Header())
|
||||||
|
if err != nil {
|
||||||
|
log.Error("[wait] Unable to handle new proposed block", "err", err, "number", block.Number(), "hash", block.Hash())
|
||||||
|
}
|
||||||
|
|
||||||
authorized := c.IsAuthorisedAddress(block.Header(), self.chain, self.coinbase)
|
authorized := c.IsAuthorisedAddress(block.Header(), self.chain, self.coinbase)
|
||||||
if !authorized {
|
if !authorized {
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue