mirror of https://github.com/status-im/op-geth.git
core/types: cache computed block values
This commit is contained in:
parent
11b8d1df59
commit
a8889b092b
|
@ -8,6 +8,7 @@ import (
|
||||||
"io"
|
"io"
|
||||||
"math/big"
|
"math/big"
|
||||||
"sort"
|
"sort"
|
||||||
|
"sync/atomic"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
"github.com/ethereum/go-ethereum/common"
|
"github.com/ethereum/go-ethereum/common"
|
||||||
|
@ -105,8 +106,15 @@ type Block struct {
|
||||||
transactions Transactions
|
transactions Transactions
|
||||||
receipts Receipts
|
receipts Receipts
|
||||||
|
|
||||||
Td *big.Int
|
// caches
|
||||||
queued bool // flag for blockpool to skip TD check
|
hash atomic.Value
|
||||||
|
size atomic.Value
|
||||||
|
|
||||||
|
// Td is used by package core to store the total difficulty
|
||||||
|
// of the chain up to and including the block.
|
||||||
|
Td *big.Int
|
||||||
|
|
||||||
|
// ReceivedAt is used by package eth to track block propagation time.
|
||||||
ReceivedAt time.Time
|
ReceivedAt time.Time
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -223,10 +231,12 @@ func (b *Block) ValidateFields() error {
|
||||||
|
|
||||||
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()
|
||||||
if err := s.Decode(&eb); err != nil {
|
if err := s.Decode(&eb); err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
b.header, b.uncles, b.transactions = eb.Header, eb.Uncles, eb.Txs
|
b.header, b.uncles, b.transactions = eb.Header, eb.Uncles, eb.Txs
|
||||||
|
b.size.Store(common.StorageSize(rlp.ListSize(size)))
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -295,8 +305,12 @@ func (b *Block) HashNoNonce() common.Hash {
|
||||||
}
|
}
|
||||||
|
|
||||||
func (b *Block) Size() common.StorageSize {
|
func (b *Block) Size() common.StorageSize {
|
||||||
|
if size := b.size.Load(); size != nil {
|
||||||
|
return size.(common.StorageSize)
|
||||||
|
}
|
||||||
c := writeCounter(0)
|
c := writeCounter(0)
|
||||||
rlp.Encode(&c, b)
|
rlp.Encode(&c, b)
|
||||||
|
b.size.Store(common.StorageSize(c))
|
||||||
return common.StorageSize(c)
|
return common.StorageSize(c)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -329,7 +343,12 @@ func (b *Block) WithMiningResult(nonce uint64, mixDigest common.Hash) *Block {
|
||||||
// Implement pow.Block
|
// Implement pow.Block
|
||||||
|
|
||||||
func (b *Block) Hash() common.Hash {
|
func (b *Block) Hash() common.Hash {
|
||||||
return b.header.Hash()
|
if hash := b.hash.Load(); hash != nil {
|
||||||
|
return hash.(common.Hash)
|
||||||
|
}
|
||||||
|
v := rlpHash(b.header)
|
||||||
|
b.hash.Store(v)
|
||||||
|
return v
|
||||||
}
|
}
|
||||||
|
|
||||||
func (b *Block) String() string {
|
func (b *Block) String() string {
|
||||||
|
|
Loading…
Reference in New Issue