diff options
author | Wei-Ning Huang <w@dexon.org> | 2018-09-19 18:48:41 +0800 |
---|---|---|
committer | missionliao <38416648+missionliao@users.noreply.github.com> | 2018-09-19 18:48:41 +0800 |
commit | 22e70f6da486ed6796a493f25e04679b9afa1439 (patch) | |
tree | 41998daa892812957daa58d7fe84d6fd06f4327c /core/consensus.go | |
parent | a2a733e6f98018cb2ecc4b3982386be8892d7433 (diff) | |
download | tangerine-consensus-22e70f6da486ed6796a493f25e04679b9afa1439.tar tangerine-consensus-22e70f6da486ed6796a493f25e04679b9afa1439.tar.gz tangerine-consensus-22e70f6da486ed6796a493f25e04679b9afa1439.tar.bz2 tangerine-consensus-22e70f6da486ed6796a493f25e04679b9afa1439.tar.lz tangerine-consensus-22e70f6da486ed6796a493f25e04679b9afa1439.tar.xz tangerine-consensus-22e70f6da486ed6796a493f25e04679b9afa1439.tar.zst tangerine-consensus-22e70f6da486ed6796a493f25e04679b9afa1439.zip |
core: rename Notary (Acks) to Witness (#118)
Diffstat (limited to 'core/consensus.go')
-rw-r--r-- | core/consensus.go | 30 |
1 files changed, 15 insertions, 15 deletions
diff --git a/core/consensus.go b/core/consensus.go index 5179baf..7398628 100644 --- a/core/consensus.go +++ b/core/consensus.go @@ -345,8 +345,8 @@ func (con *Consensus) processMsg( if err := blockProcesser(val); err != nil { log.Println(err) } - case *types.NotaryAck: - if err := con.ProcessNotaryAck(val); err != nil { + case *types.WitnessAck: + if err := con.ProcessWitnessAck(val); err != nil { log.Println(err) } case *types.Vote: @@ -476,22 +476,22 @@ func (con *Consensus) ProcessBlock(block *types.Block) (err error) { if err = con.db.Update(*b); err != nil { return } - con.app.DeliverBlock(b.Hash, b.Notary.Timestamp) + con.app.DeliverBlock(b.Hash, b.Witness.Timestamp) // TODO(mission): Find a way to safely recycle the block. // We should deliver block directly to // nonBlockingApplication and let them recycle the // block. } - var notaryAck *types.NotaryAck - notaryAck, err = con.ccModule.prepareNotaryAck(con.prvKey) + var witnessAck *types.WitnessAck + witnessAck, err = con.ccModule.prepareWitnessAck(con.prvKey) if err != nil { return } - err = con.ProcessNotaryAck(notaryAck) + err = con.ProcessWitnessAck(witnessAck) if err != nil { return } - con.app.NotaryAckDeliver(notaryAck) + con.app.WitnessAckDeliver(witnessAck) } return } @@ -552,18 +552,18 @@ func (con *Consensus) PrepareGenesisBlock(b *types.Block, return } -// ProcessNotaryAck is the entry point to submit one notary ack. -func (con *Consensus) ProcessNotaryAck(notaryAck *types.NotaryAck) (err error) { - notaryAck = notaryAck.Clone() - if _, exists := con.gov.GetNotarySet()[notaryAck.ProposerID]; !exists { +// ProcessWitnessAck is the entry point to submit one witness ack. +func (con *Consensus) ProcessWitnessAck(witnessAck *types.WitnessAck) (err error) { + witnessAck = witnessAck.Clone() + if _, exists := con.gov.GetNotarySet()[witnessAck.ProposerID]; !exists { err = ErrProposerNotValidator return } - err = con.ccModule.processNotaryAck(notaryAck) + err = con.ccModule.processWitnessAck(witnessAck) return } -// NotaryAcks returns the latest NotaryAck received from all other validators. -func (con *Consensus) NotaryAcks() map[types.ValidatorID]*types.NotaryAck { - return con.ccModule.notaryAcks() +// WitnessAcks returns the latest WitnessAck received from all other validators. +func (con *Consensus) WitnessAcks() map[types.ValidatorID]*types.WitnessAck { + return con.ccModule.witnessAcks() } |