aboutsummaryrefslogtreecommitdiffstats
path: root/dex/blockproposer.go
diff options
context:
space:
mode:
authorWei-Ning Huang <w@dexon.org>2019-03-17 20:14:41 +0800
committerWei-Ning Huang <w@byzantine-lab.io>2019-06-12 17:27:23 +0800
commit6d4dd6853393014e6a355995dd91ecefd7a3095d (patch)
tree264e0fc935a19081af6cb72019040fc0855d39bb /dex/blockproposer.go
parent19c6af0154aa305288ab1ca2c3e716176dbd9563 (diff)
downloadgo-tangerine-6d4dd6853393014e6a355995dd91ecefd7a3095d.tar
go-tangerine-6d4dd6853393014e6a355995dd91ecefd7a3095d.tar.gz
go-tangerine-6d4dd6853393014e6a355995dd91ecefd7a3095d.tar.bz2
go-tangerine-6d4dd6853393014e6a355995dd91ecefd7a3095d.tar.lz
go-tangerine-6d4dd6853393014e6a355995dd91ecefd7a3095d.tar.xz
go-tangerine-6d4dd6853393014e6a355995dd91ecefd7a3095d.tar.zst
go-tangerine-6d4dd6853393014e6a355995dd91ecefd7a3095d.zip
dex: properly shutdown protocol stack (#267)
Diffstat (limited to 'dex/blockproposer.go')
-rw-r--r--dex/blockproposer.go3
1 files changed, 2 insertions, 1 deletions
diff --git a/dex/blockproposer.go b/dex/blockproposer.go
index 6c1de818a..58e6eafee 100644
--- a/dex/blockproposer.go
+++ b/dex/blockproposer.go
@@ -79,10 +79,10 @@ func (b *blockProposer) run(c *dexCore.Consensus) {
atomic.StoreInt32(&b.proposing, 1)
<-b.stopCh
log.Debug("Block proposer receive stop signal")
- c.Stop()
}
func (b *blockProposer) Stop() {
+ log.Info("Stopping block proposer")
b.mu.Lock()
defer b.mu.Unlock()
@@ -92,6 +92,7 @@ func (b *blockProposer) Stop() {
b.wg.Wait()
atomic.StoreInt32(&b.proposing, 0)
}
+ log.Info("Block proposer stopped")
}
func (b *blockProposer) IsCoreSyncing() bool {