• R/O
  • HTTP
  • SSH
  • HTTPS

vapor: コミット

Golang implemented sidechain for Bytom


コミットメタ情報

リビジョンfd56a274b4b82851d1095d00853f0ba6cd5aefd5 (tree)
日時2019-08-21 10:42:16
作者HAOYUatHZ <haoyu@prot...>
コミッターHAOYUatHZ

ログメッセージ

fix

変更サマリ

差分

--- a/toolbar/precog/monitor/monitor.go
+++ b/toolbar/precog/monitor/monitor.go
@@ -6,7 +6,7 @@ import (
66 "os"
77 "os/user"
88 "strings"
9- "sync"
9+ // "sync"
1010 // "time"
1111
1212 "github.com/jinzhu/gorm"
@@ -29,7 +29,7 @@ import (
2929 )
3030
3131 type monitor struct {
32- *sync.RWMutex
32+ // *sync.RWMutex
3333 cfg *config.Config
3434 db *gorm.DB
3535 nodeCfg *vaporCfg.Config
@@ -72,7 +72,7 @@ func NewMonitor(cfg *config.Config, db *gorm.DB) *monitor {
7272 }
7373
7474 return &monitor{
75- RWMutex: &sync.RWMutex{},
75+ // RWMutex: &sync.RWMutex{},
7676 cfg: cfg,
7777 db: db,
7878 nodeCfg: nodeCfg,
@@ -169,7 +169,6 @@ func (m *monitor) prepareReactors(peers *peers.PeerSet) error {
169169 }
170170
171171 func (m *monitor) checkStatusRoutine() {
172- // TODO: peers problem????
173172 peers := peers.NewPeerSet(m.sw)
174173 if err := m.prepareReactors(peers); err != nil {
175174 log.Fatal(err)
@@ -185,13 +184,10 @@ func (m *monitor) checkStatusRoutine() {
185184 // m.Lock()
186185
187186 for _, peer := range m.sw.GetPeers().List() {
188- peers.AddPeer(peer)
189187 peer.Start()
190188 protocolReactor.AddPeer(peer)
191189 }
192- log.Info("connected peers: ", m.sw.GetPeers().List())
193- log.Info("peers: ", peers)
194-
190+ log.Infof("%d connected peers: %v", len(m.sw.GetPeers().List()), m.sw.GetPeers().List())
195191 for _, peer := range m.sw.GetPeers().List() {
196192 p := peers.GetPeer(peer.ID())
197193 if p == nil {
@@ -199,8 +195,8 @@ func (m *monitor) checkStatusRoutine() {
199195 }
200196
201197 if err := p.SendStatus(m.chain.BestBlockHeader(), m.chain.LastIrreversibleHeader()); err != nil {
202- // log.Error(err)
203- // peers.RemovePeer(p.ID())
198+ log.Error(err)
199+ peers.RemovePeer(p.ID())
204200 }
205201 }
206202
旧リポジトリブラウザで表示