mirror of
https://github.com/ethereum/go-ethereum.git
synced 2026-07-18 02:40:45 +00:00
* all: cleanup trie interface * eth, trie: address comments Co-authored-by: rjl493456442 <garyrong0905@gmail.com>
This commit is contained in:
parent
07328dcec4
commit
d47260ea98
3 changed files with 28 additions and 21 deletions
|
|
@ -73,8 +73,13 @@ type Trie interface {
|
||||||
// trie.MissingNodeError is returned.
|
// trie.MissingNodeError is returned.
|
||||||
TryGet(key []byte) ([]byte, error)
|
TryGet(key []byte) ([]byte, error)
|
||||||
|
|
||||||
// TryGetAccount abstract an account read from the trie.
|
// TryGetAccount abstracts an account read from the trie. It retrieves the
|
||||||
TryGetAccount(key []byte) (*types.StateAccount, error)
|
// account blob from the trie with provided account address and decodes it
|
||||||
|
// with associated decoding algorithm. If the specified account is not in
|
||||||
|
// the trie, nil will be returned. If the trie is corrupted(e.g. some nodes
|
||||||
|
// are missing or the account blob is incorrect for decoding), an error will
|
||||||
|
// be returned.
|
||||||
|
TryGetAccount(address common.Address) (*types.StateAccount, error)
|
||||||
|
|
||||||
// TryUpdate associates key with value in the trie. If value has length zero, any
|
// TryUpdate associates key with value in the trie. If value has length zero, any
|
||||||
// existing value is deleted from the trie. The value bytes must not be modified
|
// existing value is deleted from the trie. The value bytes must not be modified
|
||||||
|
|
@ -82,15 +87,17 @@ type Trie interface {
|
||||||
// database, a trie.MissingNodeError is returned.
|
// database, a trie.MissingNodeError is returned.
|
||||||
TryUpdate(key, value []byte) error
|
TryUpdate(key, value []byte) error
|
||||||
|
|
||||||
// TryUpdateAccount abstract an account write to the trie.
|
// TryUpdateAccount abstracts an account write to the trie. It encodes the
|
||||||
TryUpdateAccount(key []byte, account *types.StateAccount) error
|
// provided account object with associated algorithm and then updates it
|
||||||
|
// in the trie with provided address.
|
||||||
|
TryUpdateAccount(address common.Address, account *types.StateAccount) error
|
||||||
|
|
||||||
// TryDelete removes any existing value for key from the trie. If a node was not
|
// TryDelete removes any existing value for key from the trie. If a node was not
|
||||||
// found in the database, a trie.MissingNodeError is returned.
|
// found in the database, a trie.MissingNodeError is returned.
|
||||||
TryDelete(key []byte) error
|
TryDelete(key []byte) error
|
||||||
|
|
||||||
// TryDeleteAccount abstracts an account deletion from the trie.
|
// TryDeleteAccount abstracts an account deletion from the trie.
|
||||||
TryDeleteAccount(key []byte) error
|
TryDeleteAccount(address common.Address) error
|
||||||
|
|
||||||
// Hash returns the root hash of the trie. It does not write to the database and
|
// Hash returns the root hash of the trie. It does not write to the database and
|
||||||
// can be used even if the trie doesn't have one.
|
// can be used even if the trie doesn't have one.
|
||||||
|
|
|
||||||
|
|
@ -537,7 +537,7 @@ func (s *StateDB) updateStateObject(obj *stateObject) {
|
||||||
|
|
||||||
// Encode the account and update the account trie
|
// Encode the account and update the account trie
|
||||||
addr := obj.Address()
|
addr := obj.Address()
|
||||||
if err := s.trie.TryUpdateAccount(addr[:], &obj.data); err != nil {
|
if err := s.trie.TryUpdateAccount(addr, &obj.data); err != nil {
|
||||||
s.setError(fmt.Errorf("updateStateObject (%x) error: %v", addr[:], err))
|
s.setError(fmt.Errorf("updateStateObject (%x) error: %v", addr[:], err))
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
@ -549,7 +549,7 @@ func (s *StateDB) deleteStateObject(obj *stateObject) {
|
||||||
|
|
||||||
// Delete the account from the trie
|
// Delete the account from the trie
|
||||||
addr := obj.Address()
|
addr := obj.Address()
|
||||||
if err := s.trie.TryDeleteAccount(addr[:]); err != nil {
|
if err := s.trie.TryDeleteAccount(addr); err != nil {
|
||||||
s.setError(fmt.Errorf("deleteStateObject (%x) error: %v", addr[:], err))
|
s.setError(fmt.Errorf("deleteStateObject (%x) error: %v", addr[:], err))
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
@ -584,7 +584,7 @@ func (s *StateDB) getDeletedStateObject(addr common.Address) *stateObject {
|
||||||
}
|
}
|
||||||
// Load the object from the database
|
// Load the object from the database
|
||||||
start := time.Now()
|
start := time.Now()
|
||||||
data, err := s.trie.TryGetAccount(addr.Bytes())
|
data, err := s.trie.TryGetAccount(addr)
|
||||||
s.AccountReads += time.Since(start)
|
s.AccountReads += time.Since(start)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
s.setError(fmt.Errorf("getDeleteStateObject (%x) error: %w", addr.Bytes(), err))
|
s.setError(fmt.Errorf("getDeleteStateObject (%x) error: %w", addr.Bytes(), err))
|
||||||
|
|
|
||||||
|
|
@ -90,11 +90,11 @@ func (t *StateTrie) TryGet(key []byte) ([]byte, error) {
|
||||||
return t.trie.TryGet(t.hashKey(key))
|
return t.trie.TryGet(t.hashKey(key))
|
||||||
}
|
}
|
||||||
|
|
||||||
// TryGetAccount attempts to retrieve an account with provided trie path.
|
// TryGetAccount attempts to retrieve an account with provided account address.
|
||||||
// If the specified account is not in the trie, nil will be returned.
|
// If the specified account is not in the trie, nil will be returned.
|
||||||
// If a trie node is not found in the database, a MissingNodeError is returned.
|
// If a trie node is not found in the database, a MissingNodeError is returned.
|
||||||
func (t *StateTrie) TryGetAccount(key []byte) (*types.StateAccount, error) {
|
func (t *StateTrie) TryGetAccount(address common.Address) (*types.StateAccount, error) {
|
||||||
res, err := t.trie.TryGet(t.hashKey(key))
|
res, err := t.trie.TryGet(t.hashKey(address.Bytes()))
|
||||||
if res == nil || err != nil {
|
if res == nil || err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
|
|
@ -103,11 +103,11 @@ func (t *StateTrie) TryGetAccount(key []byte) (*types.StateAccount, error) {
|
||||||
return ret, err
|
return ret, err
|
||||||
}
|
}
|
||||||
|
|
||||||
// TryGetAccountWithPreHashedKey does the same thing as TryGetAccount, however
|
// TryGetAccountByHash does the same thing as TryGetAccount, however
|
||||||
// it expects a key that is already hashed. This constitutes an abstraction leak,
|
// it expects an account hash that is the hash of address. This constitutes an
|
||||||
// since the client code needs to know the key format.
|
// abstraction leak, since the client code needs to know the key format.
|
||||||
func (t *StateTrie) TryGetAccountWithPreHashedKey(key []byte) (*types.StateAccount, error) {
|
func (t *StateTrie) TryGetAccountByHash(addrHash common.Hash) (*types.StateAccount, error) {
|
||||||
res, err := t.trie.TryGet(key)
|
res, err := t.trie.TryGet(addrHash.Bytes())
|
||||||
if res == nil || err != nil {
|
if res == nil || err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
|
|
@ -156,8 +156,8 @@ func (t *StateTrie) TryUpdate(key, value []byte) error {
|
||||||
|
|
||||||
// TryUpdateAccount account will abstract the write of an account to the
|
// TryUpdateAccount account will abstract the write of an account to the
|
||||||
// secure trie.
|
// secure trie.
|
||||||
func (t *StateTrie) TryUpdateAccount(key []byte, acc *types.StateAccount) error {
|
func (t *StateTrie) TryUpdateAccount(address common.Address, acc *types.StateAccount) error {
|
||||||
hk := t.hashKey(key)
|
hk := t.hashKey(address.Bytes())
|
||||||
data, err := rlp.EncodeToBytes(acc)
|
data, err := rlp.EncodeToBytes(acc)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
|
|
@ -165,7 +165,7 @@ func (t *StateTrie) TryUpdateAccount(key []byte, acc *types.StateAccount) error
|
||||||
if err := t.trie.TryUpdate(hk, data); err != nil {
|
if err := t.trie.TryUpdate(hk, data); err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
t.getSecKeyCache()[string(hk)] = common.CopyBytes(key)
|
t.getSecKeyCache()[string(hk)] = address.Bytes()
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
@ -186,8 +186,8 @@ func (t *StateTrie) TryDelete(key []byte) error {
|
||||||
}
|
}
|
||||||
|
|
||||||
// TryDeleteAccount abstracts an account deletion from the trie.
|
// TryDeleteAccount abstracts an account deletion from the trie.
|
||||||
func (t *StateTrie) TryDeleteAccount(key []byte) error {
|
func (t *StateTrie) TryDeleteAccount(address common.Address) error {
|
||||||
hk := t.hashKey(key)
|
hk := t.hashKey(address.Bytes())
|
||||||
delete(t.getSecKeyCache(), string(hk))
|
delete(t.getSecKeyCache(), string(hk))
|
||||||
return t.trie.TryDelete(hk)
|
return t.trie.TryDelete(hk)
|
||||||
}
|
}
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue