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

htlcswitch/link: pass link quit to ForwardPackets

Browse Source
This commit is contained in:
Conner Fromknecht 2018-07-30 13:11:11 -07:00
parent d08003b285
commit 0fef1c71fe
No known key found for this signature in database
GPG Key ID: E7D737B67FA592C7
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
htlcswitch/link.go
View File

@ -117,9 +117,10 @@ type ChannelLinkConfig struct {
Switch *Switch Switch *Switch
// ForwardPackets attempts to forward the batch of htlcs through the // ForwardPackets attempts to forward the batch of htlcs through the
// switch. Any failed packets will be returned to the provided // switch, any failed packets will be returned to the provided
// ChannelLink. // ChannelLink. The link's quit signal should be provided to allow
ForwardPackets func(...*htlcPacket) chan error // cancellation of forwarding during link shutdown.
ForwardPackets func(chan struct{}, ...*htlcPacket) chan error
// DecodeHopIterators facilitates batched decoding of HTLC Sphinx onion // DecodeHopIterators facilitates batched decoding of HTLC Sphinx onion
// blobs, which are then used to inform how to forward an HTLC. // blobs, which are then used to inform how to forward an HTLC.
@ -2542,7 +2543,7 @@ func (l *channelLink) forwardBatch(packets ...*htlcPacket) {
filteredPkts = append(filteredPkts, pkt) filteredPkts = append(filteredPkts, pkt)
} }
errChan := l.cfg.ForwardPackets(filteredPkts...) errChan := l.cfg.ForwardPackets(l.quit, filteredPkts...)
go l.handleBatchFwdErrs(errChan) go l.handleBatchFwdErrs(errChan)
} }