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

routing/router: break rescans on router quit

Browse Source 
This commit reevaluates the router's quit channel between each block
during the initial call to syncGraphWithChain, which, in the worst case,
may have to scan several thousand blocks on startup if the node has not
been active for some time. Without this, attempting to stop the daemon
will not exit until the rescan has completed, which for certain backends
could be several hours.
This commit is contained in:
Conner Fromknecht 2019-05-06 15:02:35 -07:00
parent b31510102a
commit 3f59e31248
No known key found for this signature in database
GPG Key ID: E7D737B67FA592C7
1 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
routing/router.go
View File

@ -584,6 +584,15 @@ func (r *ChannelRouter) syncGraphWithChain() error {
// consumed by the channel graph. // consumed by the channel graph.
var numChansClosed uint32 var numChansClosed uint32
for nextHeight := pruneHeight + 1; nextHeight <= uint32(bestHeight); nextHeight++ { for nextHeight := pruneHeight + 1; nextHeight <= uint32(bestHeight); nextHeight++ {
// Break out of the rescan early if a shutdown has been
// requested, otherwise long rescans will block the daemon from
// shutting down promptly.
select {
case <-r.quit:
return ErrRouterShuttingDown
default:
}
// Using the next height, request a manual block pruning from // Using the next height, request a manual block pruning from
// the chainview for the particular block hash. // the chainview for the particular block hash.
nextHash, err := r.cfg.Chain.GetBlockHash(int64(nextHeight)) nextHash, err := r.cfg.Chain.GetBlockHash(int64(nextHeight))