parallel

package
v0.0.0-...-8b5660e Latest Latest
Warning

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

Go to latest
Published: Jun 25, 2025 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BlockTxnStatManager

type BlockTxnStatManager struct {
	TxnCount           int
	TxnBatchCount      int
	TxnBatchRedoCount  int
	ConflictCount      int
	ExecuteDuration    time.Duration
	ExecuteTxnDuration time.Duration
	PrepareDuration    time.Duration
	CommitDuration     time.Duration
	CopyDuration       time.Duration
}

func (*BlockTxnStatManager) UpdateMetrics

func (stat *BlockTxnStatManager) UpdateMetrics()

type EvmProcessor

type EvmProcessor interface {
	Prepare(block *types.Block)
	Execute(block *types.Block)
	Receipts(block *types.Block) map[common.Hash]*types.Receipt
}

type ParallelEVM

type ParallelEVM struct {
	*tripod.Tripod

	Solidity *evm.Solidity `tripod:"solidity"`
	// contains filtered or unexported fields
}

func NewParallelEVM

func NewParallelEVM() *ParallelEVM

func (*ParallelEVM) Commit

func (k *ParallelEVM) Commit(block *types.Block, receipts map[common.Hash]*types.Receipt) error

func (*ParallelEVM) Execute

func (k *ParallelEVM) Execute(block *types.Block) error

type ParallelEvmExecutor

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

func NewParallelEvmExecutor

func NewParallelEvmExecutor(evm *ParallelEVM) *ParallelEvmExecutor

func (*ParallelEvmExecutor) CopyStateDb

func (e *ParallelEvmExecutor) CopyStateDb(list []*txnCtx) []*pending_state.PendingStateWrapper

func (*ParallelEvmExecutor) Execute

func (e *ParallelEvmExecutor) Execute(block *types.Block)

func (*ParallelEvmExecutor) Prepare

func (e *ParallelEvmExecutor) Prepare(block *types.Block)

func (*ParallelEvmExecutor) Receipts

func (e *ParallelEvmExecutor) Receipts(block *types.Block) map[common.Hash]*types.Receipt

type SerialEvmExecutor

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

func NewSerialEvmExecutor

func NewSerialEvmExecutor(evm *ParallelEVM) *SerialEvmExecutor

func (*SerialEvmExecutor) Execute

func (s *SerialEvmExecutor) Execute(block *types.Block)

func (*SerialEvmExecutor) Prepare

func (s *SerialEvmExecutor) Prepare(block *types.Block)

func (*SerialEvmExecutor) Receipts

func (s *SerialEvmExecutor) Receipts(block *types.Block) map[common.Hash]*types.Receipt

Jump to

Keyboard shortcuts

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