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

chainntnfs/txnotifier: add more debug logs aroung spend dispatch

Browse Source 
To track down missing spends.
This commit is contained in:
Johan T. Halseth 2019-11-21 15:13:16 +01:00
parent 1c832789d6
commit 339543857a
No known key found for this signature in database
GPG Key ID: 15BAADA29DA20D26
1 changed files with 15 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
chainntnfs/txnotifier.go
View File

@ -1245,6 +1245,8 @@ func (n *TxNotifier) updateSpendDetails(spendRequest SpendRequest,
n.currentHeight, spendRequest, err) n.currentHeight, spendRequest, err)
} }
Log.Debugf("Updated spend hint to height=%v for unconfirmed "+
"spend request %v", n.currentHeight, spendRequest)
return nil return nil
} }
@ -1270,6 +1272,9 @@ func (n *TxNotifier) updateSpendDetails(spendRequest SpendRequest,
details.SpendingHeight, spendRequest, err) details.SpendingHeight, spendRequest, err)
} }
Log.Debugf("Updated spend hint to height=%v for confirmed spend "+
"request %v", details.SpendingHeight, spendRequest)
spendSet.details = details spendSet.details = details
for _, ntfn := range spendSet.ntfns { for _, ntfn := range spendSet.ntfns {
err := n.dispatchSpendDetails(ntfn, spendSet.details) err := n.dispatchSpendDetails(ntfn, spendSet.details)
@ -1288,6 +1293,9 @@ func (n *TxNotifier) dispatchSpendDetails(ntfn *SpendNtfn, details *SpendDetail)
// If there are no spend details to dispatch or if the notification has // If there are no spend details to dispatch or if the notification has
// already been dispatched, then we can skip dispatching to this client. // already been dispatched, then we can skip dispatching to this client.
if details == nil || ntfn.dispatched { if details == nil || ntfn.dispatched {
Log.Debugf("Skipping dispatch of spend details(%v) for "+
"request %v, dispatched=%v", details, ntfn.SpendRequest,
ntfn.dispatched)
return nil return nil
} }
@ -1345,6 +1353,8 @@ func (n *TxNotifier) ConnectTip(blockHash *chainhash.Hash, blockHeight uint32,
// First, we'll iterate over all the transactions found in this block to // First, we'll iterate over all the transactions found in this block to
// determine if it includes any relevant transactions to the TxNotifier. // determine if it includes any relevant transactions to the TxNotifier.
Log.Debugf("Filtering %d txns for %d spend requests at height %d",
len(txns), len(n.spendNotifications), blockHeight)
for _, tx := range txns { for _, tx := range txns {
n.filterTx( n.filterTx(
tx, blockHash, blockHeight, n.handleConfDetailsAtTip, tx, blockHash, blockHeight, n.handleConfDetailsAtTip,
@ -1386,6 +1396,8 @@ func (n *TxNotifier) ConnectTip(blockHash *chainhash.Hash, blockHeight uint32,
} }
} }
Log.Debugf("Deleting mature spend request %v at "+
"height=%d", spendRequest, blockHeight)
delete(n.spendNotifications, spendRequest) delete(n.spendNotifications, spendRequest)
} }
delete(n.spendsByHeight, matureBlockHeight) delete(n.spendsByHeight, matureBlockHeight)
@ -1587,6 +1599,9 @@ func (n *TxNotifier) handleSpendDetailsAtTip(spendRequest SpendRequest,
n.spendsByHeight[spendHeight] = opSet n.spendsByHeight[spendHeight] = opSet
} }
opSet[spendRequest] = struct{}{} opSet[spendRequest] = struct{}{}
Log.Debugf("Spend request %v spent at tip=%d", spendRequest,
spendHeight)
} }
// NotifyHeight dispatches confirmation and spend notifications to the clients // NotifyHeight dispatches confirmation and spend notifications to the clients