mempool

Documentation

Index

• Constants
• Variables
• type Mempool
  • func NewMempool(conf *viper.Viper) *Mempool
  • func (mem *Mempool) Flush()
  • func (mem *Mempool) GetPendingMaxNonce(byt []byte) (uint64, error)
  • func (mem *Mempool) Lock()
  • func (mem *Mempool) Reap(maxTxs int) []types.Tx
  • func (mem *Mempool) ReceiveTx(tx types.Tx) (err error)
  • func (mem *Mempool) RegisterFilter(filter types.IFilter)
  • func (mem *Mempool) Size() int
  • func (mem *Mempool) TxsFrontWait() *clist.CElement
  • func (mem *Mempool) Unlock()
  • func (mem *Mempool) Update(height int64, txs []types.Tx)
• type MempoolMessage
  • func DecodeMessage(bz []byte) (msgType byte, msg MempoolMessage, err error)
• type MempoolReactor
  • func NewTxReactor(conf *viper.Viper, mempool types.TxPool) *MempoolReactor
  • func (memR *MempoolReactor) AddPeer(peer *p2p.Peer)
  • func (memR *MempoolReactor) GetChannels() []*p2p.ChannelDescriptor
  • func (memR *MempoolReactor) Receive(chID byte, src *p2p.Peer, msgBytes []byte)
  • func (memR *MempoolReactor) RemovePeer(peer *p2p.Peer, reason interface{})
  • func (memR *MempoolReactor) SetEventSwitch(evsw types.EventSwitch)
• type Peer
• type PeerState
• type TxMessage
  • func (m *TxMessage) String() string

Constants

const (
	MempoolChannel = byte(0x30)
)

Variables

var (
	ErrTxInCache = errors.New("Tx already exists in cache")
)

Types

type Mempool

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

func NewMempool

func NewMempool(conf *viper.Viper) *Mempool

func (*Mempool) Flush

func (mem *Mempool) Flush()

Remove all transactions from mempool and cache

func (*Mempool) GetPendingMaxNonce

func (mem *Mempool) GetPendingMaxNonce(byt []byte) (uint64, error)

func (*Mempool) Lock

func (mem *Mempool) Lock()

consensus must be able to hold lock to safely update

func (*Mempool) Reap

func (mem *Mempool) Reap(maxTxs int) []types.Tx

Get the valid transactions remaining If maxTxs is -1, there is no cap on returned transactions.

func (*Mempool) ReceiveTx

func (mem *Mempool) ReceiveTx(tx types.Tx) (err error)

Try a new transaction in the mempool. Potentially blocking if we're blocking on Update() or Reap(). cb: A callback from the CheckTx command.

It gets called from another goroutine.

CONTRACT: Either cb will get called, or err returned.

func (*Mempool) RegisterFilter

func (mem *Mempool) RegisterFilter(filter types.IFilter)

func (*Mempool) Size

func (mem *Mempool) Size() int

Number of transactions in the mempool clist

func (*Mempool) TxsFrontWait

func (mem *Mempool) TxsFrontWait() *clist.CElement

Return the first element of mem.txs for peer goroutines to call .NextWait() on. Blocks until txs has elements.

func (*Mempool) Unlock

func (mem *Mempool) Unlock()

func (*Mempool) Update

func (mem *Mempool) Update(height int64, txs []types.Tx)

Tell mempool that these txs were committed. Mempool will discard these txs. NOTE: this should be called *after* block is committed by consensus. NOTE: unsafe; Lock/Unlock must be managed by caller

type MempoolMessage

type MempoolMessage interface{}

func DecodeMessage

func DecodeMessage(bz []byte) (msgType byte, msg MempoolMessage, err error)

type MempoolReactor

type MempoolReactor struct {
	p2p.BaseReactor

	Mempool types.TxPool
	// contains filtered or unexported fields
}

MempoolReactor handles mempool tx broadcasting amongst peers.

func NewTxReactor

func NewTxReactor(conf *viper.Viper, mempool types.TxPool) *MempoolReactor

func (*MempoolReactor) AddPeer

func (memR *MempoolReactor) AddPeer(peer *p2p.Peer)

Implements Reactor

func (*MempoolReactor) GetChannels

func (memR *MempoolReactor) GetChannels() []*p2p.ChannelDescriptor

Implements Reactor

func (*MempoolReactor) Receive

func (memR *MempoolReactor) Receive(chID byte, src *p2p.Peer, msgBytes []byte)

Implements Reactor

func (*MempoolReactor) RemovePeer

func (memR *MempoolReactor) RemovePeer(peer *p2p.Peer, reason interface{})

Implements Reactor

func (*MempoolReactor) SetEventSwitch

func (memR *MempoolReactor) SetEventSwitch(evsw types.EventSwitch)

implements events.Eventable

type Peer

type Peer interface {
	IsRunning() bool
	Send(byte, interface{}) bool
	Get(string) interface{}
}

type PeerState

type PeerState interface {
	GetHeight() int64
}

type TxMessage

type TxMessage struct {
	Tx types.Tx
}

func (*TxMessage) String

func (m *TxMessage) String() string