synctrl

package
v0.0.0-...-e495fa0 Latest Latest
Warning

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

Go to latest
Published: Mar 2, 2022 License: GPL-3.0, LGPL-3.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func HandleGetStateMsg

func HandleGetStateMsg(p *p2p.Peer, msg p2p.Msg) error

func HandleProofConfirmMsg

func HandleProofConfirmMsg(p *p2p.Peer, msg p2p.Msg) error

func HandleResStateMsg

func HandleResStateMsg(p *p2p.Peer, msg p2p.Msg) error

func HandleTxMsg

func HandleTxMsg(p *p2p.Peer, msg p2p.Msg) error

HandleTxMsg deal received TxMsg

func HandleWorkProofMsg

func HandleWorkProofMsg(p *p2p.Peer, msg p2p.Msg) error

func TxsPoolLoop

func TxsPoolLoop()

Types

type DoneEvent

type DoneEvent struct{}

type FailedEvent

type FailedEvent struct{ Err error }

type StartEvent

type StartEvent struct{}

type SynCtrl

type SynCtrl struct {
	AcceptTxs uint32 // Flag whether we're considered synchronised (enables transaction processing)

	SubProtocols []p2p.Protocol
	// contains filtered or unexported fields
}

func InstanceSynCtrl

func InstanceSynCtrl() *SynCtrl

InstanceSynCtrl returns the singleton of SynCtrl.

func (*SynCtrl) NewBlockMux

func (this *SynCtrl) NewBlockMux() *sub.TypeMux

func (*SynCtrl) Start

func (this *SynCtrl) Start()

func (*SynCtrl) Stop

func (this *SynCtrl) Stop()

Jump to

Keyboard shortcuts

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