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

htlcswitch/link: remove unused isReProcess argument

Browse Source
This commit is contained in:
Conner Fromknecht 2020-04-07 11:55:25 -07:00
parent 759d7a122f
commit e86ddf6ae7
No known key found for this signature in database
GPG Key ID: E7D737B67FA592C7
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
htlcswitch/link.go
View File

@ -1109,7 +1109,7 @@ out:
l.log.Tracef("reprocessing downstream add update "+ l.log.Tracef("reprocessing downstream add update "+
"with payment hash(%x)", msg.PaymentHash[:]) "with payment hash(%x)", msg.PaymentHash[:])
l.handleDownStreamPkt(packet, true) l.handleDownstreamPkt(packet)
// A message from the switch was just received. This indicates // A message from the switch was just received. This indicates
// that the link is an intermediate hop in a multi-hop HTLC // that the link is an intermediate hop in a multi-hop HTLC
@ -1131,7 +1131,7 @@ out:
continue continue
} }
l.handleDownStreamPkt(pkt, false) l.handleDownstreamPkt(pkt)
// A message from the connected peer was just received. This // A message from the connected peer was just received. This
// indicates that we have a new incoming HTLC, either directly // indicates that we have a new incoming HTLC, either directly
@ -1275,13 +1275,13 @@ func (l *channelLink) randomFeeUpdateTimeout() time.Duration {
return time.Duration(prand.Int63n(upper-lower) + lower) return time.Duration(prand.Int63n(upper-lower) + lower)
} }
// handleDownStreamPkt processes an HTLC packet sent from the downstream HTLC // handleDownstreamPkt processes an HTLC packet sent from the downstream HTLC
// Switch. Possible messages sent by the switch include requests to forward new // Switch. Possible messages sent by the switch include requests to forward new
// HTLCs, timeout previously cleared HTLCs, and finally to settle currently // HTLCs, timeout previously cleared HTLCs, and finally to settle currently
// cleared HTLCs with the upstream peer. // cleared HTLCs with the upstream peer.
// //
// TODO(roasbeef): add sync ntfn to ensure switch always has consistent view? // TODO(roasbeef): add sync ntfn to ensure switch always has consistent view?
func (l *channelLink) handleDownStreamPkt(pkt *htlcPacket, isReProcess bool) { func (l *channelLink) handleDownstreamPkt(pkt *htlcPacket) {
var isSettle bool var isSettle bool
switch htlc := pkt.htlc.(type) { switch htlc := pkt.htlc.(type) {
case *lnwire.UpdateAddHTLC: case *lnwire.UpdateAddHTLC: