aboutsummaryrefslogtreecommitdiffstats
path: root/core/total-ordering-syncer_test.go
diff options
context:
space:
mode:
authorMission Liao <mission.liao@dexon.org>2019-01-04 12:08:55 +0800
committerhaoping-ku <haoping.ku@dexon.org>2019-01-04 12:08:55 +0800
commit47cb69d390aedf53f44cae35629b3568a166e3fb (patch)
tree699aa6f972a78e069456458b8a159797d8595f9a /core/total-ordering-syncer_test.go
parentc5bfa29c2ad5d51147d0a5c1b725369b75da3cd8 (diff)
downloadtangerine-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.go14
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