diff options
| author | bojie <a1346494@gmail.com> | 2018-11-12 09:15:21 +0800 |
|---|---|---|
| committer | Wei-Ning Huang <w@dexon.org> | 2019-04-09 13:49:56 +0800 |
| commit | cde3dfa5a29db9eeea9803a0942a4eb97792f72a (patch) | |
| tree | fb93913a23c3e2a819193fe7b8dcd899ba1ad2d6 /dex | |
| parent | 378223ef1d14e9c0d282844ade18699a8f596db0 (diff) | |
| download | dexon-cde3dfa5a29db9eeea9803a0942a4eb97792f72a.tar dexon-cde3dfa5a29db9eeea9803a0942a4eb97792f72a.tar.gz dexon-cde3dfa5a29db9eeea9803a0942a4eb97792f72a.tar.bz2 dexon-cde3dfa5a29db9eeea9803a0942a4eb97792f72a.tar.lz dexon-cde3dfa5a29db9eeea9803a0942a4eb97792f72a.tar.xz dexon-cde3dfa5a29db9eeea9803a0942a4eb97792f72a.tar.zst dexon-cde3dfa5a29db9eeea9803a0942a4eb97792f72a.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) |