| Revision | e529893f802f1e4a3a24646c8843a71e6314d91a (tree) |
|---|---|
| Time | 2019-08-21 12:30:54 |
| Author | HAOYUatHZ <haoyu@prot...> |
| Commiter | HAOYUatHZ |
add
toolbar/precog/monitor/connection.go (diff) toolbar/precog/monitor/stats.go (diff)| @@ -45,6 +45,7 @@ func (m *monitor) dialNodes() error { | ||
| 45 | 45 | // connected peers will be skipped in switch.DialPeers() |
| 46 | 46 | m.sw.DialPeers(addresses) |
| 47 | 47 | log.Info("DialPeers done.") |
| 48 | + m.processDialResult() | |
| 48 | 49 | m.checkStatusCh <- struct{}{} |
| 49 | 50 | return nil |
| 50 | 51 | } |
| @@ -49,6 +49,10 @@ func (m *monitor) upSertNode(node *config.Node) error { | ||
| 49 | 49 | }).FirstOrCreate(ormNode).Error |
| 50 | 50 | } |
| 51 | 51 | |
| 52 | +func (m *monitor) processDialResult() error { | |
| 53 | + return nil | |
| 54 | +} | |
| 55 | + | |
| 52 | 56 | func (m *monitor) processPeerInfos(peerInfos []*peers.PeerInfo) error { |
| 53 | 57 | for _, peerInfo := range peerInfos { |
| 54 | 58 | dbTx := m.db.Begin() |
Fork