Documentation ¶
Overview ¶
Package miner implements Quai block creation and mining.
Index ¶
- Constants
- Variables
- func ApplyTransaction(config *params.ChainConfig, bc ChainContext, author *common.Address, ...) (*types.Receipt, error)
- func CalcGasCeil(blockNumber uint64, gasCeil uint64) uint64
- func CalcGasLimit(parent *types.Header, gasCeil uint64) uint64
- func CanTransfer(db vm.StateDB, addr common.Address, amount *big.Int) bool
- func ErrGasLimit(txGas uint64, limit uint64) error
- func GenerateChain(config *params.ChainConfig, parent *types.Block, engine consensus.Engine, ...) ([]*types.Block, []types.Receipts)
- func GenesisBlockForTesting(db ethdb.Database, addr common.Address, balance *big.Int) *types.Block
- func GetHashFn(ref *types.Header, chain ChainContext) func(n uint64) common.Hash
- func IntrinsicGas(data []byte, accessList types.AccessList, isContractCreation bool) (uint64, error)
- func NewEVMBlockContext(header *types.Header, chain ChainContext, author *common.Address) vm.BlockContext
- func NewEVMTxContext(msg Message) vm.TxContext
- func ReadGenesisAlloc(filename string) map[string]GenesisAccount
- func ReadKnot(chainfile string) []*types.Block
- func SetupGenesisBlock(db ethdb.Database, genesis *Genesis) (*params.ChainConfig, common.Hash, error)
- func SetupGenesisBlockWithOverride(db ethdb.Database, genesis *Genesis) (*params.ChainConfig, common.Hash, error)
- func Transfer(db vm.StateDB, sender, recipient common.Address, amount *big.Int) error
- type BlockGen
- func (b *BlockGen) AddTx(tx *types.Transaction, etxRLimit, etxPLimit *int)
- func (b *BlockGen) AddTxWithChain(hc *HeaderChain, tx *types.Transaction, etxRLimit, etxPLimit *int)
- func (b *BlockGen) AddUncheckedReceipt(receipt *types.Receipt)
- func (b *BlockGen) AddUncheckedTx(tx *types.Transaction)
- func (b *BlockGen) AddUncle(h *types.Header)
- func (b *BlockGen) BaseFee() *big.Int
- func (b *BlockGen) GetBalance(addr common.Address) *big.Int
- func (b *BlockGen) Number() *big.Int
- func (b *BlockGen) OffsetTime(seconds int64)
- func (b *BlockGen) PrevBlock(index int) *types.Block
- func (b *BlockGen) SetCoinbase(addr common.Address)
- func (b *BlockGen) SetDifficulty(diff *big.Int)
- func (b *BlockGen) SetExtra(data []byte)
- func (b *BlockGen) SetNonce(nonce types.BlockNonce)
- func (b *BlockGen) TxNonce(addr common.Address) uint64
- type BlockValidator
- type BloomIndexer
- type BodyDb
- func (bc *BodyDb) Append(block *types.Block, newInboundEtxs types.Transactions) ([]*types.Log, error)
- func (bc *BodyDb) Config() *params.ChainConfig
- func (bc *BodyDb) Engine() consensus.Engine
- func (bc *BodyDb) GetBlock(hash common.Hash, number uint64) *types.Block
- func (bc *BodyDb) GetBlockOrCandidate(hash common.Hash, number uint64) *types.Block
- func (bc *BodyDb) HasBlock(hash common.Hash, number uint64) bool
- func (bc *BodyDb) HasBlockAndState(hash common.Hash, number uint64) bool
- func (bc *BodyDb) ProcessingState() bool
- func (bc *BodyDb) Processor() *StateProcessor
- func (bc *BodyDb) SubscribeBlockProcessingEvent(ch chan<- bool) event.Subscription
- func (bc *BodyDb) SubscribeChainEvent(ch chan<- ChainEvent) event.Subscription
- func (bc *BodyDb) SubscribeLogsEvent(ch chan<- []*types.Log) event.Subscription
- func (bc *BodyDb) SubscribeRemovedLogsEvent(ch chan<- RemovedLogsEvent) event.Subscription
- func (bc *BodyDb) WriteBlock(block *types.Block)
- type CacheConfig
- type ChainContext
- type ChainEvent
- type ChainHeadEvent
- type ChainIndexer
- func (c *ChainIndexer) AddChildIndexer(indexer *ChainIndexer)
- func (c *ChainIndexer) Close() error
- func (c *ChainIndexer) Prune(threshold uint64) error
- func (c *ChainIndexer) SectionHead(section uint64) common.Hash
- func (c *ChainIndexer) Sections() (uint64, uint64, common.Hash)
- func (c *ChainIndexer) Start(chain ChainIndexerChain)
- type ChainIndexerBackend
- type ChainIndexerChain
- type ChainSideEvent
- type Config
- type Core
- func (c *Core) AddLocal(tx *types.Transaction) error
- func (c *Core) AddPendingEtxs(pEtxs types.PendingEtxs) error
- func (c *Core) AddPendingEtxsRollup(pEtxsRollup types.PendingEtxsRollup) error
- func (c *Core) Append(header *types.Header, domPendingHeader *types.Header, domTerminus common.Hash, ...) (types.Transactions, bool, error)
- func (c *Core) BadHashExistsInChain() bool
- func (c *Core) CalcOrder(header *types.Header) (*big.Int, int, error)
- func (c *Core) CalculateBaseFee(header *types.Header) *big.Int
- func (c *Core) Config() *params.ChainConfig
- func (c *Core) ConstructLocalMinedBlock(header *types.Header) (*types.Block, error)
- func (c *Core) Content() (map[common.InternalAddress]types.Transactions, ...)
- func (c *Core) ContentFrom(addr common.Address) (types.Transactions, types.Transactions)
- func (c *Core) ContractCode(hash common.Hash) ([]byte, error)
- func (c *Core) ContractCodeWithPrefix(hash common.Hash) ([]byte, error)
- func (c *Core) CurrentBlock() *types.Block
- func (c *Core) CurrentHeader() *types.Header
- func (c *Core) CurrentLogEntropy() *big.Int
- func (c *Core) DisablePreseal()
- func (c *Core) EnablePreseal()
- func (c *Core) Engine() consensus.Engine
- func (c *Core) Export(w io.Writer) error
- func (c *Core) ExportN(w io.Writer, first uint64, last uint64) error
- func (c *Core) GenerateRecoveryPendingHeader(pendingHeader *types.Header, checkpointHashes types.Termini) error
- func (c *Core) Genesis() *types.Block
- func (c *Core) Get(hash common.Hash) *types.Transaction
- func (c *Core) GetAncestor(hash common.Hash, number, ancestor uint64, maxNonCanonical *uint64) (common.Hash, uint64)
- func (c *Core) GetBlock(hash common.Hash, number uint64) *types.Block
- func (c *Core) GetBlockByHash(hash common.Hash) *types.Block
- func (c *Core) GetBlockByNumber(number uint64) *types.Block
- func (c *Core) GetBlockHashesFromHash(hash common.Hash, max uint64) []common.Hash
- func (c *Core) GetBlockOrCandidateByHash(hash common.Hash) *types.Block
- func (c *Core) GetBlocksFromHash(hash common.Hash, n int) []*types.Block
- func (c *Core) GetBody(hash common.Hash) *types.Body
- func (c *Core) GetBodyRLP(hash common.Hash) rlp.RawValue
- func (c *Core) GetCanonicalHash(number uint64) common.Hash
- func (c *Core) GetGasUsedInChain(block *types.Block, length int) int64
- func (c *Core) GetHeader(hash common.Hash, number uint64) *types.Header
- func (c *Core) GetHeaderByHash(hash common.Hash) *types.Header
- func (c *Core) GetHeaderByNumber(number uint64) *types.Header
- func (c *Core) GetHeaderOrCandidate(hash common.Hash, number uint64) *types.Header
- func (c *Core) GetHeaderOrCandidateByHash(hash common.Hash) *types.Header
- func (c *Core) GetManifest(blockHash common.Hash) (types.BlockManifest, error)
- func (c *Core) GetPendingEtxs(hash common.Hash) *types.PendingEtxs
- func (c *Core) GetPendingEtxsRollup(hash common.Hash) *types.PendingEtxsRollup
- func (c *Core) GetPendingHeader() (*types.Header, error)
- func (c *Core) GetReceiptsByHash(hash common.Hash) types.Receipts
- func (c *Core) GetSubManifest(slice common.Location, blockHash common.Hash) (types.BlockManifest, error)
- func (c *Core) GetTerminiByHash(hash common.Hash) *types.Termini
- func (c *Core) GetTransactionLookup(hash common.Hash) *rawdb.LegacyTxLookupEntry
- func (c *Core) GetUnclesInChain(block *types.Block, length int) []*types.Header
- func (c *Core) GetVMConfig() *vm.Config
- func (c *Core) HasBlock(hash common.Hash, number uint64) bool
- func (c *Core) HasBlockAndState(hash common.Hash, number uint64) bool
- func (c *Core) HasHeader(hash common.Hash, number uint64) bool
- func (c *Core) HasPendingEtxs(hash common.Hash) bool
- func (c *Core) Hashrate() uint64
- func (c *Core) InsertChain(blocks types.Blocks) (int, error)
- func (c *Core) InsertChainWithoutSealVerification(block *types.Block) (int, error)
- func (c *Core) IsBlockHashABadHash(hash common.Hash) bool
- func (c *Core) IsMining() bool
- func (c *Core) Miner() *Miner
- func (c *Core) NewGenesisPendigHeader(pendingHeader *types.Header)
- func (c *Core) Nonce(addr common.Address) uint64
- func (c *Core) Pending() *types.Block
- func (c *Core) PendingBlock() *types.Block
- func (c *Core) PendingBlockAndReceipts() (*types.Block, types.Receipts)
- func (c *Core) ProcessingState() bool
- func (c *Core) Processor() *StateProcessor
- func (c *Core) RequestDomToAppendOrFetch(hash common.Hash, order int)
- func (c *Core) SendPendingEtxsToDom(pEtxs types.PendingEtxs) error
- func (c *Core) SetEtherbase(addr common.Address)
- func (c *Core) SetExtra(extra []byte) error
- func (c *Core) SetGasCeil(ceil uint64)
- func (c *Core) SetGasPrice(price *big.Int)
- func (c *Core) SetRecommitInterval(interval time.Duration)
- func (c *Core) Slice() *Slice
- func (c *Core) Snapshots() *snapshot.Tree
- func (c *Core) State() (*state.StateDB, error)
- func (c *Core) StateAt(root common.Hash) (*state.StateDB, error)
- func (c *Core) StateAtBlock(block *types.Block, reexec uint64, base *state.StateDB, checkLive bool) (statedb *state.StateDB, err error)
- func (c *Core) StateAtTransaction(block *types.Block, txIndex int, reexec uint64) (Message, vm.BlockContext, *state.StateDB, error)
- func (c *Core) StateCache() state.Database
- func (c *Core) Stats() (int, int)
- func (c *Core) Stop()
- func (c *Core) StopMining()
- func (c *Core) SubRelayPendingHeader(slPendingHeader types.PendingHeader, newEntropy *big.Int, ...)
- func (c *Core) SubscribeBlockProcessingEvent(ch chan<- bool) event.Subscription
- func (c *Core) SubscribeChainEvent(ch chan<- ChainEvent) event.Subscription
- func (c *Core) SubscribeChainHeadEvent(ch chan<- ChainHeadEvent) event.Subscription
- func (c *Core) SubscribeChainSideEvent(ch chan<- ChainSideEvent) event.Subscription
- func (c *Core) SubscribeLogsEvent(ch chan<- []*types.Log) event.Subscription
- func (c *Core) SubscribeMissingParentEvent(ch chan<- common.Hash) event.Subscription
- func (c *Core) SubscribeNewTxsEvent(ch chan<- NewTxsEvent) event.Subscription
- func (c *Core) SubscribePendingHeader(ch chan<- *types.Header) event.Subscription
- func (c *Core) SubscribePendingLogs(ch chan<- []*types.Log) event.Subscription
- func (c *Core) SubscribeRemovedLogsEvent(ch chan<- RemovedLogsEvent) event.Subscription
- func (c *Core) TotalLogS(header *types.Header) *big.Int
- func (c *Core) TrieNode(hash common.Hash) ([]byte, error)
- func (c *Core) TxLookupLimit() uint64
- func (c *Core) TxPool() *TxPool
- func (c *Core) TxPoolPending(enforceTips bool) (map[common.AddressBytes]types.Transactions, error)
- func (c *Core) UpdateDom(oldTerminus common.Hash, pendingHeader types.PendingHeader, ...)
- func (c *Core) WriteBlock(block *types.Block)
- type ExecutionResult
- type GasPool
- type Genesis
- func DefaultColosseumGenesisBlock(consensusEngine string) *Genesis
- func DefaultGardenGenesisBlock(consensusEngine string) *Genesis
- func DefaultGenesisBlock() *Genesis
- func DefaultLighthouseGenesisBlock(consensusEngine string) *Genesis
- func DefaultLocalGenesisBlock(consensusEngine string) *Genesis
- func DefaultOrchardGenesisBlock(consensusEngine string) *Genesis
- func DeveloperGenesisBlock(period uint64, faucet common.Address) *Genesis
- type GenesisAccount
- type GenesisAlloc
- type GenesisMismatchError
- type HeaderChain
- func (hc *HeaderChain) AddBloom(bloom types.Bloom, hash common.Hash) error
- func (hc *HeaderChain) AddPendingEtxs(pEtxs types.PendingEtxs) error
- func (hc *HeaderChain) AppendBlock(block *types.Block, newInboundEtxs types.Transactions) error
- func (hc *HeaderChain) AppendHeader(header *types.Header) error
- func (hc *HeaderChain) CalculateBaseFee(header *types.Header) *big.Int
- func (hc *HeaderChain) CheckContext(context int) error
- func (hc *HeaderChain) CheckLocationRange(location []byte) error
- func (hc *HeaderChain) CollectEtxRollup(b *types.Block) (types.Transactions, error)
- func (hc *HeaderChain) CollectSubRollup(b *types.Block) (types.Transactions, error)
- func (hc *HeaderChain) Config() *params.ChainConfig
- func (hc *HeaderChain) CurrentBlock() *types.Block
- func (hc *HeaderChain) CurrentHeader() *types.Header
- func (hc *HeaderChain) Empty() bool
- func (hc *HeaderChain) Engine() consensus.Engine
- func (hc *HeaderChain) Export(w io.Writer) error
- func (hc *HeaderChain) ExportN(w io.Writer, first uint64, last uint64) error
- func (hc *HeaderChain) GasLimit() uint64
- func (hc *HeaderChain) GetAncestor(hash common.Hash, number, ancestor uint64, maxNonCanonical *uint64) (common.Hash, uint64)
- func (hc *HeaderChain) GetBlock(hash common.Hash, number uint64) *types.Block
- func (hc *HeaderChain) GetBlockByHash(hash common.Hash) *types.Block
- func (hc *HeaderChain) GetBlockByNumber(number uint64) *types.Block
- func (hc *HeaderChain) GetBlockFromCacheOrDb(hash common.Hash, number uint64) *types.Block
- func (hc *HeaderChain) GetBlockHashesFromHash(hash common.Hash, max uint64) []common.Hash
- func (hc *HeaderChain) GetBlockNumber(hash common.Hash) *uint64
- func (hc *HeaderChain) GetBlockOrCandidate(hash common.Hash, number uint64) *types.Block
- func (hc *HeaderChain) GetBlockOrCandidateByHash(hash common.Hash) *types.Block
- func (hc *HeaderChain) GetBlocksFromHash(hash common.Hash, n int) (blocks []*types.Block)
- func (hc *HeaderChain) GetBloom(hash common.Hash) (*types.Bloom, error)
- func (hc *HeaderChain) GetBody(hash common.Hash) *types.Body
- func (hc *HeaderChain) GetBodyRLP(hash common.Hash) rlp.RawValue
- func (hc *HeaderChain) GetCanonicalHash(number uint64) common.Hash
- func (hc *HeaderChain) GetGasUsedInChain(block *types.Block, length int) int64
- func (hc *HeaderChain) GetHeader(hash common.Hash, number uint64) *types.Header
- func (hc *HeaderChain) GetHeaderByHash(hash common.Hash) *types.Header
- func (hc *HeaderChain) GetHeaderByNumber(number uint64) *types.Header
- func (hc *HeaderChain) GetHeaderOrCandidate(hash common.Hash, number uint64) *types.Header
- func (hc *HeaderChain) GetHeaderOrCandidateByHash(hash common.Hash) *types.Header
- func (hc *HeaderChain) GetPendingEtxs(hash common.Hash) (*types.PendingEtxs, error)
- func (hc *HeaderChain) GetPendingEtxsRollup(hash common.Hash) (*types.PendingEtxsRollup, error)
- func (hc *HeaderChain) GetTerminiByHash(hash common.Hash) *types.Termini
- func (hc *HeaderChain) GetUnclesInChain(block *types.Block, length int) []*types.Header
- func (hc *HeaderChain) HasHeader(hash common.Hash, number uint64) bool
- func (hc *HeaderChain) ProcessingState() bool
- func (hc *HeaderChain) ReadInboundEtxsAndAppendBlock(header *types.Header) error
- func (hc *HeaderChain) SetCurrentHeader(head *types.Header) error
- func (hc *HeaderChain) SetGenesis(head *types.Header)
- func (hc *HeaderChain) StateAt(root common.Hash) (*state.StateDB, error)
- func (hc *HeaderChain) Stop()
- func (hc *HeaderChain) SubscribeChainHeadEvent(ch chan<- ChainHeadEvent) event.Subscription
- func (hc *HeaderChain) SubscribeChainSideEvent(ch chan<- ChainSideEvent) event.Subscription
- func (hc *HeaderChain) WriteBlock(block *types.Block)
- type HeirarchyBadHashes
- type Message
- type Miner
- func (miner *Miner) DisablePreseal()
- func (miner *Miner) EnablePreseal()
- func (miner *Miner) Hashrate() uint64
- func (miner *Miner) MakeExtraData(extra []byte) []byte
- func (miner *Miner) Mining() bool
- func (miner *Miner) Pending() *types.Block
- func (miner *Miner) PendingBlock() *types.Block
- func (miner *Miner) PendingBlockAndReceipts() (*types.Block, types.Receipts)
- func (miner *Miner) SetEtherbase(addr common.Address)
- func (miner *Miner) SetExtra(extra []byte) error
- func (miner *Miner) SetGasCeil(ceil uint64)
- func (miner *Miner) SetRecommitInterval(interval time.Duration)
- func (miner *Miner) Start(coinbase common.Address)
- func (miner *Miner) Stop()
- func (miner *Miner) StopMining()
- func (miner *Miner) SubscribePendingHeader(ch chan<- *types.Header) event.Subscription
- func (miner *Miner) SubscribePendingLogs(ch chan<- []*types.Log) event.Subscription
- type NewMinedBlockEvent
- type NewTxsEvent
- type Prefetcher
- type Processor
- type RemovedLogsEvent
- type RollingAverage
- type Slice
- func (sl *Slice) AddPendingEtxs(pEtxs types.PendingEtxs) error
- func (sl *Slice) AddPendingEtxsRollup(pEtxsRollup types.PendingEtxsRollup) error
- func (sl *Slice) AddToBadHashesList(badHashes []common.Hash)
- func (sl *Slice) Append(header *types.Header, domPendingHeader *types.Header, domTerminus common.Hash, ...) (types.Transactions, bool, error)
- func (sl *Slice) CheckForBadHashAndRecover()
- func (sl *Slice) CollectNewlyConfirmedEtxs(block *types.Block, location common.Location) (types.Transactions, types.Transactions, error)
- func (sl *Slice) ComputeRecoveryPendingHeader(hash common.Hash) types.PendingHeader
- func (sl *Slice) Config() *params.ChainConfig
- func (sl *Slice) ConstructLocalBlock(header *types.Header) (*types.Block, error)
- func (sl *Slice) ConstructLocalMinedBlock(header *types.Header) (*types.Block, error)
- func (sl *Slice) CurrentInfo(header *types.Header) bool
- func (sl *Slice) Engine() consensus.Engine
- func (sl *Slice) GenerateRecoveryPendingHeader(pendingHeader *types.Header, checkPointHashes types.Termini) error
- func (sl *Slice) GetManifest(blockHash common.Hash) (types.BlockManifest, error)
- func (sl *Slice) GetPendingBlockBody(header *types.Header) *types.Body
- func (sl *Slice) GetPendingHeader() (*types.Header, error)
- func (sl *Slice) GetSubManifest(slice common.Location, blockHash common.Hash) (types.BlockManifest, error)
- func (sl *Slice) HashExistsInBadHashesList(hash common.Hash) bool
- func (sl *Slice) HeaderChain() *HeaderChain
- func (sl *Slice) IsBlockHashABadHash(hash common.Hash) bool
- func (sl *Slice) Miner() *Miner
- func (sl *Slice) NewGenesisPendingHeader(domPendingHeader *types.Header)
- func (sl *Slice) ProcessingState() bool
- func (sl *Slice) SendPendingEtxsToDom(pEtxs types.PendingEtxs) error
- func (sl *Slice) SetHeadBackToRecoveryState(pendingHeader *types.Header, hash common.Hash) types.PendingHeader
- func (sl *Slice) Stop()
- func (sl *Slice) SubRelayPendingHeader(pendingHeader types.PendingHeader, newEntropy *big.Int, ...)
- func (sl *Slice) SubscribeMissingParentEvent(ch chan<- common.Hash) event.Subscription
- func (sl *Slice) TxPool() *TxPool
- func (sl *Slice) UpdateDom(oldTerminus common.Hash, pendingHeader types.PendingHeader, ...)
- func (sl *Slice) WriteBlock(block *types.Block)
- type StateProcessor
- func (p *StateProcessor) Apply(batch ethdb.Batch, block *types.Block, newInboundEtxs types.Transactions) ([]*types.Log, error)
- func (p *StateProcessor) ContractCode(hash common.Hash) ([]byte, error)
- func (p *StateProcessor) ContractCodeWithPrefix(hash common.Hash) ([]byte, error)
- func (p *StateProcessor) GetReceiptsByHash(hash common.Hash) types.Receipts
- func (p *StateProcessor) GetTransactionLookup(hash common.Hash) *rawdb.LegacyTxLookupEntry
- func (p *StateProcessor) GetVMConfig() *vm.Config
- func (p *StateProcessor) HasBlockAndState(hash common.Hash, number uint64) bool
- func (p *StateProcessor) HasState(hash common.Hash) bool
- func (p *StateProcessor) Process(block *types.Block, etxSet types.EtxSet) (types.Receipts, []*types.Log, *state.StateDB, uint64, error)
- func (p *StateProcessor) State() (*state.StateDB, error)
- func (p *StateProcessor) StateAt(root common.Hash) (*state.StateDB, error)
- func (p *StateProcessor) StateAtBlock(block *types.Block, reexec uint64, base *state.StateDB, checkLive bool) (statedb *state.StateDB, err error)
- func (p *StateProcessor) StateAtTransaction(block *types.Block, txIndex int, reexec uint64) (Message, vm.BlockContext, *state.StateDB, error)
- func (p *StateProcessor) StateCache() state.Database
- func (p *StateProcessor) Stop()
- func (p *StateProcessor) TrieNode(hash common.Hash) ([]byte, error)
- type StateTransition
- type TxPool
- func (pool *TxPool) AddLocal(tx *types.Transaction) error
- func (pool *TxPool) AddLocals(txs []*types.Transaction) []error
- func (pool *TxPool) AddRemote(tx *types.Transaction) errordeprecated
- func (pool *TxPool) AddRemotes(txs []*types.Transaction) []error
- func (pool *TxPool) AddRemotesSync(txs []*types.Transaction) []error
- func (pool *TxPool) Content() (map[common.InternalAddress]types.Transactions, ...)
- func (pool *TxPool) ContentFrom(addr common.InternalAddress) (types.Transactions, types.Transactions)
- func (pool *TxPool) GasPrice() *big.Int
- func (pool *TxPool) Get(hash common.Hash) *types.Transaction
- func (pool *TxPool) GetSender(hash common.Hash) (common.InternalAddress, bool)
- func (pool *TxPool) GetSenderThreadUnsafe(hash common.Hash) (common.InternalAddress, bool)
- func (pool *TxPool) Has(hash common.Hash) bool
- func (pool *TxPool) Locals() []common.InternalAddress
- func (pool *TxPool) Nonce(addr common.InternalAddress) uint64
- func (pool *TxPool) SetGasPrice(price *big.Int)
- func (pool *TxPool) SetSender(hash common.Hash, address common.InternalAddress)
- func (pool *TxPool) Stats() (int, int)
- func (pool *TxPool) Status(hashes []common.Hash) []TxStatus
- func (pool *TxPool) Stop()
- func (pool *TxPool) SubscribeNewTxsEvent(ch chan<- NewTxsEvent) event.Subscription
- func (pool *TxPool) TxPoolPending(enforceTips bool, etxSet types.EtxSet) (map[common.AddressBytes]types.Transactions, error)
- type TxPoolConfig
- type TxStatus
- type Validator
Constants ¶
const ( TriesInMemory = 128 // BlockChainVersion ensures that an incompatible database forces a resync from scratch. // // Changelog: // // - Version 4 // The following incompatible database changes were added: // * the `BlockNumber`, `TxHash`, `TxIndex`, `BlockHash` and `Index` fields of log are deleted // * the `Bloom` field of receipt is deleted // * the `BlockIndex` and `TxIndex` fields of txlookup are deleted // - Version 5 // The following incompatible database changes were added: // * the `TxHash`, `GasCost`, and `ContractAddress` fields are no longer stored for a receipt // * the `TxHash`, `GasCost`, and `ContractAddress` fields are computed by looking up the // receipts' corresponding block // - Version 6 // The following incompatible database changes were added: // * Transaction lookup information stores the corresponding block number instead of block hash // - Version 7 // The following incompatible database changes were added: // * Use freezer as the ancient database to maintain all ancient data // - Version 8 // The following incompatible database changes were added: // * New scheme for contract code in order to separate the codes and trie nodes BlockChainVersion uint64 = 8 )
Variables ¶
var ( // ErrKnownBlock is returned when a block to import is already known locally. ErrKnownBlock = errors.New("block already known") // ErrBannedHash is returned if a block to import is on the banned list. ErrBannedHash = errors.New("banned hash") // ErrNoGenesis is returned when there is no Genesis Block. ErrNoGenesis = errors.New("genesis not found in chain") // ErrSubNotSyncedToDom is returned when the subordinate cannot find the parent of the block which is being appended by the dom. ErrSubNotSyncedToDom = errors.New("sub not synced to dom") // ErrPendingEtxAlreadyKnown is returned received pending etx already in the cache/db ErrPendingEtxAlreadyKnown = errors.New("pending etx already known") // ErrBloomAlreadyKnown is returned if received bloom is already in the cache/db ErrBloomAlreadyKnown = errors.New("bloom already known") // ErrBodyNotFound is returned when body data for a given header hash cannot be found. ErrBodyNotFound = errors.New("could not find the body data to match the header root hash") // ErrDomClientNotUp is returned when block is trying to be appended when domClient is not up. ErrDomClientNotUp = errors.New("dom client is not online") // ErrBadSubManifest is returned when a block's subordinate manifest does not match the subordinate manifest hash ErrBadSubManifest = errors.New("subordinate manifest is incorrect") //ErrPendingBlock indicates the block couldn't yet be processed. This is likely due to missing information (ancestor, body, pendingEtxs, etc) ErrPendingBlock = errors.New("block cannot be appended yet") //ErrPendingEtxNotFound is returned when pendingEtxs cannot be found for a hash given in the submanifest ErrPendingEtxNotFound = errors.New("pending etx not found") //ErrBloomNotFound is returned when bloom cannot be found for a hash ErrBloomNotFound = errors.New("bloom not found") //ErrPendingEtxRollupNotFound is returned when pendingEtxsRollup cannot be found for a hash given in the submanifest ErrPendingEtxRollupNotFound = errors.New("pending etx rollup not found") //ErrPendingEtxNotValid is returned when pendingEtxs is not valid ErrPendingEtxNotValid = errors.New("pending etx not valid") //ErrPendingEtxRollupNotValid is returned when pendingEtxsRollup is not valid ErrPendingEtxRollupNotValid = errors.New("pending etx rollup not valid") // ErrBadBlockHash is returned when block being appended is in the badBlockHashes list ErrBadBlockHash = errors.New("block hash exists in bad block hashes list") // ErrPendingHeaderNotInCache is returned when a coord gives an update but the slice has not yet created the referenced ph ErrPendingHeaderNotInCache = errors.New("no pending header found in cache") )
var ( // ErrNonceTooLow is returned if the nonce of a transaction is lower than the // one present in the local chain. ErrNonceTooLow = errors.New("nonce too low") // ErrNonceTooHigh is returned if the nonce of a transaction is higher than the // next one expected based on the local chain. ErrNonceTooHigh = errors.New("nonce too high") // ErrGasLimitReached is returned by the gas pool if the amount of gas required // by a transaction is higher than what's left in the block. ErrGasLimitReached = errors.New("gas limit reached") // ErrEtxLimitReached is returned when the ETXs emitted by a transaction // would violate the block's ETX limits. ErrEtxLimitReached = errors.New("etx limit reached") // ErrInsufficientFundsForTransfer is returned if the transaction sender doesn't // have enough funds for transfer(topmost call only). ErrInsufficientFundsForTransfer = errors.New("insufficient funds for transfer") // ErrInsufficientFunds is returned if the total cost of executing a transaction // is higher than the balance of the user's account. ErrInsufficientFunds = errors.New("insufficient funds for gas * price + value") // ErrGasUintOverflow is returned when calculating gas usage. ErrGasUintOverflow = errors.New("gas uint64 overflow") // ErrIntrinsicGas is returned if the transaction is specified to use less gas // than required to start the invocation. ErrIntrinsicGas = errors.New("intrinsic gas too low") // ErrTxTypeNotSupported is returned if a transaction is not supported in the // current network configuration. ErrTxTypeNotSupported = types.ErrTxTypeNotSupported // ErrTipAboveFeeCap is a sanity error to ensure no one is able to specify a // transaction with a tip higher than the total fee cap. ErrTipAboveFeeCap = errors.New("max priority fee per gas higher than max fee per gas") // ErrTipVeryHigh is a sanity error to avoid extremely big numbers specified // in the tip field. ErrTipVeryHigh = errors.New("max priority fee per gas higher than 2^256-1") // ErrFeeCapVeryHigh is a sanity error to avoid extremely big numbers specified // in the fee cap field. ErrFeeCapVeryHigh = errors.New("max fee per gas higher than 2^256-1") // ErrFeeCapTooLow is returned if the transaction fee cap is less than the // the base fee of the block. ErrFeeCapTooLow = errors.New("max fee per gas less than block base fee") // ErrSenderNoEOA is returned if the sender of a transaction is a contract. ErrSenderNoEOA = errors.New("sender not an eoa") // ErrSenderInoperable is returned if the sender of a transaction is outside of context. ErrSenderInoperable = errors.New("sender is in inoperable state") )
List of evm-call-message pre-checking errors. All state transition messages will be pre-checked before execution. If any invalidation detected, the corresponding error should be returned which is defined here.
- If the pre-checking happens in the miner, then the transaction won't be packed. - If the pre-checking happens in the block processing procedure, then a "BAD BLOCk" error should be emitted.
var ( // ErrAlreadyKnown is returned if the transactions is already contained // within the pool. ErrAlreadyKnown = errors.New("already known") // ErrInvalidSender is returned if the transaction contains an invalid signature. ErrInvalidSender = errors.New("invalid sender") // ErrUnderpriced is returned if a transaction's gas price is below the minimum // configured for the transaction pool. ErrUnderpriced = errors.New("transaction underpriced") // ErrTxPoolOverflow is returned if the transaction pool is full and can't accpet // another remote transaction. ErrTxPoolOverflow = errors.New("txpool is full") // ErrReplaceUnderpriced is returned if a transaction is attempted to be replaced // with a different one without the required price bump. ErrReplaceUnderpriced = errors.New("replacement transaction underpriced") // ErrNegativeValue is a sanity error to ensure no one is able to specify a // transaction with a negative value. ErrNegativeValue = errors.New("negative value") // ErrOversizedData is returned if the input data of a transaction is greater // than some meaningful limit a user might use. This is not a consensus error // making the transaction invalid, rather a DOS protection. ErrOversizedData = errors.New("oversized data") )
var BadHashes = []HeirarchyBadHashes{}
var DefaultTxPoolConfig = TxPoolConfig{ Journal: "transactions.rlp", Rejournal: time.Hour, PriceLimit: 1, PriceBump: 10, AccountSlots: 1, GlobalSlots: 9000 + 1024, MaxSenders: 100000, SendersChBuffer: 1024, AccountQueue: 1, GlobalQueue: 2048, Lifetime: 3 * time.Hour, }
DefaultTxPoolConfig contains the default configurations for the transaction pool.
Functions ¶
func ApplyTransaction ¶
func ApplyTransaction(config *params.ChainConfig, bc ChainContext, author *common.Address, gp *GasPool, statedb *state.StateDB, header *types.Header, tx *types.Transaction, usedGas *uint64, cfg vm.Config, etxRLimit, etxPLimit *int) (*types.Receipt, error)
ApplyTransaction attempts to apply a transaction to the given state database and uses the input parameters for its environment. It returns the receipt for the transaction, gas used and an error if the transaction failed, indicating the block was invalid.
func CalcGasCeil ¶
func CalcGasLimit ¶
CalcGasLimit computes the gas limit of the next block after parent. It aims to keep the baseline gas close to the provided target, and increase it towards the target if the baseline gas is lower.
func CanTransfer ¶
CanTransfer checks whether there are enough funds in the address' account to make a transfer. This does not take the necessary gas in to account to make the transfer valid.
func ErrGasLimit ¶
func GenerateChain ¶
func GenerateChain(config *params.ChainConfig, parent *types.Block, engine consensus.Engine, db ethdb.Database, n int, gen func(int, *BlockGen)) ([]*types.Block, []types.Receipts)
GenerateChain creates a chain of n blocks. The first block's parent will be the provided parent. db is used to store intermediate states and should contain the parent's state trie.
The generator function is called with a new block generator for every block. Any transactions and uncles added to the generator become part of the block. If gen is nil, the blocks will be empty and their coinbase will be the zero address.
Blocks created by GenerateChain do not contain valid proof of work values. Inserting them into BlockChain requires use of FakePow or a similar non-validating proof of work implementation.
func GenesisBlockForTesting ¶
GenesisBlockForTesting creates and writes a block in which addr has the given wei balance.
func IntrinsicGas ¶
func IntrinsicGas(data []byte, accessList types.AccessList, isContractCreation bool) (uint64, error)
IntrinsicGas computes the 'intrinsic gas' for a message with the given data.
func NewEVMBlockContext ¶
func NewEVMBlockContext(header *types.Header, chain ChainContext, author *common.Address) vm.BlockContext
NewEVMBlockContext creates a new context for use in the EVM.
func NewEVMTxContext ¶
NewEVMTxContext creates a new transaction context for a single transaction.
func ReadGenesisAlloc ¶
func ReadGenesisAlloc(filename string) map[string]GenesisAccount
func SetupGenesisBlock ¶
func SetupGenesisBlock(db ethdb.Database, genesis *Genesis) (*params.ChainConfig, common.Hash, error)
SetupGenesisBlock writes or updates the genesis block in db. The block that will be used is:
genesis == nil genesis != nil +------------------------------------------ db has no genesis | main-net default | genesis db has genesis | from DB | genesis (if compatible)
The stored chain configuration will be updated if it is compatible (i.e. does not specify a fork block below the local head block). In case of a conflict, the error is a *params.ConfigCompatError and the new, unwritten config is returned.
The returned chain configuration is never nil.
Types ¶
type BlockGen ¶
type BlockGen struct {
// contains filtered or unexported fields
}
BlockGen creates blocks for testing. See GenerateChain for a detailed explanation.
func (*BlockGen) AddTx ¶
func (b *BlockGen) AddTx(tx *types.Transaction, etxRLimit, etxPLimit *int)
AddTx adds a transaction to the generated block. If no coinbase has been set, the block's coinbase is set to the zero address.
AddTx panics if the transaction cannot be executed. In addition to the protocol-imposed limitations (gas limit, etc.), there are some further limitations on the content of transactions that can be added. Notably, contract code relying on the BLOCKHASH instruction will panic during execution.
func (*BlockGen) AddTxWithChain ¶
func (b *BlockGen) AddTxWithChain(hc *HeaderChain, tx *types.Transaction, etxRLimit, etxPLimit *int)
AddTxWithChain adds a transaction to the generated block. If no coinbase has been set, the block's coinbase is set to the zero address.
AddTxWithChain panics if the transaction cannot be executed. In addition to the protocol-imposed limitations (gas limit, etc.), there are some further limitations on the content of transactions that can be added. If contract code relies on the BLOCKHASH instruction, the block in chain will be returned.
func (*BlockGen) AddUncheckedReceipt ¶
AddUncheckedReceipt forcefully adds a receipts to the block without a backing transaction.
AddUncheckedReceipt will cause consensus failures when used during real chain processing. This is best used in conjunction with raw block insertion.
func (*BlockGen) AddUncheckedTx ¶
func (b *BlockGen) AddUncheckedTx(tx *types.Transaction)
AddUncheckedTx forcefully adds a transaction to the block without any validation.
AddUncheckedTx will cause consensus failures when used during real chain processing. This is best used in conjunction with raw block insertion.
func (*BlockGen) GetBalance ¶
GetBalance returns the balance of the given address at the generated block.
func (*BlockGen) OffsetTime ¶
OffsetTime modifies the time instance of a block, implicitly changing its associated difficulty. It's useful to test scenarios where forking is not tied to chain length directly.
func (*BlockGen) PrevBlock ¶
PrevBlock returns a previously generated block by number. It panics if num is greater or equal to the number of the block being generated. For index -1, PrevBlock returns the parent block given to GenerateChain.
func (*BlockGen) SetCoinbase ¶
SetCoinbase sets the coinbase of the generated block. It can be called at most once.
func (*BlockGen) SetDifficulty ¶
SetDifficulty sets the difficulty field of the generated block. This method is useful for Clique tests where the difficulty does not depend on time. For the progpow tests, please use OffsetTime, which implicitly recalculates the diff.
func (*BlockGen) SetNonce ¶
func (b *BlockGen) SetNonce(nonce types.BlockNonce)
SetNonce sets the nonce field of the generated block.
type BlockValidator ¶
type BlockValidator struct {
// contains filtered or unexported fields
}
BlockValidator is responsible for validating block headers, uncles and processed state.
BlockValidator implements Validator.
func NewBlockValidator ¶
func NewBlockValidator(config *params.ChainConfig, headerChain *HeaderChain, engine consensus.Engine) *BlockValidator
NewBlockValidator returns a new block validator which is safe for re-use
func (*BlockValidator) ValidateBody ¶
func (v *BlockValidator) ValidateBody(block *types.Block) error
ValidateBody validates the given block's uncles and verifies the block header's transaction and uncle roots. The headers are assumed to be already validated at this point.
func (*BlockValidator) ValidateState ¶
func (v *BlockValidator) ValidateState(block *types.Block, statedb *state.StateDB, receipts types.Receipts, usedGas uint64) error
ValidateState validates the various changes that happen after a state transition, such as amount of used gas, the receipt roots and the state root itself. ValidateState returns a database batch if the validation was a success otherwise nil and an error is returned.
type BloomIndexer ¶
type BloomIndexer struct {
// contains filtered or unexported fields
}
BloomIndexer implements a core.ChainIndexer, building up a rotated bloom bits index for the Quai header bloom filters, permitting blazing fast filtering.
func (*BloomIndexer) Commit ¶
func (b *BloomIndexer) Commit() error
Commit implements core.ChainIndexerBackend, finalizing the bloom section and writing it out into the database.
func (*BloomIndexer) Process ¶
Process implements core.ChainIndexerBackend, adding a new header's bloom into the index.
func (*BloomIndexer) Prune ¶
func (b *BloomIndexer) Prune(threshold uint64) error
Prune returns an empty error since we don't support pruning here.
type BodyDb ¶
type BodyDb struct {
// contains filtered or unexported fields
}
func NewBodyDb ¶
func NewBodyDb(db ethdb.Database, engine consensus.Engine, hc *HeaderChain, chainConfig *params.ChainConfig, cacheConfig *CacheConfig, txLookupLimit *uint64, vmConfig vm.Config, slicesRunning []common.Location) (*BodyDb, error)
func (*BodyDb) Append ¶
func (bc *BodyDb) Append(block *types.Block, newInboundEtxs types.Transactions) ([]*types.Log, error)
Append
func (*BodyDb) Config ¶
func (bc *BodyDb) Config() *params.ChainConfig
Config retrieves the chain's fork configuration.
func (*BodyDb) GetBlock ¶
GetBlock retrieves a block from the database by hash and number, caching it if found.
func (*BodyDb) GetBlockOrCandidate ¶
GetBlockOrCandidate retrieves any known block from the database by hash and number, caching it if found.
func (*BodyDb) HasBlockAndState ¶
func (*BodyDb) ProcessingState ¶
func (*BodyDb) Processor ¶
func (bc *BodyDb) Processor() *StateProcessor
func (*BodyDb) SubscribeBlockProcessingEvent ¶
func (bc *BodyDb) SubscribeBlockProcessingEvent(ch chan<- bool) event.Subscription
SubscribeBlockProcessingEvent registers a subscription of bool where true means block processing has started while false means it has stopped.
func (*BodyDb) SubscribeChainEvent ¶
func (bc *BodyDb) SubscribeChainEvent(ch chan<- ChainEvent) event.Subscription
SubscribeChainEvent registers a subscription of ChainEvent.
func (*BodyDb) SubscribeLogsEvent ¶
func (bc *BodyDb) SubscribeLogsEvent(ch chan<- []*types.Log) event.Subscription
SubscribeLogsEvent registers a subscription of []*types.Log.
func (*BodyDb) SubscribeRemovedLogsEvent ¶
func (bc *BodyDb) SubscribeRemovedLogsEvent(ch chan<- RemovedLogsEvent) event.Subscription
SubscribeRemovedLogsEvent registers a subscription of RemovedLogsEvent.
func (*BodyDb) WriteBlock ¶
WriteBlock write the block to the bodydb database
type CacheConfig ¶
type CacheConfig struct { TrieCleanLimit int // Memory allowance (MB) to use for caching trie nodes in memory TrieCleanJournal string // Disk journal for saving clean cache entries. TrieCleanRejournal time.Duration // Time interval to dump clean cache to disk periodically TrieCleanNoPrefetch bool // Whether to disable heuristic state prefetching for followup blocks TrieDirtyLimit int // Memory limit (MB) at which to start flushing dirty trie nodes to disk TrieDirtyDisabled bool // Whether to disable trie write caching and GC altogether (archive node) TrieTimeLimit time.Duration // Time limit after which to flush the current in-memory trie to disk SnapshotLimit int // Memory allowance (MB) to use for caching snapshot entries in memory Preimages bool // Whether to store preimage of trie key to the disk }
CacheConfig contains the configuration values for the trie caching/pruning that's resident in a blockchain.
type ChainContext ¶
type ChainContext interface { // Engine retrieves the chain's consensus engine. Engine() consensus.Engine // GetHeader returns the hash corresponding to their hash. GetHeader(common.Hash, uint64) *types.Header }
ChainContext supports retrieving headers and consensus parameters from the current blockchain to be used during transaction processing.
type ChainHeadEvent ¶
type ChainIndexer ¶
type ChainIndexer struct { GetBloom func(common.Hash) (*types.Bloom, error) // contains filtered or unexported fields }
ChainIndexer does a post-processing job for equally sized sections of the canonical chain (like BlooomBits and CHT structures). A ChainIndexer is connected to the blockchain through the event system by starting a ChainHeadEventLoop in a goroutine.
Further child ChainIndexers can be added which use the output of the parent section indexer. These child indexers receive new head notifications only after an entire section has been finished or in case of rollbacks that might affect already finished sections.
func NewBloomIndexer ¶
func NewBloomIndexer(db ethdb.Database, size, confirms uint64) *ChainIndexer
NewBloomIndexer returns a chain indexer that generates bloom bits data for the canonical chain for fast logs filtering.
func NewChainIndexer ¶
func NewChainIndexer(chainDb ethdb.Database, indexDb ethdb.Database, backend ChainIndexerBackend, section, confirm uint64, throttling time.Duration, kind string) *ChainIndexer
NewChainIndexer creates a new chain indexer to do background processing on chain segments of a given size after certain number of confirmations passed. The throttling parameter might be used to prevent database thrashing.
func (*ChainIndexer) AddChildIndexer ¶
func (c *ChainIndexer) AddChildIndexer(indexer *ChainIndexer)
AddChildIndexer adds a child ChainIndexer that can use the output of this one
func (*ChainIndexer) Close ¶
func (c *ChainIndexer) Close() error
Close tears down all goroutines belonging to the indexer and returns any error that might have occurred internally.
func (*ChainIndexer) Prune ¶
func (c *ChainIndexer) Prune(threshold uint64) error
Prune deletes all chain data older than given threshold.
func (*ChainIndexer) SectionHead ¶
func (c *ChainIndexer) SectionHead(section uint64) common.Hash
SectionHead retrieves the last block hash of a processed section from the index database.
func (*ChainIndexer) Sections ¶
func (c *ChainIndexer) Sections() (uint64, uint64, common.Hash)
Sections returns the number of processed sections maintained by the indexer and also the information about the last header indexed for potential canonical verifications.
func (*ChainIndexer) Start ¶
func (c *ChainIndexer) Start(chain ChainIndexerChain)
Start creates a goroutine to feed chain head events into the indexer for cascading background processing. Children do not need to be started, they are notified about new events by their parents.
type ChainIndexerBackend ¶
type ChainIndexerBackend interface { // Reset initiates the processing of a new chain segment, potentially terminating // any partially completed operations (in case of a reorg). Reset(ctx context.Context, section uint64, prevHead common.Hash) error // Process crunches through the next header in the chain segment. The caller // will ensure a sequential order of headers. Process(ctx context.Context, header *types.Header, bloom types.Bloom) error // Commit finalizes the section metadata and stores it into the database. Commit() error // Prune deletes the chain index older than the given threshold. Prune(threshold uint64) error }
ChainIndexerBackend defines the methods needed to process chain segments in the background and write the segment results into the database. These can be used to create filter blooms or CHTs.
type ChainIndexerChain ¶
type ChainIndexerChain interface { // CurrentHeader retrieves the latest locally known header. CurrentHeader() *types.Header // GetBloom retrieves the bloom for the given block hash. GetBloom(blockhash common.Hash) (*types.Bloom, error) // SubscribeChainHeadEvent subscribes to new head header notifications. SubscribeChainHeadEvent(ch chan<- ChainHeadEvent) event.Subscription }
ChainIndexerChain interface is used for connecting the indexer to a blockchain
type ChainSideEvent ¶
type Config ¶
type Config struct { Etherbase common.Address `toml:",omitempty"` // Public address for block mining rewards (default = first account) Notify []string `toml:",omitempty"` // HTTP URL list to be notified of new work packages (only useful in ethash). NotifyFull bool `toml:",omitempty"` // Notify with pending block headers instead of work packages ExtraData hexutil.Bytes `toml:",omitempty"` // Block extra data set by the miner GasFloor uint64 // Target gas floor for mined blocks. GasCeil uint64 // Target gas ceiling for mined blocks. GasPrice *big.Int // Minimum gas price for mining a transaction Recommit time.Duration // The time interval for miner to re-create mining work. Noverify bool // Disable remote mining solution verification(only useful in ethash). }
Config is the configuration parameters of mining.
type Core ¶
type Core struct {
// contains filtered or unexported fields
}
func NewCore ¶
func NewCore(db ethdb.Database, config *Config, isLocalBlock func(block *types.Header) bool, txConfig *TxPoolConfig, txLookupLimit *uint64, chainConfig *params.ChainConfig, slicesRunning []common.Location, domClientUrl string, subClientUrls []string, engine consensus.Engine, cacheConfig *CacheConfig, vmConfig vm.Config, genesis *Genesis) (*Core, error)
func (*Core) AddPendingEtxs ¶
func (c *Core) AddPendingEtxs(pEtxs types.PendingEtxs) error
func (*Core) AddPendingEtxsRollup ¶
func (c *Core) AddPendingEtxsRollup(pEtxsRollup types.PendingEtxsRollup) error
func (*Core) BadHashExistsInChain ¶
func (*Core) CalculateBaseFee ¶
GetGasUsedInChain retrieves all the gas used from a given block backwards until a specific distance is reached.
func (*Core) Config ¶
func (c *Core) Config() *params.ChainConfig
func (*Core) ConstructLocalMinedBlock ¶
ConstructLocalBlock takes a header and construct the Block locally
func (*Core) Content ¶
func (c *Core) Content() (map[common.InternalAddress]types.Transactions, map[common.InternalAddress]types.Transactions)
func (*Core) ContentFrom ¶
func (c *Core) ContentFrom(addr common.Address) (types.Transactions, types.Transactions)
func (*Core) ContractCode ¶
ContractCode retrieves a blob of data associated with a contract hash either from ephemeral in-memory cache, or from persistent storage.
func (*Core) ContractCodeWithPrefix ¶
ContractCodeWithPrefix retrieves a blob of data associated with a contract hash either from ephemeral in-memory cache, or from persistent storage.
If the code doesn't exist in the in-memory cache, check the storage with new code scheme.
func (*Core) CurrentBlock ¶
CurrentBlock returns the block for the current header.
func (*Core) CurrentHeader ¶
CurrentHeader retrieves the current head header of the canonical chain. The header is retrieved from the HeaderChain's internal cache.
func (*Core) CurrentLogEntropy ¶
CurrentLogEntropy returns the logarithm of the total entropy reduction since genesis for our current head block
func (*Core) DisablePreseal ¶
func (c *Core) DisablePreseal()
DisablePreseal turns off the preseal mining feature. It's necessary for some fake consensus engine which can seal blocks instantaneously. Note this function shouldn't be exposed to API, it's unnecessary for users (miners) to actually know the underlying detail. It's only for outside project which uses this library.
func (*Core) EnablePreseal ¶
func (c *Core) EnablePreseal()
EnablePreseal turns on the preseal mining feature. It's enabled by default. Note this function shouldn't be exposed to API, it's unnecessary for users (miners) to actually know the underlying detail. It's only for outside project which uses this library.
func (*Core) GenerateRecoveryPendingHeader ¶
func (*Core) GetAncestor ¶
func (c *Core) GetAncestor(hash common.Hash, number, ancestor uint64, maxNonCanonical *uint64) (common.Hash, uint64)
GetAncestor retrieves the Nth ancestor of a given block. It assumes that either the given block or a close ancestor of it is canonical. maxNonCanonical points to a downwards counter limiting the number of blocks to be individually checked before we reach the canonical chain.
Note: ancestor == 0 returns the same block, 1 returns its parent and so on.
func (*Core) GetBlock ¶
GetBlock retrieves a block from the database by hash and number, caching it if found.
func (*Core) GetBlockByHash ¶
GetBlockByHash retrieves a block from the database by hash, caching it if found.
func (*Core) GetBlockByNumber ¶
GetBlockByNumber retrieves a block from the database by number, caching it (associated with its hash) if found.
func (*Core) GetBlockHashesFromHash ¶
GetBlockHashesFromHash retrieves a number of block hashes starting at a given hash, fetching towards the genesis block.
func (*Core) GetBlockOrCandidateByHash ¶
GetBlockOrCandidateByHash retrieves a block from the database by hash, caching it if found.
func (*Core) GetBlocksFromHash ¶
GetBlocksFromHash returns the block corresponding to hash and up to n-1 ancestors. [deprecated by eth/62]
func (*Core) GetBody ¶
GetBody retrieves a block body (transactions and uncles) from the database by hash, caching it if found.
func (*Core) GetBodyRLP ¶
GetBodyRLP retrieves a block body in RLP encoding from the database by hash, caching it if found.
func (*Core) GetCanonicalHash ¶
GetCanonicalHash returns the canonical hash for a given block number
func (*Core) GetGasUsedInChain ¶
GetGasUsedInChain retrieves all the gas used from a given block backwards until a specific distance is reached.
func (*Core) GetHeader ¶
GetHeader retrieves a block header from the database by hash and number, caching it if found.
func (*Core) GetHeaderByHash ¶
GetHeaderByHash retrieves a block header from the database by hash, caching it if found.
func (*Core) GetHeaderByNumber ¶
GetHeaderByNumber retrieves a block header from the database by number, caching it (associated with its hash) if found.
func (*Core) GetHeaderOrCandidate ¶
GetHeaderOrCandidate retrieves a block header from the database by hash and number, caching it if found.
func (*Core) GetHeaderOrCandidateByHash ¶
GetHeaderOrCandidateByHash retrieves a block header from the database by hash, caching it if found.
func (*Core) GetManifest ¶
func (*Core) GetPendingEtxs ¶
func (c *Core) GetPendingEtxs(hash common.Hash) *types.PendingEtxs
func (*Core) GetPendingEtxsRollup ¶
func (c *Core) GetPendingEtxsRollup(hash common.Hash) *types.PendingEtxsRollup
func (*Core) GetReceiptsByHash ¶
GetReceiptsByHash retrieves the receipts for all transactions in a given block.
func (*Core) GetSubManifest ¶
func (*Core) GetTerminiByHash ¶
GetTerminiByHash retrieves the termini stored for a given header hash
func (*Core) GetTransactionLookup ¶
func (c *Core) GetTransactionLookup(hash common.Hash) *rawdb.LegacyTxLookupEntry
GetTransactionLookup retrieves the lookup associate with the given transaction hash from the cache or database.
func (*Core) GetUnclesInChain ¶
GetUnclesInChain retrieves all the uncles from a given block backwards until a specific distance is reached.
func (*Core) GetVMConfig ¶
GetVMConfig returns the block chain VM config.
func (*Core) HasBlockAndState ¶
func (*Core) HasHeader ¶
HasHeader checks if a block header is present in the database or not, caching it if present.
func (*Core) InsertChain ¶
InsertChain attempts to append a list of blocks to the slice, optionally caching any pending blocks which cannot yet be appended. InsertChain return the number of blocks which were successfully consumed (either appended, or cached), and an error.
func (*Core) InsertChainWithoutSealVerification ¶
InsertChainWithoutSealVerification works exactly the same except for seal verification, seal verification is omitted
func (*Core) NewGenesisPendigHeader ¶
func (*Core) PendingBlock ¶
PendingBlock returns the currently pending block.
Note, to access both the pending block and the pending state simultaneously, please use Pending(), as the pending state can change between multiple method calls
func (*Core) PendingBlockAndReceipts ¶
PendingBlockAndReceipts returns the currently pending block and corresponding receipts.
func (*Core) ProcessingState ¶
func (*Core) Processor ¶
func (c *Core) Processor() *StateProcessor
func (*Core) RequestDomToAppendOrFetch ¶
func (*Core) SendPendingEtxsToDom ¶
func (c *Core) SendPendingEtxsToDom(pEtxs types.PendingEtxs) error
func (*Core) SetEtherbase ¶
func (*Core) SetGasCeil ¶
SetGasCeil sets the gaslimit to strive for when mining blocks.
func (*Core) SetGasPrice ¶
func (*Core) SetRecommitInterval ¶
func (*Core) StateAtBlock ¶
func (*Core) StateAtTransaction ¶
func (*Core) StateCache ¶
StateCache returns the caching database underpinning the blockchain instance.
func (*Core) StopMining ¶
func (c *Core) StopMining()
func (*Core) SubRelayPendingHeader ¶
func (*Core) SubscribeBlockProcessingEvent ¶
func (c *Core) SubscribeBlockProcessingEvent(ch chan<- bool) event.Subscription
SubscribeBlockProcessingEvent registers a subscription of bool where true means block processing has started while false means it has stopped.
func (*Core) SubscribeChainEvent ¶
func (c *Core) SubscribeChainEvent(ch chan<- ChainEvent) event.Subscription
SubscribeChainEvent registers a subscription of ChainEvent.
func (*Core) SubscribeChainHeadEvent ¶
func (c *Core) SubscribeChainHeadEvent(ch chan<- ChainHeadEvent) event.Subscription
SubscribeChainHeadEvent registers a subscription of ChainHeadEvent.
func (*Core) SubscribeChainSideEvent ¶
func (c *Core) SubscribeChainSideEvent(ch chan<- ChainSideEvent) event.Subscription
SubscribeChainSideEvent registers a subscription of ChainSideEvent.
func (*Core) SubscribeLogsEvent ¶
func (c *Core) SubscribeLogsEvent(ch chan<- []*types.Log) event.Subscription
SubscribeChainSideEvent registers a subscription of ChainSideEvent.
func (*Core) SubscribeMissingParentEvent ¶
func (c *Core) SubscribeMissingParentEvent(ch chan<- common.Hash) event.Subscription
func (*Core) SubscribeNewTxsEvent ¶
func (c *Core) SubscribeNewTxsEvent(ch chan<- NewTxsEvent) event.Subscription
func (*Core) SubscribePendingHeader ¶
func (c *Core) SubscribePendingHeader(ch chan<- *types.Header) event.Subscription
SubscribePendingBlock starts delivering the pending block to the given channel.
func (*Core) SubscribePendingLogs ¶
func (c *Core) SubscribePendingLogs(ch chan<- []*types.Log) event.Subscription
SubscribePendingLogs starts delivering logs from pending transactions to the given channel.
func (*Core) SubscribeRemovedLogsEvent ¶
func (c *Core) SubscribeRemovedLogsEvent(ch chan<- RemovedLogsEvent) event.Subscription
SubscribeChainHeadEvent registers a subscription of ChainHeadEvent.
func (*Core) TotalLogS ¶
TotalLogS returns the total entropy reduction if the chain since genesis to the given header
func (*Core) TxLookupLimit ¶
func (*Core) TxPoolPending ¶
func (c *Core) TxPoolPending(enforceTips bool) (map[common.AddressBytes]types.Transactions, error)
func (*Core) WriteBlock ¶
WriteBlock write the block to the bodydb database
type ExecutionResult ¶
type ExecutionResult struct { UsedGas uint64 // Total used gas but include the refunded gas Err error // Any error encountered during the execution(listed in core/vm/errors.go) ReturnData []byte // Returned data from evm(function result or data supplied with revert opcode) Etxs []*types.Transaction // External transactions generated from opETX }
ExecutionResult includes all output after executing given evm message no matter the execution itself is successful or not.
func ApplyMessage ¶
ApplyMessage computes the new state by applying the given message against the old state within the environment.
ApplyMessage returns the bytes returned by any EVM execution (if it took place), the gas used (which includes gas refunds) and an error if it failed. An error always indicates a core error meaning that the message would always fail for that particular state and would never be accepted within a block.
func (*ExecutionResult) Failed ¶
func (result *ExecutionResult) Failed() bool
Failed returns the indicator whether the execution is successful or not
func (*ExecutionResult) Return ¶
func (result *ExecutionResult) Return() []byte
Return is a helper function to help caller distinguish between revert reason and function return. Return returns the data after execution if no error occurs.
func (*ExecutionResult) Revert ¶
func (result *ExecutionResult) Revert() []byte
Revert returns the concrete revert reason if the execution is aborted by `REVERT` opcode. Note the reason can be nil if no data supplied with revert opcode.
func (*ExecutionResult) Unwrap ¶
func (result *ExecutionResult) Unwrap() error
Unwrap returns the internal evm error which allows us for further analysis outside.
type GasPool ¶
type GasPool uint64
GasPool tracks the amount of gas available during execution of the transactions in a block. The zero value is a pool with zero gas available.
type Genesis ¶
type Genesis struct { Config *params.ChainConfig `json:"config"` Nonce uint64 `json:"nonce"` Timestamp uint64 `json:"timestamp"` ExtraData []byte `json:"extraData"` GasLimit uint64 `json:"gasLimit" gencodec:"required"` Difficulty *big.Int `json:"difficulty" gencodec:"required"` Mixhash common.Hash `json:"mixHash"` Coinbase common.Address `json:"coinbase"` // These fields are used for consensus tests. Please don't use them // in actual genesis blocks. Number []uint64 `json:"number"` GasUsed uint64 `json:"gasUsed"` ParentHash []common.Hash `json:"parentHash"` BaseFee *big.Int `json:"baseFeePerGas"` }
Genesis specifies the header fields, state of a genesis block. It also defines hard fork switch-over blocks through the chain configuration.
func DefaultColosseumGenesisBlock ¶
DefaultColosseumGenesisBlock returns the Quai Colosseum testnet genesis block.
func DefaultGardenGenesisBlock ¶
DefaultGardenGenesisBlock returns the Garden testnet genesis block.
func DefaultGenesisBlock ¶
func DefaultGenesisBlock() *Genesis
DefaultGenesisBlock returns the Latest default Genesis block. Currently it returns the DefaultColosseumGenesisBlock.
func DefaultLighthouseGenesisBlock ¶
DefaultLighthouseGenesisBlock returns the Lighthouse testnet genesis block.
func DefaultLocalGenesisBlock ¶
DefaultLocalGenesisBlock returns the Local testnet genesis block.
func DefaultOrchardGenesisBlock ¶
DefaultOrchardGenesisBlock returns the Orchard testnet genesis block.
func DeveloperGenesisBlock ¶
DeveloperGenesisBlock returns the 'quai --dev' genesis block.
func (*Genesis) Commit ¶
Commit writes the block and state of a genesis specification to the database. The block is committed as the canonical head block.
func (Genesis) MarshalJSON ¶
MarshalJSON marshals as JSON.
func (*Genesis) MustCommit ¶
MustCommit writes the genesis block and state to db, panicking on error. The block is committed as the canonical head block.
func (*Genesis) ToBlock ¶
ToBlock creates the genesis block and writes state of a genesis specification to the given database (or discards it if nil).
func (*Genesis) UnmarshalJSON ¶
UnmarshalJSON unmarshals from JSON.
type GenesisAccount ¶
type GenesisAccount struct { Code []byte `json:"code,omitempty"` Storage map[common.Hash]common.Hash `json:"storage,omitempty"` Balance *big.Int `json:"balance" gencodec:"required"` Nonce uint64 `json:"nonce,omitempty"` PrivateKey []byte `json:"secretKey,omitempty"` // for tests }
GenesisAccount is an account in the state of the genesis block.
func (GenesisAccount) MarshalJSON ¶
func (g GenesisAccount) MarshalJSON() ([]byte, error)
MarshalJSON marshals as JSON.
func (*GenesisAccount) UnmarshalJSON ¶
func (g *GenesisAccount) UnmarshalJSON(input []byte) error
UnmarshalJSON unmarshals from JSON.
type GenesisAlloc ¶
type GenesisAlloc map[common.Address]GenesisAccount
GenesisAlloc specifies the initial state that is part of the genesis block.
func (*GenesisAlloc) UnmarshalJSON ¶
func (ga *GenesisAlloc) UnmarshalJSON(data []byte) error
type GenesisMismatchError ¶
GenesisMismatchError is raised when trying to overwrite an existing genesis block with an incompatible one.
func (*GenesisMismatchError) Error ¶
func (e *GenesisMismatchError) Error() string
type HeaderChain ¶
type HeaderChain struct {
// contains filtered or unexported fields
}
func NewHeaderChain ¶
func NewHeaderChain(db ethdb.Database, engine consensus.Engine, chainConfig *params.ChainConfig, cacheConfig *CacheConfig, txLookupLimit *uint64, vmConfig vm.Config, slicesRunning []common.Location) (*HeaderChain, error)
NewHeaderChain creates a new HeaderChain structure. ProcInterrupt points to the parent's interrupt semaphore.
func (*HeaderChain) AddPendingEtxs ¶
func (hc *HeaderChain) AddPendingEtxs(pEtxs types.PendingEtxs) error
func (*HeaderChain) AppendBlock ¶
func (hc *HeaderChain) AppendBlock(block *types.Block, newInboundEtxs types.Transactions) error
Append
func (*HeaderChain) AppendHeader ¶
func (hc *HeaderChain) AppendHeader(header *types.Header) error
Append
func (*HeaderChain) CalculateBaseFee ¶
func (hc *HeaderChain) CalculateBaseFee(header *types.Header) *big.Int
GetGasUsedInChain retrieves all the gas used from a given block backwards until a specific distance is reached.
func (*HeaderChain) CheckContext ¶
func (hc *HeaderChain) CheckContext(context int) error
CheckContext checks to make sure the range of a context or order is valid
func (*HeaderChain) CheckLocationRange ¶
func (hc *HeaderChain) CheckLocationRange(location []byte) error
CheckLocationRange checks to make sure the range of r and z are valid
func (*HeaderChain) CollectEtxRollup ¶
func (hc *HeaderChain) CollectEtxRollup(b *types.Block) (types.Transactions, error)
Collect all emmitted ETXs since the last coincident block, but excluding those emitted in this block
func (*HeaderChain) CollectSubRollup ¶
func (hc *HeaderChain) CollectSubRollup(b *types.Block) (types.Transactions, error)
CollectSubRollup collects the rollup of ETXs emitted from the subordinate chain in the slice which emitted the given block.
func (*HeaderChain) Config ¶
func (hc *HeaderChain) Config() *params.ChainConfig
Config retrieves the header chain's chain configuration.
func (*HeaderChain) CurrentBlock ¶
func (hc *HeaderChain) CurrentBlock() *types.Block
CurrentBlock returns the block for the current header.
func (*HeaderChain) CurrentHeader ¶
func (hc *HeaderChain) CurrentHeader() *types.Header
CurrentHeader retrieves the current head header of the canonical chain. The header is retrieved from the HeaderChain's internal cache.
func (*HeaderChain) Empty ¶
func (hc *HeaderChain) Empty() bool
Empty checks if the headerchain is empty.
func (*HeaderChain) Engine ¶
func (hc *HeaderChain) Engine() consensus.Engine
Engine reterives the consensus engine.
func (*HeaderChain) Export ¶
func (hc *HeaderChain) Export(w io.Writer) error
Export writes the active chain to the given writer.
func (*HeaderChain) GasLimit ¶
func (hc *HeaderChain) GasLimit() uint64
GasLimit returns the gas limit of the current HEAD block.
func (*HeaderChain) GetAncestor ¶
func (hc *HeaderChain) GetAncestor(hash common.Hash, number, ancestor uint64, maxNonCanonical *uint64) (common.Hash, uint64)
GetAncestor retrieves the Nth ancestor of a given block. It assumes that either the given block or a close ancestor of it is canonical. maxNonCanonical points to a downwards counter limiting the number of blocks to be individually checked before we reach the canonical chain.
Note: ancestor == 0 returns the same block, 1 returns its parent and so on.
func (*HeaderChain) GetBlock ¶
GetBlock implements consensus.ChainReader, and returns nil for every input as a header chain does not have blocks available for retrieval.
func (*HeaderChain) GetBlockByHash ¶
func (hc *HeaderChain) GetBlockByHash(hash common.Hash) *types.Block
GetBlockByHash retrieves a block from the database by hash, caching it if found.
func (*HeaderChain) GetBlockByNumber ¶
func (hc *HeaderChain) GetBlockByNumber(number uint64) *types.Block
GetBlockByNumber retrieves a block from the database by number, caching it (associated with its hash) if found.
func (*HeaderChain) GetBlockFromCacheOrDb ¶
GetBlockFromCacheOrDb looks up the body cache first and then checks the db
func (*HeaderChain) GetBlockHashesFromHash ¶
GetBlockHashesFromHash retrieves a number of block hashes starting at a given hash, fetching towards the genesis block.
func (*HeaderChain) GetBlockNumber ¶
func (hc *HeaderChain) GetBlockNumber(hash common.Hash) *uint64
GetBlockNumber retrieves the block number belonging to the given hash from the cache or database
func (*HeaderChain) GetBlockOrCandidate ¶
func (*HeaderChain) GetBlockOrCandidateByHash ¶
func (hc *HeaderChain) GetBlockOrCandidateByHash(hash common.Hash) *types.Block
GetBlockOrCandidateByHash retrieves any block from the database by hash, caching it if found.
func (*HeaderChain) GetBlocksFromHash ¶
GetBlocksFromHash returns the block corresponding to hash and up to n-1 ancestors. [deprecated by eth/62]
func (*HeaderChain) GetBody ¶
func (hc *HeaderChain) GetBody(hash common.Hash) *types.Body
GetBody retrieves a block body (transactions and uncles) from the database by hash, caching it if found.
func (*HeaderChain) GetBodyRLP ¶
func (hc *HeaderChain) GetBodyRLP(hash common.Hash) rlp.RawValue
GetBodyRLP retrieves a block body in RLP encoding from the database by hash, caching it if found.
func (*HeaderChain) GetCanonicalHash ¶
func (hc *HeaderChain) GetCanonicalHash(number uint64) common.Hash
func (*HeaderChain) GetGasUsedInChain ¶
func (hc *HeaderChain) GetGasUsedInChain(block *types.Block, length int) int64
GetGasUsedInChain retrieves all the gas used from a given block backwards until a specific distance is reached.
func (*HeaderChain) GetHeader ¶
GetHeader retrieves a block header from the database by hash and number, caching it if found.
func (*HeaderChain) GetHeaderByHash ¶
func (hc *HeaderChain) GetHeaderByHash(hash common.Hash) *types.Header
GetHeaderByHash retrieves a block header from the database by hash, caching it if found.
func (*HeaderChain) GetHeaderByNumber ¶
func (hc *HeaderChain) GetHeaderByNumber(number uint64) *types.Header
GetHeaderByNumber retrieves a block header from the database by number, caching it (associated with its hash) if found.
func (*HeaderChain) GetHeaderOrCandidate ¶
GetHeaderOrCandidate retrieves a block header from the database by hash and number, caching it if found.
func (*HeaderChain) GetHeaderOrCandidateByHash ¶
func (hc *HeaderChain) GetHeaderOrCandidateByHash(hash common.Hash) *types.Header
GetHeaderOrCandidateByHash retrieves a block header from the database by hash, caching it if found.
func (*HeaderChain) GetPendingEtxs ¶
func (hc *HeaderChain) GetPendingEtxs(hash common.Hash) (*types.PendingEtxs, error)
GetPendingEtxs gets the pendingEtxs form the
func (*HeaderChain) GetPendingEtxsRollup ¶
func (hc *HeaderChain) GetPendingEtxsRollup(hash common.Hash) (*types.PendingEtxsRollup, error)
func (*HeaderChain) GetTerminiByHash ¶
func (hc *HeaderChain) GetTerminiByHash(hash common.Hash) *types.Termini
func (*HeaderChain) GetUnclesInChain ¶
GetUnclesInChain retrieves all the uncles from a given block backwards until a specific distance is reached.
func (*HeaderChain) HasHeader ¶
func (hc *HeaderChain) HasHeader(hash common.Hash, number uint64) bool
HasHeader checks if a block header is present in the database or not. In theory, if header is present in the database, all relative components like td and hash->number should be present too.
func (*HeaderChain) ProcessingState ¶
func (hc *HeaderChain) ProcessingState() bool
func (*HeaderChain) ReadInboundEtxsAndAppendBlock ¶
func (hc *HeaderChain) ReadInboundEtxsAndAppendBlock(header *types.Header) error
ReadInboundEtxsAndAppendBlock reads the inbound etxs from database and appends the block
func (*HeaderChain) SetCurrentHeader ¶
func (hc *HeaderChain) SetCurrentHeader(head *types.Header) error
SetCurrentHeader sets the in-memory head header marker of the canonical chan as the given header.
func (*HeaderChain) SetGenesis ¶
func (hc *HeaderChain) SetGenesis(head *types.Header)
SetGenesis sets a new genesis block header for the chain
func (*HeaderChain) Stop ¶
func (hc *HeaderChain) Stop()
Stop stops the blockchain service. If any imports are currently in progress it will abort them using the procInterrupt.
func (*HeaderChain) SubscribeChainHeadEvent ¶
func (hc *HeaderChain) SubscribeChainHeadEvent(ch chan<- ChainHeadEvent) event.Subscription
SubscribeChainHeadEvent registers a subscription of ChainHeadEvent.
func (*HeaderChain) SubscribeChainSideEvent ¶
func (hc *HeaderChain) SubscribeChainSideEvent(ch chan<- ChainSideEvent) event.Subscription
SubscribeChainSideEvent registers a subscription of ChainSideEvent.
func (*HeaderChain) WriteBlock ¶
func (hc *HeaderChain) WriteBlock(block *types.Block)
type HeirarchyBadHashes ¶
type Message ¶
type Message interface { From() common.Address To() *common.Address GasPrice() *big.Int GasFeeCap() *big.Int GasTipCap() *big.Int Gas() uint64 Value() *big.Int Nonce() uint64 CheckNonce() bool Data() []byte AccessList() types.AccessList ETXSender() common.Address Type() byte ETXGasLimit() uint64 ETXGasPrice() *big.Int ETXGasTip() *big.Int ETXData() []byte ETXAccessList() types.AccessList }
Message represents a message sent to a contract.
type Miner ¶
type Miner struct {
// contains filtered or unexported fields
}
Miner creates blocks and searches for proof-of-work values.
func (*Miner) DisablePreseal ¶
func (miner *Miner) DisablePreseal()
DisablePreseal turns off the preseal mining feature. It's necessary for some fake consensus engine which can seal blocks instantaneously. Note this function shouldn't be exposed to API, it's unnecessary for users (miners) to actually know the underlying detail. It's only for outside project which uses this library.
func (*Miner) EnablePreseal ¶
func (miner *Miner) EnablePreseal()
EnablePreseal turns on the preseal mining feature. It's enabled by default. Note this function shouldn't be exposed to API, it's unnecessary for users (miners) to actually know the underlying detail. It's only for outside project which uses this library.
func (*Miner) MakeExtraData ¶
func (*Miner) PendingBlock ¶
PendingBlock returns the currently pending block.
Note, to access both the pending block and the pending state simultaneously, please use Pending(), as the pending state can change between multiple method calls
func (*Miner) PendingBlockAndReceipts ¶
PendingBlockAndReceipts returns the currently pending block and corresponding receipts.
func (*Miner) SetEtherbase ¶
func (*Miner) SetGasCeil ¶
SetGasCeil sets the gaslimit to strive for when mining blocks.
func (*Miner) SetRecommitInterval ¶
SetRecommitInterval sets the interval for sealing work resubmitting.
func (*Miner) StopMining ¶
func (miner *Miner) StopMining()
func (*Miner) SubscribePendingHeader ¶
func (miner *Miner) SubscribePendingHeader(ch chan<- *types.Header) event.Subscription
SubscribePendingBlock starts delivering the pending block to the given channel.
func (*Miner) SubscribePendingLogs ¶
func (miner *Miner) SubscribePendingLogs(ch chan<- []*types.Log) event.Subscription
SubscribePendingLogs starts delivering logs from pending transactions to the given channel.
type NewMinedBlockEvent ¶
NewMinedBlockEvent is posted when a block has been imported.
type NewTxsEvent ¶
type NewTxsEvent struct{ Txs []*types.Transaction }
NewTxsEvent is posted when a batch of transactions enter the transaction pool.
type Prefetcher ¶
type Prefetcher interface { // Prefetch processes the state changes according to the Quai rules by running // the transaction messages using the statedb, but any changes are discarded. The // only goal is to pre-cache transaction signatures and state trie nodes. Prefetch(block *types.Block, statedb *state.StateDB, cfg vm.Config, interrupt *uint32) }
Prefetcher is an interface for pre-caching transaction signatures and state.
type Processor ¶
type Processor interface { // Process processes the state changes according to the Quai rules by running // the transaction messages using the statedb and applying any rewards to both // the processor (coinbase) and any included uncles. Process(block *types.Block, statedb *state.StateDB, cfg vm.Config) (types.Receipts, []*types.Log, uint64, error) Apply(block *types.Block) error }
Processor is an interface for processing blocks using a given initial state.
type RemovedLogsEvent ¶
RemovedLogsEvent is posted when a reorg happens
type RollingAverage ¶
type RollingAverage struct {
// contains filtered or unexported fields
}
func (*RollingAverage) Add ¶
func (ra *RollingAverage) Add(d time.Duration)
func (*RollingAverage) Average ¶
func (ra *RollingAverage) Average() time.Duration
type Slice ¶
type Slice struct {
// contains filtered or unexported fields
}
func NewSlice ¶
func NewSlice(db ethdb.Database, config *Config, txConfig *TxPoolConfig, txLookupLimit *uint64, isLocalBlock func(block *types.Header) bool, chainConfig *params.ChainConfig, slicesRunning []common.Location, domClientUrl string, subClientUrls []string, engine consensus.Engine, cacheConfig *CacheConfig, vmConfig vm.Config, genesis *Genesis) (*Slice, error)
func (*Slice) AddPendingEtxs ¶
func (sl *Slice) AddPendingEtxs(pEtxs types.PendingEtxs) error
func (*Slice) AddPendingEtxsRollup ¶
func (sl *Slice) AddPendingEtxsRollup(pEtxsRollup types.PendingEtxsRollup) error
func (*Slice) AddToBadHashesList ¶
AddToBadHashesList adds a given set of badHashes to the BadHashesList
func (*Slice) Append ¶
func (sl *Slice) Append(header *types.Header, domPendingHeader *types.Header, domTerminus common.Hash, domOrigin bool, newInboundEtxs types.Transactions) (types.Transactions, bool, error)
Append takes a proposed header and constructs a local block and attempts to hierarchically append it to the block graph. If this is called from a dominant context a domTerminus must be provided else a common.Hash{} should be used and domOrigin should be set to true.
func (*Slice) CheckForBadHashAndRecover ¶
func (sl *Slice) CheckForBadHashAndRecover()
func (*Slice) CollectNewlyConfirmedEtxs ¶
func (sl *Slice) CollectNewlyConfirmedEtxs(block *types.Block, location common.Location) (types.Transactions, types.Transactions, error)
CollectNewlyConfirmedEtxs collects all newly confirmed ETXs since the last coincident with the given location
func (*Slice) ComputeRecoveryPendingHeader ¶
func (sl *Slice) ComputeRecoveryPendingHeader(hash common.Hash) types.PendingHeader
ComputeRecoveryPendingHeader generates the pending header at a given hash and gets the termini from the database and returns the pending header with termini
func (*Slice) Config ¶
func (sl *Slice) Config() *params.ChainConfig
func (*Slice) ConstructLocalBlock ¶
constructLocalBlock takes a header and construct the Block locally by getting the body from the candidate body db. This method is used when peers give the block as a placeholder for the body.
func (*Slice) ConstructLocalMinedBlock ¶
constructLocalMinedBlock takes a header and construct the Block locally by getting the block body from the workers pendingBlockBodyCache. This method is used when the miner sends in the header.
func (*Slice) GenerateRecoveryPendingHeader ¶
func (*Slice) GetManifest ¶
GetManifest gathers the manifest of ancestor block hashes since the last coincident block.
func (*Slice) GetPendingBlockBody ¶
func (*Slice) GetPendingHeader ¶
GetPendingHeader is used by the miner to request the current pending header
func (*Slice) GetSubManifest ¶
func (sl *Slice) GetSubManifest(slice common.Location, blockHash common.Hash) (types.BlockManifest, error)
GetSubManifest gets the block manifest from the subordinate node which produced this block
func (*Slice) HashExistsInBadHashesList ¶
HashExistsInBadHashesList checks if the given hash exists in the badHashesCache
func (*Slice) HeaderChain ¶
func (sl *Slice) HeaderChain() *HeaderChain
func (*Slice) IsBlockHashABadHash ¶
IsBlockHashABadHash checks if the given hash exists in BadHashes List
func (*Slice) NewGenesisPendingHeader ¶
NewGenesisPendingHeader creates a pending header on the genesis block
func (*Slice) ProcessingState ¶
func (*Slice) SendPendingEtxsToDom ¶
func (sl *Slice) SendPendingEtxsToDom(pEtxs types.PendingEtxs) error
SendPendingEtxsToDom shares a set of pending ETXs with your dom, so he can reference them when a coincident block is found
func (*Slice) SetHeadBackToRecoveryState ¶
func (sl *Slice) SetHeadBackToRecoveryState(pendingHeader *types.Header, hash common.Hash) types.PendingHeader
SetHeadBackToRecoveryState sets the heads of the whole hierarchy to the recovery state
func (*Slice) Stop ¶
func (sl *Slice) Stop()
Stop stores the phCache and the sl.pendingHeader hash value to the db.
func (*Slice) SubRelayPendingHeader ¶
func (sl *Slice) SubRelayPendingHeader(pendingHeader types.PendingHeader, newEntropy *big.Int, location common.Location, subReorg bool, order int)
SubRelayPendingHeader takes a pending header from the sender (ie dominant), updates the phCache with a composited header and relays result to subordinates
func (*Slice) SubscribeMissingParentEvent ¶
func (sl *Slice) SubscribeMissingParentEvent(ch chan<- common.Hash) event.Subscription
func (*Slice) UpdateDom ¶
func (sl *Slice) UpdateDom(oldTerminus common.Hash, pendingHeader types.PendingHeader, location common.Location)
If a zone changes its best ph key on a dom block, it sends a signal to the dom and we can relay that information to the coords, to build on the right dom header
func (*Slice) WriteBlock ¶
type StateProcessor ¶
type StateProcessor struct {
// contains filtered or unexported fields
}
StateProcessor is a basic Processor, which takes care of transitioning state from one point to another.
StateProcessor implements Processor.
func NewStateProcessor ¶
func NewStateProcessor(config *params.ChainConfig, hc *HeaderChain, engine consensus.Engine, vmConfig vm.Config, cacheConfig *CacheConfig, txLookupLimit *uint64) *StateProcessor
NewStateProcessor initialises a new StateProcessor.
func (*StateProcessor) Apply ¶
func (p *StateProcessor) Apply(batch ethdb.Batch, block *types.Block, newInboundEtxs types.Transactions) ([]*types.Log, error)
Apply State
func (*StateProcessor) ContractCode ¶
func (p *StateProcessor) ContractCode(hash common.Hash) ([]byte, error)
ContractCode retrieves a blob of data associated with a contract hash either from ephemeral in-memory cache, or from persistent storage.
func (*StateProcessor) ContractCodeWithPrefix ¶
func (p *StateProcessor) ContractCodeWithPrefix(hash common.Hash) ([]byte, error)
ContractCodeWithPrefix retrieves a blob of data associated with a contract hash either from ephemeral in-memory cache, or from persistent storage.
If the code doesn't exist in the in-memory cache, check the storage with new code scheme.
func (*StateProcessor) GetReceiptsByHash ¶
func (p *StateProcessor) GetReceiptsByHash(hash common.Hash) types.Receipts
GetReceiptsByHash retrieves the receipts for all transactions in a given block.
func (*StateProcessor) GetTransactionLookup ¶
func (p *StateProcessor) GetTransactionLookup(hash common.Hash) *rawdb.LegacyTxLookupEntry
GetTransactionLookup retrieves the lookup associate with the given transaction hash from the cache or database.
func (*StateProcessor) GetVMConfig ¶
func (p *StateProcessor) GetVMConfig() *vm.Config
GetVMConfig returns the block chain VM config.
func (*StateProcessor) HasBlockAndState ¶
func (p *StateProcessor) HasBlockAndState(hash common.Hash, number uint64) bool
HasBlockAndState checks if a block and associated state trie is fully present in the database or not, caching it if present.
func (*StateProcessor) HasState ¶
func (p *StateProcessor) HasState(hash common.Hash) bool
HasState checks if state trie is fully present in the database or not.
func (*StateProcessor) Process ¶
func (p *StateProcessor) Process(block *types.Block, etxSet types.EtxSet) (types.Receipts, []*types.Log, *state.StateDB, uint64, error)
Process processes the state changes according to the Quai rules by running the transaction messages using the statedb and applying any rewards to both the processor (coinbase) and any included uncles.
Process returns the receipts and logs accumulated during the process and returns the amount of gas that was used in the process. If any of the transactions failed to execute due to insufficient gas it will return an error.
func (*StateProcessor) State ¶
func (p *StateProcessor) State() (*state.StateDB, error)
State returns a new mutable state based on the current HEAD block.
func (*StateProcessor) StateAt ¶
StateAt returns a new mutable state based on a particular point in time.
func (*StateProcessor) StateAtBlock ¶
func (p *StateProcessor) StateAtBlock(block *types.Block, reexec uint64, base *state.StateDB, checkLive bool) (statedb *state.StateDB, err error)
StateAtBlock retrieves the state database associated with a certain block. If no state is locally available for the given block, a number of blocks are attempted to be reexecuted to generate the desired state. The optional base layer statedb can be passed then it's regarded as the statedb of the parent block. Parameters:
- block: The block for which we want the state (== state at the stateRoot of the parent)
- reexec: The maximum number of blocks to reprocess trying to obtain the desired state
- base: If the caller is tracing multiple blocks, the caller can provide the parent state continuously from the callsite.
- checklive: if true, then the live 'blockchain' state database is used. If the caller want to perform Commit or other 'save-to-disk' changes, this should be set to false to avoid storing trash persistently
func (*StateProcessor) StateAtTransaction ¶
func (p *StateProcessor) StateAtTransaction(block *types.Block, txIndex int, reexec uint64) (Message, vm.BlockContext, *state.StateDB, error)
stateAtTransaction returns the execution environment of a certain transaction.
func (*StateProcessor) StateCache ¶
func (p *StateProcessor) StateCache() state.Database
StateCache returns the caching database underpinning the blockchain instance.
func (*StateProcessor) Stop ¶
func (p *StateProcessor) Stop()
type StateTransition ¶
type StateTransition struct {
// contains filtered or unexported fields
}
The State Transitioning Model
A state transition is a change made when a transaction is applied to the current world state The state transitioning model does all the necessary work to work out a valid new state root.
1) Nonce handling 2) Pre pay gas 3) Create a new state object if the recipient is \0*32 4) Value transfer == If contract creation ==
4a) Attempt to run transaction data 4b) If valid, use result as code for the new state object
== end == 5) Run Script section 6) Derive new state root
func NewStateTransition ¶
func NewStateTransition(evm *vm.EVM, msg Message, gp *GasPool) *StateTransition
NewStateTransition initialises and returns a new state transition object.
func (*StateTransition) TransitionDb ¶
func (st *StateTransition) TransitionDb() (*ExecutionResult, error)
TransitionDb will transition the state by applying the current message and returning the evm execution result with following fields.
- used gas: total gas used (including gas being refunded)
- returndata: the returned data from evm
- concrete execution error: various **EVM** error which aborts the execution, e.g. ErrOutOfGas, ErrExecutionReverted
However if any consensus issue encountered, return the error directly with nil evm execution result.
type TxPool ¶
type TxPool struct { SendersMutex sync.RWMutex // Mutex for senders map // contains filtered or unexported fields }
TxPool contains all currently known transactions. Transactions enter the pool when they are received from the network or submitted locally. They exit the pool when they are included in the blockchain.
The pool separates processable transactions (which can be applied to the current state) and future transactions. Transactions move between those two states over time as they are received and processed.
func NewTxPool ¶
func NewTxPool(config TxPoolConfig, chainconfig *params.ChainConfig, chain blockChain) *TxPool
NewTxPool creates a new transaction pool to gather, sort and filter inbound transactions from the network.
func (*TxPool) AddLocal ¶
func (pool *TxPool) AddLocal(tx *types.Transaction) error
AddLocal enqueues a single local transaction into the pool if it is valid. This is a convenience wrapper aroundd AddLocals.
func (*TxPool) AddLocals ¶
func (pool *TxPool) AddLocals(txs []*types.Transaction) []error
AddLocals enqueues a batch of transactions into the pool if they are valid, marking the senders as a local ones, ensuring they go around the local pricing constraints.
This method is used to add transactions from the RPC API and performs synchronous pool reorganization and event propagation.
func (*TxPool) AddRemote
deprecated
func (pool *TxPool) AddRemote(tx *types.Transaction) error
AddRemote enqueues a single transaction into the pool if it is valid. This is a convenience wrapper around AddRemotes.
Deprecated: use AddRemotes
func (*TxPool) AddRemotes ¶
func (pool *TxPool) AddRemotes(txs []*types.Transaction) []error
AddRemotes enqueues a batch of transactions into the pool if they are valid. If the senders are not among the locally tracked ones, full pricing constraints will apply.
This method is used to add transactions from the p2p network and does not wait for pool reorganization and internal event propagation.
func (*TxPool) AddRemotesSync ¶
func (pool *TxPool) AddRemotesSync(txs []*types.Transaction) []error
This is like AddRemotes, but waits for pool reorganization. Tests use this method.
func (*TxPool) Content ¶
func (pool *TxPool) Content() (map[common.InternalAddress]types.Transactions, map[common.InternalAddress]types.Transactions)
Content retrieves the data content of the transaction pool, returning all the pending as well as queued transactions, grouped by account and sorted by nonce.
func (*TxPool) ContentFrom ¶
func (pool *TxPool) ContentFrom(addr common.InternalAddress) (types.Transactions, types.Transactions)
ContentFrom retrieves the data content of the transaction pool, returning the pending as well as queued transactions of this address, grouped by nonce.
func (*TxPool) Get ¶
func (pool *TxPool) Get(hash common.Hash) *types.Transaction
Get returns a transaction if it is contained in the pool and nil otherwise.
func (*TxPool) GetSenderThreadUnsafe ¶
GetSenderThreadUnsafe returns the sender of a stored transaction. It is not thread safe and should only be used when the pool senders mutex is locked.
func (*TxPool) Has ¶
Has returns an indicator whether txpool has a transaction cached with the given hash.
func (*TxPool) Locals ¶
func (pool *TxPool) Locals() []common.InternalAddress
Locals retrieves the accounts currently considered local by the pool.
func (*TxPool) Nonce ¶
func (pool *TxPool) Nonce(addr common.InternalAddress) uint64
Nonce returns the next nonce of an account, with all transactions executable by the pool already applied on top.
func (*TxPool) SetGasPrice ¶
SetGasPrice updates the minimum price required by the transaction pool for a new transaction, and drops all transactions below this threshold.
func (*TxPool) SetSender ¶
func (pool *TxPool) SetSender(hash common.Hash, address common.InternalAddress)
SetSender caches the sender of a transaction.
func (*TxPool) Stats ¶
Stats retrieves the current pool stats, namely the number of pending and the number of queued (non-executable) transactions.
func (*TxPool) Status ¶
Status returns the status (unknown/pending/queued) of a batch of transactions identified by their hashes.
func (*TxPool) SubscribeNewTxsEvent ¶
func (pool *TxPool) SubscribeNewTxsEvent(ch chan<- NewTxsEvent) event.Subscription
SubscribeNewTxsEvent registers a subscription of NewTxsEvent and starts sending event to the given channel.
func (*TxPool) TxPoolPending ¶
func (pool *TxPool) TxPoolPending(enforceTips bool, etxSet types.EtxSet) (map[common.AddressBytes]types.Transactions, error)
Pending retrieves all currently processable transactions, grouped by origin account and sorted by nonce. The returned transaction set is a copy and can be freely modified by calling code.
The enforceTips parameter can be used to do an extra filtering on the pending transactions and only return those whose **effective** tip is large enough in the next pending execution environment.
type TxPoolConfig ¶
type TxPoolConfig struct { Locals []common.InternalAddress // Addresses that should be treated by default as local NoLocals bool // Whether local transaction handling should be disabled Journal string // Journal of local transactions to survive node restarts Rejournal time.Duration // Time interval to regenerate the local transaction journal PriceLimit uint64 // Minimum gas price to enforce for acceptance into the pool PriceBump uint64 // Minimum price bump percentage to replace an already existing transaction (nonce) AccountSlots uint64 // Number of executable transaction slots guaranteed per account GlobalSlots uint64 // Maximum number of executable transaction slots for all accounts MaxSenders uint64 // Maximum number of senders in the senders cache SendersChBuffer uint64 // Senders cache channel buffer size AccountQueue uint64 // Maximum number of non-executable transaction slots permitted per account GlobalQueue uint64 // Maximum number of non-executable transaction slots for all accounts Lifetime time.Duration // Maximum amount of time non-executable transaction are queued }
TxPoolConfig are the configuration parameters of the transaction pool.
type TxStatus ¶
type TxStatus uint
TxStatus is the current status of a transaction as seen by the pool.
type Validator ¶
type Validator interface { // ValidateBody validates the given block's content. ValidateBody(block *types.Block) error // ValidateState validates the given statedb and optionally the receipts and // gas used. ValidateState(block *types.Block, state *state.StateDB, receipts types.Receipts, usedGas uint64) error }
Validator is an interface which defines the standard for block validation. It is only responsible for validating block contents, as the header validation is done by the specific consensus engines.
Source Files ¶
- block_validator.go
- blockchain_insert.go
- blocks.go
- bloom_indexer.go
- bodydb.go
- chain_indexer.go
- chain_makers.go
- core.go
- error.go
- events.go
- evm.go
- gaspool.go
- gen_genesis.go
- gen_genesis_account.go
- genesis.go
- genesis_alloc.go
- headerchain.go
- knot.go
- miner.go
- slice.go
- state_processor.go
- state_transition.go
- tx_cacher.go
- tx_journal.go
- tx_list.go
- tx_noncer.go
- tx_pool.go
- types.go
- worker.go
Directories ¶
Path | Synopsis |
---|---|
Provides support for dealing with EVM assembly instructions (e.g., disassembling them).
|
Provides support for dealing with EVM assembly instructions (e.g., disassembling them). |
Package bloombits implements bloom filtering on batches of data.
|
Package bloombits implements bloom filtering on batches of data. |
Package rawdb contains a collection of low level database accessors.
|
Package rawdb contains a collection of low level database accessors. |
Package state provides a caching layer atop the Quai state trie.
|
Package state provides a caching layer atop the Quai state trie. |
snapshot
Package snapshot implements a journalled, dynamic state dump.
|
Package snapshot implements a journalled, dynamic state dump. |
Package types contains data types related to Quai consensus.
|
Package types contains data types related to Quai consensus. |
Package vm implements the Quai Virtual Machine.
|
Package vm implements the Quai Virtual Machine. |
runtime
Package runtime provides a basic execution model for executing EVM code.
|
Package runtime provides a basic execution model for executing EVM code. |