From a8ccbd941822183c87b5436281c2728572db10ec Mon Sep 17 00:00:00 2001 From: HAOYUatHZ Date: Thu, 29 Aug 2019 14:07:56 +0800 Subject: [PATCH] fix --- toolbar/precog/monitor/monitor.go | 6 +++--- toolbar/precog/monitor/stats.go | 4 +--- 2 files changed, 4 insertions(+), 6 deletions(-) diff --git a/toolbar/precog/monitor/monitor.go b/toolbar/precog/monitor/monitor.go index e9349907..bfb7b5e7 100644 --- 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 0e659b9f..e3fe0de7 100644 --- 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 { -- 2.11.0