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

routing/pathfind: fmt whitespace

Browse Source
This commit is contained in:
Conner Fromknecht 2018-07-31 00:19:49 -07:00
parent 1ded697e8d
commit 614b3b3862
No known key found for this signature in database
GPG Key ID: E7D737B67FA592C7
1 changed files with 10 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
routing/pathfind.go
View File

@ -66,7 +66,7 @@ type HopHint struct {
// ChannelHop describes the channel through which an intermediate or final // ChannelHop describes the channel through which an intermediate or final
// hop can be reached. This struct contains the relevant routing policy of // hop can be reached. This struct contains the relevant routing policy of
// the particular edge (which is a property of the source node of the channel // the particular edge (which is a property of the source node of the channel
// edge), as well as the total capacity. It also includes the origin chain of // edge), as well as the total capacity. It also includes the origin chain of
// the channel itself. // the channel itself.
type ChannelHop struct { type ChannelHop struct {
// Capacity is the total capacity of the channel being traversed. This // Capacity is the total capacity of the channel being traversed. This
@ -87,7 +87,7 @@ type ChannelHop struct {
// is in line with the definition given in BOLT #4: Onion Routing Protocol. // is in line with the definition given in BOLT #4: Onion Routing Protocol.
// The struct houses the channel along which this hop can be reached and // The struct houses the channel along which this hop can be reached and
// the values necessary to create the HTLC that needs to be sent to the // the values necessary to create the HTLC that needs to be sent to the
// next hop. It is also used to encode the per-hop payload included within // next hop. It is also used to encode the per-hop payload included within
// the Sphinx packet. // the Sphinx packet.
type Hop struct { type Hop struct {
// Channel is the active payment channel edge along which the packet // Channel is the active payment channel edge along which the packet
@ -297,7 +297,7 @@ func newRoute(amtToSend, feeLimit lnwire.MilliSatoshi, sourceVertex Vertex,
route.chanIndex[edge.ChannelID] = struct{}{} route.chanIndex[edge.ChannelID] = struct{}{}
// If this isn't a direct payment, and this isn't the edge to // If this isn't a direct payment, and this isn't the edge to
// the last hop in the route, then we'll also populate the // the last hop in the route, then we'll also populate the
// nextHop map to allow easy route traversal by callers. // nextHop map to allow easy route traversal by callers.
if len(pathEdges) > 1 && i != len(pathEdges)-1 { if len(pathEdges) > 1 && i != len(pathEdges)-1 {
route.nextHopMap[v] = route.Hops[i+1].Channel route.nextHopMap[v] = route.Hops[i+1].Channel
@ -316,7 +316,7 @@ func newRoute(amtToSend, feeLimit lnwire.MilliSatoshi, sourceVertex Vertex,
// reporting through RPC. Set to zero for the final hop. // reporting through RPC. Set to zero for the final hop.
fee := lnwire.MilliSatoshi(0) fee := lnwire.MilliSatoshi(0)
// If the current hop isn't the last hop, then add enough funds // If the current hop isn't the last hop, then add enough funds
// to pay for transit over the next link. // to pay for transit over the next link.
if i != len(pathEdges)-1 { if i != len(pathEdges)-1 {
// We'll grab the per-hop payload of the next hop (the // We'll grab the per-hop payload of the next hop (the
@ -324,13 +324,13 @@ func newRoute(amtToSend, feeLimit lnwire.MilliSatoshi, sourceVertex Vertex,
// route so we can calculate fees properly. // route so we can calculate fees properly.
nextHop := route.Hops[i+1] nextHop := route.Hops[i+1]
// The amount that the current hop needs to forward is // The amount that the current hop needs to forward is
// based on how much the next hop forwards plus the fee // based on how much the next hop forwards plus the fee
// that needs to be paid to the next hop. // that needs to be paid to the next hop.
amtToForward = nextHop.AmtToForward + nextHop.Fee amtToForward = nextHop.AmtToForward + nextHop.Fee
// The fee that needs to be paid to the current hop is // The fee that needs to be paid to the current hop is
// based on the amount that this hop needs to forward // based on the amount that this hop needs to forward
// and its policy for the outgoing channel. This policy // and its policy for the outgoing channel. This policy
// is stored as part of the incoming channel of // is stored as part of the incoming channel of
// the next hop. // the next hop.
@ -358,7 +358,7 @@ func newRoute(amtToSend, feeLimit lnwire.MilliSatoshi, sourceVertex Vertex,
// enough capacity to carry the required amount which // enough capacity to carry the required amount which
// includes the fee dictated at each hop. Make the comparison // includes the fee dictated at each hop. Make the comparison
// in msat to prevent rounding errors. // in msat to prevent rounding errors.
if currentHop.AmtToForward + fee > lnwire.NewMSatFromSatoshis( if currentHop.AmtToForward+fee > lnwire.NewMSatFromSatoshis(
currentHop.Channel.Capacity) { currentHop.Channel.Capacity) {
err := fmt.Sprintf("channel graph has insufficient "+ err := fmt.Sprintf("channel graph has insufficient "+
@ -439,9 +439,9 @@ type edgeWithPrev struct {
// edgeWeight computes the weight of an edge. This value is used when searching // edgeWeight computes the weight of an edge. This value is used when searching
// for the shortest path within the channel graph between two nodes. Weight is // for the shortest path within the channel graph between two nodes. Weight is
// is the fee itself plus a time lock penalty added to it. This benefits // is the fee itself plus a time lock penalty added to it. This benefits
// channels with shorter time lock deltas and shorter (hops) routes in general. // channels with shorter time lock deltas and shorter (hops) routes in general.
// RiskFactor controls the influence of time lock on route selection. This is // RiskFactor controls the influence of time lock on route selection. This is
// currently a fixed value, but might be configurable in the future. // currently a fixed value, but might be configurable in the future.
func edgeWeight(amt lnwire.MilliSatoshi, e *channeldb.ChannelEdgePolicy) int64 { func edgeWeight(amt lnwire.MilliSatoshi, e *channeldb.ChannelEdgePolicy) int64 {
// First, we'll compute the "pure" fee through this hop. We say pure, // First, we'll compute the "pure" fee through this hop. We say pure,