txpool

package

v1.3.0 Latest Latest Go to latest Published: Jun 14, 2019 License: LGPL-3.0 Imports: 7 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/LemoFoundationLtd/lemochain-go

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
type BlockTimeBucket
type BlocksTrie
- func NewBlocksTrie() *BlocksTrie
- func (trie *BlocksTrie) DelBlock(block *types.Block)
- func (trie *BlocksTrie) Path(hash common.Hash, height uint32, minHeight uint32, maxHeight uint32) []*TrieNode
- func (trie *BlocksTrie) PushBlock(block *types.Block) error
type HashSet
- func (set HashSet) Add(hash common.Hash)
- func (set HashSet) Collect() []common.Hash
- func (set HashSet) Del(hash common.Hash)
- func (set HashSet) Has(hash common.Hash) bool
type NodeByHash
type RecentTx
- func NewTxRecently() *RecentTx
- func (recent *RecentTx) GetTrace(txs []*types.Transaction) map[common.Hash]TxTrace
- func (recent *RecentTx) IsExist(tx *types.Transaction) bool
- func (recent *RecentTx) PruneBlock(hash common.Hash, height int64, txs []*types.Transaction)
- func (recent *RecentTx) RecvBlock(hash common.Hash, height int64, txs []*types.Transaction)
- func (recent *RecentTx) RecvTx(tx *types.Transaction)
type TrieNode
type TxPool
- func NewTxPool() *TxPool
- func (pool *TxPool) DelInvalidTxs(txs []*types.Transaction)
- func (pool *TxPool) Get(time uint32, size int) []*types.Transaction
- func (pool *TxPool) PruneBlock(block *types.Block)
- func (pool *TxPool) RecvBlock(block *types.Block)
- func (pool *TxPool) RecvTx(tx *types.Transaction) bool
- func (pool *TxPool) RecvTxs(txs []*types.Transaction) bool
- func (pool *TxPool) VerifyTxInBlock(block *types.Block) bool
type TxQueue
- func NewTxQueue() *TxQueue
- func (queue *TxQueue) Del(hash common.Hash)
- func (queue *TxQueue) DelBatch(hashes []common.Hash)
- func (queue *TxQueue) Pop(time uint32, size int) []*types.Transaction
- func (queue *TxQueue) Push(tx *types.Transaction)
- func (queue *TxQueue) PushBatch(txs []*types.Transaction)
type TxTimeBucket
type TxTrace
- func NewEmptyTxTrace() TxTrace
- func NewTxTrace(hash common.Hash, height int64) TxTrace

Constants ¶

This section is empty.

Variables ¶

View Source

var ErrTxPoolBlockExpired = errors.New("the block has expired")

Functions ¶

This section is empty.

Types ¶

type BlockTimeBucket ¶

type BlockTimeBucket struct {
	/* 块时间 */
	Time uint32

	/* 块列表，以高度索引块列表 */
	BlocksByHeight map[uint32]HashSet
}

type BlocksTrie ¶

type BlocksTrie struct {

	/* 根据高度对块进行索引 */
	HeightBuckets map[uint32]NodeByHash

	/* 根据时间刻度对块Hash进行索引，用来回收块 */
	TimeBuckets []*BlockTimeBucket
}

最近一个小时的所有块

func NewBlocksTrie ¶

func NewBlocksTrie() *BlocksTrie

func (*BlocksTrie) DelBlock ¶

func (trie *BlocksTrie) DelBlock(block *types.Block)

func (*BlocksTrie) Path ¶

func (trie *BlocksTrie) Path(hash common.Hash, height uint32, minHeight uint32, maxHeight uint32) []*TrieNode

从指定块开始，收集该块所在链指定高度区间的块[minHeight, maxHeight]

func (*BlocksTrie) PushBlock ¶

func (trie *BlocksTrie) PushBlock(block *types.Block) error

收到一个新块，并返回过期的块的交易列表，块过期了，块中的交易肯定也过期了

type HashSet ¶

type HashSet map[common.Hash]struct{}

HashSet 是hash的集合，用map实现高效查询

func (HashSet) Add ¶

func (set HashSet) Add(hash common.Hash)

func (HashSet) Collect ¶

func (set HashSet) Collect() []common.Hash

func (HashSet) Del ¶

func (set HashSet) Del(hash common.Hash)

func (HashSet) Has ¶

func (set HashSet) Has(hash common.Hash) bool

type NodeByHash ¶

type NodeByHash map[common.Hash]*TrieNode

type RecentTx ¶

type RecentTx struct {
	// key是交易hash，value是交易所在块的记录
	TraceMap map[common.Hash]TxTrace

	TxsByTime []*TxTimeBucket
}

近一个小时收到的所有交易的集合，用于防止交易重放

func NewTxRecently ¶

func NewTxRecently() *RecentTx

func (*RecentTx) GetTrace ¶

func (recent *RecentTx) GetTrace(txs []*types.Transaction) map[common.Hash]TxTrace

GetTrace 获取交易在区块中出现过的记录

func (*RecentTx) IsExist ¶

func (recent *RecentTx) IsExist(tx *types.Transaction) bool

func (*RecentTx) PruneBlock ¶

func (recent *RecentTx) PruneBlock(hash common.Hash, height int64, txs []*types.Transaction)

func (*RecentTx) RecvBlock ¶

func (recent *RecentTx) RecvBlock(hash common.Hash, height int64, txs []*types.Transaction)

收到一个新块，把该块种的交易放入最近交易列表

func (*RecentTx) RecvTx ¶

func (recent *RecentTx) RecvTx(tx *types.Transaction)

收到一条新的交易，放入最近交易列表

type TrieNode ¶

type TrieNode struct {
	Header *types.Header

	/* 该块打包的交易列表的索引 */
	TxHashSet HashSet
}

type TxPool ¶

type TxPool struct {
	/* 还未被打包进块的交易 */
	PendingTxs *TxQueue

	/* 最近1个小时的所有交易 */
	RecentTxs *RecentTx

	/* 从当前高度向后的3600个块 */
	BlockCache *BlocksTrie

	RW sync.RWMutex
}

func NewTxPool ¶

func NewTxPool() *TxPool

func (*TxPool) DelInvalidTxs ¶

func (pool *TxPool) DelInvalidTxs(txs []*types.Transaction)

本节点出块时，执行交易后，发现错误的交易通过该接口进行删除

func (*TxPool) Get ¶

func (pool *TxPool) Get(time uint32, size int) []*types.Transaction

本节点出块时，从交易池中取出交易进行打包，但并不从交易池中删除

func (*TxPool) PruneBlock ¶

func (pool *TxPool) PruneBlock(block *types.Block)

对链进行剪枝，剪下的块中的交易需要回归交易池

func (*TxPool) RecvBlock ¶

func (pool *TxPool) RecvBlock(block *types.Block)

新收到一个通过验证的新块（包括本节点出的块），需要从交易池中删除该块中已打包的交易

func (*TxPool) RecvTx ¶

func (pool *TxPool) RecvTx(tx *types.Transaction) bool

收到一笔新的交易

func (*TxPool) RecvTxs ¶

func (pool *TxPool) RecvTxs(txs []*types.Transaction) bool

func (*TxPool) VerifyTxInBlock ¶

func (pool *TxPool) VerifyTxInBlock(block *types.Block) bool

新收一个块时，验证块中的交易是否被同一条分叉上的其他块打包了

type TxQueue ¶

type TxQueue struct {
	/* 交易状态标记，true：正常；false：已删除 */
	TxsStatus map[common.Hash]bool

	TxsQueue []*types.Transaction
}

func NewTxQueue ¶

func NewTxQueue() *TxQueue

func (*TxQueue) Del ¶

func (queue *TxQueue) Del(hash common.Hash)

func (*TxQueue) DelBatch ¶

func (queue *TxQueue) DelBatch(hashes []common.Hash)

func (*TxQueue) Pop ¶

func (queue *TxQueue) Pop(time uint32, size int) []*types.Transaction

func (*TxQueue) Push ¶

func (queue *TxQueue) Push(tx *types.Transaction)

func (*TxQueue) PushBatch ¶

func (queue *TxQueue) PushBatch(txs []*types.Transaction)

type TxTimeBucket ¶

type TxTimeBucket struct {
	/* 交易超时时间，UTC */
	Expiration uint64

	/* 该超时时间下的所有交易列表 */
	TxIndexes HashSet
}

type TxTrace ¶

type TxTrace map[common.Hash]int64

交易在区块中出现过的记录。key是区块hash，value是区块高度

func NewEmptyTxTrace ¶

func NewEmptyTxTrace() TxTrace

func NewTxTrace ¶

func NewTxTrace(hash common.Hash, height int64) TxTrace

Source Files ¶

View all Source files

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