mempool

Documentation

Index

• Constants
• type IFilter
• type Mempool
  • func NewMempool(logger *zap.Logger, config *viper.Viper) *Mempool
  • func (mem *Mempool) CheckTx(tx agtypes.Tx) (err error)
  • func (mem *Mempool) Flush()
  • func (mem *Mempool) Lock()
  • func (mem *Mempool) Reap(maxTxs int) []agtypes.Tx
  • func (mem *Mempool) RegisterFilter(filter IFilter)
  • func (mem *Mempool) Size() int
  • func (mem *Mempool) TxsFrontWait() *clist.CElement
  • func (mem *Mempool) Unlock()
  • func (mem *Mempool) Update(height def.INT, txs []agtypes.Tx)
• type MempoolReactor
  • func NewMempoolReactor(logger *zap.Logger, config *viper.Viper, mempool *Mempool) *MempoolReactor
  • func (memR *MempoolReactor) AddPeer(peer *p2p.Peer)
  • func (memR *MempoolReactor) BroadcastTx(tx agtypes.Tx) error
  • 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 agtypes.EventSwitch)
• type Peer
• type PeerState

Constants

const (
	MempoolChannel = byte(0x30)
)

Types

type IFilter

type IFilter interface {
	CheckTx(agtypes.Tx) (bool, error)
}

anyone impplements IFilter can be register as a tx filter

type Mempool

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

func NewMempool

func NewMempool(logger *zap.Logger, config *viper.Viper) *Mempool

func (*Mempool) CheckTx

func (mem *Mempool) CheckTx(tx agtypes.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) Flush

func (mem *Mempool) Flush()

Remove all transactions from mempool and cache

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) []agtypes.Tx

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

func (*Mempool) RegisterFilter

func (mem *Mempool) RegisterFilter(filter 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 def.INT, txs []agtypes.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 MempoolReactor

type MempoolReactor struct {
	p2p.BaseReactor

	Mempool *Mempool
	// contains filtered or unexported fields
}

MempoolReactor handles mempool tx broadcasting amongst peers.

func NewMempoolReactor

func NewMempoolReactor(logger *zap.Logger, config *viper.Viper, mempool *Mempool) *MempoolReactor

func (*MempoolReactor) AddPeer

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

Implements Reactor

func (*MempoolReactor) BroadcastTx

func (memR *MempoolReactor) BroadcastTx(tx agtypes.Tx) error

Just an alias for CheckTx since broadcasting happens in peer routines

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 agtypes.EventSwitch)

implements events.Eventable

type Peer

type Peer interface {
	IsRunning() bool
	SendBytes(byte, []byte) bool
	Get(string) interface{}
}

type PeerState

type PeerState interface {
	GetHeight() def.INT
}