diff options
author | Sonic <sonic@dexon.org> | 2018-12-21 14:53:37 +0800 |
---|---|---|
committer | Wei-Ning Huang <w@dexon.org> | 2019-03-12 12:19:09 +0800 |
commit | f5522f0ffcbe127a8fd364647848be46ecc68cda (patch) | |
tree | fb31ed0a49864ff6876f2130acd5e33c245fad1a /dex/app.go | |
parent | 4002c85e8e073f3a03dbd8c71e98188c0306a942 (diff) | |
download | dexon-f5522f0ffcbe127a8fd364647848be46ecc68cda.tar dexon-f5522f0ffcbe127a8fd364647848be46ecc68cda.tar.gz dexon-f5522f0ffcbe127a8fd364647848be46ecc68cda.tar.bz2 dexon-f5522f0ffcbe127a8fd364647848be46ecc68cda.tar.lz dexon-f5522f0ffcbe127a8fd364647848be46ecc68cda.tar.xz dexon-f5522f0ffcbe127a8fd364647848be46ecc68cda.tar.zst dexon-f5522f0ffcbe127a8fd364647848be46ecc68cda.zip |
core, dex, internal: block proposer syncing (first iteration) (#96)
* dex, internal: block proposer syncing (first iteration)
* core: find block from db if not in memory
This fix handles stopping proposing and then restarting
* core: no need to reorg when reset
Dexon will not fork. This commit also fix when a block confirm but
its parent is not in db yet, during restarting proposing.
* dex: always accept NewBlockMsg, NewBlockHashesMsg
We need to accept NewBlockMsg, NewBlockHashesMsg to sync current block with
other peers in block proposer mode when syncing lattice data. It's a waste
when the node is synced and start proposing.
Todo: control msg processing on/off more granular, accept NewBlockMsg,
NewBlockHashesMsg when syncing, but stop when synced.
Diffstat (limited to 'dex/app.go')
-rw-r--r-- | dex/app.go | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/dex/app.go b/dex/app.go index 9dcfd87e9..d04b2afd6 100644 --- a/dex/app.go +++ b/dex/app.go @@ -451,6 +451,9 @@ func (d *DexconApp) BlockDelivered( blockPosition coreTypes.Position, result coreTypes.FinalizationResult) { + log.Debug("DexconApp block deliver", "height", result.Height, "hash", blockHash, "position", blockPosition.String()) + defer log.Debug("DexconApp block delivered", "height", result.Height, "hash", blockHash, "position", blockPosition.String()) + chainID := blockPosition.ChainID d.chainLock(chainID) defer d.chainUnlock(chainID) @@ -461,6 +464,7 @@ func (d *DexconApp) BlockDelivered( } block.Payload = nil + block.Finalization = result dexconMeta, err := rlp.EncodeToBytes(block) if err != nil { panic(err) @@ -501,6 +505,7 @@ func (d *DexconApp) BlockConfirmed(block coreTypes.Block) { d.chainLock(block.Position.ChainID) defer d.chainUnlock(block.Position.ChainID) + log.Debug("DexconApp block confirmed", "block", block.String()) if err := d.blockchain.AddConfirmedBlock(&block); err != nil { panic(err) } |