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

htlcswitch+lntest: add more debug logs

Browse Source
This commit is contained in:
yyforyongyu
2025-06-06 19:40:35 +08:00
parent fc906f2a65
commit 26960e36ce
2 changed files with 11 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
htlcswitch/switch.go
View File

@@ -2270,6 +2270,9 @@ func (s *Switch) getLinkByMapping(pkt *htlcPacket) (ChannelLink, error) {
// forwardingIndex. // forwardingIndex.
link, ok := s.forwardingIndex[baseScid] link, ok := s.forwardingIndex[baseScid]
if !ok { if !ok {
log.Debugf("Forwarding index not found using "+
"baseScid=%v", baseScid)
// Link not found, bail. // Link not found, bail.
return nil, ErrChannelLinkNotFound return nil, ErrChannelLinkNotFound
} }
@@ -2291,6 +2294,9 @@ func (s *Switch) getLinkByMapping(pkt *htlcPacket) (ChannelLink, error) {
// negotiated. We'll fetch the link and return it. // negotiated. We'll fetch the link and return it.
link, ok := s.forwardingIndex[chanID] link, ok := s.forwardingIndex[chanID]
if !ok { if !ok {
log.Debugf("Forwarding index not found using "+
"chanID=%v", chanID)
// The link wasn't found, bail out. // The link wasn't found, bail out.
return nil, ErrChannelLinkNotFound return nil, ErrChannelLinkNotFound
} }
@@ -2301,6 +2307,9 @@ func (s *Switch) getLinkByMapping(pkt *htlcPacket) (ChannelLink, error) {
// Fetch the link whose internal SCID is baseScid. // Fetch the link whose internal SCID is baseScid.
link, ok := s.forwardingIndex[baseScid] link, ok := s.forwardingIndex[baseScid]
if !ok { if !ok {
log.Debugf("Forwarding index not found using baseScid=%v",
baseScid)
// Link wasn't found, bail out. // Link wasn't found, bail out.
return nil, ErrChannelLinkNotFound return nil, ErrChannelLinkNotFound
} }

3
lntest/harness.go
View File

@@ -1588,7 +1588,8 @@ func (h *HarnessTest) completePaymentRequestsAssertStatus(hn *node.HarnessNode,
h.AssertPaymentStatusFromStream(stream, status) h.AssertPaymentStatusFromStream(stream, status)
case <-timer: case <-timer:
require.Fail(h, "timeout", "waiting payment results timeout") require.Failf(h, "timeout", "%s: waiting payment results "+
"timeout", hn.Name())
} }
} }