tx

README

tx

交易逻辑实现。

Documentation

Overview

package txn deals with tx data

Index

• Constants
• Variables
• func GenerateAutoTxWithRWSets(inputs []*protos.TxInputExt, outputs []*protos.TxOutputExt) (*pb.Transaction, error)
• func GenerateAwardTx(address, awardAmount string, desc []byte) (*pb.Transaction, error)
• func GenerateEmptyTx(desc []byte) (*pb.Transaction, error)
• func GenerateRootTx(js []byte) (*pb.Transaction, error)
• func ParseContractTransferRequest(requests []*protos.InvokeRequest) (string, *big.Int, error)
• func SplitToDags(block *pb.InternalBlock) [][]*pb.Transaction
• func TopSortDFS(g TxGraph) (order []string, cyclic bool, childDAGSize []int)
• type Mempool
  • func NewMempool(tx *Tx, log logs.Logger, txLimit int) *Mempool
  • func (m *Mempool) BatchConfirmTx(txs []*pb.Transaction)
  • func (m *Mempool) BatchConfirmTxID(txids []string)
  • func (m *Mempool) BatchDeleteTx(txs []*pb.Transaction)
  • func (m *Mempool) ConfirmTx(tx *pb.Transaction) error
  • func (m *Mempool) ConfirmTxID(txid string)
  • func (m *Mempool) Debug()
  • func (m *Mempool) DeleteTxAndChildren(txid string) []*pb.Transaction
  • func (m *Mempool) FindConflictByTx(tx *pb.Transaction, txidInBlock map[string]bool, ranged map[*Node]bool) []*pb.Transaction
  • func (m *Mempool) Full() bool
  • func (m *Mempool) GetTx(txid string) (*pb.Transaction, bool)
  • func (m *Mempool) GetTxCounnt() int
  • func (m *Mempool) HasTx(txid string) bool
  • func (m *Mempool) PutTx(tx *pb.Transaction) error
  • func (m *Mempool) Range(f func(tx *pb.Transaction) bool)
• type Node
  • func NewNode(txid string, tx *pb.Transaction) *Node
• type RootJSON
• type Tx
  • func NewTx(sctx *context.StateCtx, stateDB kvdb.Database) (*Tx, error)
  • func (t *Tx) GetDelayedTxs() []*pb.Transaction
  • func (t *Tx) GetUnconfirmedTx(dedup bool, sizeLimit int) ([]*pb.Transaction, error)
  • func (t *Tx) LoadUnconfirmedTxFromDisk() error
  • func (t *Tx) QueryTx(txid []byte) (*pb.Transaction, error)
  • func (t *Tx) SetMaxConfirmedDelay(seconds uint32)
  • func (t *Tx) SortUnconfirmedTx(sizeLimit int) ([]*pb.Transaction, []*pb.Transaction, error)
• type TxGraph

Constants

const (
	TxVersion                = 1
	RootTxVersion            = 0
	DefaultMaxConfirmedDelay = 300
)

Variables

var (
	ErrNegativeAmount = errors.New("amount in transaction can not be negative number")
	ErrTxNotFound     = errors.New("transaction not found")
	ErrUnexpected     = errors.New("this is a unexpected error")
)

var (
	// ErrTxExist tx already in mempool when put tx.
	ErrTxExist = errors.New("tx already in mempool")
)

Functions

func GenerateAutoTxWithRWSets

func GenerateAutoTxWithRWSets(inputs []*protos.TxInputExt, outputs []*protos.TxOutputExt) (*pb.Transaction, error)

生成只有读写集的空交易

func GenerateAwardTx

func GenerateAwardTx(address, awardAmount string, desc []byte) (*pb.Transaction, error)

生成奖励TX

func GenerateEmptyTx

func GenerateEmptyTx(desc []byte) (*pb.Transaction, error)

生成只有Desc的空交易

func GenerateRootTx

func GenerateRootTx(js []byte) (*pb.Transaction, error)

通过创世块配置生成创世区块交易

func ParseContractTransferRequest

func ParseContractTransferRequest(requests []*protos.InvokeRequest) (string, *big.Int, error)

func SplitToDags

func SplitToDags(block *pb.InternalBlock) [][]*pb.Transaction

func TopSortDFS

func TopSortDFS(g TxGraph) (order []string, cyclic bool, childDAGSize []int)

TopSortDFS 对依赖关系图进行拓扑排序 输入：依赖关系图，就是个map 输出:

order: 排序后的有序数组，依赖者排在前面，被依赖的排在后面
cyclic: 如果发现有环形依赖关系则输出这个数组

实现参考： https://rosettacode.org/wiki/Topological_sort#Go 在我们映射中，RefTx是边的源点

Types

type Mempool

type Mempool struct {
	Tx *Tx
	// contains filtered or unexported fields
}

Mempool tx mempool.

func NewMempool

func NewMempool(tx *Tx, log logs.Logger, txLimit int) *Mempool

NewMempool new mempool.

func (*Mempool) BatchConfirmTx

func (m *Mempool) BatchConfirmTx(txs []*pb.Transaction)

BatchConfirmTx 批量确认交易

func (*Mempool) BatchConfirmTxID

func (m *Mempool) BatchConfirmTxID(txids []string)

BatchConfirmTxID 批量确认交易ID

func (*Mempool) BatchDeleteTx

func (m *Mempool) BatchDeleteTx(txs []*pb.Transaction)

BatchDeleteTx 从 mempool 删除所有 txs。

func (*Mempool) ConfirmTx

func (m *Mempool) ConfirmTx(tx *pb.Transaction) error

ConfirmTx confirm tx. 将 tx 从未确认交易表放入确认交易表，或者删除。

func (*Mempool) ConfirmTxID

func (m *Mempool) ConfirmTxID(txid string)

ConfirmTxID txid

func (*Mempool) Debug

func (m *Mempool) Debug()

Debug Debug mempool.

func (*Mempool) DeleteTxAndChildren

func (m *Mempool) DeleteTxAndChildren(txid string) []*pb.Transaction

DeleteTxAndChildren delete tx from mempool. 返回交易是从子交易到父交易顺序。

func (*Mempool) FindConflictByTx

func (m *Mempool) FindConflictByTx(tx *pb.Transaction, txidInBlock map[string]bool, ranged map[*Node]bool) []*pb.Transaction

FindConflictByTx 找到所有与 tx 冲突的交易。返回数组中，前面是子交易，后面是父交易。 保证事物原子性，此接口不删除交易，只返回交易列表，如果需要删除需要调用删除交易相关接口。 1.区块内只读交易不在mempool，mempool中有写交易无论在不在区块内，找到所有mempool中的写交易，上层进行undo； 2.区块内写交易无论在不在mempool，mempool中只读交易（不在区块内），找到所有mempool中的只读交易，上层进行undo； 3.区块内写交易无论在不在mempool，mempool中写交易，mempool 中的写交易为无效交易，上层进行undo。

func (*Mempool) Full

func (m *Mempool) Full() bool

Full 交易池满了返回 true

func (*Mempool) GetTx

func (m *Mempool) GetTx(txid string) (*pb.Transaction, bool)

GetTx 从 mempool 中查询一笔交易，先查未确认交易表，然后是孤儿交易表。

func (*Mempool) GetTxCounnt

func (m *Mempool) GetTxCounnt() int

GetTxCounnt get 获取未确认交易与孤儿交易总数

func (*Mempool) HasTx

func (m *Mempool) HasTx(txid string) bool

HasTx has tx in mempool.

func (*Mempool) PutTx

func (m *Mempool) PutTx(tx *pb.Transaction) error

PutTx put tx. TODO：后续判断新增的交易是否会导致循环依赖。

func (*Mempool) Range

func (m *Mempool) Range(f func(tx *pb.Transaction) bool)

Range 按照拓扑排序遍历节点交易。

type Node

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

Node tx wrapper.

func NewNode

func NewNode(txid string, tx *pb.Transaction) *Node

NewNode new node.

type RootJSON

type RootJSON struct {
	Version   string `json:"version"`
	Consensus struct {
		Miner string `json:"miner"`
	} `json:"consensus"`
	Predistribution []struct {
		Address string `json:"address"`
		Quota   string `json:"quota"`
	} `json:"predistribution"`
}

RootJSON xuper.json对应的struct，目前先只写了utxovm关注的字段

type Tx

type Tx struct {
	UnconfirmTxAmount int64
	// UnconfirmTxInMem  *sync.Map // 使用新版 mempool 就不用这个字段了。
	AvgDelay int64

	Mempool *Mempool
	// contains filtered or unexported fields
}

func NewTx

func NewTx(sctx *context.StateCtx, stateDB kvdb.Database) (*Tx, error)

func (*Tx) GetDelayedTxs

func (t *Tx) GetDelayedTxs() []*pb.Transaction

GetDelayedTxs 获取当前 mempool 中超时的交易。

func (*Tx) GetUnconfirmedTx

func (t *Tx) GetUnconfirmedTx(dedup bool, sizeLimit int) ([]*pb.Transaction, error)

GetUnconfirmedTx 挖掘一批unconfirmed的交易打包，返回的结果要保证是按照交易执行的先后顺序 maxSize: 打包交易最大的长度（in byte）, -1（小于0） 表示不限制

func (*Tx) LoadUnconfirmedTxFromDisk

func (t *Tx) LoadUnconfirmedTxFromDisk() error

从disk还原unconfirm表到内存, 初始化的时候

func (*Tx) QueryTx

func (t *Tx) QueryTx(txid []byte) (*pb.Transaction, error)

QueryTx 查询一笔交易，从unconfirm表中查询

func (*Tx) SetMaxConfirmedDelay

func (t *Tx) SetMaxConfirmedDelay(seconds uint32)

func (*Tx) SortUnconfirmedTx

func (t *Tx) SortUnconfirmedTx(sizeLimit int) ([]*pb.Transaction, []*pb.Transaction, error)

SortUnconfirmedTx 返回未确认交易列表以及延迟时间过长交易。

type TxGraph

type TxGraph map[string][]string

交易依赖关系图