protocol

package
v0.4.0 Latest Latest
Warning

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

 Go to latest Published: Feb 1, 2018 License: AGPL-3.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	// ErrBadBlock is returned when a block is invalid.
	ErrBadBlock = errors.New("invalid block")

	// ErrBadStateRoot is returned when the computed assets merkle root
	// disagrees with the one declared in a block header.
	ErrBadStateRoot = errors.New("invalid state merkle root")
)
View Source 
var (

	// ErrTransactionNotExist is the pre-defined error message
	ErrTransactionNotExist = errors.New("transaction are not existed in the mempool")
	ErrPoolIsFull          = errors.New("transaction pool reach the max number")
)
View Source 
var ErrBadTx = errors.New("invalid transaction")

ErrBadTx is returned for transactions failing validation

View Source 
var (
	// ErrTheDistantFuture is returned when waiting for a blockheight
	// too far in excess of the tip of the blockchain.
	ErrTheDistantFuture = errors.New("block height too far in future")
)

Functions

This section is empty.

Types

type Chain 

type Chain struct {
	InitialBlockHash  bc.Hash
	MaxIssuanceWindow time.Duration // only used by generators
	// contains filtered or unexported fields
}

Chain provides a complete, minimal blockchain database. It delegates the underlying storage to other objects, and uses validation logic from package validation to decide what objects can be safely stored.

func NewChain 

func NewChain(initialBlockHash bc.Hash, store Store, txPool *TxPool) (*Chain, error)

NewChain returns a new Chain using store as the underlying storage.

func (*Chain) BestBlock added in v0.3.0 

func (c *Chain) BestBlock() *legacy.Block

BestBlock returns the chain tail block

func (*Chain) BestBlockHash added in v0.1.4 

func (c *Chain) BestBlockHash() *bc.Hash

BestBlockHash return the hash of the chain tail block

func (*Chain) BlockExist added in v0.1.4 

func (c *Chain) BlockExist(hash *bc.Hash) bool

BlockExist check is a block in chain or orphan

func (*Chain) BlockSoonWaiter 

func (c *Chain) BlockSoonWaiter(ctx context.Context, height uint64) <-chan error

BlockSoonWaiter returns a channel that waits for the block at the given height, but it is an error to wait for a block far in the future. WaitForBlockSoon will timeout if the context times out. To wait unconditionally, the caller should use WaitForBlock.

func (*Chain) BlockWaiter 

func (c *Chain) BlockWaiter(height uint64) <-chan struct{}

BlockWaiter returns a channel that waits for the block at the given height.

func (*Chain) ConnectBlock added in v0.1.4 

func (c *Chain) ConnectBlock(block *legacy.Block) error

ConnectBlock append block to end of chain

func (*Chain) GetBlockByHash added in v0.1.4 

func (c *Chain) GetBlockByHash(hash *bc.Hash) (*legacy.Block, error)

GetBlockByHash return a block by given hash

func (*Chain) GetBlockByHeight added in v0.1.4 

func (c *Chain) GetBlockByHeight(height uint64) (*legacy.Block, error)

GetBlockByHeight return a block by given height

func (*Chain) GetTransactionsUtxo added in v0.3.0 

func (c *Chain) GetTransactionsUtxo(view *state.UtxoViewpoint, txs []*bc.Tx) error

GetTransactionsUtxo return all the utxos that related to the txs' inputs

func (*Chain) GetUtxo added in v0.3.0 

func (c *Chain) GetUtxo(hash *bc.Hash) (*storage.UtxoEntry, error)

GetUtxo try to find the utxo status in db

func (*Chain) Height 

func (c *Chain) Height() uint64

Height returns the current height of the blockchain.

func (*Chain) InMainChain added in v0.2.0 

func (c *Chain) InMainChain(height uint64, hash bc.Hash) bool

InMainChain checks wheather a block is in the main chain

func (*Chain) ProcessBlock added in v0.1.4 

func (c *Chain) ProcessBlock(block *legacy.Block) (bool, error)

ProcessBlock is the entry for handle block insert

func (*Chain) SaveBlock added in v0.1.4 

func (c *Chain) SaveBlock(block *legacy.Block) error

SaveBlock will validate and save block into storage

func (*Chain) Timestamp added in v0.4.0 

func (c *Chain) Timestamp() uint64

TimestampMS returns the latest known block timestamp.

func (*Chain) ValidateBlock 

func (c *Chain) ValidateBlock(block, prev *legacy.Block) error

ValidateBlock validates an incoming block in advance of applying it to a snapshot (with ApplyValidBlock) and committing it to the blockchain (with CommitAppliedBlock).

func (*Chain) ValidateTx 

func (c *Chain) ValidateTx(tx *legacy.Tx) error

ValidateTx validates the given transaction. A cache holds per-transaction validation results and is consulted before performing full validation.

type OrphanManage added in v0.1.4 

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

OrphanManage is use to handle all the orphan block

func NewOrphanManage added in v0.1.4 

func NewOrphanManage() *OrphanManage

NewOrphanManage return a new orphan block

func (*OrphanManage) Add added in v0.1.4 

func (o *OrphanManage) Add(block *legacy.Block)

Add will add the block to OrphanManage

func (*OrphanManage) BlockExist added in v0.1.4 

func (o *OrphanManage) BlockExist(hash *bc.Hash) bool

BlockExist check is the block in OrphanManage

func (*OrphanManage) Delete added in v0.1.4 

func (o *OrphanManage) Delete(hash *bc.Hash)

Delete will delelte the block from OrphanManage

func (*OrphanManage) Get added in v0.1.4 

func (o *OrphanManage) Get(hash *bc.Hash) (*legacy.Block, bool)

Get return the orphan block by hash

type Store 

type Store interface {
	BlockExist(*bc.Hash) bool

	GetBlock(*bc.Hash) (*legacy.Block, error)
	GetMainchain(*bc.Hash) (map[uint64]*bc.Hash, error)
	GetStoreStatus() txdb.BlockStoreStateJSON
	GetTransactionsUtxo(*state.UtxoViewpoint, []*bc.Tx) error
	GetUtxo(*bc.Hash) (*storage.UtxoEntry, error)

	SaveBlock(*legacy.Block) error
	SaveChainStatus(*legacy.Block, *state.UtxoViewpoint, map[uint64]*bc.Hash) error
}

Store provides storage for blockchain data: blocks and state tree snapshots.

Note, this is different from a state snapshot. A state snapshot provides access to the state at a given point in time -- outputs and issuance memory. The Chain type uses Store to load state from storage and persist validated data.

type TxDesc 

type TxDesc struct {
	Tx       *legacy.Tx
	Added    time.Time
	Height   uint64
	Weight   uint64
	Fee      uint64
	FeePerKB uint64
}

TxDesc store tx and related info for mining strategy

type TxPool 

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

TxPool is use for store the unconfirmed transaction

func NewTxPool 

func NewTxPool() *TxPool

NewTxPool init a new TxPool

func (*TxPool) AddErrCache 

func (mp *TxPool) AddErrCache(txHash *bc.Hash, err error)

AddErrCache add a failed transaction record to lru cache

func (*TxPool) AddTransaction 

func (mp *TxPool) AddTransaction(tx *legacy.Tx, gasOnlyTx bool, height, fee uint64) (*TxDesc, error)

AddTransaction add a verified transaction to pool

func (*TxPool) Count 

func (mp *TxPool) Count() int

Count return number of transcation in pool

func (*TxPool) GetErrCache 

func (mp *TxPool) GetErrCache(txHash *bc.Hash) error

GetErrCache return the error of the transaction

func (*TxPool) GetNewTxCh 

func (mp *TxPool) GetNewTxCh() chan *legacy.Tx

GetNewTxCh return a unconfirmed transaction feed channel

func (*TxPool) GetTransaction 

func (mp *TxPool) GetTransaction(txHash *bc.Hash) (*TxDesc, error)

GetTransaction return the TxDesc by hash

func (*TxPool) GetTransactionUTXO added in v0.4.0 

func (mp *TxPool) GetTransactionUTXO(tx *bc.Tx) *state.UtxoViewpoint

GetTransactionUTXO return unconfirmed utxo

func (*TxPool) GetTransactions 

func (mp *TxPool) GetTransactions() []*TxDesc

GetTransactions return all the transactions in the pool

func (*TxPool) HaveTransaction 

func (mp *TxPool) HaveTransaction(txHash *bc.Hash) bool

HaveTransaction IsTransactionInErrCache check is transaction in errCache or pool

func (*TxPool) IsTransactionInErrCache 

func (mp *TxPool) IsTransactionInErrCache(txHash *bc.Hash) bool

IsTransactionInErrCache check wheather a transaction in errCache or not

func (*TxPool) IsTransactionInPool 

func (mp *TxPool) IsTransactionInPool(txHash *bc.Hash) bool

IsTransactionInPool check wheather a transaction in pool or not

func (*TxPool) RemoveTransaction 

func (mp *TxPool) RemoveTransaction(txHash *bc.Hash)

RemoveTransaction remove a transaction from the pool

Source Files

View all Source files

Directories

Path Synopsis
bc
Package bc is a generated protocol buffer package.
 Package bc is a generated protocol buffer package.
bctest
Package bctest provides utilities for constructing blockchain data structures.
 Package bctest provides utilities for constructing blockchain data structures.
legacy
vm
vmutil

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.