From b02fa5ee430cff9dafc9d9c399099a88d554a083 Mon Sep 17 00:00:00 2001 From: Jimmy Hu Date: Fri, 15 Mar 2019 18:17:53 +0800 Subject: core/syncer: add force sync (#468) * core: Add Recovery Interface * core/syncer: modify recovery interface * core: fix Recovery interface * core/syncer: rename terminator to watchcat (#491) * core/syncer: rename terminator to watchcat * Add error log * Rename Pat to Feed * core/syncer: add force sync * run prepareRandomness if round >= DKGDelayRound * Add test for Forcsync --- core/test/app.go | 9 +++++++++ 1 file changed, 9 insertions(+) (limited to 'core/test') diff --git a/core/test/app.go b/core/test/app.go index 0a17f13..4cfd580 100644 --- a/core/test/app.go +++ b/core/test/app.go @@ -208,6 +208,15 @@ func (app *App) BlockConfirmed(b types.Block) { app.LastConfirmedHeight = b.Position.Height } +// ClearUndeliveredBlocks -- +func (app *App) ClearUndeliveredBlocks() { + app.deliveredLock.RLock() + defer app.deliveredLock.RUnlock() + app.confirmedLock.Lock() + defer app.confirmedLock.Unlock() + app.LastConfirmedHeight = uint64(len(app.DeliverSequence) - 1) +} + // BlockDelivered implements Application interface. func (app *App) BlockDelivered(blockHash common.Hash, pos types.Position, result types.FinalizationResult) { -- cgit v1.2.3