diff options
| author | Jimmy Hu <jimmy.hu@dexon.org> | 2018-12-05 16:48:35 +0800 |
|---|---|---|
| committer | Mission Liao <mission.liao@dexon.org> | 2018-12-05 16:48:35 +0800 |
| commit | 1f48b590f6e9a6d3fd773846a3d8ba1b7f0419e6 (patch) | |
| tree | 57cd33f82dcd24e2d03661eb3a1851be002c4ee6 | |
| parent | 56e872f84131348adbc0861afb3554bba4a8e5db (diff) | |
| download | tangerine-consensus-1f48b590f6e9a6d3fd773846a3d8ba1b7f0419e6.tar.gz tangerine-consensus-1f48b590f6e9a6d3fd773846a3d8ba1b7f0419e6.tar.zst tangerine-consensus-1f48b590f6e9a6d3fd773846a3d8ba1b7f0419e6.zip | |
core: fix agreement sync issue. (#358)
| -rw-r--r-- | core/agreement-mgr.go | 5 |
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: } |