diff options
| author | Sonic <sonic@dexon.org> | 2019-03-20 14:48:21 +0800 |
|---|---|---|
| committer | Wei-Ning Huang <w@dexon.org> | 2019-03-20 14:48:21 +0800 |
| commit | 3406cb6d47922d0e7d6952b166748f56dbd47e55 (patch) | |
| tree | 537d3da6ab8d77e1bd39dbeb7334f5d4b4e78c2c /dex/blockproposer.go | |
| parent | d72b0255b760b3b0ded0c1ce59985754b8000a78 (diff) | |
| download | dexon-3406cb6d47922d0e7d6952b166748f56dbd47e55.tar dexon-3406cb6d47922d0e7d6952b166748f56dbd47e55.tar.gz dexon-3406cb6d47922d0e7d6952b166748f56dbd47e55.tar.bz2 dexon-3406cb6d47922d0e7d6952b166748f56dbd47e55.tar.lz dexon-3406cb6d47922d0e7d6952b166748f56dbd47e55.tar.xz dexon-3406cb6d47922d0e7d6952b166748f56dbd47e55.tar.zst dexon-3406cb6d47922d0e7d6952b166748f56dbd47e55.zip | |
dex: ignore acceptableDist when force synchronise (#285)
Diffstat (limited to 'dex/blockproposer.go')
| -rw-r--r-- | dex/blockproposer.go | 12 |
1 files changed, 12 insertions, 0 deletions
diff --git a/dex/blockproposer.go b/dex/blockproposer.go index 5af08f6c4..63aaa5b51 100644 --- a/dex/blockproposer.go +++ b/dex/blockproposer.go @@ -18,6 +18,10 @@ import ( "github.com/dexon-foundation/dexon/rlp" ) +var ( + forceSyncTimeout = 20 * time.Second +) + type blockProposer struct { mu sync.Mutex running int32 @@ -223,6 +227,14 @@ ListenLoop: case <-b.stopCh: log.Debug("Early stop, before consensus core can run") return nil, errors.New("early stop") + case <-time.After(forceSyncTimeout): + log.Debug("no new chain head for a while") + if p := b.dex.protocolManager.peers.BestPeer(); p != nil { + log.Debug("try force sync with peer", "id", p.id) + b.dex.protocolManager.synchronise(p, true) + } else { + log.Debug("no peer to sync") + } case <-b.watchCat.Meow(): log.Info("WatchCat signaled to stop syncing") |