state

package
v0.0.0-...-1f8a15b Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 12, 2023 License: GPL-3.0 Imports: 50 Imported by: 0

Documentation

Overview

Package state provides a caching layer atop the Ethereum state trie.

Index

Constants

View Source
const (
	//FirstContractIncarnation - first incarnation for contract accounts. After 1 it increases by 1.
	FirstContractIncarnation = 1
	//NonContractIncarnation incarnation for non contracts
	NonContractIncarnation = 0
)
View Source
const CodeSizeTable = "CodeSize"
View Source
const StorageTable = "Storage"

Variables

View Source
var SystemAddress = libcommon.HexToAddress("0xfffffffffffffffffffffffffffffffffffffffe")

SystemAddress - sender address for internal state updates.

Functions

func ReconnLess

func ReconnLess(i, thanItem reconPair) bool

func WalkAsOfAccounts

func WalkAsOfAccounts(tx kv.Tx, startAddress libcommon.Address, timestamp uint64, walker func(k []byte, v []byte) (bool, error)) error

func WalkAsOfStorage

func WalkAsOfStorage(tx kv.Tx, address libcommon.Address, incarnation uint64, startLocation libcommon.Hash, timestamp uint64, walker func(k1, k2, v []byte) (bool, error)) error

startKey is the concatenation of address and incarnation (BigEndian 8 byte)

Types

type BalanceIncrease

type BalanceIncrease struct {
	// contains filtered or unexported fields
}

BalanceIncrease represents the increase of balance of an account that did not require reading the account first

type CachedReader

type CachedReader struct {
	// contains filtered or unexported fields
}

CachedReader is a wrapper for an instance of type StateReader This wrapper only makes calls to the underlying reader if the item is not in the cache

func NewCachedReader

func NewCachedReader(r StateReader, cache *shards.StateCache) *CachedReader

NewCachedReader wraps a given state reader into the cached reader

func (*CachedReader) ReadAccountCode

func (cr *CachedReader) ReadAccountCode(address common.Address, incarnation uint64, codeHash common.Hash) ([]byte, error)

ReadAccountCode is called when code of an account needs to be fetched from the state Usually, one of (address;incarnation) or codeHash is enough to uniquely identify the code

func (*CachedReader) ReadAccountCodeSize

func (cr *CachedReader) ReadAccountCodeSize(address common.Address, incarnation uint64, codeHash common.Hash) (int, error)

func (*CachedReader) ReadAccountData

func (cr *CachedReader) ReadAccountData(address common.Address) (*accounts.Account, error)

ReadAccountData is called when an account needs to be fetched from the state

func (*CachedReader) ReadAccountIncarnation

func (cr *CachedReader) ReadAccountIncarnation(address common.Address) (uint64, error)

ReadAccountIncarnation is called when incarnation of the account is required (to create and recreate contract)

func (*CachedReader) ReadAccountStorage

func (cr *CachedReader) ReadAccountStorage(address common.Address, incarnation uint64, key *common.Hash) ([]byte, error)

ReadAccountStorage is called when a storage item needs to be fetched from the state

type CachedReader2

type CachedReader2 struct {
	// contains filtered or unexported fields
}

CachedReader2 is a wrapper for an instance of type StateReader This wrapper only makes calls to the underlying reader if the item is not in the cache

func NewCachedReader2

func NewCachedReader2(cache kvcache.CacheView, tx kv.Tx) *CachedReader2

NewCachedReader2 wraps a given state reader into the cached reader

func (*CachedReader2) ReadAccountCode

func (r *CachedReader2) ReadAccountCode(address common.Address, incarnation uint64, codeHash common.Hash) ([]byte, error)

func (*CachedReader2) ReadAccountCodeSize

func (r *CachedReader2) ReadAccountCodeSize(address common.Address, incarnation uint64, codeHash common.Hash) (int, error)

func (*CachedReader2) ReadAccountData

func (r *CachedReader2) ReadAccountData(address common.Address) (*accounts.Account, error)

ReadAccountData is called when an account needs to be fetched from the state

func (*CachedReader2) ReadAccountIncarnation

func (r *CachedReader2) ReadAccountIncarnation(address common.Address) (uint64, error)

func (*CachedReader2) ReadAccountStorage

func (r *CachedReader2) ReadAccountStorage(address common.Address, incarnation uint64, key *common.Hash) ([]byte, error)

type CachedWriter

type CachedWriter struct {
	// contains filtered or unexported fields
}

CachedWriter is a wrapper for an instance of type StateWriter

func NewCachedWriter

func NewCachedWriter(w WriterWithChangeSets, cache *shards.StateCache) *CachedWriter

NewCachedWriter wraps a given state writer into a cached writer

func (*CachedWriter) CreateContract

func (cw *CachedWriter) CreateContract(address common.Address) error

func (*CachedWriter) DeleteAccount

func (cw *CachedWriter) DeleteAccount(address common.Address, original *accounts.Account) error

func (*CachedWriter) UpdateAccountCode

func (cw *CachedWriter) UpdateAccountCode(address common.Address, incarnation uint64, codeHash common.Hash, code []byte) error

func (*CachedWriter) UpdateAccountData

func (cw *CachedWriter) UpdateAccountData(address common.Address, original, account *accounts.Account) error

func (*CachedWriter) WriteAccountStorage

func (cw *CachedWriter) WriteAccountStorage(address common.Address, incarnation uint64, key *common.Hash, original, value *uint256.Int) error

func (*CachedWriter) WriteChangeSets

func (cw *CachedWriter) WriteChangeSets() error

func (*CachedWriter) WriteHistory

func (cw *CachedWriter) WriteHistory() error

type ChangeSetWriter

type ChangeSetWriter struct {
	// contains filtered or unexported fields
}

ChangeSetWriter is a mock StateWriter that accumulates changes in-memory into ChangeSets.

func NewChangeSetWriter

func NewChangeSetWriter() *ChangeSetWriter

func NewChangeSetWriterPlain

func NewChangeSetWriterPlain(db kv.RwTx, blockNumber uint64) *ChangeSetWriter

func (*ChangeSetWriter) CreateContract

func (w *ChangeSetWriter) CreateContract(address libcommon.Address) error

func (*ChangeSetWriter) DeleteAccount

func (w *ChangeSetWriter) DeleteAccount(address libcommon.Address, original *accounts.Account) error

func (*ChangeSetWriter) GetAccountChanges

func (w *ChangeSetWriter) GetAccountChanges() (*historyv22.ChangeSet, error)

func (*ChangeSetWriter) GetStorageChanges

func (w *ChangeSetWriter) GetStorageChanges() (*historyv22.ChangeSet, error)

func (*ChangeSetWriter) PrintChangedAccounts

func (w *ChangeSetWriter) PrintChangedAccounts()

func (*ChangeSetWriter) UpdateAccountCode

func (w *ChangeSetWriter) UpdateAccountCode(address libcommon.Address, incarnation uint64, codeHash libcommon.Hash, code []byte) error

func (*ChangeSetWriter) UpdateAccountData

func (w *ChangeSetWriter) UpdateAccountData(address libcommon.Address, original, account *accounts.Account) error

func (*ChangeSetWriter) WriteAccountStorage

func (w *ChangeSetWriter) WriteAccountStorage(address libcommon.Address, incarnation uint64, key *libcommon.Hash, original, value *uint256.Int) error

func (*ChangeSetWriter) WriteChangeSets

func (w *ChangeSetWriter) WriteChangeSets() error

func (*ChangeSetWriter) WriteHistory

func (w *ChangeSetWriter) WriteHistory() error

type Code

type Code []byte

func (Code) String

func (c Code) String() string

type DbStateReader

type DbStateReader struct {
	// contains filtered or unexported fields
}

Implements StateReader by wrapping database only, without trie

func NewDbStateReader

func NewDbStateReader(db kv.Getter) *DbStateReader

func (*DbStateReader) ReadAccountCode

func (dbr *DbStateReader) ReadAccountCode(address libcommon.Address, incarnation uint64, codeHash libcommon.Hash) ([]byte, error)

func (*DbStateReader) ReadAccountCodeSize

func (dbr *DbStateReader) ReadAccountCodeSize(address libcommon.Address, incarnation uint64, codeHash libcommon.Hash) (codeSize int, err error)

func (*DbStateReader) ReadAccountData

func (dbr *DbStateReader) ReadAccountData(address libcommon.Address) (*accounts.Account, error)

func (*DbStateReader) ReadAccountIncarnation

func (dbr *DbStateReader) ReadAccountIncarnation(address libcommon.Address) (uint64, error)

func (*DbStateReader) ReadAccountStorage

func (dbr *DbStateReader) ReadAccountStorage(address libcommon.Address, incarnation uint64, key *libcommon.Hash) ([]byte, error)

func (*DbStateReader) SetAccountCache

func (dbr *DbStateReader) SetAccountCache(accountCache *fastcache.Cache)

func (*DbStateReader) SetCodeCache

func (dbr *DbStateReader) SetCodeCache(codeCache *fastcache.Cache)

func (*DbStateReader) SetCodeSizeCache

func (dbr *DbStateReader) SetCodeSizeCache(codeSizeCache *fastcache.Cache)

func (*DbStateReader) SetStorageCache

func (dbr *DbStateReader) SetStorageCache(storageCache *fastcache.Cache)

type DbStateWriter

type DbStateWriter struct {
	// contains filtered or unexported fields
}

func NewDbStateWriter

func NewDbStateWriter(db putDel, blockNr uint64) *DbStateWriter

func (*DbStateWriter) ChangeSetWriter

func (dsw *DbStateWriter) ChangeSetWriter() *ChangeSetWriter

func (*DbStateWriter) CreateContract

func (dsw *DbStateWriter) CreateContract(address libcommon.Address) error

func (*DbStateWriter) DeleteAccount

func (dsw *DbStateWriter) DeleteAccount(address libcommon.Address, original *accounts.Account) error

func (*DbStateWriter) UpdateAccountCode

func (dsw *DbStateWriter) UpdateAccountCode(address libcommon.Address, incarnation uint64, codeHash libcommon.Hash, code []byte) error

func (*DbStateWriter) UpdateAccountData

func (dsw *DbStateWriter) UpdateAccountData(address libcommon.Address, original, account *accounts.Account) error

func (*DbStateWriter) WriteAccountStorage

func (dsw *DbStateWriter) WriteAccountStorage(address libcommon.Address, incarnation uint64, key *libcommon.Hash, original, value *uint256.Int) error

func (*DbStateWriter) WriteChangeSets

func (dsw *DbStateWriter) WriteChangeSets() error

WriteChangeSets causes accumulated change sets to be written into the database (or batch) associated with the `dsw`

func (*DbStateWriter) WriteHistory

func (dsw *DbStateWriter) WriteHistory() error

type Dump

type Dump struct {
	Root     string                            `json:"root"`
	Accounts map[libcommon.Address]DumpAccount `json:"accounts"`
}

Dump represents the full dump in a collected format, as one large map.

func (*Dump) OnAccount

func (d *Dump) OnAccount(addr libcommon.Address, account DumpAccount)

OnAccount implements DumpCollector interface

func (*Dump) OnRoot

func (d *Dump) OnRoot(root libcommon.Hash)

OnRoot implements DumpCollector interface

type DumpAccount

type DumpAccount struct {
	Balance   string             `json:"balance"`
	Nonce     uint64             `json:"nonce"`
	Root      hexutility.Bytes   `json:"root"`
	CodeHash  hexutility.Bytes   `json:"codeHash"`
	Code      hexutility.Bytes   `json:"code,omitempty"`
	Storage   map[string]string  `json:"storage,omitempty"`
	Address   *libcommon.Address `json:"address,omitempty"` // Address only present in iterative (line-by-line) mode
	SecureKey *hexutility.Bytes  `json:"key,omitempty"`     // If we don't have address, we can output the key
}

DumpAccount represents an account in the state.

type DumpCollector

type DumpCollector interface {
	// OnRoot is called with the state root
	OnRoot(libcommon.Hash)
	// OnAccount is called once for each account in the trie
	OnAccount(libcommon.Address, DumpAccount)
}

DumpCollector interface which the state trie calls during iteration

type Dumper

type Dumper struct {
	// contains filtered or unexported fields
}

func NewDumper

func NewDumper(db kv.Tx, blockNumber uint64, historyV3 bool) *Dumper

func (*Dumper) DefaultDump

func (d *Dumper) DefaultDump() []byte

DefaultDump returns a JSON string representing the state with the default params

func (*Dumper) DefaultRawDump

func (d *Dumper) DefaultRawDump() Dump

func (*Dumper) Dump

func (d *Dumper) Dump(excludeCode, excludeStorage bool) []byte

Dump returns a JSON string representing the entire state as a single json-object

func (*Dumper) DumpToCollector

func (d *Dumper) DumpToCollector(c DumpCollector, excludeCode, excludeStorage bool, startAddress libcommon.Address, maxResults int) ([]byte, error)

func (*Dumper) IterativeDump

func (d *Dumper) IterativeDump(excludeCode, excludeStorage bool, output *json.Encoder)

IterativeDump dumps out accounts as json-objects, delimited by linebreaks on stdout

func (*Dumper) IteratorDump

func (d *Dumper) IteratorDump(excludeCode, excludeStorage bool, start libcommon.Address, maxResults int) (IteratorDump, error)

IteratorDump dumps out a batch of accounts starts with the given start key

func (*Dumper) RawDump

func (d *Dumper) RawDump(excludeCode, excludeStorage bool) Dump

RawDump returns the entire state an a single large object

type HistoryReaderInc

type HistoryReaderInc struct {
	// contains filtered or unexported fields
}

func NewHistoryReaderInc

func NewHistoryReaderInc(as *libstate.AggregatorStep, rs *ReconState) *HistoryReaderInc

func (*HistoryReaderInc) ReadAccountCode

func (hr *HistoryReaderInc) ReadAccountCode(address common.Address, incarnation uint64, codeHash common.Hash) ([]byte, error)

func (*HistoryReaderInc) ReadAccountCodeSize

func (hr *HistoryReaderInc) ReadAccountCodeSize(address common.Address, incarnation uint64, codeHash common.Hash) (int, error)

func (*HistoryReaderInc) ReadAccountData

func (hr *HistoryReaderInc) ReadAccountData(address common.Address) (*accounts.Account, error)

func (*HistoryReaderInc) ReadAccountIncarnation

func (hr *HistoryReaderInc) ReadAccountIncarnation(address common.Address) (uint64, error)

func (*HistoryReaderInc) ReadAccountStorage

func (hr *HistoryReaderInc) ReadAccountStorage(address common.Address, incarnation uint64, key *common.Hash) ([]byte, error)

func (*HistoryReaderInc) ReadError

func (hr *HistoryReaderInc) ReadError() (uint64, bool)

func (*HistoryReaderInc) ResetError

func (hr *HistoryReaderInc) ResetError()

func (*HistoryReaderInc) SetChainTx

func (hr *HistoryReaderInc) SetChainTx(chainTx kv.Tx)

func (*HistoryReaderInc) SetTrace

func (hr *HistoryReaderInc) SetTrace(trace bool)

func (*HistoryReaderInc) SetTx

func (hr *HistoryReaderInc) SetTx(tx kv.Tx)

func (*HistoryReaderInc) SetTxNum

func (hr *HistoryReaderInc) SetTxNum(txNum uint64)

type HistoryReaderV3

type HistoryReaderV3 struct {
	// contains filtered or unexported fields
}

HistoryReaderV3 Implements StateReader and StateWriter

func NewHistoryReaderV3

func NewHistoryReaderV3() *HistoryReaderV3

func (*HistoryReaderV3) ReadAccountCode

func (hr *HistoryReaderV3) ReadAccountCode(address common.Address, incarnation uint64, codeHash common.Hash) ([]byte, error)

func (*HistoryReaderV3) ReadAccountCodeSize

func (hr *HistoryReaderV3) ReadAccountCodeSize(address common.Address, incarnation uint64, codeHash common.Hash) (int, error)

func (*HistoryReaderV3) ReadAccountData

func (hr *HistoryReaderV3) ReadAccountData(address common.Address) (*accounts.Account, error)

func (*HistoryReaderV3) ReadAccountIncarnation

func (hr *HistoryReaderV3) ReadAccountIncarnation(address common.Address) (uint64, error)

func (*HistoryReaderV3) ReadAccountStorage

func (hr *HistoryReaderV3) ReadAccountStorage(address common.Address, incarnation uint64, key *common.Hash) ([]byte, error)

func (*HistoryReaderV3) SetTrace

func (hr *HistoryReaderV3) SetTrace(trace bool)

func (*HistoryReaderV3) SetTx

func (hr *HistoryReaderV3) SetTx(tx kv.Tx)

func (*HistoryReaderV3) SetTxNum

func (hr *HistoryReaderV3) SetTxNum(txNum uint64)

type IntraBlockState

type IntraBlockState struct {
	// contains filtered or unexported fields
}

IntraBlockState is responsible for caching and managing state changes that occur during block's execution. NOT THREAD SAFE!

func New

func New(stateReader StateReader) *IntraBlockState

Create a new state from a given trie

func (*IntraBlockState) AddAddressToAccessList

func (sdb *IntraBlockState) AddAddressToAccessList(addr libcommon.Address) (addrMod bool)

AddAddressToAccessList adds the given address to the access list

func (*IntraBlockState) AddBalance

func (sdb *IntraBlockState) AddBalance(addr libcommon.Address, amount *uint256.Int)

AddBalance adds amount to the account associated with addr. DESCRIBED: docs/programmers_guide/guide.md#address---identifier-of-an-account

func (*IntraBlockState) AddLog

func (sdb *IntraBlockState) AddLog(log2 *types.Log)

func (*IntraBlockState) AddRefund

func (sdb *IntraBlockState) AddRefund(gas uint64)

AddRefund adds gas to the refund counter

func (*IntraBlockState) AddSlotToAccessList

func (sdb *IntraBlockState) AddSlotToAccessList(addr libcommon.Address, slot libcommon.Hash) (addrMod, slotMod bool)

AddSlotToAccessList adds the given (address, slot)-tuple to the access list

func (*IntraBlockState) AddressInAccessList

func (sdb *IntraBlockState) AddressInAccessList(addr libcommon.Address) bool

AddressInAccessList returns true if the given address is in the access list.

func (*IntraBlockState) BalanceIncreaseSet

func (sdb *IntraBlockState) BalanceIncreaseSet() map[libcommon.Address]uint256.Int

func (*IntraBlockState) CommitBlock

func (sdb *IntraBlockState) CommitBlock(chainRules *chain.Rules, stateWriter StateWriter) error

CommitBlock finalizes the state by removing the self destructed objects and clears the journal as well as the refunds.

func (*IntraBlockState) CreateAccount

func (sdb *IntraBlockState) CreateAccount(addr libcommon.Address, contractCreation bool)

CreateAccount explicitly creates a state object. If a state object with the address already exists the balance is carried over to the new account.

CreateAccount is called during the EVM CREATE operation. The situation might arise that a contract does the following:

  1. sends funds to sha(account ++ (nonce + 1))
  2. tx_create(sha(account ++ nonce)) (note that this gets the address of 1)

Carrying over the balance ensures that Ether doesn't disappear.

func (*IntraBlockState) Empty

func (sdb *IntraBlockState) Empty(addr libcommon.Address) bool

Empty returns whether the state object is either non-existent or empty according to the EIP161 specification (balance = nonce = code = 0)

func (*IntraBlockState) Error

func (sdb *IntraBlockState) Error() error

func (*IntraBlockState) Exist

func (sdb *IntraBlockState) Exist(addr libcommon.Address) bool

Exist reports whether the given account address exists in the state. Notably this also returns true for suicided accounts.

func (*IntraBlockState) FinalizeTx

func (sdb *IntraBlockState) FinalizeTx(chainRules *chain.Rules, stateWriter StateWriter) error

FinalizeTx should be called after every transaction.

func (*IntraBlockState) GetBalance

func (sdb *IntraBlockState) GetBalance(addr libcommon.Address) *uint256.Int

GetBalance retrieves the balance from the given address or 0 if object not found DESCRIBED: docs/programmers_guide/guide.md#address---identifier-of-an-account

func (*IntraBlockState) GetCode

func (sdb *IntraBlockState) GetCode(addr libcommon.Address) []byte

DESCRIBED: docs/programmers_guide/guide.md#address---identifier-of-an-account

func (*IntraBlockState) GetCodeHash

func (sdb *IntraBlockState) GetCodeHash(addr libcommon.Address) libcommon.Hash

DESCRIBED: docs/programmers_guide/guide.md#address---identifier-of-an-account

func (*IntraBlockState) GetCodeSize

func (sdb *IntraBlockState) GetCodeSize(addr libcommon.Address) int

DESCRIBED: docs/programmers_guide/guide.md#address---identifier-of-an-account

func (*IntraBlockState) GetCommittedState

func (sdb *IntraBlockState) GetCommittedState(addr libcommon.Address, key *libcommon.Hash, value *uint256.Int)

GetCommittedState retrieves a value from the given account's committed storage trie. DESCRIBED: docs/programmers_guide/guide.md#address---identifier-of-an-account

func (*IntraBlockState) GetIncarnation

func (sdb *IntraBlockState) GetIncarnation(addr libcommon.Address) uint64

func (*IntraBlockState) GetLogs

func (sdb *IntraBlockState) GetLogs(hash libcommon.Hash) []*types.Log

func (*IntraBlockState) GetNonce

func (sdb *IntraBlockState) GetNonce(addr libcommon.Address) uint64

DESCRIBED: docs/programmers_guide/guide.md#address---identifier-of-an-account

func (*IntraBlockState) GetOrNewStateObject

func (sdb *IntraBlockState) GetOrNewStateObject(addr libcommon.Address) *stateObject

Retrieve a state object or create a new state object if nil.

func (*IntraBlockState) GetRefund

func (sdb *IntraBlockState) GetRefund() uint64

GetRefund returns the current value of the refund counter.

func (*IntraBlockState) GetState

func (sdb *IntraBlockState) GetState(addr libcommon.Address, key *libcommon.Hash, value *uint256.Int)

GetState retrieves a value from the given account's storage trie. DESCRIBED: docs/programmers_guide/guide.md#address---identifier-of-an-account

func (*IntraBlockState) GetTransientState

func (sdb *IntraBlockState) GetTransientState(addr libcommon.Address, key libcommon.Hash) uint256.Int

GetTransientState gets transient storage for a given account.

func (*IntraBlockState) HasSelfdestructed

func (sdb *IntraBlockState) HasSelfdestructed(addr libcommon.Address) bool

func (*IntraBlockState) Logs

func (sdb *IntraBlockState) Logs() []*types.Log

func (*IntraBlockState) MakeWriteSet

func (sdb *IntraBlockState) MakeWriteSet(chainRules *chain.Rules, stateWriter StateWriter) error

func (*IntraBlockState) Prepare

func (sdb *IntraBlockState) Prepare(rules *chain.Rules, sender, coinbase libcommon.Address, dst *libcommon.Address,
	precompiles []libcommon.Address, list types2.AccessList,
)

Prepare handles the preparatory steps for executing a state transition. This method must be invoked before state transition.

Berlin fork: - Add sender to access list (EIP-2929) - Add destination to access list (EIP-2929) - Add precompiles to access list (EIP-2929) - Add the contents of the optional tx access list (EIP-2930)

Shanghai fork: - Add coinbase to access list (EIP-3651)

Cancun fork: - Reset transient storage (EIP-1153)

func (*IntraBlockState) Print

func (sdb *IntraBlockState) Print(chainRules chain.Rules)

func (*IntraBlockState) Reset

func (sdb *IntraBlockState) Reset()

Reset clears out all ephemeral state objects from the state db, but keeps the underlying state trie to avoid reloading data for the next operations.

func (*IntraBlockState) RevertToSnapshot

func (sdb *IntraBlockState) RevertToSnapshot(revid int)

RevertToSnapshot reverts all state changes made since the given revision.

func (*IntraBlockState) Selfdestruct

func (sdb *IntraBlockState) Selfdestruct(addr libcommon.Address) bool

Selfdestruct marks the given account as suicided. This clears the account balance.

The account's state object is still available until the state is committed, getStateObject will return a non-nil account after Suicide.

func (*IntraBlockState) Selfdestruct6780

func (sdb *IntraBlockState) Selfdestruct6780(addr libcommon.Address)

func (*IntraBlockState) SetBalance

func (sdb *IntraBlockState) SetBalance(addr libcommon.Address, amount *uint256.Int)

DESCRIBED: docs/programmers_guide/guide.md#address---identifier-of-an-account

func (*IntraBlockState) SetCode

func (sdb *IntraBlockState) SetCode(addr libcommon.Address, code []byte)

DESCRIBED: docs/programmers_guide/guide.md#code-hash DESCRIBED: docs/programmers_guide/guide.md#address---identifier-of-an-account

func (*IntraBlockState) SetIncarnation

func (sdb *IntraBlockState) SetIncarnation(addr libcommon.Address, incarnation uint64)

SetIncarnation sets incarnation for account if account exists

func (*IntraBlockState) SetNonce

func (sdb *IntraBlockState) SetNonce(addr libcommon.Address, nonce uint64)

DESCRIBED: docs/programmers_guide/guide.md#address---identifier-of-an-account

func (*IntraBlockState) SetState

func (sdb *IntraBlockState) SetState(addr libcommon.Address, key *libcommon.Hash, value uint256.Int)

DESCRIBED: docs/programmers_guide/guide.md#address---identifier-of-an-account

func (*IntraBlockState) SetStorage

func (sdb *IntraBlockState) SetStorage(addr libcommon.Address, storage Storage)

SetStorage replaces the entire storage for the specified account with given storage. This function should only be used for debugging.

func (*IntraBlockState) SetTrace

func (sdb *IntraBlockState) SetTrace(trace bool)

func (*IntraBlockState) SetTransientState

func (sdb *IntraBlockState) SetTransientState(addr libcommon.Address, key libcommon.Hash, value uint256.Int)

SetTransientState sets transient storage for a given account. It adds the change to the journal so that it can be rolled back to its previous value if there is a revert.

func (*IntraBlockState) SetTxContext

func (sdb *IntraBlockState) SetTxContext(thash, bhash libcommon.Hash, ti int)

SetTxContext sets the current transaction hash and index and block hash which are used when the EVM emits new state logs. It should be invoked before transaction execution.

func (*IntraBlockState) SlotInAccessList

func (sdb *IntraBlockState) SlotInAccessList(addr libcommon.Address, slot libcommon.Hash) (addressPresent bool, slotPresent bool)

func (*IntraBlockState) Snapshot

func (sdb *IntraBlockState) Snapshot() int

Snapshot returns an identifier for the current revision of the state.

func (*IntraBlockState) SubBalance

func (sdb *IntraBlockState) SubBalance(addr libcommon.Address, amount *uint256.Int)

SubBalance subtracts amount from the account associated with addr. DESCRIBED: docs/programmers_guide/guide.md#address---identifier-of-an-account

func (*IntraBlockState) SubRefund

func (sdb *IntraBlockState) SubRefund(gas uint64)

SubRefund removes gas from the refund counter. This method will panic if the refund counter goes below zero

func (*IntraBlockState) TxIndex

func (sdb *IntraBlockState) TxIndex() int

TxIndex returns the current transaction index set by Prepare.

type IteratorDump

type IteratorDump struct {
	Root     string                            `json:"root"`
	Accounts map[libcommon.Address]DumpAccount `json:"accounts"`
	Next     []byte                            `json:"next,omitempty"` // nil if no more accounts
}

IteratorDump is an implementation for iterating over data.

func (*IteratorDump) OnAccount

func (d *IteratorDump) OnAccount(addr libcommon.Address, account DumpAccount)

OnAccount implements DumpCollector interface

func (*IteratorDump) OnRoot

func (d *IteratorDump) OnRoot(root libcommon.Hash)

OnRoot implements DumpCollector interface

type NoopWriter

type NoopWriter struct {
}

func NewNoopWriter

func NewNoopWriter() *NoopWriter

func (*NoopWriter) CreateContract

func (nw *NoopWriter) CreateContract(address common.Address) error

func (*NoopWriter) DeleteAccount

func (nw *NoopWriter) DeleteAccount(address common.Address, original *accounts.Account) error

func (*NoopWriter) UpdateAccountCode

func (nw *NoopWriter) UpdateAccountCode(address common.Address, incarnation uint64, codeHash common.Hash, code []byte) error

func (*NoopWriter) UpdateAccountData

func (nw *NoopWriter) UpdateAccountData(address common.Address, original, account *accounts.Account) error

func (*NoopWriter) WriteAccountStorage

func (nw *NoopWriter) WriteAccountStorage(address common.Address, incarnation uint64, key *common.Hash, original, value *uint256.Int) error

func (*NoopWriter) WriteChangeSets

func (nw *NoopWriter) WriteChangeSets() error

func (*NoopWriter) WriteHistory

func (nw *NoopWriter) WriteHistory() error

type PlainState

type PlainState struct {
	// contains filtered or unexported fields
}

State at the beginning of blockNr

func NewPlainState

func NewPlainState(tx kv.Tx, blockNr uint64, systemContractLookup map[libcommon.Address][]libcommon.CodeRecord) *PlainState

func (*PlainState) CreateContract

func (s *PlainState) CreateContract(address libcommon.Address) error

func (*PlainState) DeleteAccount

func (s *PlainState) DeleteAccount(address libcommon.Address, original *accounts.Account) error

func (*PlainState) ForEachStorage

func (s *PlainState) ForEachStorage(addr libcommon.Address, startLocation libcommon.Hash, cb func(key, seckey libcommon.Hash, value uint256.Int) bool, maxResults int) error

func (*PlainState) GetBlockNr

func (s *PlainState) GetBlockNr() uint64

func (*PlainState) ReadAccountCode

func (s *PlainState) ReadAccountCode(address libcommon.Address, incarnation uint64, codeHash libcommon.Hash) ([]byte, error)

func (*PlainState) ReadAccountCodeSize

func (s *PlainState) ReadAccountCodeSize(address libcommon.Address, incarnation uint64, codeHash libcommon.Hash) (int, error)

func (*PlainState) ReadAccountData

func (s *PlainState) ReadAccountData(address libcommon.Address) (*accounts.Account, error)

func (*PlainState) ReadAccountIncarnation

func (s *PlainState) ReadAccountIncarnation(address libcommon.Address) (uint64, error)

func (*PlainState) ReadAccountStorage

func (s *PlainState) ReadAccountStorage(address libcommon.Address, incarnation uint64, key *libcommon.Hash) ([]byte, error)

func (*PlainState) SetBlockNr

func (s *PlainState) SetBlockNr(blockNr uint64)

func (*PlainState) SetTrace

func (s *PlainState) SetTrace(trace bool)

func (*PlainState) UpdateAccountCode

func (s *PlainState) UpdateAccountCode(address libcommon.Address, incarnation uint64, codeHash libcommon.Hash, code []byte) error

func (*PlainState) UpdateAccountData

func (s *PlainState) UpdateAccountData(address libcommon.Address, original, account *accounts.Account) error

func (*PlainState) WriteAccountStorage

func (s *PlainState) WriteAccountStorage(address libcommon.Address, incarnation uint64, key *libcommon.Hash, original, value *uint256.Int) error

type PlainStateReader

type PlainStateReader struct {
	// contains filtered or unexported fields
}

PlainStateReader reads data from so called "plain state". Data in the plain state is stored using un-hashed account/storage items as opposed to the "normal" state that uses hashes of merkle paths to store items.

func NewPlainStateReader

func NewPlainStateReader(db kv.Getter) *PlainStateReader

func (*PlainStateReader) ReadAccountCode

func (r *PlainStateReader) ReadAccountCode(address libcommon.Address, incarnation uint64, codeHash libcommon.Hash) ([]byte, error)

func (*PlainStateReader) ReadAccountCodeSize

func (r *PlainStateReader) ReadAccountCodeSize(address libcommon.Address, incarnation uint64, codeHash libcommon.Hash) (int, error)

func (*PlainStateReader) ReadAccountData

func (r *PlainStateReader) ReadAccountData(address libcommon.Address) (*accounts.Account, error)

func (*PlainStateReader) ReadAccountIncarnation

func (r *PlainStateReader) ReadAccountIncarnation(address libcommon.Address) (uint64, error)

func (*PlainStateReader) ReadAccountStorage

func (r *PlainStateReader) ReadAccountStorage(address libcommon.Address, incarnation uint64, key *libcommon.Hash) ([]byte, error)

type PlainStateWriter

type PlainStateWriter struct {
	// contains filtered or unexported fields
}

func NewPlainStateWriter

func NewPlainStateWriter(db putDel, changeSetsDB kv.RwTx, blockNumber uint64) *PlainStateWriter

func NewPlainStateWriterNoHistory

func NewPlainStateWriterNoHistory(db putDel) *PlainStateWriter

func (*PlainStateWriter) ChangeSetWriter

func (w *PlainStateWriter) ChangeSetWriter() *ChangeSetWriter

func (*PlainStateWriter) CreateContract

func (w *PlainStateWriter) CreateContract(address libcommon.Address) error

func (*PlainStateWriter) DeleteAccount

func (w *PlainStateWriter) DeleteAccount(address libcommon.Address, original *accounts.Account) error

func (*PlainStateWriter) SetAccumulator

func (w *PlainStateWriter) SetAccumulator(accumulator *shards.Accumulator) *PlainStateWriter

func (*PlainStateWriter) UpdateAccountCode

func (w *PlainStateWriter) UpdateAccountCode(address libcommon.Address, incarnation uint64, codeHash libcommon.Hash, code []byte) error

func (*PlainStateWriter) UpdateAccountData

func (w *PlainStateWriter) UpdateAccountData(address libcommon.Address, original, account *accounts.Account) error

func (*PlainStateWriter) WriteAccountStorage

func (w *PlainStateWriter) WriteAccountStorage(address libcommon.Address, incarnation uint64, key *libcommon.Hash, original, value *uint256.Int) error

func (*PlainStateWriter) WriteChangeSets

func (w *PlainStateWriter) WriteChangeSets() error

func (*PlainStateWriter) WriteHistory

func (w *PlainStateWriter) WriteHistory() error

type ReconState

type ReconState struct {
	*ReconnWork //has it's own mutex. allow avoid lock-contention between state.Get() and work.Done() methods
	// contains filtered or unexported fields
}

ReconState is the accumulator of changes to the state

func NewReconState

func NewReconState(workCh chan *exec22.TxTask) *ReconState

func (*ReconState) Delete

func (rs *ReconState) Delete(table string, key1, key2 []byte, txNum uint64)

func (*ReconState) Flush

func (rs *ReconState) Flush(rwTx kv.RwTx) error

func (*ReconState) Get

func (rs *ReconState) Get(table string, key1, key2 []byte, txNum uint64) []byte

func (*ReconState) Put

func (rs *ReconState) Put(table string, key1, key2, val []byte, txNum uint64)

func (*ReconState) RemoveAll

func (rs *ReconState) RemoveAll(table string, key1 []byte)

func (*ReconState) Reset

func (rs *ReconState) Reset(workCh chan *exec22.TxTask)

func (*ReconState) SizeEstimate

func (rs *ReconState) SizeEstimate() uint64

type ReconnWork

type ReconnWork struct {
	// contains filtered or unexported fields
}

func (*ReconnWork) CommitTxNum

func (rs *ReconnWork) CommitTxNum(txNum uint64)

func (*ReconnWork) Done

func (rs *ReconnWork) Done(txNum uint64) bool

func (*ReconnWork) DoneCount

func (rs *ReconnWork) DoneCount() uint64

func (*ReconnWork) MaxTxNum

func (rs *ReconnWork) MaxTxNum() uint64

func (*ReconnWork) QueueLen

func (rs *ReconnWork) QueueLen() int

func (*ReconnWork) RollbackCount

func (rs *ReconnWork) RollbackCount() uint64

func (*ReconnWork) RollbackTx

func (rs *ReconnWork) RollbackTx(txTask *exec22.TxTask, dependency uint64)

func (*ReconnWork) Schedule

func (rs *ReconnWork) Schedule(ctx context.Context) (*exec22.TxTask, bool, error)

type RequiredStateError

type RequiredStateError struct {
	StateTxNum uint64
}

func (*RequiredStateError) Error

func (r *RequiredStateError) Error() string

type StateReader

type StateReader interface {
	ReadAccountData(address common.Address) (*accounts.Account, error)
	ReadAccountStorage(address common.Address, incarnation uint64, key *common.Hash) ([]byte, error)
	ReadAccountCode(address common.Address, incarnation uint64, codeHash common.Hash) ([]byte, error)
	ReadAccountCodeSize(address common.Address, incarnation uint64, codeHash common.Hash) (int, error)
	ReadAccountIncarnation(address common.Address) (uint64, error)
}

type StateReaderV3

type StateReaderV3 struct {
	// contains filtered or unexported fields
}

func NewStateReaderV3

func NewStateReaderV3(rs *StateV3) *StateReaderV3

func (*StateReaderV3) DiscardReadList

func (r *StateReaderV3) DiscardReadList()

func (*StateReaderV3) ReadAccountCode

func (r *StateReaderV3) ReadAccountCode(address common.Address, incarnation uint64, codeHash common.Hash) ([]byte, error)

func (*StateReaderV3) ReadAccountCodeSize

func (r *StateReaderV3) ReadAccountCodeSize(address common.Address, incarnation uint64, codeHash common.Hash) (int, error)

func (*StateReaderV3) ReadAccountData

func (r *StateReaderV3) ReadAccountData(address common.Address) (*accounts.Account, error)

func (*StateReaderV3) ReadAccountIncarnation

func (r *StateReaderV3) ReadAccountIncarnation(address common.Address) (uint64, error)

func (*StateReaderV3) ReadAccountStorage

func (r *StateReaderV3) ReadAccountStorage(address common.Address, incarnation uint64, key *common.Hash) ([]byte, error)

func (*StateReaderV3) ReadSet

func (r *StateReaderV3) ReadSet() map[string]*libstate.KvList

func (*StateReaderV3) ResetReadSet

func (r *StateReaderV3) ResetReadSet()

func (*StateReaderV3) SetTrace

func (r *StateReaderV3) SetTrace(trace bool)

func (*StateReaderV3) SetTx

func (r *StateReaderV3) SetTx(tx kv.Tx)

func (*StateReaderV3) SetTxNum

func (r *StateReaderV3) SetTxNum(txNum uint64)

type StateReconWriterInc

type StateReconWriterInc struct {
	// contains filtered or unexported fields
}

func NewStateReconWriterInc

func NewStateReconWriterInc(as *libstate.AggregatorStep, rs *ReconState) *StateReconWriterInc

func (*StateReconWriterInc) CreateContract

func (w *StateReconWriterInc) CreateContract(address libcommon.Address) error

func (*StateReconWriterInc) DeleteAccount

func (w *StateReconWriterInc) DeleteAccount(address libcommon.Address, original *accounts.Account) error

func (*StateReconWriterInc) SetChainTx

func (w *StateReconWriterInc) SetChainTx(chainTx kv.Tx)

func (*StateReconWriterInc) SetTx

func (w *StateReconWriterInc) SetTx(tx kv.Tx)

func (*StateReconWriterInc) SetTxNum

func (w *StateReconWriterInc) SetTxNum(txNum uint64)

func (*StateReconWriterInc) UpdateAccountCode

func (w *StateReconWriterInc) UpdateAccountCode(address libcommon.Address, incarnation uint64, codeHash libcommon.Hash, code []byte) error

func (*StateReconWriterInc) UpdateAccountData

func (w *StateReconWriterInc) UpdateAccountData(address libcommon.Address, original, account *accounts.Account) error

func (*StateReconWriterInc) WriteAccountStorage

func (w *StateReconWriterInc) WriteAccountStorage(address libcommon.Address, incarnation uint64, key *libcommon.Hash, original, value *uint256.Int) error

type StateV3

type StateV3 struct {
	// contains filtered or unexported fields
}

func NewStateV3

func NewStateV3(tmpdir string, logger log.Logger) *StateV3

func (*StateV3) AddWork

func (rs *StateV3) AddWork(ctx context.Context, txTask *exec22.TxTask, in *exec22.QueueWithRetry)

func (*StateV3) ApplyHistory

func (rs *StateV3) ApplyHistory(txTask *exec22.TxTask, agg *libstate.AggregatorV3) error

func (*StateV3) ApplyState

func (rs *StateV3) ApplyState(roTx kv.Tx, txTask *exec22.TxTask, agg *libstate.AggregatorV3) error

func (*StateV3) CommitTxNum

func (rs *StateV3) CommitTxNum(sender *common.Address, txNum uint64, in *exec22.QueueWithRetry) (count int)

func (*StateV3) DoneCount

func (rs *StateV3) DoneCount() uint64

func (*StateV3) Flush

func (rs *StateV3) Flush(ctx context.Context, rwTx kv.RwTx, logPrefix string, logEvery *time.Ticker) error

func (*StateV3) Get

func (rs *StateV3) Get(table string, key []byte) (v []byte, ok bool)

func (*StateV3) ReTry

func (rs *StateV3) ReTry(txTask *exec22.TxTask, in *exec22.QueueWithRetry)

func (*StateV3) ReadsValid

func (rs *StateV3) ReadsValid(readLists map[string]*libstate.KvList) bool

func (*StateV3) RegisterSender

func (rs *StateV3) RegisterSender(txTask *exec22.TxTask) bool

func (*StateV3) SizeEstimate

func (rs *StateV3) SizeEstimate() (r uint64)

func (*StateV3) Unwind

func (rs *StateV3) Unwind(ctx context.Context, tx kv.RwTx, txUnwindTo uint64, agg *libstate.AggregatorV3, accumulator *shards.Accumulator) error

type StateWriter

type StateWriter interface {
	UpdateAccountData(address common.Address, original, account *accounts.Account) error
	UpdateAccountCode(address common.Address, incarnation uint64, codeHash common.Hash, code []byte) error
	DeleteAccount(address common.Address, original *accounts.Account) error
	WriteAccountStorage(address common.Address, incarnation uint64, key *common.Hash, original, value *uint256.Int) error
	CreateContract(address common.Address) error
}

type StateWriterBufferedV3

type StateWriterBufferedV3 struct {
	// contains filtered or unexported fields
}

StateWriterBufferedV3 - used by parallel workers to accumulate updates and then send them to conflict-resolution.

func NewStateWriterBufferedV3

func NewStateWriterBufferedV3(rs *StateV3) *StateWriterBufferedV3

func (*StateWriterBufferedV3) CreateContract

func (w *StateWriterBufferedV3) CreateContract(address common.Address) error

func (*StateWriterBufferedV3) DeleteAccount

func (w *StateWriterBufferedV3) DeleteAccount(address common.Address, original *accounts.Account) error

func (*StateWriterBufferedV3) PrevAndDels

func (w *StateWriterBufferedV3) PrevAndDels() (map[string][]byte, map[string]*accounts.Account, map[string][]byte, map[string]uint64)

func (*StateWriterBufferedV3) ResetWriteSet

func (w *StateWriterBufferedV3) ResetWriteSet()

func (*StateWriterBufferedV3) SetTxNum

func (w *StateWriterBufferedV3) SetTxNum(txNum uint64)

func (*StateWriterBufferedV3) UpdateAccountCode

func (w *StateWriterBufferedV3) UpdateAccountCode(address common.Address, incarnation uint64, codeHash common.Hash, code []byte) error

func (*StateWriterBufferedV3) UpdateAccountData

func (w *StateWriterBufferedV3) UpdateAccountData(address common.Address, original, account *accounts.Account) error

func (*StateWriterBufferedV3) WriteAccountStorage

func (w *StateWriterBufferedV3) WriteAccountStorage(address common.Address, incarnation uint64, key *common.Hash, original, value *uint256.Int) error

func (*StateWriterBufferedV3) WriteSet

func (w *StateWriterBufferedV3) WriteSet() map[string]*libstate.KvList

type Storage

type Storage map[libcommon.Hash]uint256.Int

func (Storage) Copy

func (s Storage) Copy() Storage

func (Storage) String

func (s Storage) String() (str string)

type WriterWithChangeSets

type WriterWithChangeSets interface {
	StateWriter
	WriteChangeSets() error
	WriteHistory() error
}

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL