From: HAOYUatHZ Date: Wed, 28 Aug 2019 02:28:41 +0000 (+0800) Subject: refactot X-Git-Url: http://git.osdn.net/view?p=bytom%2Fvapor.git;a=commitdiff_plain;h=bfb2ede88283cb4936768674d5bcec6ad0f4bc80 refactot --- diff --git a/toolbar/precog/monitor/connection.go b/toolbar/precog/monitor/connection.go index 5d3b45ee..0f378f8c 100644 --- a/toolbar/precog/monitor/connection.go +++ b/toolbar/precog/monitor/connection.go @@ -14,6 +14,7 @@ func (m *monitor) connectNodesRoutine() { for ; true; <-ticker.C { <-m.dialCh m.Lock() + if err := m.dialNodes(); err != nil { log.Error(err) } diff --git a/toolbar/precog/monitor/monitor.go b/toolbar/precog/monitor/monitor.go index b0de9a2d..1554e2a0 100644 --- a/toolbar/precog/monitor/monitor.go +++ b/toolbar/precog/monitor/monitor.go @@ -198,6 +198,7 @@ func (m *monitor) checkStatusRoutine() { peers.RemovePeer(p.ID()) } log.Info("Disonnect all peers.") + m.Unlock() m.dialCh <- struct{}{} }