akovalenko/lnd.xprv
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

contractcourt: extend resolveContract to also stop any active chainWatcher

Browse Source
This commit is contained in:
Olaoluwa Osuntokun 2018-01-19 17:13:41 -08:00
parent 723bfb0eac
commit bdbb33344a
No known key found for this signature in database
GPG Key ID: 964EA263DD637C21
1 changed files with 14 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
contractcourt/chain_arbitrator.go
View File

@ -273,17 +273,24 @@ func (c *ChainArbitrator) resolveContract(chanPoint wire.OutPoint,
return err return err
} }
// Once this has been marked as resolved, we'll wipe the log that the if arbLog != nil {
// channel arbitrator was using to store its persistent state. We do // Once this has been marked as resolved, we'll wipe the log
// this after marking the channel resolved, as otherwise, the // that the channel arbitrator was using to store its
// arbitrator would be re-created, and think it was starting from the // persistent state. We do this after marking the channel
// default state. // resolved, as otherwise, the arbitrator would be re-created,
// and think it was starting from the default state.
if err := arbLog.WipeHistory(); err != nil { if err := arbLog.WipeHistory(); err != nil {
return err return err
} }
}
c.Lock() c.Lock()
delete(c.activeChannels, chanPoint) delete(c.activeChannels, chanPoint)
chainWatcher, ok := c.activeWatchers[chanPoint]
if ok {
chainWatcher.Stop()
}
c.Unlock() c.Unlock()
return nil return nil