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

htlcswitch/switch: use non-strict PaymentControl

Browse Source
This commit is contained in:
Conner Fromknecht 2018-08-13 18:49:22 -07:00
parent 2027444a56
commit 2dd8f07014
No known key found for this signature in database
GPG Key ID: E7D737B67FA592C7
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
htlcswitch/switch.go
View File

@ -290,7 +290,7 @@ func New(cfg Config, currentHeight uint32) (*Switch, error) {
cfg: &cfg,
circuits: circuitMap,
paymentSequencer: sequencer,
control: NewPaymentControl(cfg.DB),
control: NewPaymentControl(false, cfg.DB),
linkIndex: make(map[lnwire.ChannelID]ChannelLink),
mailOrchestrator: newMailOrchestrator(),
forwardingIndex: make(map[lnwire.ShortChannelID]ChannelLink),
@ -852,7 +852,8 @@ func (s *Switch) handleLocalDispatch(pkt *htlcPacket) error {
// Persistently mark that a payment to this payment hash
// succeeded. This will prevent us from ever making another
// payment to this hash.
if err := s.control.Success(pkt.circuit.PaymentHash); err != nil {
err := s.control.Success(pkt.circuit.PaymentHash)
if err != nil && err != ErrPaymentAlreadyCompleted {
return err
}
@ -864,7 +865,8 @@ func (s *Switch) handleLocalDispatch(pkt *htlcPacket) error {
// Persistently mark that a payment to this payment hash failed.
// This will permit us to make another attempt at a successful
// payment.
if err := s.control.Fail(pkt.circuit.PaymentHash); err != nil {
err := s.control.Fail(pkt.circuit.PaymentHash)
if err != nil && err != ErrPaymentAlreadyCompleted {
return err
}