aboutsummaryrefslogtreecommitdiffstats
path: root/dex/handler.go
diff options
context:
space:
mode:
authorSonic <sonic@dexon.org>2018-12-21 14:53:37 +0800
committerWei-Ning Huang <w@dexon.org>2019-04-09 21:32:55 +0800
commitbebcd229959b250a4127bdd678b49048ee0208ea (patch)
tree62dbf8ef24f1fd1a3b7ff352bc5c9bebaa967dff /dex/handler.go
parent0c9666161c9630edf8eca571e7c93db7d21dfba3 (diff)
downloaddexon-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.go8
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 {