clean

diff --git a/toolbar/precog/monitor/connection.go b/toolbar/precog/monitor/connection.go
index 7211f0d..8394aa0 100644 (file)
--- a/toolbar/precog/monitor/connection.go
+++ b/toolbar/precog/monitor/connection.go
@@ -10,7 +10,6 @@ import (
 )
 
 func (m *monitor) connectNodesRoutine() {
-       // TODO: change name?
        ticker := time.NewTicker(time.Duration(m.cfg.CheckFreqSeconds) * time.Second)
        for ; true; <-ticker.C {
                <-m.dialCh
@@ -21,7 +20,6 @@ func (m *monitor) connectNodesRoutine() {
 }
 
 func (m *monitor) dialNodes() error {
-       // m.Lock()
        log.Info("Start to reconnect to nodes...")
        var nodes []*orm.Node
        if err := m.db.Model(&orm.Node{}).Find(&nodes).Error; err != nil {
@@ -48,6 +46,5 @@ func (m *monitor) dialNodes() error {
        m.sw.DialPeers(addresses)
        log.Info("DialPeers done.")
        m.checkStatusCh <- struct{}{}
-       // m.Unlock()
        return nil
 }

diff --git a/toolbar/precog/monitor/discover.go b/toolbar/precog/monitor/discover.go
index 9392104..a4d60e2 100644 (file)
--- a/toolbar/precog/monitor/discover.go
+++ b/toolbar/precog/monitor/discover.go
@@ -19,7 +19,6 @@ func (m *monitor) discoveryRoutine() {
        for range ticker.C {
                nodes := make([]*dht.Node, nodesToDiscv)
                n := m.sw.GetDiscv().ReadRandomNodes(nodes)
-               // TODO: improve
                for i := 0; i < n; i++ {
                        m.discvCh <- nodes[i]
                }
@@ -34,9 +33,6 @@ func (m *monitor) collectDiscoveredNodes() {
                        continue
                }
                log.Info("discover new node: ", node)
-               // m.Lock()
-
-               return
 
                if err := m.upSertNode(&config.Node{
                        PublicKey: node.ID.String(),
@@ -47,7 +43,5 @@ func (m *monitor) collectDiscoveredNodes() {
                } else {
                        log.Error(err)
                }
-
-               // m.Unlock()
        }
 }

diff --git a/toolbar/precog/monitor/monitor.go b/toolbar/precog/monitor/monitor.go
index eb5b07e..b82bfe2 100644 (file)
--- a/toolbar/precog/monitor/monitor.go
+++ b/toolbar/precog/monitor/monitor.go
@@ -175,8 +175,6 @@ func (m *monitor) checkStatusRoutine() {
 
        bestHeight := uint64(0)
        for range m.checkStatusCh {
-               // m.Lock()
-
                for _, peer := range m.sw.GetPeers().List() {
                        peer.Start()
                        peers.AddPeer(peer)
@@ -218,7 +216,6 @@ func (m *monitor) checkStatusRoutine() {
                        peers.RemovePeer(p.ID())
                }
                log.Info("Disonnect all peers.")
-               // m.Unlock()
                m.dialCh <- struct{}{}
        }
 }