diff options
author | Mission Liao <mission.liao@dexon.org> | 2018-09-28 14:42:11 +0800 |
---|---|---|
committer | GitHub <noreply@github.com> | 2018-09-28 14:42:11 +0800 |
commit | fa841708d78404ab45667a697c8527831ad820d8 (patch) | |
tree | e7310797b19932a4aebea1638ba783f85309e77e /core/agreement_test.go | |
parent | 9ad4ae71b5a49ddc77687cc368c31416a0ee0688 (diff) | |
download | dexon-consensus-fa841708d78404ab45667a697c8527831ad820d8.tar dexon-consensus-fa841708d78404ab45667a697c8527831ad820d8.tar.gz dexon-consensus-fa841708d78404ab45667a697c8527831ad820d8.tar.bz2 dexon-consensus-fa841708d78404ab45667a697c8527831ad820d8.tar.lz dexon-consensus-fa841708d78404ab45667a697c8527831ad820d8.tar.xz dexon-consensus-fa841708d78404ab45667a697c8527831ad820d8.tar.zst dexon-consensus-fa841708d78404ab45667a697c8527831ad820d8.zip |
core: remove legacy mode (#149)
Diffstat (limited to 'core/agreement_test.go')
-rw-r--r-- | core/agreement_test.go | 18 |
1 files changed, 9 insertions, 9 deletions
diff --git a/core/agreement_test.go b/core/agreement_test.go index d384dc6..db50bd5 100644 --- a/core/agreement_test.go +++ b/core/agreement_test.go @@ -29,15 +29,17 @@ import ( // agreementTestReceiver implements core.agreementReceiveer type agreementTestReceiver struct { - s *AgreementTestSuite + s *AgreementTestSuite + agreementIndex int } func (r *agreementTestReceiver) ProposeVote(vote *types.Vote) { r.s.voteChan <- vote } -func (r *agreementTestReceiver) ProposeBlock(block common.Hash) { - r.s.blockChan <- block +func (r *agreementTestReceiver) ProposeBlock() { + block := r.s.proposeBlock(r.agreementIndex) + r.s.blockChan <- block.Hash } func (r *agreementTestReceiver) ConfirmBlock(block common.Hash) { @@ -82,10 +84,6 @@ func (s *AgreementTestSuite) SetupTest() { func (s *AgreementTestSuite) newAgreement(numNotarySet int) *agreement { leader := newGenesisLeaderSelector([]byte("🖖👽")) agreementIdx := len(s.agreement) - blockProposer := func() *types.Block { - return s.proposeBlock(agreementIdx) - } - notarySet := make(map[types.NodeID]struct{}) for i := 0; i < numNotarySet-1; i++ { prvKey, err := ecdsa.NewPrivateKey() @@ -97,10 +95,12 @@ func (s *AgreementTestSuite) newAgreement(numNotarySet int) *agreement { notarySet[s.ID] = struct{}{} agreement := newAgreement( s.ID, - &agreementTestReceiver{s}, + &agreementTestReceiver{ + s: s, + agreementIndex: agreementIdx, + }, notarySet, leader, - blockProposer, ) s.agreement = append(s.agreement, agreement) return agreement |