mirrors/lnd
1
0
Fork 0
mirror of https://github.com/lightningnetwork/lnd.git synced 2024-11-19 01:43:16 +01:00
Code Issues Projects Releases Wiki Activity

routing: fix missionControlStore blocks on shutting down

Browse Source
This commit is contained in:
yyforyongyu 2024-11-02 11:21:42 +08:00
parent e3cc4d70c0
commit 227cc3a45c
No known key found for this signature in database
GPG Key ID: 9BCD95C4FF296868
1 changed files with 13 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
routing/missioncontrol_store.go
View File

@ -50,6 +50,9 @@ type missionControlStore struct {
wg sync.WaitGroup
db missionControlDB
// TODO(yy): Remove the usage of sync.Cond - we are better off using
// channes than a Cond as suggested in the official godoc.
//
// queueCond is signalled when items are put into the queue.
queueCond *sync.Cond
@ -347,8 +350,14 @@ func (b *missionControlStore) run() {
// Wait for the queue to not be empty.
b.queueCond.L.Lock()
for b.queue.Front() == nil {
b.queueCond.Wait()
// To make sure we can properly stop, we must
// read the `done` channel first before
// attempting to call `Wait()`. This is due to
// the fact when `Signal` is called before the
// `Wait` call, the `Wait` call will block
// indefinitely.
//
// TODO(yy): replace this with channels.
select {
case <-b.done:
b.queueCond.L.Unlock()
@ -356,6 +365,8 @@ func (b *missionControlStore) run() {
return
default:
}
b.queueCond.Wait()
}
b.queueCond.L.Unlock()