From 25a546686f6e3a2f9953779d7a77f2692385ee78 Mon Sep 17 00:00:00 2001 From: HAOYUatHZ Date: Fri, 16 Aug 2019 11:25:49 +0800 Subject: [PATCH] fk --- netsync/peers/peer.go | 3 ++- toolbar/precog/monitor/monitor.go | 1 - 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/netsync/peers/peer.go b/netsync/peers/peer.go index e0c52f53..4db047d6 100644 --- a/netsync/peers/peer.go +++ b/netsync/peers/peer.go @@ -408,7 +408,8 @@ func (ps *PeerSet) AddPeer(peer BasePeer) { ps.peers[peer.ID()] = newPeer(peer) return } - log.WithField("module", logModule).Warning("add existing peer to blockKeeper") + // TODO: change back to warn + log.WithField("module", logModule).Debug("add existing peer to blockKeeper") } func (ps *PeerSet) BestPeer(flag consensus.ServiceFlag) *Peer { diff --git a/toolbar/precog/monitor/monitor.go b/toolbar/precog/monitor/monitor.go index c08a9b94..cd5d4da3 100644 --- a/toolbar/precog/monitor/monitor.go +++ b/toolbar/precog/monitor/monitor.go @@ -161,7 +161,6 @@ func (m *monitor) checkStatusRoutine() { for _, reactor := range m.sw.GetReactors() { for _, peer := range m.sw.GetPeers().List() { log.Debug("AddPeer %v for reactor %v", peer, reactor) - // TODO: if not in sw reactor.AddPeer(peer) } } -- 2.11.0