highperfocused/lnd
1
0
Fork 0
mirror of https://github.com/lightningnetwork/lnd.git synced 2025-08-30 23:53:41 +02:00
Code Issues Packages Projects Releases Wiki Activity

autopilot: use pointer receivers for dbNode methods

Browse Source
This commit is contained in:
Elle Mouton
2023-11-08 14:50:21 +02:00
parent fa7c1e250b
commit d37f5d7e1a
1 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
autopilot/graph.go
View File

@@ -69,7 +69,7 @@ var _ Node = (*dbNode)(nil)
// will be returned in serialized compressed format. // will be returned in serialized compressed format.
// //
// NOTE: Part of the autopilot.Node interface. // NOTE: Part of the autopilot.Node interface.
func (d dbNode) PubKey() [33]byte { func (d *dbNode) PubKey() [33]byte {
return d.node.PubKeyBytes return d.node.PubKeyBytes
} }
@@ -77,7 +77,7 @@ func (d dbNode) PubKey() [33]byte {
// peer is known to be listening on. // peer is known to be listening on.
// //
// NOTE: Part of the autopilot.Node interface. // NOTE: Part of the autopilot.Node interface.
func (d dbNode) Addrs() []net.Addr { func (d *dbNode) Addrs() []net.Addr {
return d.node.Addresses return d.node.Addresses
} }
@@ -87,7 +87,7 @@ func (d dbNode) Addrs() []net.Addr {
// describes the active channel. // describes the active channel.
// //
// NOTE: Part of the autopilot.Node interface. // NOTE: Part of the autopilot.Node interface.
func (d dbNode) ForEachChannel(cb func(ChannelEdge) error) error { func (d *dbNode) ForEachChannel(cb func(ChannelEdge) error) error {
return d.db.ForEachNodeChannel(d.tx, d.node.PubKeyBytes, return d.db.ForEachNodeChannel(d.tx, d.node.PubKeyBytes,
func(tx kvdb.RTx, ei *channeldb.ChannelEdgeInfo, ep, func(tx kvdb.RTx, ei *channeldb.ChannelEdgeInfo, ep,
_ *channeldb.ChannelEdgePolicy) error { _ *channeldb.ChannelEdgePolicy) error {
@@ -109,7 +109,7 @@ func (d dbNode) ForEachChannel(cb func(ChannelEdge) error) error {
ep.ChannelID, ep.ChannelID,
), ),
Capacity: ei.Capacity, Capacity: ei.Capacity,
Peer: dbNode{ Peer: &dbNode{
tx: tx, tx: tx,
db: d.db, db: d.db,
node: ep.Node, node: ep.Node,
@@ -134,7 +134,7 @@ func (d *databaseChannelGraph) ForEachNode(cb func(Node) error) error {
return nil return nil
} }
node := dbNode{ node := &dbNode{
db: d.db, db: d.db,
tx: tx, tx: tx,
node: n, node: n,
@@ -273,7 +273,7 @@ func (d *databaseChannelGraph) addRandChannel(node1, node2 *btcec.PublicKey,
return &ChannelEdge{ return &ChannelEdge{
ChanID: chanID, ChanID: chanID,
Capacity: capacity, Capacity: capacity,
Peer: dbNode{ Peer: &dbNode{
db: d.db, db: d.db,
node: vertex1, node: vertex1,
}, },
@@ -281,7 +281,7 @@ func (d *databaseChannelGraph) addRandChannel(node1, node2 *btcec.PublicKey,
&ChannelEdge{ &ChannelEdge{
ChanID: chanID, ChanID: chanID,
Capacity: capacity, Capacity: capacity,
Peer: dbNode{ Peer: &dbNode{
db: d.db, db: d.db,
node: vertex2, node: vertex2,
}, },