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

chainntnfs/btcd+neutrino: close spendChan after send

Browse Source
This commit is contained in:
Conner Fromknecht 2017-08-03 00:18:33 -07:00 committed by Olaoluwa Osuntokun
parent 0d4ee08372
commit d1e797451d
2 changed files with 10 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
chainntnfs/btcdnotify/btcd.go
View File

@ -398,8 +398,12 @@ out:
"spend notification for "+ "spend notification for "+
"outpoint=%v", ntfn.targetOutpoint) "outpoint=%v", ntfn.targetOutpoint)
ntfn.spendChan <- spendDetails ntfn.spendChan <- spendDetails
}
// Close spendChan to ensure that any calls to Cancel will not
// block. This is safe to do since the channel is buffered, and the
// message can still be read by the receiver.
close(ntfn.spendChan)
}
delete(b.spendNotifications, prevOut) delete(b.spendNotifications, prevOut)
} }
} }

5
chainntnfs/neutrinonotify/neutrino.go
View File

@ -398,6 +398,11 @@ func (n *NeutrinoNotifier) notificationDispatcher() {
"spend notification for "+ "spend notification for "+
"outpoint=%v", ntfn.targetOutpoint) "outpoint=%v", ntfn.targetOutpoint)
ntfn.spendChan <- spendDetails ntfn.spendChan <- spendDetails
// Close spendChan to ensure that any calls to Cancel will not
// block. This is safe to do since the channel is buffered, and the
// message can still be read by the receiver.
close(ntfn.spendChan)
} }
delete(n.spendNotifications, prevOut) delete(n.spendNotifications, prevOut)