diff options
author | Mission Liao <mission.liao@dexon.org> | 2019-01-04 12:08:55 +0800 |
---|---|---|
committer | haoping-ku <haoping.ku@dexon.org> | 2019-01-04 12:08:55 +0800 |
commit | 47cb69d390aedf53f44cae35629b3568a166e3fb (patch) | |
tree | 699aa6f972a78e069456458b8a159797d8595f9a /core/total-ordering-syncer_test.go | |
parent | c5bfa29c2ad5d51147d0a5c1b725369b75da3cd8 (diff) | |
download | tangerine-consensus-47cb69d390aedf53f44cae35629b3568a166e3fb.tar.gz tangerine-consensus-47cb69d390aedf53f44cae35629b3568a166e3fb.tar.zst tangerine-consensus-47cb69d390aedf53f44cae35629b3568a166e3fb.zip |
core: check if deliverable for each added block in total ordering (#395)
* Check if deliverable multiple times for each added block
* Fix format
Diffstat (limited to 'core/total-ordering-syncer_test.go')
-rw-r--r-- | core/total-ordering-syncer_test.go | 14 |
1 files changed, 10 insertions, 4 deletions
diff --git a/core/total-ordering-syncer_test.go b/core/total-ordering-syncer_test.go index 79a6830..4a4e8e0 100644 --- a/core/total-ordering-syncer_test.go +++ b/core/total-ordering-syncer_test.go @@ -76,10 +76,16 @@ func (s *TotalOrderingSyncerTestSuite) genDeliverySet(numChains uint32) ( } s.Require().NoError(err) // Perform total ordering. - blocks, _, err := to.processBlock(&b) - s.Require().NoError(err) - if len(blocks) > 0 { - deliverySet = append(deliverySet, blocks) + s.Require().NoError(to.addBlock(&b)) + for { + blocks, _, err := to.extractBlocks() + s.Require().NoError(err) + if len(blocks) == 0 { + break + } + if len(blocks) > 0 { + deliverySet = append(deliverySet, blocks) + } } } return |