ebp

Documentation

Index

• Constants
• Variables
• func AddSystemAccBalance(ctx *types.Context, amount *uint256.Int) error
• func GetBlackHoleBalance(ctx *types.Context) *uint256.Int
• func GetSystemBalance(ctx *types.Context) *uint256.Int
• func LogsBloom(logs []types.Log) [256]byte
• func NewEbpTxExec(exeRoundCount, runnerNumber, parallelNum, defaultTxListCap int, ...) *txEngine
• func RunTxForRpc(currBlock *types.BlockInfo, estimateGas bool, runner *TxRunner) int64
• func StatusIsFailure(status int) bool
• func StatusToStr(status int) string
• func SubSenderAccBalance(ctx *types.Context, sender common.Address, amount *uint256.Int) error
• func SubSystemAccBalance(ctx *types.Context, amount *uint256.Int) error
• func TransferFromSenderAccToBlackHoleAcc(ctx *types.Context, sender common.Address, amount *uint256.Int) error
• type TxExecutor
• type TxRange
• type TxRunner
  • func NewTxRunner(ctx *types.Context, tx *types.TxToRun) *TxRunner

Constants

const (
	RpcRunnersIdStart int = 10000
	RpcRunnersCount   int = 256
	SMALL_BUF_SIZE    int = int(C.SMALL_BUF_SIZE)

	AdjustGasUsed = false
)

Variables

var (
	MaxTxGasLimit uint64 = 1000_0000
)

var PredefinedSystemContractExecutor types.SystemContractExecutor = nil

var RpcRunnerLocks [RpcRunnersCount]spinLock

var RpcRunners [RpcRunnersCount]*TxRunner

Its usage is similar with Runners. Runners are for transactions in block. RpcRunners are for transactions in Web3 RPC: call and estimateGas.

var Runners []*TxRunner

This is a global variable. The parameter 'collector_handler' passed to zero_depth_call_wrap is an index to select one TxRunner from this global variable.

var T1, T2, T3, T4 uint64

Functions

func AddSystemAccBalance

func AddSystemAccBalance(ctx *types.Context, amount *uint256.Int) error

func GetBlackHoleBalance

func GetBlackHoleBalance(ctx *types.Context) *uint256.Int

func GetSystemBalance

func GetSystemBalance(ctx *types.Context) *uint256.Int

func LogsBloom

func LogsBloom(logs []types.Log) [256]byte

func NewEbpTxExec

func NewEbpTxExec(exeRoundCount, runnerNumber, parallelNum, defaultTxListCap int, s gethtypes.Signer) *txEngine

func RunTxForRpc

func RunTxForRpc(currBlock *types.BlockInfo, estimateGas bool, runner *TxRunner) int64

func StatusIsFailure

func StatusIsFailure(status int) bool

func StatusToStr

func StatusToStr(status int) string

func SubSenderAccBalance

func SubSenderAccBalance(ctx *types.Context, sender common.Address, amount *uint256.Int) error

guarantee account exists externally

func SubSystemAccBalance

func SubSystemAccBalance(ctx *types.Context, amount *uint256.Int) error

func TransferFromSenderAccToBlackHoleAcc

func TransferFromSenderAccToBlackHoleAcc(ctx *types.Context, sender common.Address, amount *uint256.Int) error

Types

type TxExecutor

type TxExecutor interface {
	//step 1: for deliverTx, collect block txs in engine.txList
	CollectTx(tx *gethtypes.Transaction)
	//step 2: for commit, check sig, insert regular txs standbyTxQ
	Prepare(reorderSeed int64, minGasPrice uint64) (touchedAddrs map[common.Address]int)
	//step 3: for postCommit, parallel execute tx in standbyTxQ
	Execute(currBlock *types.BlockInfo)

	//set context
	SetContext(ctx *types.Context)
	Context() *types.Context

	//collect infos, not thread safe
	CollectTxsCount() int
	CommittedTxs() []*types.Transaction
	GasUsedInfo() (gasUsed uint64, gasRefund, gasFee uint256.Int)
	StandbyQLen() int
}

type TxRange

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

type TxRunner

type TxRunner struct {
	Ctx       *types.Context
	GasUsed   uint64
	GasRefund uint256.Int
	Tx        *types.TxToRun
	Logs      []types.EvmLog
	Status    int
	OutData   []byte
	ForRpc    bool

	CreatedContractAddress common.Address
	// contains filtered or unexported fields
}

func NewTxRunner

func NewTxRunner(ctx *types.Context, tx *types.TxToRun) *TxRunner