Merge pull request #4195 from cfromknecht/mailbox-cancel-fixups
htlcswitch: mailbox cancel followups
This commit is contained in:
commit
30b7036709
@ -2309,8 +2309,7 @@ func (l *channelLink) HandleSwitchPacket(pkt *htlcPacket) error {
|
|||||||
l.log.Tracef("received switch packet inkey=%v, outkey=%v",
|
l.log.Tracef("received switch packet inkey=%v, outkey=%v",
|
||||||
pkt.inKey(), pkt.outKey())
|
pkt.inKey(), pkt.outKey())
|
||||||
|
|
||||||
l.mailBox.AddPacket(pkt)
|
return l.mailBox.AddPacket(pkt)
|
||||||
return nil
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// HandleChannelUpdate handles the htlc requests as settle/add/fail which sent
|
// HandleChannelUpdate handles the htlc requests as settle/add/fail which sent
|
||||||
|
@ -1167,7 +1167,7 @@ func (h *hopNetwork) createChannelLink(server, peer *mockServer,
|
|||||||
BatchSize: 10,
|
BatchSize: 10,
|
||||||
BatchTicker: ticker.NewForce(testBatchTimeout),
|
BatchTicker: ticker.NewForce(testBatchTimeout),
|
||||||
FwdPkgGCTicker: ticker.NewForce(fwdPkgTimeout),
|
FwdPkgGCTicker: ticker.NewForce(fwdPkgTimeout),
|
||||||
PendingCommitTicker: ticker.NewForce(time.Minute),
|
PendingCommitTicker: ticker.NewForce(2 * time.Minute),
|
||||||
MinFeeUpdateTimeout: minFeeUpdateTimeout,
|
MinFeeUpdateTimeout: minFeeUpdateTimeout,
|
||||||
MaxFeeUpdateTimeout: maxFeeUpdateTimeout,
|
MaxFeeUpdateTimeout: maxFeeUpdateTimeout,
|
||||||
OnChannelFailure: func(lnwire.ChannelID, lnwire.ShortChannelID, LinkFailureError) {},
|
OnChannelFailure: func(lnwire.ChannelID, lnwire.ShortChannelID, LinkFailureError) {},
|
||||||
|
Loading…
Reference in New Issue
Block a user