@@ -147,21 +147,15 @@ impl PendingOutboundPayment {
147
147
* self = PendingOutboundPayment :: Fulfilled { session_privs, payment_hash, timer_ticks_without_htlcs : 0 } ;
148
148
}
149
149
150
- fn mark_abandoned ( & mut self , reason : PaymentFailureReason ) -> Result < ( ) , ( ) > {
151
- match self {
152
- PendingOutboundPayment :: Legacy { .. } |
153
- PendingOutboundPayment :: Fulfilled { .. } => Err ( ( ) ) ,
154
- PendingOutboundPayment :: Retryable { session_privs, payment_hash, .. } => {
155
- let mut our_session_privs = HashSet :: new ( ) ;
156
- core:: mem:: swap ( & mut our_session_privs, session_privs) ;
157
- * self = PendingOutboundPayment :: Abandoned {
158
- session_privs : our_session_privs,
159
- payment_hash : * payment_hash,
160
- reason : Some ( reason)
161
- } ;
162
- Ok ( ( ) )
163
- } ,
164
- PendingOutboundPayment :: Abandoned { .. } => Ok ( ( ) ) ,
150
+ fn mark_abandoned ( & mut self , reason : PaymentFailureReason ) {
151
+ if let PendingOutboundPayment :: Retryable { session_privs, payment_hash, .. } = self {
152
+ let mut our_session_privs = HashSet :: new ( ) ;
153
+ core:: mem:: swap ( & mut our_session_privs, session_privs) ;
154
+ * self = PendingOutboundPayment :: Abandoned {
155
+ session_privs : our_session_privs,
156
+ payment_hash : * payment_hash,
157
+ reason : Some ( reason)
158
+ } ;
165
159
}
166
160
}
167
161
@@ -591,7 +585,7 @@ impl OutboundPayments {
591
585
outbounds. retain ( |pmt_id, pmt| {
592
586
let mut retain = true ;
593
587
if !pmt. is_auto_retryable_now ( ) && pmt. remaining_parts ( ) == 0 {
594
- let _ = pmt. mark_abandoned ( PaymentFailureReason :: RetriesExhausted ) ;
588
+ pmt. mark_abandoned ( PaymentFailureReason :: RetriesExhausted ) ;
595
589
if let PendingOutboundPayment :: Abandoned { payment_hash, reason, .. } = pmt {
596
590
pending_events. lock ( ) . unwrap ( ) . push ( events:: Event :: PaymentFailed {
597
591
payment_id : * pmt_id,
@@ -709,7 +703,7 @@ impl OutboundPayments {
709
703
710
704
macro_rules! abandon_with_entry {
711
705
( $payment: expr, $reason: expr) => {
712
- let _ = $payment. get_mut( ) . mark_abandoned( $reason) ;
706
+ $payment. get_mut( ) . mark_abandoned( $reason) ;
713
707
if let PendingOutboundPayment :: Abandoned { reason, .. } = $payment. get( ) {
714
708
if $payment. get( ) . remaining_parts( ) == 0 {
715
709
pending_events. lock( ) . unwrap( ) . push( events:: Event :: PaymentFailed {
@@ -1232,7 +1226,7 @@ impl OutboundPayments {
1232
1226
} else {
1233
1227
PaymentFailureReason :: RetriesExhausted
1234
1228
} ;
1235
- let _ = payment. get_mut ( ) . mark_abandoned ( reason) ; // we'll only Err if it's a legacy payment
1229
+ payment. get_mut ( ) . mark_abandoned ( reason) ;
1236
1230
is_retryable_now = false ;
1237
1231
}
1238
1232
if payment. get ( ) . remaining_parts ( ) == 0 {
@@ -1303,7 +1297,7 @@ impl OutboundPayments {
1303
1297
) {
1304
1298
let mut outbounds = self . pending_outbound_payments . lock ( ) . unwrap ( ) ;
1305
1299
if let hash_map:: Entry :: Occupied ( mut payment) = outbounds. entry ( payment_id) {
1306
- let _ = payment. get_mut ( ) . mark_abandoned ( reason) ;
1300
+ payment. get_mut ( ) . mark_abandoned ( reason) ;
1307
1301
if let PendingOutboundPayment :: Abandoned { payment_hash, reason, .. } = payment. get ( ) {
1308
1302
if payment. get ( ) . remaining_parts ( ) == 0 {
1309
1303
pending_events. lock ( ) . unwrap ( ) . push ( events:: Event :: PaymentFailed {
0 commit comments