htlcswitch/switch: shutdown links concurrently

This commit is contained in:
Conner Fromknecht committed 2018-08-20 22:05:05 -07:00
1 parent 6c903393e5
commit 4e093a6cd2
1 file changed
+9 -1
+9 -1
View File
@@ -1401,9 +1401,17 @@ func (s *Switch) htlcForwarder() {
// Now that all pending and live links have been removed from
// the forwarding indexes, stop each one before shutting down.
// We'll shut them down in parallel to make exiting as fast as
// possible.
var wg sync.WaitGroup
for _, link := range linksToStop {
link.Stop()
wg.Add(1)
go func(l ChannelLink) {
defer wg.Done()
l.Stop()
}(link)
}
wg.Wait()
// Before we exit fully, we'll attempt to flush out any
// forwarding events that may still be lingering since the last