aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorJimmy Hu <jimmy.hu@dexon.org>2018-12-05 16:48:35 +0800
committerMission Liao <mission.liao@dexon.org>2018-12-05 16:48:35 +0800
commit1f48b590f6e9a6d3fd773846a3d8ba1b7f0419e6 (patch)
tree57cd33f82dcd24e2d03661eb3a1851be002c4ee6
parent56e872f84131348adbc0861afb3554bba4a8e5db (diff)
downloaddexon-consensus-1f48b590f6e9a6d3fd773846a3d8ba1b7f0419e6.tar
dexon-consensus-1f48b590f6e9a6d3fd773846a3d8ba1b7f0419e6.tar.gz
dexon-consensus-1f48b590f6e9a6d3fd773846a3d8ba1b7f0419e6.tar.bz2
dexon-consensus-1f48b590f6e9a6d3fd773846a3d8ba1b7f0419e6.tar.lz
dexon-consensus-1f48b590f6e9a6d3fd773846a3d8ba1b7f0419e6.tar.xz
dexon-consensus-1f48b590f6e9a6d3fd773846a3d8ba1b7f0419e6.tar.zst
dexon-consensus-1f48b590f6e9a6d3fd773846a3d8ba1b7f0419e6.zip
core: fix agreement sync issue. (#358)
-rw-r--r--core/agreement-mgr.go5
1 files changed, 3 insertions, 2 deletions
diff --git a/core/agreement-mgr.go b/core/agreement-mgr.go
index 57fb5c5..d3a0af2 100644
--- a/core/agreement-mgr.go
+++ b/core/agreement-mgr.go
@@ -394,6 +394,7 @@ func (mgr *agreementMgr) baRoutineForOneRound(
setting *baRoundSetting) (err error) {
agr := setting.agr
recv := setting.recv
+ oldPos := agr.agreementID()
Loop:
for {
select {
@@ -407,7 +408,6 @@ Loop:
// This round is finished.
break Loop
}
- oldPos := agr.agreementID()
var nextHeight uint64
for {
nextHeight, err = mgr.lattice.NextHeight(recv.round, setting.chainID)
@@ -425,15 +425,16 @@ Loop:
if nextHeight > oldPos.Height {
break
}
- time.Sleep(100 * time.Millisecond)
mgr.logger.Debug("Lattice not ready!!!",
"old", &oldPos, "next", nextHeight)
+ time.Sleep(100 * time.Millisecond)
}
nextPos := types.Position{
Round: recv.round,
ChainID: setting.chainID,
Height: nextHeight,
}
+ oldPos = nextPos
agr.restart(setting.notarySet, nextPos, setting.crs)
default:
}