aboutsummaryrefslogtreecommitdiffstats
path: root/dex/backend.go
diff options
context:
space:
mode:
authorSonic <sonic@dexon.org>2018-12-05 15:17:38 +0800
committerWei-Ning Huang <w@dexon.org>2019-04-09 21:32:54 +0800
commit8a244e8fb95eac41e41ecb07e5652fedb6949d0e (patch)
tree3404cb5da63865d5045d910157e67fa66c717c3d /dex/backend.go
parent9e5b923db28f0776bd6e34dbe1c9eddef03ffea9 (diff)
downloaddexon-8a244e8fb95eac41e41ecb07e5652fedb6949d0e.tar
dexon-8a244e8fb95eac41e41ecb07e5652fedb6949d0e.tar.gz
dexon-8a244e8fb95eac41e41ecb07e5652fedb6949d0e.tar.bz2
dexon-8a244e8fb95eac41e41ecb07e5652fedb6949d0e.tar.lz
dexon-8a244e8fb95eac41e41ecb07e5652fedb6949d0e.tar.xz
dexon-8a244e8fb95eac41e41ecb07e5652fedb6949d0e.tar.zst
dexon-8a244e8fb95eac41e41ecb07e5652fedb6949d0e.zip
core, dex: polish sync (#75)
- Broadcasting blocks at chain head event is not correct when the full node is not running in block proposer mode. Introduce NewFinalizedBlockEvent, this event is post by the full node which runs in block proposer mode when a block is witnessed and resulting in some blocks are considered finalized. - Non block proposer node will still broadcast blocks at the following moment (same as ethereum): 1. a sync with a peer is terminated successfully 2. a block passes the fetcher's header check during inserting blocks 3. a block is successfully inserted by fetcher - Don't trigger a sync when we are not behind other peers more than acceptable distance. Fetcher is able to cover this.
Diffstat (limited to 'dex/backend.go')
-rw-r--r--dex/backend.go3
1 files changed, 2 insertions, 1 deletions
diff --git a/dex/backend.go b/dex/backend.go
index eb9d8f765..4e7def8e4 100644
--- a/dex/backend.go
+++ b/dex/backend.go
@@ -157,7 +157,7 @@ func New(ctx *node.ServiceContext, config *Config) (*Dexon, error) {
pm, err := NewProtocolManager(dex.chainConfig, config.SyncMode,
config.NetworkId, dex.eventMux, dex.txPool, dex.engine, dex.blockchain,
- chainDb, config.BlockProposerEnabled, dex.governance)
+ chainDb, config.BlockProposerEnabled, dex.governance, dex.app)
if err != nil {
return nil, err
}
@@ -245,6 +245,7 @@ func (s *Dexon) Start(srvr *p2p.Server) error {
}
func (s *Dexon) Stop() error {
+ s.app.Stop()
return nil
}