core/types: fix immutability guarantees in Block (#27844)
This change rearranges the accessor methods in block.go and fixes some minor issues with the copy-on-write logic of block data. Fixed issues: - Block.WithWithdrawals did not create a shallow copy of the block. - Block.WithBody copied the header unnecessarily, and did not preserve withdrawals. However, the bugs did not affect any code in go-ethereum because blocks are *always* created using NewBlockWithHeader().WithBody().WithWithdrawals()
This commit is contained in:
parent
6e934f40f9
commit
df544350bc
@ -170,7 +170,23 @@ type Body struct {
|
|||||||
Withdrawals []*Withdrawal `rlp:"optional"`
|
Withdrawals []*Withdrawal `rlp:"optional"`
|
||||||
}
|
}
|
||||||
|
|
||||||
// Block represents an entire block in the Ethereum blockchain.
|
// Block represents an Ethereum block.
|
||||||
|
//
|
||||||
|
// Note the Block type tries to be 'immutable', and contains certain caches that rely
|
||||||
|
// on that. The rules around block immutability are as follows:
|
||||||
|
//
|
||||||
|
// - We copy all data when the block is constructed. This makes references held inside
|
||||||
|
// the block independent of whatever value was passed in.
|
||||||
|
//
|
||||||
|
// - We copy all header data on access. This is because any change to the header would mess
|
||||||
|
// up the cached hash and size values in the block. Calling code is expected to take
|
||||||
|
// advantage of this to avoid over-allocating!
|
||||||
|
//
|
||||||
|
// - When new body data is attached to the block, a shallow copy of the block is returned.
|
||||||
|
// This ensures block modifications are race-free.
|
||||||
|
//
|
||||||
|
// - We do not copy body data on access because it does not affect the caches, and also
|
||||||
|
// because it would be too expensive.
|
||||||
type Block struct {
|
type Block struct {
|
||||||
header *Header
|
header *Header
|
||||||
uncles []*Header
|
uncles []*Header
|
||||||
@ -195,9 +211,8 @@ type extblock struct {
|
|||||||
Withdrawals []*Withdrawal `rlp:"optional"`
|
Withdrawals []*Withdrawal `rlp:"optional"`
|
||||||
}
|
}
|
||||||
|
|
||||||
// NewBlock creates a new block. The input data is copied,
|
// NewBlock creates a new block. The input data is copied, changes to header and to the
|
||||||
// changes to header and to the field values will not affect the
|
// field values will not affect the block.
|
||||||
// block.
|
|
||||||
//
|
//
|
||||||
// The values of TxHash, UncleHash, ReceiptHash and Bloom in header
|
// The values of TxHash, UncleHash, ReceiptHash and Bloom in header
|
||||||
// are ignored and set to values derived from the given txs, uncles
|
// are ignored and set to values derived from the given txs, uncles
|
||||||
@ -234,13 +249,11 @@ func NewBlock(header *Header, txs []*Transaction, uncles []*Header, receipts []*
|
|||||||
return b
|
return b
|
||||||
}
|
}
|
||||||
|
|
||||||
// NewBlockWithWithdrawals creates a new block with withdrawals. The input data
|
// NewBlockWithWithdrawals creates a new block with withdrawals. The input data is copied,
|
||||||
// is copied, changes to header and to the field values will not
|
// changes to header and to the field values will not affect the block.
|
||||||
// affect the block.
|
|
||||||
//
|
//
|
||||||
// The values of TxHash, UncleHash, ReceiptHash and Bloom in header
|
// The values of TxHash, UncleHash, ReceiptHash and Bloom in header are ignored and set to
|
||||||
// are ignored and set to values derived from the given txs, uncles
|
// values derived from the given txs, uncles and receipts.
|
||||||
// and receipts.
|
|
||||||
func NewBlockWithWithdrawals(header *Header, txs []*Transaction, uncles []*Header, receipts []*Receipt, withdrawals []*Withdrawal, hasher TrieHasher) *Block {
|
func NewBlockWithWithdrawals(header *Header, txs []*Transaction, uncles []*Header, receipts []*Receipt, withdrawals []*Withdrawal, hasher TrieHasher) *Block {
|
||||||
b := NewBlock(header, txs, uncles, receipts, hasher)
|
b := NewBlock(header, txs, uncles, receipts, hasher)
|
||||||
|
|
||||||
@ -256,15 +269,7 @@ func NewBlockWithWithdrawals(header *Header, txs []*Transaction, uncles []*Heade
|
|||||||
return b.WithWithdrawals(withdrawals)
|
return b.WithWithdrawals(withdrawals)
|
||||||
}
|
}
|
||||||
|
|
||||||
// NewBlockWithHeader creates a block with the given header data. The
|
// CopyHeader creates a deep copy of a block header.
|
||||||
// header data is copied, changes to header and to the field values
|
|
||||||
// will not affect the block.
|
|
||||||
func NewBlockWithHeader(header *Header) *Block {
|
|
||||||
return &Block{header: CopyHeader(header)}
|
|
||||||
}
|
|
||||||
|
|
||||||
// CopyHeader creates a deep copy of a block header to prevent side effects from
|
|
||||||
// modifying a header variable.
|
|
||||||
func CopyHeader(h *Header) *Header {
|
func CopyHeader(h *Header) *Header {
|
||||||
cpy := *h
|
cpy := *h
|
||||||
if cpy.Difficulty = new(big.Int); h.Difficulty != nil {
|
if cpy.Difficulty = new(big.Int); h.Difficulty != nil {
|
||||||
@ -295,7 +300,7 @@ func CopyHeader(h *Header) *Header {
|
|||||||
return &cpy
|
return &cpy
|
||||||
}
|
}
|
||||||
|
|
||||||
// DecodeRLP decodes the Ethereum
|
// DecodeRLP decodes a block from RLP.
|
||||||
func (b *Block) DecodeRLP(s *rlp.Stream) error {
|
func (b *Block) DecodeRLP(s *rlp.Stream) error {
|
||||||
var eb extblock
|
var eb extblock
|
||||||
_, size, _ := s.Kind()
|
_, size, _ := s.Kind()
|
||||||
@ -307,9 +312,9 @@ func (b *Block) DecodeRLP(s *rlp.Stream) error {
|
|||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
// EncodeRLP serializes b into the Ethereum RLP block format.
|
// EncodeRLP serializes a block as RLP.
|
||||||
func (b *Block) EncodeRLP(w io.Writer) error {
|
func (b *Block) EncodeRLP(w io.Writer) error {
|
||||||
return rlp.Encode(w, extblock{
|
return rlp.Encode(w, &extblock{
|
||||||
Header: b.header,
|
Header: b.header,
|
||||||
Txs: b.transactions,
|
Txs: b.transactions,
|
||||||
Uncles: b.uncles,
|
Uncles: b.uncles,
|
||||||
@ -317,10 +322,18 @@ func (b *Block) EncodeRLP(w io.Writer) error {
|
|||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
// TODO: copies
|
// Body returns the non-header content of the block.
|
||||||
|
// Note the returned data is not an independent copy.
|
||||||
|
func (b *Block) Body() *Body {
|
||||||
|
return &Body{b.transactions, b.uncles, b.withdrawals}
|
||||||
|
}
|
||||||
|
|
||||||
|
// Accessors for body data. These do not return a copy because the content
|
||||||
|
// of the body slices does not affect the cached hash/size in block.
|
||||||
|
|
||||||
func (b *Block) Uncles() []*Header { return b.uncles }
|
func (b *Block) Uncles() []*Header { return b.uncles }
|
||||||
func (b *Block) Transactions() Transactions { return b.transactions }
|
func (b *Block) Transactions() Transactions { return b.transactions }
|
||||||
|
func (b *Block) Withdrawals() Withdrawals { return b.withdrawals }
|
||||||
|
|
||||||
func (b *Block) Transaction(hash common.Hash) *Transaction {
|
func (b *Block) Transaction(hash common.Hash) *Transaction {
|
||||||
for _, transaction := range b.transactions {
|
for _, transaction := range b.transactions {
|
||||||
@ -331,6 +344,13 @@ func (b *Block) Transaction(hash common.Hash) *Transaction {
|
|||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Header returns the block header (as a copy).
|
||||||
|
func (b *Block) Header() *Header {
|
||||||
|
return CopyHeader(b.header)
|
||||||
|
}
|
||||||
|
|
||||||
|
// Header value accessors. These do copy!
|
||||||
|
|
||||||
func (b *Block) Number() *big.Int { return new(big.Int).Set(b.header.Number) }
|
func (b *Block) Number() *big.Int { return new(big.Int).Set(b.header.Number) }
|
||||||
func (b *Block) GasLimit() uint64 { return b.header.GasLimit }
|
func (b *Block) GasLimit() uint64 { return b.header.GasLimit }
|
||||||
func (b *Block) GasUsed() uint64 { return b.header.GasUsed }
|
func (b *Block) GasUsed() uint64 { return b.header.GasUsed }
|
||||||
@ -356,10 +376,6 @@ func (b *Block) BaseFee() *big.Int {
|
|||||||
return new(big.Int).Set(b.header.BaseFee)
|
return new(big.Int).Set(b.header.BaseFee)
|
||||||
}
|
}
|
||||||
|
|
||||||
func (b *Block) Withdrawals() Withdrawals {
|
|
||||||
return b.withdrawals
|
|
||||||
}
|
|
||||||
|
|
||||||
func (b *Block) ExcessBlobGas() *uint64 {
|
func (b *Block) ExcessBlobGas() *uint64 {
|
||||||
var excessBlobGas *uint64
|
var excessBlobGas *uint64
|
||||||
if b.header.ExcessBlobGas != nil {
|
if b.header.ExcessBlobGas != nil {
|
||||||
@ -378,11 +394,6 @@ func (b *Block) BlobGasUsed() *uint64 {
|
|||||||
return blobGasUsed
|
return blobGasUsed
|
||||||
}
|
}
|
||||||
|
|
||||||
func (b *Block) Header() *Header { return CopyHeader(b.header) }
|
|
||||||
|
|
||||||
// Body returns the non-header content of the block.
|
|
||||||
func (b *Block) Body() *Body { return &Body{b.transactions, b.uncles, b.withdrawals} }
|
|
||||||
|
|
||||||
// Size returns the true RLP encoded storage size of the block, either by encoding
|
// Size returns the true RLP encoded storage size of the block, either by encoding
|
||||||
// and returning it, or returning a previously cached value.
|
// and returning it, or returning a previously cached value.
|
||||||
func (b *Block) Size() uint64 {
|
func (b *Block) Size() uint64 {
|
||||||
@ -415,25 +426,31 @@ func CalcUncleHash(uncles []*Header) common.Hash {
|
|||||||
return rlpHash(uncles)
|
return rlpHash(uncles)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// NewBlockWithHeader creates a block with the given header data. The
|
||||||
|
// header data is copied, changes to header and to the field values
|
||||||
|
// will not affect the block.
|
||||||
|
func NewBlockWithHeader(header *Header) *Block {
|
||||||
|
return &Block{header: CopyHeader(header)}
|
||||||
|
}
|
||||||
|
|
||||||
// WithSeal returns a new block with the data from b but the header replaced with
|
// WithSeal returns a new block with the data from b but the header replaced with
|
||||||
// the sealed one.
|
// the sealed one.
|
||||||
func (b *Block) WithSeal(header *Header) *Block {
|
func (b *Block) WithSeal(header *Header) *Block {
|
||||||
cpy := *header
|
|
||||||
|
|
||||||
return &Block{
|
return &Block{
|
||||||
header: &cpy,
|
header: CopyHeader(header),
|
||||||
transactions: b.transactions,
|
transactions: b.transactions,
|
||||||
uncles: b.uncles,
|
uncles: b.uncles,
|
||||||
withdrawals: b.withdrawals,
|
withdrawals: b.withdrawals,
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// WithBody returns a new block with the given transaction and uncle contents.
|
// WithBody returns a copy of the block with the given transaction and uncle contents.
|
||||||
func (b *Block) WithBody(transactions []*Transaction, uncles []*Header) *Block {
|
func (b *Block) WithBody(transactions []*Transaction, uncles []*Header) *Block {
|
||||||
block := &Block{
|
block := &Block{
|
||||||
header: CopyHeader(b.header),
|
header: b.header,
|
||||||
transactions: make([]*Transaction, len(transactions)),
|
transactions: make([]*Transaction, len(transactions)),
|
||||||
uncles: make([]*Header, len(uncles)),
|
uncles: make([]*Header, len(uncles)),
|
||||||
|
withdrawals: b.withdrawals,
|
||||||
}
|
}
|
||||||
copy(block.transactions, transactions)
|
copy(block.transactions, transactions)
|
||||||
for i := range uncles {
|
for i := range uncles {
|
||||||
@ -442,13 +459,18 @@ func (b *Block) WithBody(transactions []*Transaction, uncles []*Header) *Block {
|
|||||||
return block
|
return block
|
||||||
}
|
}
|
||||||
|
|
||||||
// WithWithdrawals sets the withdrawal contents of a block, does not return a new block.
|
// WithWithdrawals returns a copy of the block containing the given withdrawals.
|
||||||
func (b *Block) WithWithdrawals(withdrawals []*Withdrawal) *Block {
|
func (b *Block) WithWithdrawals(withdrawals []*Withdrawal) *Block {
|
||||||
if withdrawals != nil {
|
block := &Block{
|
||||||
b.withdrawals = make([]*Withdrawal, len(withdrawals))
|
header: b.header,
|
||||||
copy(b.withdrawals, withdrawals)
|
transactions: b.transactions,
|
||||||
|
uncles: b.uncles,
|
||||||
}
|
}
|
||||||
return b
|
if withdrawals != nil {
|
||||||
|
block.withdrawals = make([]*Withdrawal, len(withdrawals))
|
||||||
|
copy(block.withdrawals, withdrawals)
|
||||||
|
}
|
||||||
|
return block
|
||||||
}
|
}
|
||||||
|
|
||||||
// Hash returns the keccak256 hash of b's header.
|
// Hash returns the keccak256 hash of b's header.
|
||||||
|
Loading…
Reference in New Issue
Block a user