2015-07-06 17:54:22 -07:00
|
|
|
// Copyright 2014 The go-ethereum Authors
|
2015-07-22 09:48:40 -07:00
|
|
|
// This file is part of the go-ethereum library.
|
2015-07-06 17:54:22 -07:00
|
|
|
//
|
2015-07-23 09:35:11 -07:00
|
|
|
// The go-ethereum library is free software: you can redistribute it and/or modify
|
2015-07-06 17:54:22 -07:00
|
|
|
// 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.
|
|
|
|
//
|
2015-07-22 09:48:40 -07:00
|
|
|
// The go-ethereum library is distributed in the hope that it will be useful,
|
2015-07-06 17:54:22 -07:00
|
|
|
// but WITHOUT ANY WARRANTY; without even the implied warranty of
|
2015-07-22 09:48:40 -07:00
|
|
|
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
2015-07-06 17:54:22 -07:00
|
|
|
// GNU Lesser General Public License for more details.
|
|
|
|
//
|
|
|
|
// You should have received a copy of the GNU Lesser General Public License
|
2015-07-22 09:48:40 -07:00
|
|
|
// along with the go-ethereum library. If not, see <http://www.gnu.org/licenses/>.
|
2015-07-06 17:54:22 -07:00
|
|
|
|
2014-12-05 13:14:55 -08:00
|
|
|
package eth
|
|
|
|
|
|
|
|
import (
|
2015-07-02 09:55:18 -07:00
|
|
|
"fmt"
|
|
|
|
"io"
|
2014-12-05 13:14:55 -08:00
|
|
|
"math/big"
|
|
|
|
|
2015-03-18 05:00:01 -07:00
|
|
|
"github.com/ethereum/go-ethereum/common"
|
2014-12-05 13:14:55 -08:00
|
|
|
"github.com/ethereum/go-ethereum/core/types"
|
2015-07-02 09:55:18 -07:00
|
|
|
"github.com/ethereum/go-ethereum/rlp"
|
|
|
|
)
|
|
|
|
|
|
|
|
// Constants to match up protocol versions and messages
|
|
|
|
const (
|
|
|
|
eth62 = 62
|
|
|
|
eth63 = 63
|
2014-12-05 13:14:55 -08:00
|
|
|
)
|
|
|
|
|
2015-10-27 06:10:30 -07:00
|
|
|
// Official short name of the protocol used during capability negotiation.
|
|
|
|
var ProtocolName = "eth"
|
|
|
|
|
2015-06-26 06:54:27 -07:00
|
|
|
// Supported versions of the eth protocol (first is primary).
|
2016-07-04 02:03:19 -07:00
|
|
|
var ProtocolVersions = []uint{eth63, eth62}
|
2015-06-26 06:54:27 -07:00
|
|
|
|
|
|
|
// Number of implemented message corresponding to different protocol versions.
|
2016-07-04 02:03:19 -07:00
|
|
|
var ProtocolLengths = []uint64{17, 8}
|
2015-06-26 06:54:27 -07:00
|
|
|
|
2017-04-12 07:27:23 -07:00
|
|
|
const ProtocolMaxMsgSize = 10 * 1024 * 1024 // Maximum cap on the size of a protocol message
|
2014-12-15 03:34:06 -08:00
|
|
|
|
|
|
|
// eth protocol message codes
|
|
|
|
const (
|
2016-07-21 02:36:38 -07:00
|
|
|
// Protocol messages belonging to eth/62
|
|
|
|
StatusMsg = 0x00
|
|
|
|
NewBlockHashesMsg = 0x01
|
|
|
|
TxMsg = 0x02
|
2015-07-02 09:55:18 -07:00
|
|
|
GetBlockHeadersMsg = 0x03
|
|
|
|
BlockHeadersMsg = 0x04
|
|
|
|
GetBlockBodiesMsg = 0x05
|
|
|
|
BlockBodiesMsg = 0x06
|
2016-07-21 02:36:38 -07:00
|
|
|
NewBlockMsg = 0x07
|
2015-07-02 09:55:18 -07:00
|
|
|
|
|
|
|
// Protocol messages belonging to eth/63
|
|
|
|
GetNodeDataMsg = 0x0d
|
|
|
|
NodeDataMsg = 0x0e
|
|
|
|
GetReceiptsMsg = 0x0f
|
|
|
|
ReceiptsMsg = 0x10
|
2014-12-15 03:34:06 -08:00
|
|
|
)
|
|
|
|
|
2015-04-17 16:11:09 -07:00
|
|
|
type errCode int
|
|
|
|
|
2015-02-25 05:06:59 -08:00
|
|
|
const (
|
|
|
|
ErrMsgTooLarge = iota
|
|
|
|
ErrDecode
|
|
|
|
ErrInvalidMsgCode
|
|
|
|
ErrProtocolVersionMismatch
|
|
|
|
ErrNetworkIdMismatch
|
|
|
|
ErrGenesisBlockMismatch
|
|
|
|
ErrNoStatusMsg
|
|
|
|
ErrExtraStatusMsg
|
2015-03-19 15:46:54 -07:00
|
|
|
ErrSuspendedPeer
|
2015-02-25 05:06:59 -08:00
|
|
|
)
|
|
|
|
|
2015-04-17 16:11:09 -07:00
|
|
|
func (e errCode) String() string {
|
|
|
|
return errorToString[int(e)]
|
|
|
|
}
|
|
|
|
|
|
|
|
// XXX change once legacy code is out
|
2015-02-25 05:06:59 -08:00
|
|
|
var errorToString = map[int]string{
|
|
|
|
ErrMsgTooLarge: "Message too long",
|
|
|
|
ErrDecode: "Invalid message",
|
|
|
|
ErrInvalidMsgCode: "Invalid message code",
|
|
|
|
ErrProtocolVersionMismatch: "Protocol version mismatch",
|
|
|
|
ErrNetworkIdMismatch: "NetworkId mismatch",
|
|
|
|
ErrGenesisBlockMismatch: "Genesis block mismatch",
|
|
|
|
ErrNoStatusMsg: "No status message",
|
|
|
|
ErrExtraStatusMsg: "Extra status message",
|
2015-03-19 15:46:54 -07:00
|
|
|
ErrSuspendedPeer: "Suspended peer",
|
2015-02-25 05:06:59 -08:00
|
|
|
}
|
|
|
|
|
2014-12-14 10:04:50 -08:00
|
|
|
type txPool interface {
|
2017-07-05 06:51:55 -07:00
|
|
|
// AddRemotes should add the given transactions to the pool.
|
|
|
|
AddRemotes([]*types.Transaction) error
|
2015-06-09 08:03:07 -07:00
|
|
|
|
2016-07-01 08:59:55 -07:00
|
|
|
// Pending should return pending transactions.
|
2015-06-09 08:03:07 -07:00
|
|
|
// The slice should be modifiable by the caller.
|
2016-12-10 14:54:58 -08:00
|
|
|
Pending() (map[common.Address]types.Transactions, error)
|
2014-12-14 10:04:50 -08:00
|
|
|
}
|
|
|
|
|
2015-06-29 07:32:14 -07:00
|
|
|
// statusData is the network packet for the status message.
|
|
|
|
type statusData struct {
|
|
|
|
ProtocolVersion uint32
|
2017-04-25 04:31:15 -07:00
|
|
|
NetworkId uint64
|
2015-06-29 07:32:14 -07:00
|
|
|
TD *big.Int
|
|
|
|
CurrentBlock common.Hash
|
|
|
|
GenesisBlock common.Hash
|
|
|
|
}
|
|
|
|
|
2015-07-02 09:55:18 -07:00
|
|
|
// newBlockHashesData is the network packet for the block announcements.
|
|
|
|
type newBlockHashesData []struct {
|
|
|
|
Hash common.Hash // Hash of one particular block being announced
|
|
|
|
Number uint64 // Number of one particular block being announced
|
|
|
|
}
|
|
|
|
|
|
|
|
// getBlockHeadersData represents a block header query.
|
|
|
|
type getBlockHeadersData struct {
|
|
|
|
Origin hashOrNumber // Block from which to retrieve headers
|
|
|
|
Amount uint64 // Maximum number of headers to retrieve
|
|
|
|
Skip uint64 // Blocks to skip between consecutive headers
|
|
|
|
Reverse bool // Query direction (false = rising towards latest, true = falling towards genesis)
|
|
|
|
}
|
|
|
|
|
|
|
|
// hashOrNumber is a combined field for specifying an origin block.
|
|
|
|
type hashOrNumber struct {
|
|
|
|
Hash common.Hash // Block hash from which to retrieve headers (excludes Number)
|
|
|
|
Number uint64 // Block hash from which to retrieve headers (excludes Hash)
|
|
|
|
}
|
|
|
|
|
|
|
|
// EncodeRLP is a specialized encoder for hashOrNumber to encode only one of the
|
|
|
|
// two contained union fields.
|
|
|
|
func (hn *hashOrNumber) EncodeRLP(w io.Writer) error {
|
|
|
|
if hn.Hash == (common.Hash{}) {
|
|
|
|
return rlp.Encode(w, hn.Number)
|
|
|
|
}
|
|
|
|
if hn.Number != 0 {
|
|
|
|
return fmt.Errorf("both origin hash (%x) and number (%d) provided", hn.Hash, hn.Number)
|
|
|
|
}
|
|
|
|
return rlp.Encode(w, hn.Hash)
|
|
|
|
}
|
|
|
|
|
|
|
|
// DecodeRLP is a specialized decoder for hashOrNumber to decode the contents
|
|
|
|
// into either a block hash or a block number.
|
|
|
|
func (hn *hashOrNumber) DecodeRLP(s *rlp.Stream) error {
|
|
|
|
_, size, _ := s.Kind()
|
|
|
|
origin, err := s.Raw()
|
|
|
|
if err == nil {
|
|
|
|
switch {
|
|
|
|
case size == 32:
|
|
|
|
err = rlp.DecodeBytes(origin, &hn.Hash)
|
|
|
|
case size <= 8:
|
|
|
|
err = rlp.DecodeBytes(origin, &hn.Number)
|
|
|
|
default:
|
|
|
|
err = fmt.Errorf("invalid input size %d for origin", size)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
|
2015-06-29 07:32:14 -07:00
|
|
|
// newBlockData is the network packet for the block propagation message.
|
|
|
|
type newBlockData struct {
|
2014-12-05 13:14:55 -08:00
|
|
|
Block *types.Block
|
|
|
|
TD *big.Int
|
|
|
|
}
|
2015-07-02 04:13:46 -07:00
|
|
|
|
2015-07-02 09:55:18 -07:00
|
|
|
// blockBody represents the data content of a single block.
|
|
|
|
type blockBody struct {
|
|
|
|
Transactions []*types.Transaction // Transactions contained within a block
|
|
|
|
Uncles []*types.Header // Uncles contained within a block
|
|
|
|
}
|
|
|
|
|
|
|
|
// blockBodiesData is the network packet for block content distribution.
|
|
|
|
type blockBodiesData []*blockBody
|