diff options
| author | Jimmy Hu <jimmy.hu@dexon.org> | 2019-04-03 13:42:25 +0800 |
|---|---|---|
| committer | Wei-Ning Huang <w@dexon.org> | 2019-04-09 13:50:06 +0800 |
| commit | 5637e8cfd96dbea7af4753c9cfaf26d7aad7ef52 (patch) | |
| tree | 9d99fcc68d4d73292d8ba9532af50ca6885d62c5 | |
| parent | 1cfa7789718c83be13c88c37b75509fdf1e68c21 (diff) | |
| download | dexon-5637e8cfd96dbea7af4753c9cfaf26d7aad7ef52.tar dexon-5637e8cfd96dbea7af4753c9cfaf26d7aad7ef52.tar.gz dexon-5637e8cfd96dbea7af4753c9cfaf26d7aad7ef52.tar.bz2 dexon-5637e8cfd96dbea7af4753c9cfaf26d7aad7ef52.tar.lz dexon-5637e8cfd96dbea7af4753c9cfaf26d7aad7ef52.tar.xz dexon-5637e8cfd96dbea7af4753c9cfaf26d7aad7ef52.tar.zst dexon-5637e8cfd96dbea7af4753c9cfaf26d7aad7ef52.zip | |
dex: get synced consensus before sleep (#331)
| -rw-r--r-- | dex/blockproposer.go | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/dex/blockproposer.go b/dex/blockproposer.go index c035eda7c..0b66a6cc1 100644 --- a/dex/blockproposer.go +++ b/dex/blockproposer.go @@ -193,6 +193,7 @@ Loop: log.Debug("Listen chain head event until synced") + nextDMoment := time.Now().Unix() // Listen chain head event until synced. ListenLoop: for { @@ -244,9 +245,8 @@ ListenLoop: // We set T_i = 600 to be safe. interval := int64(600) - nextDMoment := (time.Now().Unix()/interval + 1) * interval + nextDMoment = (time.Now().Unix()/interval + 1) * interval log.Info("Sleeping until next starting time", "time", nextDMoment) - time.Sleep(time.Duration(nextDMoment-time.Now().Unix()) * time.Second) b.dex.protocolManager.SetReceiveCoreMessage(true) consensusSync.ForceSync(true) @@ -254,5 +254,7 @@ ListenLoop: } } - return consensusSync.GetSyncedConsensus() + con, err := consensusSync.GetSyncedConsensus() + time.Sleep(time.Duration(nextDMoment-time.Now().Unix()) * time.Second) + return con, err } |