From: HAOYUatHZ <haoyu@protonmail.com>
Date: Tue, 27 Aug 2019 07:54:17 +0000 (+0800)
Subject: init processDialResult
X-Git-Url: http://git.osdn.net/view?a=commitdiff_plain;h=54da864321bc996c21d2b10ff9b03278e1b4a2a2;p=bytom%2Fvapor.git

init processDialResult
---

diff --git a/toolbar/precog/monitor/connection.go b/toolbar/precog/monitor/connection.go
index ed6df818..5e9167b6 100644
--- a/toolbar/precog/monitor/connection.go
+++ b/toolbar/precog/monitor/connection.go
@@ -47,7 +47,7 @@ func (m *monitor) dialNodes() error {
 	// connected peers will be skipped in switch.DialPeers()
 	m.sw.DialPeers(addresses)
 	log.Info("DialPeers done.")
-	m.processDialResult()
+	m.processDialResults()
 	m.checkStatusCh <- struct{}{}
 	return nil
 }
diff --git a/toolbar/precog/monitor/stats.go b/toolbar/precog/monitor/stats.go
index ecb841c1..fd28ee2d 100644
--- a/toolbar/precog/monitor/stats.go
+++ b/toolbar/precog/monitor/stats.go
@@ -10,6 +10,7 @@ import (
 
 	"github.com/vapor/crypto/ed25519/chainkd"
 	"github.com/vapor/netsync/peers"
+	"github.com/vapor/p2p"
 	"github.com/vapor/toolbar/precog/common"
 	"github.com/vapor/toolbar/precog/config"
 	"github.com/vapor/toolbar/precog/database/orm"
@@ -49,7 +50,20 @@ func (m *monitor) upSertNode(node *config.Node) error {
 		}).FirstOrCreate(ormNode).Error
 }
 
-func (m *monitor) processDialResult() error {
+func (m *monitor) processDialResults() error {
+	for _, peer := range m.sw.GetPeers().List() {
+		dbTx := m.db.Begin()
+		if err := m.processDialResult(dbTx, peer); err != nil {
+			log.Error(err)
+			dbTx.Rollback()
+		} else {
+			dbTx.Commit()
+		}
+	}
+	return nil
+}
+
+func (m *monitor) processDialResult(dbTx *gorm.DB, peer *p2p.Peer) error {
 	return nil
 }