• R/O
  • HTTP
  • SSH
  • HTTPS

vapor: コミット

Golang implemented sidechain for Bytom


コミットメタ情報

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

ログメッセージ

fl

変更サマリ

差分

--- a/toolbar/precog/monitor/monitor.go
+++ b/toolbar/precog/monitor/monitor.go
@@ -40,12 +40,13 @@ type monitor struct {
4040 txPool *mock.Mempool
4141 dialCh chan struct{}
4242 checkStatusCh chan struct{}
43+ // peers *peers.PeerSet
4344 }
4445
4546 // TODO: set myself as SPV?
4647 func NewMonitor(cfg *config.Config, db *gorm.DB) *monitor {
4748 //TODO: for test
48- cfg.CheckFreqSeconds = 180
49+ cfg.CheckFreqSeconds = 15
4950
5051 dbPath, err := makePath()
5152 if err != nil {
@@ -168,6 +169,7 @@ func (m *monitor) prepareReactors(peers *peers.PeerSet) error {
168169 }
169170
170171 func (m *monitor) checkStatusRoutine() {
172+ // TODO: peers problem????
171173 peers := peers.NewPeerSet(m.sw)
172174 if err := m.prepareReactors(peers); err != nil {
173175 log.Fatal(err)
@@ -181,12 +183,14 @@ func (m *monitor) checkStatusRoutine() {
181183 bestHeight := uint64(0)
182184 for range m.checkStatusCh {
183185 // m.Lock()
184- log.Info("connected peers: ", m.sw.GetPeers().List())
185186
186187 for _, peer := range m.sw.GetPeers().List() {
188+ peers.AddPeer(peer)
187189 peer.Start()
188190 protocolReactor.AddPeer(peer)
189191 }
192+ log.Info("connected peers: ", m.sw.GetPeers().List())
193+ log.Info("peers: ", peers)
190194
191195 for _, peer := range m.sw.GetPeers().List() {
192196 p := peers.GetPeer(peer.ID())
@@ -195,7 +199,8 @@ func (m *monitor) checkStatusRoutine() {
195199 }
196200
197201 if err := p.SendStatus(m.chain.BestBlockHeader(), m.chain.LastIrreversibleHeader()); err != nil {
198- peers.RemovePeer(p.ID())
202+ // log.Error(err)
203+ // peers.RemovePeer(p.ID())
199204 }
200205 }
201206
旧リポジトリブラウザで表示