aboutsummaryrefslogtreecommitdiffstats
path: root/dex
diff options
context:
space:
mode:
authorbojie <a1346494@gmail.com>2018-11-12 09:15:21 +0800
committerWei-Ning Huang <w@dexon.org>2019-04-09 21:32:53 +0800
commit832f0acdf908a18b266099c4bf5d77663e203628 (patch)
tree2db47767ead0bec5eab01b2cdcafb4a4f3cc405f /dex
parent21966c243e3b3ce8c9d421329f61dd25261c7cc2 (diff)
downloaddexon-832f0acdf908a18b266099c4bf5d77663e203628.tar.gz
dexon-832f0acdf908a18b266099c4bf5d77663e203628.tar.zst
dexon-832f0acdf908a18b266099c4bf5d77663e203628.zip
app: bug fix (#7)
Add notify mutex to prevent missing chain issue while concurrent appending with same slice.
Diffstat (limited to 'dex')
-rw-r--r--dex/app.go7
1 files changed, 7 insertions, 0 deletions
diff --git a/dex/app.go b/dex/app.go
index 7d2165118..d0d911e86 100644
--- a/dex/app.go
+++ b/dex/app.go
@@ -51,6 +51,7 @@ type DexconApp struct {
chainLocksInitMu sync.Mutex
chainLocks map[uint32]*sync.RWMutex
+ notifyMu sync.Mutex
notifyChan sync.Map
chainLatestRoot sync.Map
}
@@ -79,6 +80,9 @@ func NewDexconApp(txPool *core.TxPool, blockchain *core.BlockChain, gov *DexconG
}
func (d *DexconApp) addNotify(height uint64) <-chan uint64 {
+ d.notifyMu.Lock()
+ defer d.notifyMu.Unlock()
+
result := make(chan uint64)
v, ok := d.notifyChan.Load(height)
if ok {
@@ -92,6 +96,9 @@ func (d *DexconApp) addNotify(height uint64) <-chan uint64 {
}
func (d *DexconApp) notify(height uint64) {
+ d.notifyMu.Lock()
+ defer d.notifyMu.Unlock()
+
d.notifyChan.Range(func(key, value interface{}) bool {
h := key.(uint64)
n := value.(*notify)