mpt

package
v0.0.0-...-c763619 Latest Latest
Warning

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

 Go to latest Published: Nov 24, 2023 License: Apache-2.0, Apache-2.0 Imports: 30 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	StoreTypeMPT = types.StoreTypeMPT

	TriesInMemory = 100

	// StoreKey is string representation of the store key for mpt
	StoreKey = "mpt"
)
View Source 
const (
	FlagTrieWriteAhead    = "trie.write-ahead"
	FlagTrieDirtyDisabled = "trie.dirty-disabled"
	FlagTrieCacheSize     = "trie.cache-size"
	FlagTrieNodesLimit    = "trie.nodes-limit"
	FlagTrieImgsLimit     = "trie.imgs-limit"
)
View Source 
const (
	FlagTrieAccStoreCache = "trie.account-store-cache"
)
View Source 
const ProofOpMptAbsence = "mpt:a"
View Source 
const ProofOpMptValue = "mpt:v"

Variables

View Source 
var (
	TrieWriteAhead          = false
	TrieDirtyDisabled       = false
	TrieCacheSize     uint  = 2048 // MB
	TrieNodesLimit    uint  = 256  // MB
	TrieImgsLimit     uint  = 4    // MB
	TrieCommitGap     int64 = 100
)
View Source 
var (
	KeyPrefixAccRootMptHash        = []byte{0x11}
	KeyPrefixAccLatestStoredHeight = []byte{0x12}
	KeyPrefixEvmRootMptHash        = []byte{0x13}
	KeyPrefixEvmLatestStoredHeight = []byte{0x14}

	GAccToPrefetchChannel    = make(chan [][]byte, 2000)
	GAccTryUpdateTrieChannel = make(chan struct{})
	GAccTrieUpdatedChannel   = make(chan struct{})
)
View Source 
var (
	NilHash = ethcmn.Hash{}

	// EmptyCodeHash is the known hash of an empty code.
	EmptyCodeHash      = crypto.Keccak256Hash(nil)
	EmptyCodeHashBytes = crypto.Keccak256(nil)

	// EmptyRootHash is the known root hash of an empty trie.
	EmptyRootHash      = ethtypes.EmptyRootHash
	EmptyRootHashBytes = EmptyRootHash.Bytes()
)
View Source 
var (
	TrieAccStoreCache uint = 32 // MB
)

Functions

func InstanceOfMptStore 

func InstanceOfMptStore() ethstate.Database

Types

type MptStore 

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

MptStore Implements types.KVStore and CommitKVStore. Its main purpose is to own the same interface as iavl store in libs/cosmos-sdk/store/iavl/iavl_store.go

func NewMptStore 

func NewMptStore(logger tmlog.Logger, id types.CommitID) (*MptStore, error)

func (*MptStore) CacheWrap 

func (ms *MptStore) CacheWrap() types.CacheWrap

func (*MptStore) CacheWrapWithTrace 

func (ms *MptStore) CacheWrapWithTrace(w io.Writer, tc types.TraceContext) types.CacheWrap

func (*MptStore) CommitterCommit 

func (ms *MptStore) CommitterCommit(delta *iavl.TreeDelta) (types.CommitID, *iavl.TreeDelta)

* implement CommitStore, CommitKVStore

func (*MptStore) CommitterCommitMap 

func (ms *MptStore) CommitterCommitMap(deltaMap iavl.TreeDeltaMap) (_ types.CommitID, _ iavl.TreeDeltaMap)

func (*MptStore) CurrentVersion 

func (ms *MptStore) CurrentVersion() int64

func (*MptStore) Delete 

func (ms *MptStore) Delete(key []byte)

func (*MptStore) Get 

func (ms *MptStore) Get(key []byte) []byte

func (*MptStore) GetDBReadCount 

func (ms *MptStore) GetDBReadCount() int

func (*MptStore) GetDBReadTime 

func (ms *MptStore) GetDBReadTime() int

func (*MptStore) GetDBWriteCount 

func (ms *MptStore) GetDBWriteCount() int

func (*MptStore) GetFlatKVReadCount 

func (ms *MptStore) GetFlatKVReadCount() int

func (*MptStore) GetFlatKVReadTime 

func (ms *MptStore) GetFlatKVReadTime() int

func (*MptStore) GetFlatKVWriteCount 

func (ms *MptStore) GetFlatKVWriteCount() int

func (*MptStore) GetFlatKVWriteTime 

func (ms *MptStore) GetFlatKVWriteTime() int

func (*MptStore) GetImmutable 

func (ms *MptStore) GetImmutable(height int64) (*MptStore, error)

func (*MptStore) GetLatestStoredBlockHeight 

func (ms *MptStore) GetLatestStoredBlockHeight() uint64

GetLatestStoredBlockHeight get latest mpt storage height

func (*MptStore) GetMptRootHash 

func (ms *MptStore) GetMptRootHash(height uint64) ethcmn.Hash

GetMptRootHash gets root mpt hash from block height

func (*MptStore) GetNodeReadCount 

func (ms *MptStore) GetNodeReadCount() int

func (*MptStore) GetStoreType 

func (ms *MptStore) GetStoreType() types.StoreType

* implement KVStore

func (*MptStore) Has 

func (ms *MptStore) Has(key []byte) bool

func (*MptStore) HasVersion 

func (ms *MptStore) HasVersion(height int64) bool

func (*MptStore) Iterator 

func (ms *MptStore) Iterator(start, end []byte) types.Iterator

func (*MptStore) LastCommitID 

func (ms *MptStore) LastCommitID() types.CommitID

func (*MptStore) LastCommitVersion 

func (ms *MptStore) LastCommitVersion() int64

func (*MptStore) OnStop 

func (ms *MptStore) OnStop() error

func (*MptStore) PushData2Database 

func (ms *MptStore) PushData2Database(curHeight int64)

PushData2Database writes all associated state in cache to the database

func (*MptStore) Query 

func (ms *MptStore) Query(req abci.RequestQuery) (res abci.ResponseQuery)

* implement Queryable

func (*MptStore) ResetCount 

func (ms *MptStore) ResetCount()

func (*MptStore) ReverseIterator 

func (ms *MptStore) ReverseIterator(start, end []byte) types.Iterator

func (*MptStore) Set 

func (ms *MptStore) Set(key, value []byte)

func (*MptStore) SetLatestStoredBlockHeight 

func (ms *MptStore) SetLatestStoredBlockHeight(height uint64)

SetLatestStoredBlockHeight sets the latest stored storage height

func (*MptStore) SetMptRootHash 

func (ms *MptStore) SetMptRootHash(height uint64, hash ethcmn.Hash)

SetMptRootHash sets the mapping from block height to root mpt hash

func (*MptStore) SetPruning 

func (ms *MptStore) SetPruning(options types.PruningOptions)

func (*MptStore) SetUpgradeVersion 

func (ms *MptStore) SetUpgradeVersion(i int64)

func (*MptStore) StartPrefetcher 

func (ms *MptStore) StartPrefetcher(namespace string)

func (*MptStore) StopPrefetcher 

func (ms *MptStore) StopPrefetcher()

StopPrefetcher terminates a running prefetcher and reports any leftover stats from the gathered metrics.

func (*MptStore) StopWithVersion 

func (ms *MptStore) StopWithVersion(targetVersion int64) error

Stop stops the blockchain service. If any imports are currently in progress it will abort them using the procInterrupt.

type ProofList 

type ProofList [][]byte

func (*ProofList) Delete 

func (n *ProofList) Delete(key []byte) error

func (*ProofList) Put 

func (n *ProofList) Put(key []byte, value []byte) error

type TriePrefetcher 

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

TriePrefetcher is an active prefetcher, which receives accounts or storage items and does trie-loading of them. The goal is to get as much useful content into the caches as possible.

Note, the prefetcher's API is not thread safe.

func NewTriePrefetcher 

func NewTriePrefetcher(db ethstate.Database, root common.Hash, namespace string) *TriePrefetcher

NewTriePrefetcher

func (*TriePrefetcher) Close 

func (p *TriePrefetcher) Close()

Close iterates over all the subfetchers, aborts any that were left spinning and reports the stats to the metrics subsystem.

func (*TriePrefetcher) Copy 

func (p *TriePrefetcher) Copy() *TriePrefetcher

copy creates a deep-but-inactive copy of the trie prefetcher. Any trie data already loaded will be copied over, but no goroutines will be started. This is mostly used in the miner which creates a copy of it's actively mutated state to be sealed while it may further mutate the state.

func (*TriePrefetcher) Prefetch 

func (p *TriePrefetcher) Prefetch(root common.Hash, keys [][]byte)

prefetch schedules a batch of trie items to prefetch.

func (*TriePrefetcher) Trie 

func (p *TriePrefetcher) Trie(root common.Hash) ethstate.Trie

trie returns the trie matching the root hash, or nil if the prefetcher doesn't have it.

func (*TriePrefetcher) Used 

func (p *TriePrefetcher) Used(root common.Hash, used [][]byte)

used marks a batch of state items used to allow creating statistics as to how useful or wasteful the prefetcher is.

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.