From ba14c401c75fedca4971134f0b4a6d509c257d96 Mon Sep 17 00:00:00 2001 From: HAOYUatHZ Date: Wed, 21 Aug 2019 09:03:07 +0800 Subject: [PATCH] fl --- toolbar/precog/monitor/monitor.go | 11 ++++++++--- 1 file changed, 8 insertions(+), 3 deletions(-) diff --git a/toolbar/precog/monitor/monitor.go b/toolbar/precog/monitor/monitor.go index d2a8f287..47f3537c 100644 --- a/toolbar/precog/monitor/monitor.go +++ b/toolbar/precog/monitor/monitor.go @@ -40,12 +40,13 @@ type monitor struct { txPool *mock.Mempool dialCh chan struct{} checkStatusCh chan struct{} + // peers *peers.PeerSet } // TODO: set myself as SPV? func NewMonitor(cfg *config.Config, db *gorm.DB) *monitor { //TODO: for test - cfg.CheckFreqSeconds = 180 + cfg.CheckFreqSeconds = 15 dbPath, err := makePath() if err != nil { @@ -168,6 +169,7 @@ func (m *monitor) prepareReactors(peers *peers.PeerSet) error { } func (m *monitor) checkStatusRoutine() { + // TODO: peers problem???? peers := peers.NewPeerSet(m.sw) if err := m.prepareReactors(peers); err != nil { log.Fatal(err) @@ -181,12 +183,14 @@ func (m *monitor) checkStatusRoutine() { bestHeight := uint64(0) for range m.checkStatusCh { // m.Lock() - log.Info("connected peers: ", m.sw.GetPeers().List()) for _, peer := range m.sw.GetPeers().List() { + peers.AddPeer(peer) peer.Start() protocolReactor.AddPeer(peer) } + log.Info("connected peers: ", m.sw.GetPeers().List()) + log.Info("peers: ", peers) for _, peer := range m.sw.GetPeers().List() { p := peers.GetPeer(peer.ID()) @@ -195,7 +199,8 @@ func (m *monitor) checkStatusRoutine() { } if err := p.SendStatus(m.chain.BestBlockHeader(), m.chain.LastIrreversibleHeader()); err != nil { - peers.RemovePeer(p.ID()) + // log.Error(err) + // peers.RemovePeer(p.ID()) } } -- 2.11.0