aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorFelix Lange <fjl@twurst.com>2015-06-25 20:45:54 +0800
committerJeffrey Wilcke <geffobscura@gmail.com>2015-06-30 00:51:48 +0800
commit11b8d1df59b5a038be2066f97427da3d4d096fe6 (patch)
treefe69aad816aa40cf902e6f7f1ddee84aebac200b
parent8743cc1c1ce6b78a02cd29cc06eed3a85ea74209 (diff)
downloaddexon-11b8d1df59b5a038be2066f97427da3d4d096fe6.tar
dexon-11b8d1df59b5a038be2066f97427da3d4d096fe6.tar.gz
dexon-11b8d1df59b5a038be2066f97427da3d4d096fe6.tar.bz2
dexon-11b8d1df59b5a038be2066f97427da3d4d096fe6.tar.lz
dexon-11b8d1df59b5a038be2066f97427da3d4d096fe6.tar.xz
dexon-11b8d1df59b5a038be2066f97427da3d4d096fe6.tar.zst
dexon-11b8d1df59b5a038be2066f97427da3d4d096fe6.zip
core/types: cache computed transaction values
-rw-r--r--core/types/transaction.go33
1 files changed, 28 insertions, 5 deletions
diff --git a/core/types/transaction.go b/core/types/transaction.go
index 14b0e4174..95deac36e 100644
--- a/core/types/transaction.go
+++ b/core/types/transaction.go
@@ -6,6 +6,7 @@ import (
"fmt"
"io"
"math/big"
+ "sync/atomic"
"github.com/ethereum/go-ethereum/common"
"github.com/ethereum/go-ethereum/crypto"
@@ -20,6 +21,10 @@ func IsContractAddr(addr []byte) bool {
type Transaction struct {
data txdata
+ // caches
+ hash atomic.Value
+ size atomic.Value
+ from atomic.Value
}
type txdata struct {
@@ -88,7 +93,12 @@ func (tx *Transaction) EncodeRLP(w io.Writer) error {
}
func (tx *Transaction) DecodeRLP(s *rlp.Stream) error {
- return s.Decode(&tx.data)
+ _, size, _ := s.Kind()
+ err := s.Decode(&tx.data)
+ if err == nil {
+ tx.size.Store(common.StorageSize(rlp.ListSize(size)))
+ }
+ return err
}
func (tx *Transaction) Data() []byte { return common.CopyBytes(tx.data.Payload) }
@@ -107,6 +117,9 @@ func (tx *Transaction) To() *common.Address {
}
func (tx *Transaction) Hash() common.Hash {
+ if hash := tx.hash.Load(); hash != nil {
+ return hash.(common.Hash)
+ }
v := rlpHash([]interface{}{
tx.data.AccountNonce,
tx.data.Price,
@@ -115,21 +128,31 @@ func (tx *Transaction) Hash() common.Hash {
tx.data.Amount,
tx.data.Payload,
})
+ tx.hash.Store(v)
return v
}
func (tx *Transaction) Size() common.StorageSize {
- v, _, _ := rlp.EncodeToReader(&tx.data)
- return common.StorageSize(v)
+ if size := tx.size.Load(); size != nil {
+ return size.(common.StorageSize)
+ }
+ c := writeCounter(0)
+ rlp.Encode(&c, &tx.data)
+ tx.size.Store(common.StorageSize(c))
+ return common.StorageSize(c)
}
func (tx *Transaction) From() (common.Address, error) {
- pubkey, err := tx.PublicKey()
+ if from := tx.from.Load(); from != nil {
+ return from.(common.Address), nil
+ }
+ pubkey, err := tx.publicKey()
if err != nil {
return common.Address{}, err
}
var addr common.Address
copy(addr[:], crypto.Sha3(pubkey[1:])[12:])
+ tx.from.Store(addr)
return addr, nil
}
@@ -144,7 +167,7 @@ func (tx *Transaction) SignatureValues() (v byte, r *big.Int, s *big.Int) {
return tx.data.V, new(big.Int).Set(tx.data.R), new(big.Int).Set(tx.data.S)
}
-func (tx *Transaction) PublicKey() ([]byte, error) {
+func (tx *Transaction) publicKey() ([]byte, error) {
if !crypto.ValidateSignatureValues(tx.data.V, tx.data.R, tx.data.S) {
return nil, errors.New("invalid v, r, s values")
}