aboutsummaryrefslogtreecommitdiffstats
path: root/core/agreement_test.go
diff options
context:
space:
mode:
authorMission Liao <mission.liao@dexon.org>2018-09-28 14:42:11 +0800
committerGitHub <noreply@github.com>2018-09-28 14:42:11 +0800
commitfa841708d78404ab45667a697c8527831ad820d8 (patch)
treee7310797b19932a4aebea1638ba783f85309e77e /core/agreement_test.go
parent9ad4ae71b5a49ddc77687cc368c31416a0ee0688 (diff)
downloaddexon-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.go18
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