From: HAOYUatHZ <haoyu@protonmail.com>
Date: Sun, 1 Sep 2019 06:49:31 +0000 (+0800)
Subject: fix status
X-Git-Url: http://git.osdn.net/view?p=bytom%2Fvapor.git;a=commitdiff_plain;h=26d1d4dcacd6f36412378a5614ca1d5af422a836

fix status
---

diff --git a/toolbar/precog/monitor/stats.go b/toolbar/precog/monitor/stats.go
index af5942b9..4a57da3e 100644
--- a/toolbar/precog/monitor/stats.go
+++ b/toolbar/precog/monitor/stats.go
@@ -146,13 +146,18 @@ func (m *monitor) processPeerInfo(dbTx *gorm.DB, peerInfo *peers.PeerInfo) error
 
 	// update latest liveness
 	latestLiveness := ormNodeLivenesses[0]
-	lantencyMS := ping.Nanoseconds() / 1000000
-	if lantencyMS != 0 {
+	rttMS := ping.Nanoseconds() / 1000000
+	if rttMS != 0 {
 		ormNode.AvgRttMS = sql.NullInt64{
-			Int64: (ormNode.AvgRttMS.Int64*int64(latestLiveness.PongTimes) + lantencyMS) / int64(latestLiveness.PongTimes+1),
+			Int64: (ormNode.AvgRttMS.Int64*int64(latestLiveness.PongTimes) + rttMS) / int64(latestLiveness.PongTimes+1),
 			Valid: true,
 		}
 	}
+	if rttMS > 0 && rttMs < 2000 {
+		ormNode.Status = common.NodeHealthyStatus
+	} else if rttMS > 2000 {
+		ormNode.Status = common.NodeCongestedStatus
+	}
 	latestLiveness.PongTimes += 1
 	if peerInfo.Height != 0 {
 		latestLiveness.BestHeight = peerInfo.Height