-func (m *monitor) discoveryRoutine() {
- ticker := time.NewTicker(time.Duration(discvFreqSec) * time.Second)
- for range ticker.C {
- nodes := make([]*dht.Node, nodesToDiscv)
- n := m.sw.GetDiscv().ReadRandomNodes(nodes)
- for i := 0; i < n; i++ {
- m.discvCh <- nodes[i]
- }
+func (m *monitor) prepareReactors(peers *peers.PeerSet) error {
+ dispatcher := event.NewDispatcher()
+ // add ConsensusReactor for consensusChannel
+ _ = consensusmgr.NewManager(m.sw, m.chain, peers, dispatcher)
+ fastSyncDB := dbm.NewDB("fastsync", m.nodeCfg.DBBackend, m.nodeCfg.DBDir())
+ // add ProtocolReactor to handle msgs
+ _, err := chainmgr.NewManager(m.nodeCfg, m.sw, m.chain, m.txPool, dispatcher, peers, fastSyncDB)
+ if err != nil {
+ return err