fix

diff --git a/toolbar/precog/monitor/monitor.go b/toolbar/precog/monitor/monitor.go
index e934990..bfb7b5e 100644 (file)
--- a/toolbar/precog/monitor/monitor.go
+++ b/toolbar/precog/monitor/monitor.go
@@ -179,11 +179,11 @@ func (m *monitor) checkStatusRoutine() {
                                continue
                        }
 
-                       if err := p.(m.chain.BestBlockHeader(), m.chain.LastIrreversibleHeader()); err != nil {
+                       if err := p.SendStatus(m.chain.BestBlockHeader(), m.chain.LastIrreversibleHeader()); err != nil {
                                log.WithFields(log.Fields{
                                        "peer": p,
-                                       "err": err,
-                                       }).Error("SendStatus")
+                                       "err":  err,
+                               }).Error("SendStatus")
                                peers.RemovePeer(p.ID())
                        }
                }

diff --git a/toolbar/precog/monitor/stats.go b/toolbar/precog/monitor/stats.go
index 0e659b9..e3fe0de 100644 (file)
--- a/toolbar/precog/monitor/stats.go
+++ b/toolbar/precog/monitor/stats.go
@@ -115,7 +115,7 @@ func (m *monitor) processOfflinePeer(ormNode *orm.Node) error {
        return m.db.Model(&orm.NodeLiveness{}).Where(&orm.NodeLiveness{NodeID: ormNode.ID}).UpdateColumn(&orm.NodeLiveness{Status: common.NodeOfflineStatus}).Error
 }
 
-func (m *monitor) processPeerInfos(peerInfos []*peers.PeerInfo) error {
+func (m *monitor) processPeerInfos(peerInfos []*peers.PeerInfo) {
        for _, peerInfo := range peerInfos {
                dbTx := m.db.Begin()
                if err := m.processPeerInfo(dbTx, peerInfo); err != nil {
@@ -128,8 +128,6 @@ func (m *monitor) processPeerInfos(peerInfos []*peers.PeerInfo) error {
                        dbTx.Commit()
                }
        }
-
-       return nil
 }
 
 func (m *monitor) processPeerInfo(dbTx *gorm.DB, peerInfo *peers.PeerInfo) error {