aboutsummaryrefslogtreecommitdiffstats
path: root/core/lattice_test.go
diff options
context:
space:
mode:
authorMission Liao <mission.liao@dexon.org>2018-10-05 09:12:26 +0800
committerGitHub <noreply@github.com>2018-10-05 09:12:26 +0800
commitefcb301ec31acf7b87312cbec962682148555999 (patch)
tree76ba2fbe5a7c7017005f771ab95102b997973f1f /core/lattice_test.go
parent6773c56fe29511aca0f4345e9fd3758ca05e174f (diff)
downloaddexon-consensus-efcb301ec31acf7b87312cbec962682148555999.tar
dexon-consensus-efcb301ec31acf7b87312cbec962682148555999.tar.gz
dexon-consensus-efcb301ec31acf7b87312cbec962682148555999.tar.bz2
dexon-consensus-efcb301ec31acf7b87312cbec962682148555999.tar.lz
dexon-consensus-efcb301ec31acf7b87312cbec962682148555999.tar.xz
dexon-consensus-efcb301ec31acf7b87312cbec962682148555999.tar.zst
dexon-consensus-efcb301ec31acf7b87312cbec962682148555999.zip
core: find block in db (#174)
* Make sure block pool is large enough It's safe to use a larger blockPool when the number of chains is smaller. * Construct latticeData via config. * Seek acked blocks in blockdb when unable to find them in memory cache. In previous implementation, we assume our cache in memory is enough to perform DAG's sanity check. However, it's no longer true when the number of chains might be changed between rounds. * Simplify purge. Remove the relation to purge block by chainStatus.
Diffstat (limited to 'core/lattice_test.go')
-rw-r--r--core/lattice_test.go5
1 files changed, 4 insertions, 1 deletions
diff --git a/core/lattice_test.go b/core/lattice_test.go
index bf65684..1270a3c 100644
--- a/core/lattice_test.go
+++ b/core/lattice_test.go
@@ -75,11 +75,14 @@ func (mgr *testLatticeMgr) processBlock(b *types.Block) (err error) {
if err = mgr.ccModule.processBlock(b); err != nil {
return
}
- if err = mgr.db.Update(*b); err != nil {
+ if err = mgr.db.Put(*b); err != nil {
return
}
mgr.app.BlockDelivered(*b)
}
+ if err = mgr.lattice.PurgeBlocks(delivered); err != nil {
+ return
+ }
// Update pending blocks for verified block (pass sanity check).
pendings = append(pendings, verified...)
}