dex: remove time alignment when force sync (#349)

* vendor: sync to latest core

* dex: remove time alignment when force sync

3 files changed, 38 insertions, 25 deletions

diff --git a/vendor/github.com/dexon-foundation/dexon-consensus/core/syncer/consensus.go b/vendor/github.com/dexon-foundation/dexon-consensus/core/syncer/consensus.go
index f4681a268..7db836a9a 100644
--- a/vendor/github.com/dexon-foundation/dexon-consensus/core/syncer/consensus.go
+++ b/vendor/github.com/dexon-foundation/dexon-consensus/core/syncer/consensus.go
@@ -276,17 +276,21 @@ func (con *Consensus) buildAllEmptyBlocks() {
 }
 
 // ForceSync forces syncer to become synced.
-func (con *Consensus) ForceSync(skip bool) {
+func (con *Consensus) ForceSync(lastPos types.Position, skip bool) {
 	if con.syncedLastBlock != nil {
 		return
 	}
-	hash, _ := con.db.GetCompactionChainTipInfo()
-	var block types.Block
+	hash, height := con.db.GetCompactionChainTipInfo()
+	if height < lastPos.Height {
+		panic(fmt.Errorf("compaction chain not synced height %d, tip %d",
+			lastPos.Height, height))
+	} else if height > lastPos.Height {
+		skip = false
+	}
 	block, err := con.db.GetBlock(hash)
 	if err != nil {
 		panic(err)
 	}
-	con.logger.Info("Force Sync", "block", &block)
 	con.syncedLastBlock = &block
 	con.stopBuffering()
 	// We might call stopBuffering without calling assureBuffering.
@@ -298,6 +302,7 @@ func (con *Consensus) ForceSync(skip bool) {
 			})
 	}
 	con.syncedSkipNext = skip
+	con.logger.Info("Force Sync", "block", &block, "skip", skip)
 }
 
 // SyncBlocks syncs blocks from compaction chain, latest is true if the caller
diff --git a/vendor/github.com/dexon-foundation/dexon-consensus/core/syncer/watch-cat.go b/vendor/github.com/dexon-foundation/dexon-consensus/core/syncer/watch-cat.go
index d08bff9e9..f2e197ebe 100644
--- a/vendor/github.com/dexon-foundation/dexon-consensus/core/syncer/watch-cat.go
+++ b/vendor/github.com/dexon-foundation/dexon-consensus/core/syncer/watch-cat.go
@@ -37,6 +37,7 @@ type WatchCat struct {
 	timeout      time.Duration
 	configReader configReader
 	feed         chan types.Position
+	lastPosition types.Position
 	polling      time.Duration
 	ctx          context.Context
 	cancel       context.CancelFunc
@@ -69,6 +70,7 @@ func (wc *WatchCat) Feed(position types.Position) {
 // Start the WatchCat.
 func (wc *WatchCat) Start() {
 	wc.Stop()
+	wc.lastPosition = types.Position{}
 	wc.ctx, wc.cancel = context.WithCancel(context.Background())
 	go func() {
 		var lastPos types.Position
@@ -124,6 +126,7 @@ func (wc *WatchCat) Start() {
 				wc.logger.Error("Failed to get recovery votes", "height", lastPos.Height, "error", err)
 			} else if votes > threshold {
 				wc.logger.Info("Threshold for recovery reached!")
+				wc.lastPosition = lastPos
 				break ResetLoop
 			}
 			select {
@@ -146,3 +149,8 @@ func (wc *WatchCat) Stop() {
 func (wc *WatchCat) Meow() <-chan struct{} {
 	return wc.ctx.Done()
 }
+
+// LastPosition returns the last position for recovery.
+func (wc *WatchCat) LastPosition() types.Position {
+	return wc.lastPosition
+}
diff --git a/vendor/vendor.json b/vendor/vendor.json
index bc11c9398..f98477f06 100644
--- a/vendor/vendor.json
+++ b/vendor/vendor.json
@@ -141,16 +141,16 @@
 		{
 			"checksumSHA1": "In6vBHYUsX7DUIGiFN2hQggBgvI=",
 			"path": "github.com/dexon-foundation/dexon-consensus/common",
-			"revision": "f5a753891357ce76308578234ed9edd15bf81f23",
-			"revisionTime": "2019-04-09T08:31:02Z",
+			"revision": "948be08a7294e26f3b52f94f9af803f69680f9df",
+			"revisionTime": "2019-04-09T09:36:40Z",
 			"version": "single-chain",
 			"versionExact": "single-chain"
 		},
 		{
 			"checksumSHA1": "+omcW5A0/pD0ScXpN2SWIP6RC7A=",
 			"path": "github.com/dexon-foundation/dexon-consensus/core",
-			"revision": "f5a753891357ce76308578234ed9edd15bf81f23",
-			"revisionTime": "2019-04-09T08:31:02Z",
+			"revision": "948be08a7294e26f3b52f94f9af803f69680f9df",
+			"revisionTime": "2019-04-09T09:36:40Z",
 			"version": "single-chain",
 			"versionExact": "single-chain"
 		},
@@ -165,64 +165,64 @@
 		{
 			"checksumSHA1": "tQSbYCu5P00lUhKsx3IbBZCuSLY=",
 			"path": "github.com/dexon-foundation/dexon-consensus/core/crypto",
-			"revision": "f5a753891357ce76308578234ed9edd15bf81f23",
-			"revisionTime": "2019-04-09T08:31:02Z",
+			"revision": "948be08a7294e26f3b52f94f9af803f69680f9df",
+			"revisionTime": "2019-04-09T09:36:40Z",
 			"version": "single-chain",
 			"versionExact": "single-chain"
 		},
 		{
 			"checksumSHA1": "m5lUT04qSHKtFukvxjnFX5Jo2hI=",
 			"path": "github.com/dexon-foundation/dexon-consensus/core/crypto/dkg",
-			"revision": "f5a753891357ce76308578234ed9edd15bf81f23",
-			"revisionTime": "2019-04-09T08:31:02Z",
+			"revision": "948be08a7294e26f3b52f94f9af803f69680f9df",
+			"revisionTime": "2019-04-09T09:36:40Z",
 			"version": "single-chain",
 			"versionExact": "single-chain"
 		},
 		{
 			"checksumSHA1": "BhLKK8RveoLaeXc9UyUKMwQqchU=",
 			"path": "github.com/dexon-foundation/dexon-consensus/core/crypto/ecdsa",
-			"revision": "f5a753891357ce76308578234ed9edd15bf81f23",
-			"revisionTime": "2019-04-09T08:31:02Z",
+			"revision": "948be08a7294e26f3b52f94f9af803f69680f9df",
+			"revisionTime": "2019-04-09T09:36:40Z",
 			"version": "single-chain",
 			"versionExact": "single-chain"
 		},
 		{
 			"checksumSHA1": "hj/KetWUHp+1CX+50V0QnCthfWc=",
 			"path": "github.com/dexon-foundation/dexon-consensus/core/db",
-			"revision": "f5a753891357ce76308578234ed9edd15bf81f23",
-			"revisionTime": "2019-04-09T08:31:02Z",
+			"revision": "948be08a7294e26f3b52f94f9af803f69680f9df",
+			"revisionTime": "2019-04-09T09:36:40Z",
 			"version": "single-chain",
 			"versionExact": "single-chain"
 		},
 		{
-			"checksumSHA1": "B+2VHG7l1JXbxjuL52d+yp54K1g=",
+			"checksumSHA1": "/OcEQKdtWDyRZibazIsAxJWHUyg=",
 			"path": "github.com/dexon-foundation/dexon-consensus/core/syncer",
-			"revision": "f5a753891357ce76308578234ed9edd15bf81f23",
-			"revisionTime": "2019-04-09T08:31:02Z",
+			"revision": "948be08a7294e26f3b52f94f9af803f69680f9df",
+			"revisionTime": "2019-04-09T09:36:40Z",
 			"version": "single-chain",
 			"versionExact": "single-chain"
 		},
 		{
 			"checksumSHA1": "zIgCdN4FJiAuPGMhB+/9YGK/Wgk=",
 			"path": "github.com/dexon-foundation/dexon-consensus/core/types",
-			"revision": "f5a753891357ce76308578234ed9edd15bf81f23",
-			"revisionTime": "2019-04-09T08:31:02Z",
+			"revision": "948be08a7294e26f3b52f94f9af803f69680f9df",
+			"revisionTime": "2019-04-09T09:36:40Z",
 			"version": "single-chain",
 			"versionExact": "single-chain"
 		},
 		{
 			"checksumSHA1": "lbG7yqVgzo2CV/CQPYjG78xp5jg=",
 			"path": "github.com/dexon-foundation/dexon-consensus/core/types/dkg",
-			"revision": "f5a753891357ce76308578234ed9edd15bf81f23",
-			"revisionTime": "2019-04-09T08:31:02Z",
+			"revision": "948be08a7294e26f3b52f94f9af803f69680f9df",
+			"revisionTime": "2019-04-09T09:36:40Z",
 			"version": "single-chain",
 			"versionExact": "single-chain"
 		},
 		{
 			"checksumSHA1": "1VsJIshz0loXnGwCtrMM8SuIo6Y=",
 			"path": "github.com/dexon-foundation/dexon-consensus/core/utils",
-			"revision": "f5a753891357ce76308578234ed9edd15bf81f23",
-			"revisionTime": "2019-04-09T08:31:02Z",
+			"revision": "948be08a7294e26f3b52f94f9af803f69680f9df",
+			"revisionTime": "2019-04-09T09:36:40Z",
 			"version": "single-chain",
 			"versionExact": "single-chain"
 		},