• R/O
  • HTTP
  • SSH
  • HTTPS

vapor: コミット

Golang implemented sidechain for Bytom


コミットメタ情報

リビジョンa12362ad566cf829063f5b9450c4b672af8d8406 (tree)
日時2019-08-20 17:54:36
作者HAOYUatHZ <haoyu@prot...>
コミッターHAOYUatHZ

ログメッセージ

???

変更サマリ

差分

--- a/toolbar/precog/monitor/connection.go
+++ b/toolbar/precog/monitor/connection.go
@@ -13,6 +13,7 @@ func (m *monitor) connectNodesRoutine() {
1313 // TODO: change name?
1414 ticker := time.NewTicker(time.Duration(m.cfg.CheckFreqSeconds) * time.Second)
1515 for ; true; <-ticker.C {
16+ <-m.dialCh
1617 if err := m.dialNodes(); err != nil {
1718 log.Error(err)
1819 }
--- a/toolbar/precog/monitor/discover.go
+++ b/toolbar/precog/monitor/discover.go
@@ -19,6 +19,7 @@ func (m *monitor) discoveryRoutine() {
1919 for range ticker.C {
2020 nodes := make([]*dht.Node, nodesToDiscv)
2121 n := m.sw.GetDiscv().ReadRandomNodes(nodes)
22+ // TODO: improve
2223 for i := 0; i < n; i++ {
2324 m.discvCh <- nodes[i]
2425 }
@@ -35,6 +36,8 @@ func (m *monitor) collectDiscoveredNodes() {
3536 log.Info("discover new node: ", node)
3637 // m.Lock()
3738
39+ return
40+
3841 if err := m.upSertNode(&config.Node{
3942 PublicKey: node.ID.String(),
4043 Host: node.IP.String(),
--- a/toolbar/precog/monitor/monitor.go
+++ b/toolbar/precog/monitor/monitor.go
@@ -38,6 +38,7 @@ type monitor struct {
3838 privKey chainkd.XPrv
3939 chain *mock.Chain
4040 txPool *mock.Mempool
41+ dialCh chan struct{}
4142 checkStatusCh chan struct{}
4243 }
4344
@@ -78,6 +79,7 @@ func NewMonitor(cfg *config.Config, db *gorm.DB) *monitor {
7879 privKey: privKey.(chainkd.XPrv),
7980 chain: chain,
8081 txPool: txPool,
82+ dialCh: make(chan struct{}, 1),
8183 checkStatusCh: make(chan struct{}, 1),
8284 }
8385 }
@@ -116,6 +118,7 @@ func (m *monitor) Run() {
116118 log.Fatal(err)
117119 }
118120
121+ m.dialCh <- struct{}{}
119122 go m.discoveryRoutine()
120123 go m.collectDiscoveredNodes()
121124 go m.connectNodesRoutine()
@@ -221,5 +224,6 @@ func (m *monitor) checkStatusRoutine() {
221224 }
222225 log.Info("Disonnect all peers.")
223226 // m.Unlock()
227+ m.dialCh <- struct{}{}
224228 }
225229 }
旧リポジトリブラウザで表示