MCPcopy Create free account
hub / github.com/DeAI-Artist/Linkis / createSwitch

Function createSwitch

test/maverick/node/node.go:581–612  ·  view source on GitHub ↗
(config *cfg.Config,
	transport p2p.Transport,
	p2pMetrics *p2p.Metrics,
	peerFilters []p2p.PeerFilterFunc,
	mempoolReactor p2p.Reactor,
	bcReactor p2p.Reactor,
	stateSyncReactor *statesync.Reactor,
	consensusReactor *cs.Reactor,
	evidenceReactor *evidence.Reactor,
	nodeInfo p2p.NodeInfo,
	nodeKey *p2p.NodeKey,
	p2pLogger log.Logger,
)

Source from the content-addressed store, hash-verified

579}
580
581func createSwitch(config *cfg.Config,
582 transport p2p.Transport,
583 p2pMetrics *p2p.Metrics,
584 peerFilters []p2p.PeerFilterFunc,
585 mempoolReactor p2p.Reactor,
586 bcReactor p2p.Reactor,
587 stateSyncReactor *statesync.Reactor,
588 consensusReactor *cs.Reactor,
589 evidenceReactor *evidence.Reactor,
590 nodeInfo p2p.NodeInfo,
591 nodeKey *p2p.NodeKey,
592 p2pLogger log.Logger,
593) *p2p.Switch {
594 sw := p2p.NewSwitch(
595 config.P2P,
596 transport,
597 p2p.WithMetrics(p2pMetrics),
598 p2p.SwitchPeerFilters(peerFilters...),
599 )
600 sw.SetLogger(p2pLogger)
601 sw.AddReactor("MEMPOOL", mempoolReactor)
602 sw.AddReactor("BLOCKCHAIN", bcReactor)
603 sw.AddReactor("CONSENSUS", consensusReactor)
604 sw.AddReactor("EVIDENCE", evidenceReactor)
605 sw.AddReactor("STATESYNC", stateSyncReactor)
606
607 sw.SetNodeInfo(nodeInfo)
608 sw.SetNodeKey(nodeKey)
609
610 p2pLogger.Info("P2P Node ID", "ID", nodeKey.ID(), "file", config.NodeKeyFile())
611 return sw
612}
613
614func createAddrBookAndSetOnSwitch(config *cfg.Config, sw *p2p.Switch,
615 p2pLogger log.Logger, nodeKey *p2p.NodeKey,

Callers 1

NewNodeFunction · 0.70

Calls 10

AddReactorMethod · 0.95
SetNodeInfoMethod · 0.95
SetNodeKeyMethod · 0.95
NewSwitchFunction · 0.92
WithMetricsFunction · 0.92
SwitchPeerFiltersFunction · 0.92
NodeKeyFileMethod · 0.80
SetLoggerMethod · 0.65
InfoMethod · 0.65
IDMethod · 0.65

Tested by

no test coverage detected