helloprotocol

type GetTipSetFunc ¶

type GetTipSetFunc func() (*types.TipSet, error)

type HelloMessage ¶

type HelloMessage struct {
	HeaviestTipSetCids   []cid.Cid
	HeaviestTipSetHeight abi.ChainEpoch
	HeaviestTipSetWeight fbig.Int
	GenesisHash          cid.Cid
}

HelloMessage is the data structure of a single message in the hello protocol.

func (t *HelloMessage) MarshalCBOR(w io.Writer) error

func (t *HelloMessage) UnmarshalCBOR(r io.Reader) (err error)

type HelloProtocolHandler ¶

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

HelloProtocolHandler implements the 'Hello' protocol handler.

Upon connecting to a new node, we send them a message containing some information about the state of our chain, and receive the same information from them. This is used to initiate a chainsync and detect connections to forks.

func NewHelloProtocolHandler(h host.Host,
	peerMgr peermgr.IPeerMgr,
	exchange exchange.Client,
	chainStore *chain.Store,
	messageStore *chain.MessageStore,
	gen cid.Cid,
	helloTimeOut time.Duration,
) *HelloProtocolHandler

func (h *HelloProtocolHandler) Register(ctx context.Context, peerDiscoveredCallback PeerDiscoveredCallback) error

type LatencyMessage ¶

type LatencyMessage struct {
	TArrival int64
	TSent    int64
}

LatencyMessage is written in response to a hello message for measuring peer latency.

func (t *LatencyMessage) MarshalCBOR(w io.Writer) error

func (t *LatencyMessage) UnmarshalCBOR(r io.Reader) (err error)

type PeerDiscoveredCallback ¶

type PeerDiscoveredCallback func(ci *types.ChainInfo)