highperfocused/lnd
1
0
Fork 0
mirror of https://github.com/lightningnetwork/lnd.git synced 2025-03-29 03:01:52 +01:00
Code Issues Packages Projects Releases Wiki Activity

sweep: fix logging

Browse Source
This commit is contained in:
yyforyongyu 2024-01-09 14:06:43 +08:00
parent 124d1764f7
commit 5496d02b27
No known key found for this signature in database
GPG Key ID: 9BCD95C4FF296868
1 changed files with 9 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
sweep/sweeper.go
View File

@ -789,7 +789,8 @@ func (s *UtxoSweeper) sweepCluster(cluster inputCluster) error {
// causing the failure and retry the rest of the // causing the failure and retry the rest of the
// inputs. // inputs.
if errAllSets != nil { if errAllSets != nil {
log.Errorf("sweep all inputs: %w", err) log.Errorf("Sweep all inputs got error: %v",
errAllSets)
break break
} }
} }
@ -800,10 +801,10 @@ func (s *UtxoSweeper) sweepCluster(cluster inputCluster) error {
return nil return nil
} }
// We'd end up there if there's no retried inputs. In this // We'd end up there if there's no retried inputs or the above
// case, we'd sweep the new input sets. If there's an error // sweeping tx failed. In this case, we'd sweep the new input
// when sweeping a given set, we'd log the error and sweep the // sets. If there's an error when sweeping a given set, we'd
// next set. // log the error and sweep the next set.
for _, inputs := range newSets { for _, inputs := range newSets {
err := s.sweep(inputs, cluster.sweepFeeRate) err := s.sweep(inputs, cluster.sweepFeeRate)
if err != nil { if err != nil {
@ -1397,7 +1398,7 @@ func (s *UtxoSweeper) handleNewInput(input *sweepInputMessage) {
outpoint := *input.input.OutPoint() outpoint := *input.input.OutPoint()
pi, pending := s.pendingInputs[outpoint] pi, pending := s.pendingInputs[outpoint]
if pending { if pending {
log.Debugf("Already pending input %v received", outpoint) log.Debugf("Already has pending input %v received", outpoint)
s.handleExistingInput(input, pi) s.handleExistingInput(input, pi)
@ -1419,7 +1420,8 @@ func (s *UtxoSweeper) handleNewInput(input *sweepInputMessage) {
pi = s.attachAvailableRBFInfo(pi) pi = s.attachAvailableRBFInfo(pi)
s.pendingInputs[outpoint] = pi s.pendingInputs[outpoint] = pi
log.Tracef("input %v added to pendingInputs", outpoint) log.Tracef("input %v, state=%v, added to pendingInputs", outpoint,
pi.state)
// Start watching for spend of this input, either by us or the remote // Start watching for spend of this input, either by us or the remote
// party. // party.