diff options
| author | bojie <a1346494@gmail.com> | 2018-11-12 09:15:21 +0800 |
|---|---|---|
| committer | Wei-Ning Huang <w@dexon.org> | 2019-04-09 21:32:53 +0800 |
| commit | 832f0acdf908a18b266099c4bf5d77663e203628 (patch) | |
| tree | 2db47767ead0bec5eab01b2cdcafb4a4f3cc405f /dex | |
| parent | 21966c243e3b3ce8c9d421329f61dd25261c7cc2 (diff) | |
| download | dexon-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.go | 7 |
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) |