From 04272793707574f68be8b888d5ecd50387fc32b4 Mon Sep 17 00:00:00 2001 From: HAOYUatHZ Date: Wed, 21 Aug 2019 11:02:56 +0800 Subject: [PATCH] ??? --- toolbar/precog/monitor/monitor.go | 3 +-- toolbar/precog/monitor/stats.go | 7 +++++++ 2 files changed, 8 insertions(+), 2 deletions(-) diff --git a/toolbar/precog/monitor/monitor.go b/toolbar/precog/monitor/monitor.go index c1bcdfa1..987a6b17 100644 --- a/toolbar/precog/monitor/monitor.go +++ b/toolbar/precog/monitor/monitor.go @@ -196,10 +196,9 @@ func (m *monitor) checkStatusRoutine() { if peerInfo.Height > bestHeight { bestHeight = peerInfo.Height } - - m.savePeerInfo(peerInfo) } log.Info("bestHeight: ", bestHeight) + m.savePeerInfos(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 808940e7..09ac96c9 100644 --- a/toolbar/precog/monitor/stats.go +++ b/toolbar/precog/monitor/stats.go @@ -49,6 +49,13 @@ func (m *monitor) upSertNode(node *config.Node) error { }).FirstOrCreate(ormNode).Error } +func (m *monitor) savePeerInfos(peerInfos []*peers.PeerInfo) error { + for _, peerInfo := range peerInfos { + m.savePeerInfo(peerInfo) + } + return nil +} + func (m *monitor) savePeerInfo(peerInfo *peers.PeerInfo) error { xPub := &chainkd.XPub{} if err := xPub.UnmarshalText([]byte(peerInfo.ID)); err != nil { -- 2.11.0