aboutsummaryrefslogtreecommitdiffstats
path: root/core/syncer/consensus.go
diff options
context:
space:
mode:
authorMission Liao <mission.liao@dexon.org>2018-12-13 09:55:14 +0800
committerGitHub <noreply@github.com>2018-12-13 09:55:14 +0800
commit06693fc13b451835ac460688903c7abb660710fb (patch)
tree22d1bfde3b023395cfe00c6df8a1edaebb0f7cce /core/syncer/consensus.go
parent338bf8676563a103cc78bbacef75fbaaac4293d7 (diff)
downloaddexon-consensus-06693fc13b451835ac460688903c7abb660710fb.tar
dexon-consensus-06693fc13b451835ac460688903c7abb660710fb.tar.gz
dexon-consensus-06693fc13b451835ac460688903c7abb660710fb.tar.bz2
dexon-consensus-06693fc13b451835ac460688903c7abb660710fb.tar.lz
dexon-consensus-06693fc13b451835ac460688903c7abb660710fb.tar.xz
dexon-consensus-06693fc13b451835ac460688903c7abb660710fb.tar.zst
dexon-consensus-06693fc13b451835ac460688903c7abb660710fb.zip
db: rename blockdb to db (#367)
* Rename blockdb package to db * Rename 'BlockDB' to 'DB' * Make all methods in db specific for ''block'. * Rename db.BlockDatabase to db.Database * Rename revealer to block-revealer * Rename test.Revealer to test.BlockRevealer
Diffstat (limited to 'core/syncer/consensus.go')
-rw-r--r--core/syncer/consensus.go22
1 files changed, 11 insertions, 11 deletions
diff --git a/core/syncer/consensus.go b/core/syncer/consensus.go
index dca6112..13a8873 100644
--- a/core/syncer/consensus.go
+++ b/core/syncer/consensus.go
@@ -26,8 +26,8 @@ import (
"github.com/dexon-foundation/dexon-consensus/common"
"github.com/dexon-foundation/dexon-consensus/core"
- "github.com/dexon-foundation/dexon-consensus/core/blockdb"
"github.com/dexon-foundation/dexon-consensus/core/crypto"
+ "github.com/dexon-foundation/dexon-consensus/core/db"
"github.com/dexon-foundation/dexon-consensus/core/types"
"github.com/dexon-foundation/dexon-consensus/core/utils"
)
@@ -46,7 +46,7 @@ var (
// Consensus is for syncing consensus module.
type Consensus struct {
- db blockdb.BlockDatabase
+ db db.Database
gov core.Governance
dMoment time.Time
logger common.Logger
@@ -82,7 +82,7 @@ func NewConsensus(
dMoment time.Time,
app core.Application,
gov core.Governance,
- db blockdb.BlockDatabase,
+ db db.Database,
network core.Network,
prv crypto.PrivateKey,
logger common.Logger) *Consensus {
@@ -170,7 +170,7 @@ func (con *Consensus) checkIfSynced(blocks []*types.Block) bool {
if (b.Finalization.ParentHash == common.Hash{}) {
return false
}
- b1, err := con.db.Get(b.Finalization.ParentHash)
+ b1, err := con.db.GetBlock(b.Finalization.ParentHash)
if err != nil {
panic(err)
}
@@ -286,7 +286,7 @@ func (con *Consensus) findLatticeSyncBlock(
if (lastBlock.Finalization.ParentHash == common.Hash{}) {
return nil, ErrGenesisBlockReached
}
- b, err := con.db.Get(lastBlock.Finalization.ParentHash)
+ b, err := con.db.GetBlock(lastBlock.Finalization.ParentHash)
if err != nil {
return nil, err
}
@@ -302,7 +302,7 @@ func (con *Consensus) findLatticeSyncBlock(
if (curBlock.Finalization.ParentHash == common.Hash{}) {
return nil, ErrGenesisBlockReached
}
- b, err := con.db.Get(curBlock.Finalization.ParentHash)
+ b, err := con.db.GetBlock(curBlock.Finalization.ParentHash)
if err != nil {
return nil, err
}
@@ -318,7 +318,7 @@ func (con *Consensus) findLatticeSyncBlock(
if (curBlock.Finalization.ParentHash == common.Hash{}) {
break
}
- b, err := con.db.Get(curBlock.Finalization.ParentHash)
+ b, err := con.db.GetBlock(curBlock.Finalization.ParentHash)
if err != nil {
return nil, err
}
@@ -338,7 +338,7 @@ func (con *Consensus) findLatticeSyncBlock(
ok = false
break
}
- b, err := con.db.Get(curBlock.Finalization.ParentHash)
+ b, err := con.db.GetBlock(curBlock.Finalization.ParentHash)
if err != nil {
return nil, err
}
@@ -403,8 +403,8 @@ func (con *Consensus) SyncBlocks(
con.setupConfigs(blocks)
for _, b := range blocks {
// TODO(haoping) remove this if lattice puts blocks into db.
- if err := con.db.Put(*b); err != nil {
- if err != blockdb.ErrBlockExists {
+ if err := con.db.PutBlock(*b); err != nil {
+ if err != db.ErrBlockExists {
return nil, err
}
}
@@ -433,7 +433,7 @@ func (con *Consensus) SyncBlocks(
if b.Hash == syncBlock.Hash {
break
}
- b1, err := con.db.Get(b.Finalization.ParentHash)
+ b1, err := con.db.GetBlock(b.Finalization.ParentHash)
if err != nil {
return nil, err
}