(addrBook pex.AddrBook, cfg *config.Config, sw *p2p.Switch, logger log.Logger)
| 705 | } |
| 706 | |
| 707 | func createPEXReactorAndAddToSwitch(addrBook pex.AddrBook, cfg *config.Config, |
| 708 | sw *p2p.Switch, logger log.Logger) *pex.Reactor { |
| 709 | |
| 710 | reactorConfig := &pex.ReactorConfig{ |
| 711 | Seeds: tmstrings.SplitAndTrimEmpty(cfg.P2P.Seeds, ",", " "), //nolint: staticcheck |
| 712 | SeedMode: cfg.Mode == config.ModeSeed, |
| 713 | // See consensus/reactor.go: blocksToContributeToBecomeGoodPeer 10000 |
| 714 | // blocks assuming 10s blocks ~ 28 hours. |
| 715 | // TODO (melekes): make it dynamic based on the actual block latencies |
| 716 | // from the live network. |
| 717 | // https://github.com/tendermint/tendermint/issues/3523 |
| 718 | SeedDisconnectWaitPeriod: 28 * time.Hour, |
| 719 | PersistentPeersMaxDialPeriod: cfg.P2P.PersistentPeersMaxDialPeriod, |
| 720 | } |
| 721 | // TODO persistent peers ? so we can have their DNS addrs saved |
| 722 | pexReactor := pex.NewReactor(addrBook, reactorConfig) |
| 723 | pexReactor.SetLogger(logger.With("module", "pex")) |
| 724 | sw.AddReactor("PEX", pexReactor) |
| 725 | return pexReactor |
| 726 | } |
| 727 | |
| 728 | func createPEXReactorV2( |
| 729 | cfg *config.Config, |
no test coverage detected
searching dependent graphs…