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

Function createSwitch

node/node.go:567–598  ·  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

565}
566
567func createSwitch(config *cfg.Config,
568 transport p2p.Transport,
569 p2pMetrics *p2p.Metrics,
570 peerFilters []p2p.PeerFilterFunc,
571 mempoolReactor p2p.Reactor,
572 bcReactor p2p.Reactor,
573 stateSyncReactor *statesync.Reactor,
574 consensusReactor *cs.Reactor,
575 evidenceReactor *evidence.Reactor,
576 nodeInfo p2p.NodeInfo,
577 nodeKey *p2p.NodeKey,
578 p2pLogger log.Logger,
579) *p2p.Switch {
580 sw := p2p.NewSwitch(
581 config.P2P,
582 transport,
583 p2p.WithMetrics(p2pMetrics),
584 p2p.SwitchPeerFilters(peerFilters...),
585 )
586 sw.SetLogger(p2pLogger)
587 sw.AddReactor("MEMPOOL", mempoolReactor)
588 sw.AddReactor("BLOCKCHAIN", bcReactor)
589 sw.AddReactor("CONSENSUS", consensusReactor)
590 sw.AddReactor("EVIDENCE", evidenceReactor)
591 sw.AddReactor("STATESYNC", stateSyncReactor)
592
593 sw.SetNodeInfo(nodeInfo)
594 sw.SetNodeKey(nodeKey)
595
596 p2pLogger.Info("P2P Node ID", "ID", nodeKey.ID(), "file", config.NodeKeyFile())
597 return sw
598}
599
600func createAddrBookAndSetOnSwitch(config *cfg.Config, sw *p2p.Switch,
601 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