123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131 |
- // Copyright 2017 The go-ethereum Authors
- // This file is part of the go-ethereum library.
- //
- // The go-ethereum library is free software: you can redistribute it and/or modify
- // it under the terms of the GNU Lesser General Public License as published by
- // the Free Software Foundation, either version 3 of the License, or
- // (at your option) any later version.
- //
- // The go-ethereum library is distributed in the hope that it will be useful,
- // but WITHOUT ANY WARRANTY; without even the implied warranty of
- // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
- // GNU Lesser General Public License for more details.
- //
- // You should have received a copy of the GNU Lesser General Public License
- // along with the go-ethereum library. If not, see <http://www.gnu.org/licenses/>.
- package core
- import (
- "time"
- "github.com/ethereum/go-ethereum/consensus"
- "github.com/ethereum/go-ethereum/consensus/istanbul"
- istanbulcommon "github.com/ethereum/go-ethereum/consensus/istanbul/common"
- ibfttypes "github.com/ethereum/go-ethereum/consensus/istanbul/ibft/types"
- )
- func (c *core) sendPreprepare(request *istanbul.Request) {
- logger := c.logger.New("state", c.state)
- // If I'm the proposer and I have the same sequence with the proposal
- if c.current.Sequence().Cmp(request.Proposal.Number()) == 0 && c.IsProposer() {
- curView := c.currentView()
- preprepare, err := ibfttypes.Encode(&istanbul.Preprepare{
- View: curView,
- Proposal: request.Proposal,
- })
- if err != nil {
- logger.Error("Failed to encode", "view", curView)
- return
- }
- c.broadcast(&ibfttypes.Message{
- Code: ibfttypes.MsgPreprepare,
- Msg: preprepare,
- })
- }
- }
- func (c *core) handlePreprepare(msg *ibfttypes.Message, src istanbul.Validator) error {
- logger := c.logger.New("from", src, "state", c.state)
- // Decode PRE-PREPARE
- var preprepare *istanbul.Preprepare
- err := msg.Decode(&preprepare)
- if err != nil {
- return istanbulcommon.ErrFailedDecodePreprepare
- }
- // Ensure we have the same view with the PRE-PREPARE message
- // If it is old message, see if we need to broadcast COMMIT
- if err := c.checkMessage(ibfttypes.MsgPreprepare, preprepare.View); err != nil {
- if err == istanbulcommon.ErrOldMessage {
- // Get validator set for the given proposal
- valSet := c.backend.ParentValidators(preprepare.Proposal).Copy()
- previousProposer := c.backend.GetProposer(preprepare.Proposal.Number().Uint64() - 1)
- valSet.CalcProposer(previousProposer, preprepare.View.Round.Uint64())
- // Broadcast COMMIT if it is an existing block
- // 1. The proposer needs to be a proposer matches the given (Sequence + Round)
- // 2. The given block must exist
- if valSet.IsProposer(src.Address()) && c.backend.HasPropsal(preprepare.Proposal.Hash(), preprepare.Proposal.Number()) {
- c.sendCommitForOldBlock(preprepare.View, preprepare.Proposal.Hash())
- return nil
- }
- }
- return err
- }
- // Check if the message comes from current proposer
- if !c.valSet.IsProposer(src.Address()) {
- logger.Warn("Ignore preprepare messages from non-proposer")
- return istanbulcommon.ErrNotFromProposer
- }
- // Verify the proposal we received
- if duration, err := c.backend.Verify(preprepare.Proposal); err != nil {
- // if it's a future block, we will handle it again after the duration
- if err == consensus.ErrFutureBlock {
- logger.Info("Proposed block will be handled in the future", "err", err, "duration", duration)
- c.stopFuturePreprepareTimer()
- c.futurePreprepareTimer = time.AfterFunc(duration, func() {
- c.sendEvent(backlogEvent{
- src: src,
- msg: msg,
- })
- })
- } else {
- logger.Warn("Failed to verify proposal", "err", err, "duration", duration)
- c.sendNextRoundChange()
- }
- return err
- }
- // Here is about to accept the PRE-PREPARE
- if c.state == ibfttypes.StateAcceptRequest {
- // Send ROUND CHANGE if the locked proposal and the received proposal are different
- if c.current.IsHashLocked() {
- if preprepare.Proposal.Hash() == c.current.GetLockedHash() {
- // Broadcast COMMIT and enters Prepared state directly
- c.acceptPreprepare(preprepare)
- c.setState(ibfttypes.StatePrepared)
- c.sendCommit()
- } else {
- // Send round change
- c.sendNextRoundChange()
- }
- } else {
- // Either
- // 1. the locked proposal and the received proposal match
- // 2. we have no locked proposal
- c.acceptPreprepare(preprepare)
- c.setState(ibfttypes.StatePreprepared)
- c.sendPrepare()
- }
- }
- return nil
- }
- func (c *core) acceptPreprepare(preprepare *istanbul.Preprepare) {
- c.consensusTimestamp = time.Now()
- c.current.SetPreprepare(preprepare)
- }
|