12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697 |
- // 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 (
- "reflect"
- "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) sendPrepare() {
- logger := c.logger.New("state", c.state)
- sub := c.current.Subject()
- encodedSubject, err := ibfttypes.Encode(sub)
- if err != nil {
- logger.Error("Failed to encode", "subject", sub)
- return
- }
- c.broadcast(&ibfttypes.Message{
- Code: ibfttypes.MsgPrepare,
- Msg: encodedSubject,
- })
- }
- func (c *core) handlePrepare(msg *ibfttypes.Message, src istanbul.Validator) error {
- // Decode PREPARE message
- var prepare *istanbul.Subject
- err := msg.Decode(&prepare)
- if err != nil {
- return istanbulcommon.ErrFailedDecodePrepare
- }
- if err := c.checkMessage(ibfttypes.MsgPrepare, prepare.View); err != nil {
- return err
- }
- // If it is locked, it can only process on the locked block.
- // Passing verifyPrepare and checkMessage implies it is processing on the locked block since it was verified in the Preprepared state.
- if err := c.verifyPrepare(prepare, src); err != nil {
- return err
- }
- c.acceptPrepare(msg, src)
- // Change to Prepared state if we've received enough PREPARE messages or it is locked
- // and we are in earlier state before Prepared state.
- if ((c.current.IsHashLocked() && prepare.Digest == c.current.GetLockedHash()) || c.current.GetPrepareOrCommitSize() >= c.QuorumSize()) &&
- c.state.Cmp(ibfttypes.StatePrepared) < 0 {
- c.current.LockHash()
- c.setState(ibfttypes.StatePrepared)
- c.sendCommit()
- }
- return nil
- }
- // verifyPrepare verifies if the received PREPARE message is equivalent to our subject
- func (c *core) verifyPrepare(prepare *istanbul.Subject, src istanbul.Validator) error {
- logger := c.logger.New("from", src, "state", c.state)
- sub := c.current.Subject()
- if !reflect.DeepEqual(prepare, sub) {
- logger.Warn("Inconsistent subjects between PREPARE and proposal", "expected", sub, "got", prepare)
- return istanbulcommon.ErrInconsistentSubject
- }
- return nil
- }
- func (c *core) acceptPrepare(msg *ibfttypes.Message, src istanbul.Validator) error {
- logger := c.logger.New("from", src, "state", c.state)
- // Add the PREPARE message to current round state
- if err := c.current.Prepares.Add(msg); err != nil {
- logger.Error("Failed to add PREPARE message to round state", "msg", msg, "err", err)
- return err
- }
- return nil
- }
|