123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109 |
- // 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/common"
- "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) sendCommit() {
- sub := c.current.Subject()
- c.broadcastCommit(sub)
- }
- func (c *core) sendCommitForOldBlock(view *istanbul.View, digest common.Hash) {
- sub := &istanbul.Subject{
- View: view,
- Digest: digest,
- }
- c.broadcastCommit(sub)
- }
- func (c *core) broadcastCommit(sub *istanbul.Subject) {
- logger := c.logger.New("state", c.state)
- encodedSubject, err := ibfttypes.Encode(sub)
- if err != nil {
- logger.Error("Failed to encode", "subject", sub)
- return
- }
- c.broadcast(&ibfttypes.Message{
- Code: ibfttypes.MsgCommit,
- Msg: encodedSubject,
- })
- }
- func (c *core) handleCommit(msg *ibfttypes.Message, src istanbul.Validator) error {
- // Decode COMMIT message
- var commit *istanbul.Subject
- err := msg.Decode(&commit)
- if err != nil {
- return istanbulcommon.ErrFailedDecodeCommit
- }
- if err := c.checkMessage(ibfttypes.MsgCommit, commit.View); err != nil {
- return err
- }
- if err := c.verifyCommit(commit, src); err != nil {
- return err
- }
- c.acceptCommit(msg, src)
- // Commit the proposal once we have enough COMMIT messages and we are not in the Committed state.
- //
- // If we already have a proposal, we may have chance to speed up the consensus process
- // by committing the proposal without PREPARE messages.
- if c.current.Commits.Size() >= c.QuorumSize() && c.state.Cmp(ibfttypes.StateCommitted) < 0 {
- // Still need to call LockHash here since state can skip Prepared state and jump directly to the Committed state.
- c.current.LockHash()
- c.commit()
- }
- return nil
- }
- // verifyCommit verifies if the received COMMIT message is equivalent to our subject
- func (c *core) verifyCommit(commit *istanbul.Subject, src istanbul.Validator) error {
- logger := c.logger.New("from", src, "state", c.state)
- sub := c.current.Subject()
- if !reflect.DeepEqual(commit, sub) {
- logger.Warn("Inconsistent subjects between commit and proposal", "expected", sub, "got", commit)
- return istanbulcommon.ErrInconsistentSubject
- }
- return nil
- }
- func (c *core) acceptCommit(msg *ibfttypes.Message, src istanbul.Validator) error {
- logger := c.logger.New("from", src, "state", c.state)
- // Add the COMMIT message to current round state
- if err := c.current.Commits.Add(msg); err != nil {
- logger.Error("Failed to record commit message", "msg", msg, "err", err)
- return err
- }
- return nil
- }
|