diff options
| author | Mission Liao <mission.liao@dexon.org> | 2018-12-12 16:55:19 +0800 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2018-12-12 16:55:19 +0800 |
| commit | 338bf8676563a103cc78bbacef75fbaaac4293d7 (patch) | |
| tree | 33587f90c7d7b8d61c99bebeb4ffee9c0b69668f /integration_test | |
| parent | d60fedadb35d56ed873bad301cf3e5fd9a96410d (diff) | |
| download | dexon-consensus-338bf8676563a103cc78bbacef75fbaaac4293d7.tar dexon-consensus-338bf8676563a103cc78bbacef75fbaaac4293d7.tar.gz dexon-consensus-338bf8676563a103cc78bbacef75fbaaac4293d7.tar.bz2 dexon-consensus-338bf8676563a103cc78bbacef75fbaaac4293d7.tar.lz dexon-consensus-338bf8676563a103cc78bbacef75fbaaac4293d7.tar.xz dexon-consensus-338bf8676563a103cc78bbacef75fbaaac4293d7.tar.zst dexon-consensus-338bf8676563a103cc78bbacef75fbaaac4293d7.zip | |
syncer: fix stuffs (#366)
* return delivered blocks when processing finalized blocks
* check deliver sequence when processing finalized blocks
* skip delivery of finalized blocks
* remove duplicated calls to BlockConfirmed
* add numChains change in test scenario
* fix the bug that restartNotary is triggered by older block
than current aID.
Diffstat (limited to 'integration_test')
| -rw-r--r-- | integration_test/consensus_test.go | 8 |
1 files changed, 7 insertions, 1 deletions
diff --git a/integration_test/consensus_test.go b/integration_test/consensus_test.go index 16cfa8f..6d693c8 100644 --- a/integration_test/consensus_test.go +++ b/integration_test/consensus_test.go @@ -322,6 +322,12 @@ func (s *ConsensusTestSuite) TestSync() { req.NoError(err) req.NoError(seedGov.State().RequestChange( test.StateChangeRoundInterval, 50*time.Second)) + req.NoError(seedGov.State().RequestChange( + test.StateChangeNumChains, uint32(5))) + seedGov.CatchUpWithRound(0) + req.NoError(seedGov.State().RequestChange( + test.StateChangeNumChains, uint32(4))) + seedGov.CatchUpWithRound(1) // A short round interval. nodes := s.setupNodes(dMoment, prvKeys, seedGov) // Choose the first node as "syncNode" that its consensus' Run() is called @@ -444,7 +450,7 @@ ReachAlive: // Stop a node, we should still be able to proceed. stoppedNode.con.Stop() stoppedNode.con = nil - fmt.Println("one node stopped") + fmt.Println("one node stopped", stoppedNode.ID) // Initiate a dummy routine to consume the receive channel. go func() { for { |