Documentation ¶
Overview ¶
Package snapshot implements a journalled, dynamic state dump.
Index ¶
- Variables
- func AccountRLP(nonce uint64, balance *big.Int, root common.Hash, codehash []byte) []byte
- func GenerateTrieRoot(it AccountIterator) common.Hash
- func SlimToFull(data []byte) ([]byte, error)
- type Account
- type AccountIterator
- type Snapshot
- type Tree
- func (t *Tree) AccountIterator(root common.Hash, seek common.Hash) (AccountIterator, error)
- func (t *Tree) Cap(root common.Hash, layers int) error
- func (t *Tree) Journal(root common.Hash) (common.Hash, error)
- func (t *Tree) Rebuild(root common.Hash)
- func (t *Tree) Snapshot(blockRoot common.Hash) Snapshot
- func (t *Tree) Update(blockRoot common.Hash, parentRoot common.Hash, ...) error
Constants ¶
This section is empty.
Variables ¶
var ( // ErrSnapshotStale is returned from data accessors if the underlying snapshot // layer had been invalidated due to the chain progressing forward far enough // to not maintain the layer's original state. ErrSnapshotStale = errors.New("snapshot stale") // ErrNotCoveredYet is returned from data accessors if the underlying snapshot // is being generated currently and the requested data item is not yet in the // range of accounts covered. ErrNotCoveredYet = errors.New("not covered yet") )
Functions ¶
func AccountRLP ¶
AccountRLP converts a state.Account content into a slim snapshot version RLP encoded.
func GenerateTrieRoot ¶
func GenerateTrieRoot(it AccountIterator) common.Hash
GenerateTrieRoot takes an account iterator and reproduces the root hash.
func SlimToFull ¶
SlimToFull converts data on the 'slim RLP' format into the full RLP-format
Types ¶
type Account ¶
Account is a slim version of a state.Account, where the root and code hash are replaced with a nil byte slice for empty accounts.
type AccountIterator ¶
type AccountIterator interface { // Next steps the iterator forward one element, returning false if exhausted, // or an error if iteration failed for some reason (e.g. root being iterated // becomes stale and garbage collected). Next() bool // Error returns any failure that occurred during iteration, which might have // caused a premature iteration exit (e.g. snapshot stack becoming stale). Error() error // Hash returns the hash of the account the iterator is currently at. Hash() common.Hash // Account returns the RLP encoded slim account the iterator is currently at. // An error will be returned if the iterator becomes invalid (e.g. snaph Account() []byte // Release releases associated resources. Release should always succeed and // can be called multiple times without causing error. Release() }
AccountIterator is an iterator to step over all the accounts in a snapshot, which may or may npt be composed of multiple layers.
type Snapshot ¶
type Snapshot interface { // Root returns the root hash for which this snapshot was made. Root() common.Hash // Account directly retrieves the account associated with a particular hash in // the snapshot slim data format. Account(hash common.Hash) (*Account, error) // AccountRLP directly retrieves the account RLP associated with a particular // hash in the snapshot slim data format. AccountRLP(hash common.Hash) ([]byte, error) // Storage directly retrieves the storage data associated with a particular hash, // within a particular account. Storage(accountHash, storageHash common.Hash) ([]byte, error) }
Snapshot represents the functionality supported by a snapshot storage layer.
type Tree ¶
type Tree struct {
// contains filtered or unexported fields
}
SnapshotTree is an Ethereum state snapshot tree. It consists of one persistent base layer backed by a key-value store, on top of which arbitrarily many in- memory diff layers are topped. The memory diffs can form a tree with branching, but the disk layer is singleton and common to all. If a reorg goes deeper than the disk layer, everything needs to be deleted.
The goal of a state snapshot is twofold: to allow direct access to account and storage data to avoid expensive multi-level trie lookups; and to allow sorted, cheap iteration of the account/storage tries for sync aid.
func New ¶
func New(diskdb ethdb.KeyValueStore, triedb *trie.Database, cache int, root common.Hash, async bool) *Tree
New attempts to load an already existing snapshot from a persistent key-value store (with a number of memory layers from a journal), ensuring that the head of the snapshot matches the expected one.
If the snapshot is missing or inconsistent, the entirety is deleted and will be reconstructed from scratch based on the tries in the key-value store, on a background thread.
func (*Tree) AccountIterator ¶
AccountIterator creates a new account iterator for the specified root hash and seeks to a starting account hash.
func (*Tree) Cap ¶
Cap traverses downwards the snapshot tree from a head block hash until the number of allowed layers are crossed. All layers beyond the permitted number are flattened downwards.
func (*Tree) Journal ¶
Journal commits an entire diff hierarchy to disk into a single journal entry. This is meant to be used during shutdown to persist the snapshot without flattening everything down (bad for reorgs).
The method returns the root hash of the base layer that needs to be persisted to disk as a trie too to allow continuing any pending generation op.
func (*Tree) Rebuild ¶
Rebuild wipes all available snapshot data from the persistent database and discard all caches and diff layers. Afterwards, it starts a new snapshot generator with the given root hash.
func (*Tree) Snapshot ¶
Snapshot retrieves a snapshot belonging to the given block root, or nil if no snapshot is maintained for that block.
func (*Tree) Update ¶
func (t *Tree) Update(blockRoot common.Hash, parentRoot common.Hash, destructs map[common.Hash]struct{}, accounts map[common.Hash][]byte, storage map[common.Hash]map[common.Hash][]byte) error
Update adds a new snapshot into the tree, if that can be linked to an existing old parent. It is disallowed to insert a disk layer (the origin of all).