diff options
author | Mission Liao <mission.liao@dexon.org> | 2018-12-13 09:55:14 +0800 |
---|---|---|
committer | GitHub <noreply@github.com> | 2018-12-13 09:55:14 +0800 |
commit | 06693fc13b451835ac460688903c7abb660710fb (patch) | |
tree | 22d1bfde3b023395cfe00c6df8a1edaebb0f7cce /core/syncer/consensus.go | |
parent | 338bf8676563a103cc78bbacef75fbaaac4293d7 (diff) | |
download | dexon-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.go | 22 |
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 } |