highperfocused/lnd
1
0
Fork 0
mirror of https://github.com/lightningnetwork/lnd.git synced 2025-06-12 18:01:23 +02:00
Code Issues Packages Projects Releases Wiki Activity

graph/db: handle previously-unhandled errors

Browse Source
This commit is contained in:
Alex Akselrod 2024-11-04 19:15:35 -08:00
parent c29fb81d1b
commit c01dcc2be7
No known key found for this signature in database
GPG Key ID: B32121A4F90A0EF4
1 changed files with 14 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
graph/db/graph.go
View File

@ -1127,7 +1127,7 @@ func (c *ChannelGraph) addChannelEdge(tx kvdb.RwTx,
err := addLightningNode(tx, &node1Shell) err := addLightningNode(tx, &node1Shell)
if err != nil { if err != nil {
return fmt.Errorf("unable to create shell node "+ return fmt.Errorf("unable to create shell node "+
"for: %x", edge.NodeKey1Bytes) "for: %x: %w", edge.NodeKey1Bytes, err)
} }
case node1Err != nil: case node1Err != nil:
return err return err
@ -1143,7 +1143,7 @@ func (c *ChannelGraph) addChannelEdge(tx kvdb.RwTx,
err := addLightningNode(tx, &node2Shell) err := addLightningNode(tx, &node2Shell)
if err != nil { if err != nil {
return fmt.Errorf("unable to create shell node "+ return fmt.Errorf("unable to create shell node "+
"for: %x", edge.NodeKey2Bytes) "for: %x: %w", edge.NodeKey2Bytes, err)
} }
case node2Err != nil: case node2Err != nil:
return err return err
@ -2692,8 +2692,14 @@ func (c *ChannelGraph) delChannelEdgeUnsafe(edges, edgeIndex, chanIndex,
// As part of deleting the edge we also remove all disabled entries // As part of deleting the edge we also remove all disabled entries
// from the edgePolicyDisabledIndex bucket. We do that for both // from the edgePolicyDisabledIndex bucket. We do that for both
// directions. // directions.
updateEdgePolicyDisabledIndex(edges, cid, false, false) err = updateEdgePolicyDisabledIndex(edges, cid, false, false)
updateEdgePolicyDisabledIndex(edges, cid, true, false) if err != nil {
return err
}
err = updateEdgePolicyDisabledIndex(edges, cid, true, false)
if err != nil {
return err
}
// With the edge data deleted, we can purge the information from the two // With the edge data deleted, we can purge the information from the two
// edge indexes. // edge indexes.
@ -4410,11 +4416,14 @@ func putChanEdgePolicy(edges kvdb.RwBucket, edge *models.ChannelEdgePolicy,
return err return err
} }
updateEdgePolicyDisabledIndex( err = updateEdgePolicyDisabledIndex(
edges, edge.ChannelID, edges, edge.ChannelID,
edge.ChannelFlags&lnwire.ChanUpdateDirection > 0, edge.ChannelFlags&lnwire.ChanUpdateDirection > 0,
edge.IsDisabled(), edge.IsDisabled(),
) )
if err != nil {
return err
}
return edges.Put(edgeKey[:], b.Bytes()[:]) return edges.Put(edgeKey[:], b.Bytes()[:])
} }