diff options
| author | Jimmy Hu <jimmy.hu@dexon.org> | 2019-03-26 11:59:24 +0800 |
|---|---|---|
| committer | Jimmy Hu <jimmy.hu@dexon.org> | 2019-03-27 15:25:10 +0800 |
| commit | 7783bc4ba52bfc534d5b4d91e78abb2ddad7d078 (patch) | |
| tree | f57ea6f4d8b2faa23ab95691717b071f507e621f /core/test/network.go | |
| parent | b8ced165b1fb03394f8758e08148b0e5d06aa07b (diff) | |
| download | dexon-consensus-7783bc4ba52bfc534d5b4d91e78abb2ddad7d078.tar.gz dexon-consensus-7783bc4ba52bfc534d5b4d91e78abb2ddad7d078.tar.zst dexon-consensus-7783bc4ba52bfc534d5b4d91e78abb2ddad7d078.zip | |
core: bring back agreement result (#515)
* core: bring back agreement result
* add logger
* Fix
* fixup
Diffstat (limited to 'core/test/network.go')
| -rw-r--r-- | core/test/network.go | 13 |
1 files changed, 8 insertions, 5 deletions
diff --git a/core/test/network.go b/core/test/network.go index c903c57..b0ce3f7 100644 --- a/core/test/network.go +++ b/core/test/network.go @@ -41,6 +41,7 @@ const ( maxVoteCache = 128 // Gossiping parameter. + maxAgreementResultBroadcast = 3 gossipAgreementResultPercent = 33 ) @@ -282,9 +283,11 @@ func (n *Network) BroadcastBlock(block *types.Block) { // Avoid data race in fake transport. block = n.cloneForFake(block).(*types.Block) notarySet := n.getNotarySet(block.Position.Round) - if err := n.trans.Broadcast( - notarySet, n.config.DirectLatency, block); err != nil { - panic(err) + if !block.IsFinalized() { + if err := n.trans.Broadcast( + notarySet, n.config.DirectLatency, block); err != nil { + panic(err) + } } if err := n.trans.Broadcast(getComplementSet(n.peers, notarySet), n.config.GossipLatency, block); err != nil { @@ -308,10 +311,10 @@ func (n *Network) BroadcastAgreementResult( n.addBlockFinalizationToCache( result.BlockHash, result.FinalizationHeight, - nil, + result.Randomness, ) notarySet := n.getNotarySet(result.Position.Round) - count := len(notarySet)*gossipAgreementResultPercent/100 + 1 + count := maxAgreementResultBroadcast for nID := range notarySet { if count--; count < 0 { break |