Help us shape the future of Go! Take the 2026 Go Developer Survey

chain

package
v0.5.0 Latest Latest
Warning

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

 Go to latest Published: Jul 12, 2019 License: MIT Imports: 40 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	BlockMsgChBufferSize        = 1024
	EternalBlockMsgChBufferSize = 65536

	MaxTimeOffsetSeconds = 2 * 60 * 60
	MaxBlockSize         = 32000000
	CoinbaseLib          = 100

	PeriodDuration = 21 * 5 * 10000

	MaxBlocksPerSync = 1024

	Threshold = 32
)

const defines constants

View Source 
const (
	// BlockTableName is the table name of db to store block chain data
	BlockTableName = "core"

	// WalletTableName is the table name of db to store wallet data
	WalletTableName = "wl"

	// SectionTableName is the table name of db to store section data
	SectionTableName = "sec"

	// Tail is the db key name of tail block
	Tail = "/tail"

	// Genesis is the db key name of genesis block
	Genesis = "/genesis"

	// Eternal is the db key name of eternal block
	Eternal = "/eternal"

	// Period is the db key name of current period
	Period = "/period/current"

	// MissCount is the db key name of minuer's block miss rate data
	// value: 4 bytes height + 4 bytes miss count + 10 bytes ts
	MissCount = "/missrate"

	// BlockPrefix is the key prefix of database key to store block content
	// /bk/{hex encoded block hash}
	// e.g.
	// key: /bk/005973c44c4879b137c3723c96d2e341eeaf83fe58845b2975556c9f3bd640bb
	// value: block binary
	BlockPrefix = "/bk"

	// TxPrefix is the key prefix of database key to store tx content
	TxPrefix = "/tx"

	// SecBloomBitSetPrefix is the key prefix of database key to store bloom bit set of section
	SecBloomBitSetPrefix = "/sec/bf"

	// SplitTxHashPrefix is the key prefix of database key to store split tx mapping
	SplitTxHashPrefix = "/split"

	// BlockHashPrefix is the key prefix of database key to store block hash of specified height
	// /bh/{hex encoded height}
	//e.g.
	// key: /bh/3e2d
	// value: block hash binary
	BlockHashPrefix = "/bh"

	// ReceiptPrefix is the key prefix of database key to store block receipts
	// of specified block hash
	// /br/{hex encoded block hash}
	// e.g.
	// key: /bk/005973c44c4879b137c3723c96d2e341eeaf83fe58845b2975556c9f3bd640bb
	// value: receipts binary
	ReceiptPrefix = "/rc"

	// TxIndexPrefix is the key prefix of database key to store tx index
	// /ti/{hex encoded tx hash}
	// e.g.
	// key: /ti/1113b8bdad74cdc045e64e09b3e2f0502d1b7f9bd8123b28239a3360bd3a8757
	// value: 4 bytes height + 4 bytes index in txs
	TxIndexPrefix = "/ti"

	// UtxoPrefix is the key prefix of database key to store utxo content
	// /ut/{hex encoded tx hash}/{vout index}
	// e.g.
	// key: /ut/1113b8bdad74cdc045e64e09b3e2f0502d1b7f9bd8123b28239a3360bd3a8757/2
	// value: utxo wrapper
	UtxoPrefix = "/ut"

	// CandidatesPrefix is the key prefix of database key to store candidates
	CandidatesPrefix = "/candidates"

	// FilterPrefix is the key prefix of block bloom filter to store a filter bytes
	// /bf/{hex encoded block hash}
	// e.g.
	// key: /bf/1113b8bdad74cdc045e64e09b3e2f0502d1b7f9bd8123b28239a3360bd3a8757
	// value: crypto hash
	FilterPrefix = "/bf"

	// SplitAddressPrefix is the key prefix of split address
	SplitAddressPrefix = "/sap"

	// AddressUtxoPrefix is the key prefix of database key to store address related utxo
	AddressUtxoPrefix = "/aut"

	// AddressTokenUtxoPrefix is the key prefix of database key to store address related token utxo
	AddressTokenUtxoPrefix = "/atut"
)
View Source 
const (
	TxGas                 uint64 = 2100
	TxGasContractCreation uint64 = 5300
	TxDataZeroGas         uint64 = 1
	TxDataNonZeroGas      uint64 = 6
)

define const

View Source 
const (
	// SectionBloomLength represents the number of blooms used in a new section.
	SectionBloomLength = 65536 >> 3
)
View Source 
const (
	VoutLimit = 1000
)

define const.

Variables

View Source 
var (

	// TotalSupply is the total supply of box: 3 billion
	TotalSupply = (uint64)(3e9 * core.DuPerBox)

	// CoinbaseMaturity coinbase only spendable after this many blocks
	CoinbaseMaturity = (uint32)(0)

	// BaseSubsidy is the starting subsidy amount for mined blocks.
	// This value is halved every SubsidyReductionInterval blocks.
	BaseSubsidy = (uint64)(50 * core.DuPerBox)
)
View Source 
var EternalKey = []byte(Eternal)

EternalKey is the db key to store eternal block content

View Source 
var GenesisBlock = types.Block{
	Header: &types.BlockHeader{
		Version:       1,
		PrevBlockHash: crypto.HashType{},
		TimeStamp:     time.Date(2018, 1, 31, 0, 0, 0, 0, time.UTC).Unix(),
		Height:        0,
	},
}

GenesisBlock represents genesis block.

View Source 
var GenesisKey = []byte(Genesis)

GenesisKey is the db key to store genesis block content

View Source 
var GenesisPeriod = []map[string]string{
	{
		"addr":   "b1ndoQmEd83y4Fza5PzbUQDYpT3mV772J5o",
		"peerID": "12D3KooWFQ2naj8XZUVyGhFzBTEMrMc6emiCEDKLjaJMsK7p8Cza",
	},
	{
		"addr":   "b1b8bzyci5VYUJVKRU2HRMMQiUXnoULkKAJ",
		"peerID": "12D3KooWKPRAK7vBBrVv9szEin55kBnJEEuHG4gDTQEM72ByZDpA",
	},
	{
		"addr":   "b1jh8DSdB6kB7N7RanrudV1hzzMCCcoX6L7",
		"peerID": "12D3KooWSdXLNeoRQQ2a7yiS6xLpTn3LdCr8B8fqPz94Bbi7itsi",
	},
	{
		"addr":   "b1UP5pbfJgZrF1ezoSHLdvkxvgF2BYLtGva",
		"peerID": "12D3KooWRHVAwymCVcA8jqyjpP3r3HBkCW2q5AZRTBvtaungzFSJ",
	},
	{
		"addr":   "b1ZWSdrg48g145VdcmBwMPVuDFdaxDLoktk",
		"peerID": "12D3KooWQSaxCgbWakLcU69f4gmNFMszwhyHbwx4xPAhV7erDC2P",
	},
	{
		"addr":   "b1fRtRnKF4qhQG7bSwqbgR2BMw9VfM2XpT4",
		"peerID": "12D3KooWNcJQzHaNpW5vZDQbTcoLXVCyGS755hTpendGzb5Hqtcu",
	},
}

GenesisPeriod genesis period

View Source 
var MissrateKey = []byte(MissCount)

MissrateKey is the db key to store bookkeeper's blocks miss rate

View Source 
var PeriodKey = []byte(Period)

PeriodKey is the db key to store current period contex content

View Source 
var TailKey = []byte(Tail)

TailKey is the db key to store tail block content

View Source 
var (
	// Transfers          map[types.AddressHash][]*TransferInfo
	// TransferToContract *types.Transaction
	Transfers = make(map[types.AddressHash][]*TransferInfo)
)

Transfers used to record the transfer information

Functions

func AddrAllTokenUtxoKey added in v0.3.0 

func AddrAllTokenUtxoKey(addr string, tid types.TokenID) []byte

AddrAllTokenUtxoKey is the key prefix to explore all token utxos of an address

func AddrAllUtxoKey added in v0.3.0 

func AddrAllUtxoKey(addr string) []byte

AddrAllUtxoKey is the key prefix to explore all utxos of an address

func AddrTokenUtxoKey added in v0.3.0 

func AddrTokenUtxoKey(addr string, tid types.TokenID, op types.OutPoint) []byte

AddrTokenUtxoKey is the key to store an token utxo which belongs to the input param address

func AddrUtxoKey added in v0.3.0 

func AddrUtxoKey(addr string, op types.OutPoint) []byte

AddrUtxoKey is the key to store an utxo which belongs to the input param address

func ApplyMessage added in v0.5.0 

func ApplyMessage(evm *vm.EVM, msg types.Message) ([]byte, uint64, uint64, bool, *types.Transaction, error)

ApplyMessage computes the new state by applying the given message against the old state within the environment.

func ApplyTransaction added in v0.5.0 

func ApplyTransaction(
	tx *types.VMTransaction, header *types.BlockHeader, bc *BlockChain,
	statedb *state.StateDB, cfg vm.Config, utxoSet *UtxoSet,
) (*types.Receipt, uint64, uint64, []*types.Transaction, error)

ApplyTransaction attempts to apply a transaction to the given state database and uses the input parameters for its environment.

func BlockHashKey 

func BlockHashKey(height uint32) []byte

BlockHashKey returns the db key to store block hash content of the height

func BlockKey 

func BlockKey(h *crypto.HashType) []byte

BlockKey returns the db key to store block content of the hash

func CalcBlockSubsidy 

func CalcBlockSubsidy(height uint32) uint64

CalcBlockSubsidy returns the subsidy amount a block at the provided height should have.

func CalcTxsHash 

func CalcTxsHash(txs []*types.Transaction) *crypto.HashType

CalcTxsHash calculate txsHash in block.

func CanTransfer added in v0.5.0 

func CanTransfer(db vm.StateDB, addr types.AddressHash, amount *big.Int) bool

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 CandidatesKey 

func CandidatesKey(h *crypto.HashType) []byte

CandidatesKey returns the db key to store candidates.

func CreateCoinbaseTx 

func CreateCoinbaseTx(addr []byte, blockHeight uint32) (*types.Transaction, error)

CreateCoinbaseTx creates a coinbase give bookkeeper address and block height

func DeserializeUtxoWrap added in v0.3.0 

func DeserializeUtxoWrap(serialized []byte) (*types.UtxoWrap, error)

DeserializeUtxoWrap returns UtxoWrap form serialized bytes.

func FetchOutPointOwner added in v0.5.0 

func FetchOutPointOwner(op *types.OutPoint, utxoSet *UtxoSet) (types.Address, error)

FetchOutPointOwner fetchs owner of outpoint in utxo set

func GetHashFn added in v0.5.0 

func GetHashFn(bc *BlockChain) func(n uint64) *crypto.HashType

GetHashFn returns a GetHashFunc which retrieves header hashes by number

func IntrinsicGas added in v0.5.0 

func IntrinsicGas(data []byte, contractCreation bool) (uint64, error)

IntrinsicGas computes the 'intrinsic gas' for a message with the given data.

func IsCoinBase 

func IsCoinBase(tx *types.Transaction) bool

IsCoinBase determines whether or not a transaction is a coinbase.

func IsTxFinalized 

func IsTxFinalized(tx *types.Transaction, blockHeight uint32, blockTime int64) bool

IsTxFinalized checks if a transaction is finalized.

func LoadBlockByHash added in v0.5.0 

func LoadBlockByHash(hash crypto.HashType, reader storage.Reader) (*types.Block, error)

LoadBlockByHash load block by hash from db.

func MakeRollbackContractUtxos added in v0.5.0 

func MakeRollbackContractUtxos(
	block *types.Block, stateDB *state.StateDB, db storage.Table,
) (types.UtxoMap, error)

MakeRollbackContractUtxos makes finally contract utxos from block

func MarshalMissData added in v0.3.0 

func MarshalMissData(height, miss uint32, ts int64) (data []byte, err error)

MarshalMissData writes miss rate data to bytes

func MarshalTxIndex 

func MarshalTxIndex(height, index uint32) (data []byte, err error)

MarshalTxIndex writes Tx height and index to bytes

func NewEVMContext added in v0.5.0 

func NewEVMContext(msg types.Message, header *types.BlockHeader, bc *BlockChain) vm.Context

NewEVMContext creates a new context for use in the EVM.

func ReceiptKey added in v0.5.0 

func ReceiptKey(h *crypto.HashType) []byte

ReceiptKey returns the db key to store receipt content of the block hash

func SecBloomBitSetKey added in v0.5.0 

func SecBloomBitSetKey(section uint32, bit uint) []byte

SecBloomBitSetKey is the key to store bloom bit set

func SerializeUtxoWrap added in v0.3.0 

func SerializeUtxoWrap(utxoWrap *types.UtxoWrap) ([]byte, error)

SerializeUtxoWrap returns the utxoWrap serialized to a format that is suitable for long-term storage.

func SplitAddrKey added in v0.3.0 

func SplitAddrKey(hash []byte) []byte

SplitAddrKey returns the db key to store split address

func SplitTxHashKey added in v0.3.1 

func SplitTxHashKey(h *crypto.HashType) []byte

SplitTxHashKey returns the db key to store split tx mapping

func TokenPreAllocation added in v0.3.0 

func TokenPreAllocation() ([]*types.Transaction, error)

TokenPreAllocation is for token preallocation

func Transfer added in v0.5.0 

func Transfer(db vm.StateDB, sender, recipient types.AddressHash, amount *big.Int, interpreterInvoke bool)

Transfer subtracts amount from sender and adds amount to recipient using the given Db

func TxIndexKey 

func TxIndexKey(h *crypto.HashType) []byte

TxIndexKey returns the db key to store tx index of the hash

func TxKey added in v0.3.0 

func TxKey(h *crypto.HashType) []byte

TxKey returns the db key to store tx content of the hash

func UnmarshalMissData added in v0.3.0 

func UnmarshalMissData(data []byte) (height uint32, miss uint32, ts int64, err error)

UnmarshalMissData return tx index from bytes

func UnmarshalTxIndex 

func UnmarshalTxIndex(data []byte) (height uint32, index uint32, err error)

UnmarshalTxIndex return tx index from bytes

func ValidateTransactionPreliminary 

func ValidateTransactionPreliminary(tx *types.Transaction) error

ValidateTransactionPreliminary performs some preliminary checks on a transaction to ensure it is sane. These checks are context free.

func ValidateTxInputs 

func ValidateTxInputs(utxoSet *UtxoSet, tx *types.Transaction, txHeight uint32) (uint64, error)

ValidateTxInputs validates the inputs of a tx. Returns the total tx fee.

func VerifyBlockTimeOut 

func VerifyBlockTimeOut(block *types.Block) error

VerifyBlockTimeOut refuse to accept a block with wrong timestamp.

Types

type BalanceChangeMap added in v0.5.0 

type BalanceChangeMap map[types.AddressHash]uint64

BalanceChangeMap defines the balance changes of accounts (add or subtract)

type BlockChain 

type BlockChain struct {
	LongestChainHeight uint32
	// contains filtered or unexported fields
}

BlockChain define chain struct

func NewBlockChain 

func NewBlockChain(parent goprocess.Process, notifiee p2p.Net, db storage.Storage, bus eventbus.Bus) (*BlockChain, error)

NewBlockChain return a blockchain.

func NewTestBlockChain 

func NewTestBlockChain() *BlockChain

NewTestBlockChain generate a chain for testing

func (*BlockChain) BroadcastOrRelayBlock added in v0.5.0 

func (chain *BlockChain) BroadcastOrRelayBlock(block *types.Block, transferMode core.TransferMode)

BroadcastOrRelayBlock broadcast or relay block to other peers.

func (*BlockChain) Bus 

func (chain *BlockChain) Bus() eventbus.Bus

Bus returns the goprocess of the BlockChain

func (*BlockChain) CalcRootHashForNBlocks 

func (chain *BlockChain) CalcRootHashForNBlocks(hash crypto.HashType, num uint32) (*crypto.HashType, error)

CalcRootHashForNBlocks return root hash for N blocks.

func (*BlockChain) ChangeNewTail added in v0.3.0 

func (chain *BlockChain) ChangeNewTail(tail *types.Block)

ChangeNewTail change chain tail block.

func (*BlockChain) Consensus added in v0.3.0 

func (chain *BlockChain) Consensus() Consensus

Consensus return chain consensus.

func (*BlockChain) DB 

func (chain *BlockChain) DB() storage.Table

DB return chain db storage.

func (*BlockChain) DelSplitTxs added in v0.3.0 

func (chain *BlockChain) DelSplitTxs(splitTxs map[crypto.HashType]*types.Transaction, db storage.Table) error

DelSplitTxs del split txs.

func (*BlockChain) DelTxIndex 

func (chain *BlockChain) DelTxIndex(
	block *types.Block, splitTxs map[crypto.HashType]*types.Transaction, db storage.Table,
) error

DelTxIndex deletes tx index in block Delete split transaction copies saved earlier, both before and after split

func (*BlockChain) DeleteSplitAddrIndex added in v0.3.0 

func (chain *BlockChain) DeleteSplitAddrIndex(block *types.Block, db storage.Table) error

DeleteSplitAddrIndex remove split address index from both db and cache

func (*BlockChain) EternalBlock 

func (chain *BlockChain) EternalBlock() *types.Block

EternalBlock return chain eternal block.

func (*BlockChain) ExtractVMTransactions added in v0.5.0 

func (chain *BlockChain) ExtractVMTransactions(
	tx *types.Transaction, ownerTxs ...*types.Transaction,
) (*types.VMTransaction, error)

ExtractVMTransactions extract Transaction to VMTransaction

func (*BlockChain) FetchNBlockAfterSpecificHash 

func (chain *BlockChain) FetchNBlockAfterSpecificHash(hash crypto.HashType, num uint32) ([]*types.Block, error)

FetchNBlockAfterSpecificHash get N block after specific hash.

func (*BlockChain) FilterLogs added in v0.5.0 

func (chain *BlockChain) FilterLogs(logs []*types.Log, topicslist [][][]byte) ([]*types.Log, error)

FilterLogs filter logs by addrs and topicslist.

func (*BlockChain) Genesis added in v0.3.0 

func (chain *BlockChain) Genesis() *types.Block

Genesis return chain genesis block.

func (*BlockChain) GetBlockHash 

func (chain *BlockChain) GetBlockHash(blockHeight uint32) (*crypto.HashType, error)

GetBlockHash finds the block in target height of main chain and returns it's hash

func (*BlockChain) GetBlockHeight 

func (chain *BlockChain) GetBlockHeight() uint32

GetBlockHeight returns current height of main chain

func (*BlockChain) GetBlockLogs added in v0.5.0 

func (chain *BlockChain) GetBlockLogs(hash *crypto.HashType) ([]*types.Log, error)

GetBlockLogs get logs by block hash.

func (*BlockChain) GetDataFromDB added in v0.3.0 

func (chain *BlockChain) GetDataFromDB(key []byte) ([]byte, error)

GetDataFromDB get data from db

func (*BlockChain) GetEvmByHeight added in v0.5.0 

func (chain *BlockChain) GetEvmByHeight(msg types.Message, height uint32) (*vm.EVM, func() error, error)

GetEvmByHeight get evm by block height.

func (*BlockChain) GetLogs added in v0.5.0 

func (chain *BlockChain) GetLogs(from, to uint32, topicslist [][][]byte) ([]*types.Log, error)

GetLogs filter logs.

func (*BlockChain) GetParentBlock added in v0.3.0 

func (chain *BlockChain) GetParentBlock(block *types.Block) *types.Block

GetParentBlock Finds the parent of a block. Return nil if nonexistent

func (*BlockChain) GetTxReceipt added in v0.5.0 

func (chain *BlockChain) GetTxReceipt(txHash *crypto.HashType) (*types.Receipt, error)

GetTxReceipt returns a tx receipt by using given tx hash.

func (*BlockChain) IsBusy added in v0.3.0 

func (chain *BlockChain) IsBusy() bool

IsBusy return if the chain is processing a block

func (*BlockChain) IsCoinBase added in v0.3.0 

func (chain *BlockChain) IsCoinBase(tx *types.Transaction) bool

IsCoinBase checks if an transaction is coinbase transaction

func (*BlockChain) LoadBlockByHeight 

func (chain *BlockChain) LoadBlockByHeight(height uint32) (*types.Block, error)

LoadBlockByHeight load block by height from db.

func (*BlockChain) LoadBlockInfoByTxHash added in v0.3.0 

func (chain *BlockChain) LoadBlockInfoByTxHash(hash crypto.HashType) (*types.Block, *types.Transaction, error)

LoadBlockInfoByTxHash returns block and txIndex of transaction with the input param hash

func (*BlockChain) LoadEternalBlock added in v0.3.0 

func (chain *BlockChain) LoadEternalBlock() (*types.Block, error)

LoadEternalBlock returns the current highest eternal block

func (*BlockChain) LocateForkPointAndFetchHeaders 

func (chain *BlockChain) LocateForkPointAndFetchHeaders(hashes []*crypto.HashType) ([]*crypto.HashType, error)

LocateForkPointAndFetchHeaders return block headers when get locate fork point request for sync service.

func (*BlockChain) Proc 

func (chain *BlockChain) Proc() goprocess.Process

Proc returns the goprocess of the BlockChain

func (*BlockChain) ProcessBlock 

func (chain *BlockChain) ProcessBlock(block *types.Block, transferMode core.TransferMode, messageFrom peer.ID) error

ProcessBlock is used to handle new blocks.

func (*BlockChain) ReadBlockFromDB added in v0.3.0 

func (chain *BlockChain) ReadBlockFromDB(hash *crypto.HashType) (*types.Block, int, error)

ReadBlockFromDB reads a block from db by hash and returns block and it's size

func (*BlockChain) ReceiptsCache added in v0.5.0 

func (chain *BlockChain) ReceiptsCache() map[uint32]types.Receipts

ReceiptsCache returns chain receipts cache.

func (*BlockChain) RemoveBlock added in v0.3.0 

func (chain *BlockChain) RemoveBlock(block *types.Block)

RemoveBlock store block to db.

func (*BlockChain) Run 

func (chain *BlockChain) Run() error

Run launch blockchain.

func (*BlockChain) SetEternal 

func (chain *BlockChain) SetEternal(block *types.Block) error

SetEternal set block eternal status.

func (*BlockChain) SetTailState added in v0.5.0 

func (chain *BlockChain) SetTailState(root, utxoRoot *crypto.HashType) error

SetTailState returns chain tail statedb

func (*BlockChain) Setup 

func (chain *BlockChain) Setup(consensus Consensus, syncManager SyncManager)

Setup prepare blockchain.

func (*BlockChain) SplitBlockOutputs added in v0.5.0 

func (chain *BlockChain) SplitBlockOutputs(block *types.Block) map[crypto.HashType]*types.Transaction

SplitBlockOutputs split outputs of txs in the block where applicable return all split transactions, i.e., transactions containing at least one output to a split address

func (*BlockChain) StateProcessor added in v0.5.0 

func (chain *BlockChain) StateProcessor() *StateProcessor

StateProcessor returns chain stateProcessor.

func (*BlockChain) Stop 

func (chain *BlockChain) Stop()

Stop the blockchain service

func (*BlockChain) StoreBlock added in v0.3.0 

func (chain *BlockChain) StoreBlock(block *types.Block) error

StoreBlock store block to db.

func (*BlockChain) StoreBlockWithIndex added in v0.5.0 

func (chain *BlockChain) StoreBlockWithIndex(block *types.Block, db storage.Table) error

StoreBlockWithIndex store block to db in batch mod.

func (*BlockChain) StoreEternalBlock 

func (chain *BlockChain) StoreEternalBlock(block *types.Block) error

StoreEternalBlock store eternal block to db.

func (*BlockChain) StoreReceipts added in v0.5.0 

func (chain *BlockChain) StoreReceipts(hash *crypto.HashType, receipts types.Receipts, db storage.Table) error

StoreReceipts store receipts to db in batch mod.

func (*BlockChain) StoreSplitTxs added in v0.3.0 

func (chain *BlockChain) StoreSplitTxs(
	splitTxs map[crypto.HashType]*types.Transaction, db storage.Table,
) error

StoreSplitTxs store split txs.

func (*BlockChain) StoreTailBlock 

func (chain *BlockChain) StoreTailBlock(block *types.Block, db storage.Table) error

StoreTailBlock store tail block to db.

func (*BlockChain) TailBlock 

func (chain *BlockChain) TailBlock() *types.Block

TailBlock return chain tail block.

func (*BlockChain) TailState added in v0.5.0 

func (chain *BlockChain) TailState() *state.StateDB

TailState returns chain tail statedb

func (*BlockChain) UpdateContractUtxoState added in v0.5.0 

func (chain *BlockChain) UpdateContractUtxoState(statedb *state.StateDB, utxoSet *UtxoSet) error

UpdateContractUtxoState updates contract utxo in statedb

func (*BlockChain) UpdateNormalTxBalanceState added in v0.5.0 

func (chain *BlockChain) UpdateNormalTxBalanceState(block *types.Block, utxoset *UtxoSet, stateDB *state.StateDB)

UpdateNormalTxBalanceState updates the balance state of normal tx

func (*BlockChain) UtxoSetCache added in v0.5.0 

func (chain *BlockChain) UtxoSetCache() map[uint32]*UtxoSet

UtxoSetCache returns chain utxoSet cache.

func (*BlockChain) ValidateExecuteResult added in v0.5.0 

func (chain *BlockChain) ValidateExecuteResult(
	block *types.Block, utxoTxs []*types.Transaction, usedGas, gasRemainingFee, totalTxsFee uint64,
	receipts types.Receipts,
) error

ValidateExecuteResult validates evm execute result

func (*BlockChain) WriteSplitAddrIndex added in v0.3.0 

func (chain *BlockChain) WriteSplitAddrIndex(block *types.Block, db storage.Table) error

WriteSplitAddrIndex writes split addr info index

func (*BlockChain) WriteTxIndex 

func (chain *BlockChain) WriteTxIndex(block *types.Block, splitTxs map[crypto.HashType]*types.Transaction, db storage.Table) error

WriteTxIndex builds tx index in block Save split transaction copies before and after split. The latter is needed when reverting a transaction during reorg, spending from utxo/coin received at a split address

type Consensus added in v0.5.0 

type Consensus interface {
	Run() error
	Stop()
	StopMint()
	RecoverMint()

	Verify(*types.Block) error
	Process(*types.Block, interface{}) error
	Finalize(*types.Block) error

	VerifyTx(*types.Transaction) error
}

Consensus define consensus interface

type DummyDpos 

type DummyDpos struct{}

DummyDpos dummy dpos

func (*DummyDpos) Finalize added in v0.5.0 

func (dpos *DummyDpos) Finalize(*types.Block) error

Finalize notify consensus to change new tail.

func (*DummyDpos) Process added in v0.5.0 

func (dpos *DummyDpos) Process(*types.Block, interface{}) error

Process notify consensus to process new block.

func (*DummyDpos) RecoverMint 

func (dpos *DummyDpos) RecoverMint()

RecoverMint revover mint

func (*DummyDpos) Run 

func (dpos *DummyDpos) Run() error

Run dummy dpos

func (*DummyDpos) Stop 

func (dpos *DummyDpos) Stop()

Stop dummy dpos

func (*DummyDpos) StopMint 

func (dpos *DummyDpos) StopMint()

StopMint stop mint

func (*DummyDpos) Verify added in v0.5.0 

func (dpos *DummyDpos) Verify(*types.Block) error

Verify verify block.

func (*DummyDpos) VerifyTx added in v0.5.0 

func (dpos *DummyDpos) VerifyTx(*types.Transaction) error

VerifyTx notify consensus to verify new tx.

type DummySyncManager 

type DummySyncManager struct{}

DummySyncManager is only used to test

func NewDummySyncManager 

func NewDummySyncManager() *DummySyncManager

NewDummySyncManager returns a new DummySyncManager

func (*DummySyncManager) ActiveLightSync 

func (dm *DummySyncManager) ActiveLightSync(pid peer.ID) error

ActiveLightSync active light sync from remote peer.

func (*DummySyncManager) Run 

func (dm *DummySyncManager) Run()

Run starts run

func (*DummySyncManager) StartSync 

func (dm *DummySyncManager) StartSync()

StartSync starts sync

type LockTime 

type LockTime struct {
	Seconds     int64
	BlockHeight uint32
}

LockTime represents the relative lock-time in seconds

type ScriptItem added in v0.3.0 

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

ScriptItem saves scripts for parallel validation

func CheckTxScripts added in v0.3.0 

func CheckTxScripts(utxoSet *UtxoSet, tx *types.Transaction, skipValidation bool) ([]*ScriptItem, error)

CheckTxScripts verifies unlocking script for each input to ensure it is authorized to spend the utxo Coinbase tx will not reach here

type SectionManager added in v0.5.0 

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

SectionManager takes a number of bloom filters and generates the rotated bloom bits to be used for batched filtering.

func NewSectionManager added in v0.5.0 

func NewSectionManager(chain *BlockChain, db storage.Storage) (mgr *SectionManager, err error)

NewSectionManager creates a rotated bloom section manager that can iteratively fill a batched bloom filter's bits.

func (*SectionManager) AddBloom added in v0.5.0 

func (sm *SectionManager) AddBloom(index uint, bloom bloom.Filter) error

AddBloom takes a single bloom filter and sets the corresponding bit column in memory accordingly.

func (*SectionManager) Bitset added in v0.5.0 

func (sm *SectionManager) Bitset(idx uint) ([]byte, error)

Bitset returns the bit vector belonging to the given bit index after all blooms have been added.

func (*SectionManager) GetLogs added in v0.5.0 

func (sm *SectionManager) GetLogs(from, to uint32, topicslist [][][]byte) ([]*types.Log, error)

GetLogs get logs matchs key words.

type StateProcessor added in v0.5.0 

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

StateProcessor is a basic Processor, which takes care of transitioning state from one point to another.

func NewStateProcessor added in v0.5.0 

func NewStateProcessor(bc *BlockChain) *StateProcessor

NewStateProcessor initialises a new StateProcessor.

func (*StateProcessor) Process added in v0.5.0 

func (sp *StateProcessor) Process(
	block *types.Block, stateDB *state.StateDB, utxoSet *UtxoSet,
) (types.Receipts, uint64, uint64, []*types.Transaction, error)

Process processes the state changes using the statedb.

type StateTransition added in v0.5.0 

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

StateTransition the State Transitioning Model

func NewStateTransition added in v0.5.0 

func NewStateTransition(evm *vm.EVM, msg types.Message) *StateTransition

NewStateTransition initialises and returns a new state transition object.

func (*StateTransition) TransitionDb added in v0.5.0 

func (st *StateTransition) TransitionDb() (ret []byte, usedGas, gasRemaining uint64, failed bool, gasRefundTx *types.Transaction, err error)

TransitionDb will transition the state by applying the current message and returning the result including the used gas. There are three scenarios for executing a tx: case 1: the tx is invalid before it is actually executed by evm. The tx is not on chain and returns an error. case 2: error returned after tx is executed by evm (the error is not an insufficient balance error). The tx is on chain but it's failed and the gas is used. case 3: the tx execution successful. The tx is on chain and it`s successful.

type SyncManager added in v0.5.0 

type SyncManager interface {
	StartSync()
	ActiveLightSync(peer.ID) error
	Run()
}

SyncManager define sync manager interface

type TransferInfo added in v0.5.0 

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

TransferInfo used to record the transfer information occurred during the execution of the contract

func NewTransferInfo added in v0.5.0 

func NewTransferInfo(from, to types.AddressHash, value *big.Int) *TransferInfo

NewTransferInfo creates a new transferInfo.

type UpdateMsg 

type UpdateMsg struct {
	// block connected/disconnected from main chain
	AttachBlocks []*types.Block
	DetachBlocks []*types.Block
}

UpdateMsg sent from blockchain to, e.g., mempool

type UtxoSet 

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

UtxoSet contains all utxos

func GetExtendedTxUtxoSet 

func GetExtendedTxUtxoSet(tx *types.Transaction, db storage.Table,
	spendableTxs *sync.Map) (*UtxoSet, error)

GetExtendedTxUtxoSet returns tx's utxo set from both db & txs in spendableTxs

func NewUtxoSet 

func NewUtxoSet() *UtxoSet

NewUtxoSet new utxo set

func NewUtxoSetFromMap 

func NewUtxoSetFromMap(utxoMap types.UtxoMap) *UtxoSet

NewUtxoSetFromMap returns the underlying utxos as a map

func (*UtxoSet) AddUtxo 

func (u *UtxoSet) AddUtxo(tx *types.Transaction, txOutIdx uint32, blockHeight uint32) error

AddUtxo adds a tx's outputs as utxos

func (*UtxoSet) All added in v0.3.0 

func (u *UtxoSet) All() types.UtxoMap

All returns all utxo contained including spent utxo

func (*UtxoSet) ApplyBlock 

func (u *UtxoSet) ApplyBlock(block *types.Block) error

ApplyBlock updates utxos with all transactions in the passed block

func (*UtxoSet) ApplyInternalTxs added in v0.5.0 

func (u *UtxoSet) ApplyInternalTxs(block *types.Block) error

ApplyInternalTxs applies internal txs in block

func (*UtxoSet) FindUtxo 

func (u *UtxoSet) FindUtxo(outPoint types.OutPoint) *types.UtxoWrap

FindUtxo returns information about an outpoint.

func (*UtxoSet) GetUtxos 

func (u *UtxoSet) GetUtxos() types.UtxoMap

GetUtxos returns the unspent utxos

func (*UtxoSet) ImportUtxoMap added in v0.5.0 

func (u *UtxoSet) ImportUtxoMap(m types.UtxoMap, overwrite bool)

ImportUtxoMap imports utxos from a UtxoMap

func (*UtxoSet) LoadBlockAllUtxos added in v0.3.0 

func (u *UtxoSet) LoadBlockAllUtxos(block *types.Block, needContract bool, db storage.Table) error

LoadBlockAllUtxos loads all UTXOs txs in the block

func (*UtxoSet) LoadBlockUtxos 

func (u *UtxoSet) LoadBlockUtxos(block *types.Block, needContract bool, db storage.Table) error

LoadBlockUtxos loads UTXOs txs in the block spend

func (*UtxoSet) LoadTxUtxos 

func (u *UtxoSet) LoadTxUtxos(tx *types.Transaction, db storage.Table) error

LoadTxUtxos loads the unspent transaction outputs related to tx

func (*UtxoSet) RevertBlock 

func (u *UtxoSet) RevertBlock(block *types.Block, chain *BlockChain) error

RevertBlock undoes utxo changes made with all the transactions in the passed block It undoes the effect of ApplyBlock on utxo set

func (*UtxoSet) RevertTx 

func (u *UtxoSet) RevertTx(tx *types.Transaction, chain *BlockChain) error

RevertTx updates utxos with the passed tx: delete all utxos in outputs and add all utxos in inputs. It undoes the effect of ApplyTx on utxo set

func (*UtxoSet) SpendUtxo 

func (u *UtxoSet) SpendUtxo(outPoint types.OutPoint)

SpendUtxo mark a utxo as the spent state.

func (*UtxoSet) TxInputAmount added in v0.3.0 

func (u *UtxoSet) TxInputAmount(tx *types.Transaction) uint64

TxInputAmount returns total amount from tx's inputs Return 0 if a tx is not fully funded, i.e., if not all of its spending utxos exist

func (*UtxoSet) WriteUtxoSetToDB 

func (u *UtxoSet) WriteUtxoSetToDB(db storage.Table) error

WriteUtxoSetToDB store utxo set to database.

Source Files

View all Source files

Jump to

Keyboard shortcuts

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