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

Merge pull request #5246 from joostjager/router-best-height

Browse Source 
routing: no backend call to fetch best block
This commit is contained in:
Olaoluwa Osuntokun 2021-05-04 19:27:37 -07:00 committed by GitHub
commit 9d9f420da5
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 7 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
routing/router.go
View File

@ -9,6 +9,7 @@ import (
"time"
"github.com/btcsuite/btcd/btcec"
"github.com/btcsuite/btcd/chaincfg/chainhash"
"github.com/btcsuite/btcd/wire"
"github.com/btcsuite/btcutil"
"github.com/davecgh/go-spew/spew"
@ -486,6 +487,7 @@ func (r *ChannelRouter) Start() error {
if err != nil {
return err
}
r.bestHeight = uint32(bestHeight)
// If the graph has never been pruned, or hasn't fully been created yet,
// then we don't treat this as an explicit error.
@ -562,7 +564,7 @@ func (r *ChannelRouter) Start() error {
// Before we begin normal operation of the router, we first need
// to synchronize the channel graph to the latest state of the
// UTXO set.
if err := r.syncGraphWithChain(); err != nil {
if err := r.syncGraphWithChain(bestHash, bestHeight); err != nil {
return err
}
@ -694,15 +696,11 @@ func (r *ChannelRouter) Stop() error {
// the latest UTXO set state. This process involves pruning from the channel
// graph any channels which have been closed by spending their funding output
// since we've been down.
func (r *ChannelRouter) syncGraphWithChain() error {
func (r *ChannelRouter) syncGraphWithChain(bestHash *chainhash.Hash,
bestHeight int32) error {
// First, we'll need to check to see if we're already in sync with the
// latest state of the UTXO set.
bestHash, bestHeight, err := r.cfg.Chain.GetBestBlock()
if err != nil {
return err
}
r.bestHeight = uint32(bestHeight)
pruneHash, pruneHeight, err := r.cfg.Graph.PruneTip()
if err != nil {
switch {
@ -2134,10 +2132,7 @@ func (r *ChannelRouter) sendPayment(
// We'll also fetch the current block height so we can properly
// calculate the required HTLC time locks within the route.
_, currentHeight, err := r.cfg.Chain.GetBestBlock()
if err != nil {
return [32]byte{}, nil, err
}
currentHeight := int32(atomic.LoadUint32(&r.bestHeight))
// Now set up a paymentLifecycle struct with these params, such that we
// can resume the payment from the current state.