(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, )
| 579 | } |
| 580 | |
| 581 | func 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 | |
| 614 | func createAddrBookAndSetOnSwitch(config *cfg.Config, sw *p2p.Switch, |
| 615 | p2pLogger log.Logger, nodeKey *p2p.NodeKey, |
no test coverage detected