diff --git a/consensus/posv/posv.go b/consensus/posv/posv.go index 683dbccc16..c8055ae818 100644 --- a/consensus/posv/posv.go +++ b/consensus/posv/posv.go @@ -652,7 +652,7 @@ func (c *Posv) verifySeal(chain consensus.ChainReader, header *types.Header, par } // verify validator - assignedValidator, err := c.GetValidator(creator, snap, chain, header) + assignedValidator, err := c.GetValidator(creator, chain, header) if err != nil { return err } @@ -664,7 +664,7 @@ func (c *Posv) verifySeal(chain consensus.ChainReader, header *types.Header, par return nil } -func (c *Posv) GetValidator(creator common.Address, snap *Snapshot, chain consensus.ChainReader, header *types.Header) (common.Address, error) { +func (c *Posv) GetValidator(creator common.Address, chain consensus.ChainReader, header *types.Header) (common.Address, error) { epoch := c.config.Epoch no := header.Number.Uint64() cpNo := no diff --git a/eth/backend.go b/eth/backend.go index b90e19ba75..b31015f043 100644 --- a/eth/backend.go +++ b/eth/backend.go @@ -200,16 +200,11 @@ func New(ctx *node.ServiceContext, config *Config) (*Ethereum, error) { log.Error("Cannot get etherbase for append m2 header", "err", err) return block, fmt.Errorf("etherbase missing: %v", err) } - // Get m1. - snap, err := c.GetSnapshot(eth.blockchain, eth.blockchain.CurrentHeader()) - if err != nil { - return block, fmt.Errorf("can't get snapshot: %v", err) - } m1, err := c.RecoverSigner(block.Header()) if err != nil { return block, fmt.Errorf("can't get block creator: %v", err) } - m2, err := c.GetValidator(m1, snap, eth.blockchain, block.Header()) + m2, err := c.GetValidator(m1, eth.blockchain, block.Header()) if err != nil { return block, fmt.Errorf("can't get block validator: %v", err) }