diff options
author | Mission Liao <mission.liao@dexon.org> | 2019-01-05 00:16:15 +0800 |
---|---|---|
committer | Wei-Ning Huang <w@dexon.org> | 2019-01-05 00:16:15 +0800 |
commit | 65f14ef166d7fd3ea30f50366d55777b54fe305f (patch) | |
tree | 6de40faba33caecc38171377a9ca8d4834562f5b /core/syncer/consensus.go | |
parent | c7fdbd64be6228aa87b14f8953311c88cc14b4ff (diff) | |
download | tangerine-consensus-65f14ef166d7fd3ea30f50366d55777b54fe305f.tar tangerine-consensus-65f14ef166d7fd3ea30f50366d55777b54fe305f.tar.gz tangerine-consensus-65f14ef166d7fd3ea30f50366d55777b54fe305f.tar.bz2 tangerine-consensus-65f14ef166d7fd3ea30f50366d55777b54fe305f.tar.lz tangerine-consensus-65f14ef166d7fd3ea30f50366d55777b54fe305f.tar.xz tangerine-consensus-65f14ef166d7fd3ea30f50366d55777b54fe305f.tar.zst tangerine-consensus-65f14ef166d7fd3ea30f50366d55777b54fe305f.zip |
core: fix stuffs (#401)
* Remove block recycling mechanism
* Return directly when previous DKG is not finished.
* Adjust some logging level
* Skip pulling when hashes to pull is empty
Diffstat (limited to 'core/syncer/consensus.go')
-rw-r--r-- | core/syncer/consensus.go | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/core/syncer/consensus.go b/core/syncer/consensus.go index 8852a47..92f8fd8 100644 --- a/core/syncer/consensus.go +++ b/core/syncer/consensus.go @@ -262,12 +262,12 @@ func (con *Consensus) ensureAgreementOverlapRound() bool { for r = range tipRoundMap { break } - con.logger.Info("check agreement round cut", + con.logger.Debug("check agreement round cut", "tip-round", r, "configs", len(con.configs)) if tipRoundMap[r] == con.configs[r].NumChains { con.agreementRoundCut = r - con.logger.Debug("agreement round cut found, round", r) + con.logger.Info("agreement round cut found, round", r) return true } } @@ -416,7 +416,7 @@ func (con *Consensus) SyncBlocks( "expected", tipHeight+1) return false, ErrInvalidSyncingFinalizationHeight } - con.logger.Debug("syncBlocks", + con.logger.Trace("syncBlocks", "position", &blocks[0].Position, "final height", blocks[0].Finalization.Height, "len", len(blocks), @@ -601,7 +601,7 @@ func (con *Consensus) setupConfigs(blocks []*types.Block) { maxRound = b.Position.Round } } - con.logger.Info("syncer setupConfigs", + con.logger.Debug("syncer setupConfigs", "max", maxRound, "lattice", con.latticeLastRound) // Get configs from governance. @@ -737,7 +737,7 @@ func (con *Consensus) startCRSMonitor() { if round == lastNotifiedRound { return } - con.logger.Info("CRS is ready", "round", round) + con.logger.Debug("CRS is ready", "round", round) lastNotifiedRound = round for _, a := range con.agreements { a.inputChan <- round |