From af4d5a2ddec8ba81a841af563e2d3e2a341c4986 Mon Sep 17 00:00:00 2001 From: HAOYUatHZ Date: Wed, 21 Aug 2019 11:21:59 +0800 Subject: [PATCH] rename --- toolbar/precog/monitor/monitor.go | 2 +- toolbar/precog/monitor/stats.go | 6 +++--- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/toolbar/precog/monitor/monitor.go b/toolbar/precog/monitor/monitor.go index 987a6b17..dfb24766 100644 --- a/toolbar/precog/monitor/monitor.go +++ b/toolbar/precog/monitor/monitor.go @@ -198,7 +198,7 @@ func (m *monitor) checkStatusRoutine() { } } log.Info("bestHeight: ", bestHeight) - m.savePeerInfos(peers.GetPeerInfos()) + m.processPeerInfos(peers.GetPeerInfos()) // TODO: // msg := struct{ msgs.BlockchainMessage }{&msgs.GetBlockMessage{Height: bestHeight + 1}} diff --git a/toolbar/precog/monitor/stats.go b/toolbar/precog/monitor/stats.go index f89418cd..79439cb2 100644 --- a/toolbar/precog/monitor/stats.go +++ b/toolbar/precog/monitor/stats.go @@ -49,10 +49,10 @@ func (m *monitor) upSertNode(node *config.Node) error { }).FirstOrCreate(ormNode).Error } -func (m *monitor) savePeerInfos(peerInfos []*peers.PeerInfo) error { +func (m *monitor) processPeerInfos(peerInfos []*peers.PeerInfo) error { for _, peerInfo := range peerInfos { dbTx := m.db.Begin() - if err := m.savePeerInfo(dbTx, peerInfo); err != nil { + if err := m.processPeerInfo(dbTx, peerInfo); err != nil { log.Error(err) dbTx.Rollback() } else { @@ -63,7 +63,7 @@ func (m *monitor) savePeerInfos(peerInfos []*peers.PeerInfo) error { return nil } -func (m *monitor) savePeerInfo(dbTx *gorm.DB, peerInfo *peers.PeerInfo) error { +func (m *monitor) processPeerInfo(dbTx *gorm.DB, peerInfo *peers.PeerInfo) error { xPub := &chainkd.XPub{} if err := xPub.UnmarshalText([]byte(peerInfo.ID)); err != nil { return err -- 2.11.0