diff options
author | Sonic <sonic@dexon.org> | 2018-12-21 14:53:37 +0800 |
---|---|---|
committer | Wei-Ning Huang <w@dexon.org> | 2019-04-09 21:32:55 +0800 |
commit | bebcd229959b250a4127bdd678b49048ee0208ea (patch) | |
tree | 62dbf8ef24f1fd1a3b7ff352bc5c9bebaa967dff /dex/handler.go | |
parent | 0c9666161c9630edf8eca571e7c93db7d21dfba3 (diff) | |
download | dexon-bebcd229959b250a4127bdd678b49048ee0208ea.tar dexon-bebcd229959b250a4127bdd678b49048ee0208ea.tar.gz dexon-bebcd229959b250a4127bdd678b49048ee0208ea.tar.bz2 dexon-bebcd229959b250a4127bdd678b49048ee0208ea.tar.lz dexon-bebcd229959b250a4127bdd678b49048ee0208ea.tar.xz dexon-bebcd229959b250a4127bdd678b49048ee0208ea.tar.zst dexon-bebcd229959b250a4127bdd678b49048ee0208ea.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/handler.go')
-rw-r--r-- | dex/handler.go | 8 |
1 files changed, 0 insertions, 8 deletions
diff --git a/dex/handler.go b/dex/handler.go index 9174d8516..ff87884d2 100644 --- a/dex/handler.go +++ b/dex/handler.go @@ -713,10 +713,6 @@ func (pm *ProtocolManager) handleMsg(p *peer) error { } case msg.Code == NewBlockHashesMsg: - // Ignore new block hash messages in block proposer mode. - if pm.isBlockProposer { - break - } var announces newBlockHashesData if err := msg.Decode(&announces); err != nil { return errResp(ErrDecode, "%v: %v", msg, err) @@ -737,10 +733,6 @@ func (pm *ProtocolManager) handleMsg(p *peer) error { } case msg.Code == NewBlockMsg: - // Ignore new block messages in block proposer mode. - if pm.isBlockProposer { - break - } // Retrieve and decode the propagated block var block types.Block if err := msg.Decode(&block); err != nil { |