aboutsummaryrefslogtreecommitdiffstats
path: root/core/consensus.go
diff options
context:
space:
mode:
authorMission Liao <mission.liao@dexon.org>2018-10-11 19:33:25 +0800
committerGitHub <noreply@github.com>2018-10-11 19:33:25 +0800
commit490fa1e9ce2b661e4c8b612bd53f20123346353b (patch)
tree2ef4a4fabb1e21d46ef3e47538dadfeecdf2cf4d /core/consensus.go
parentf3e9eb613c7e8dec6b8c6b1b0a20ddbec4e91a9c (diff)
downloaddexon-consensus-490fa1e9ce2b661e4c8b612bd53f20123346353b.tar
dexon-consensus-490fa1e9ce2b661e4c8b612bd53f20123346353b.tar.gz
dexon-consensus-490fa1e9ce2b661e4c8b612bd53f20123346353b.tar.bz2
dexon-consensus-490fa1e9ce2b661e4c8b612bd53f20123346353b.tar.lz
dexon-consensus-490fa1e9ce2b661e4c8b612bd53f20123346353b.tar.xz
dexon-consensus-490fa1e9ce2b661e4c8b612bd53f20123346353b.tar.zst
dexon-consensus-490fa1e9ce2b661e4c8b612bd53f20123346353b.zip
core: change interface (#193)
* Extract types.FinalizationResult * Change interface: - Application.BlockConfirmed returns whole block. - Application.BlockDelivered returns partial result.
Diffstat (limited to 'core/consensus.go')
-rw-r--r--core/consensus.go9
1 files changed, 3 insertions, 6 deletions
diff --git a/core/consensus.go b/core/consensus.go
index 4b1b4d3..dcc6f38 100644
--- a/core/consensus.go
+++ b/core/consensus.go
@@ -673,18 +673,15 @@ func (con *Consensus) processBlock(block *types.Block) (err error) {
if err = con.ccModule.processBlock(b); err != nil {
return
}
- go con.event.NotifyTime(b.ConsensusTimestamp)
+ go con.event.NotifyTime(b.Finalization.Timestamp)
}
deliveredBlocks = con.ccModule.extractBlocks()
for _, b := range deliveredBlocks {
if err = con.db.Put(*b); err != nil {
return
}
- con.nbModule.BlockDelivered(*b)
- // TODO(mission): Find a way to safely recycle the block.
- // We should deliver block directly to
- // nonBlocking and let them recycle the
- // block.
+ // TODO(mission): clone types.FinalizationResult
+ con.nbModule.BlockDelivered(b.Hash, b.Finalization)
}
if err = con.lattice.PurgeBlocks(deliveredBlocks); err != nil {
return