File tree 2 files changed +5
-7
lines changed
2 files changed +5
-7
lines changed Original file line number Diff line number Diff line change @@ -2606,9 +2606,7 @@ where
2606
2606
/// [`Event::PaymentSent`]: events::Event::PaymentSent
2607
2607
pub fn abandon_payment ( & self , payment_id : PaymentId ) {
2608
2608
let _persistence_guard = PersistenceNotifierGuard :: notify_on_drop ( & self . total_consistency_lock , & self . persistence_notifier ) ;
2609
- if let Some ( payment_failed_ev) = self . pending_outbound_payments . abandon_payment ( payment_id) {
2610
- self . pending_events . lock ( ) . unwrap ( ) . push ( payment_failed_ev) ;
2611
- }
2609
+ self . pending_outbound_payments . abandon_payment ( payment_id, & self . pending_events ) ;
2612
2610
}
2613
2611
2614
2612
/// Send a spontaneous payment, which is a payment that does not require the recipient to have
Original file line number Diff line number Diff line change @@ -1130,21 +1130,21 @@ impl OutboundPayments {
1130
1130
if let Some ( ev) = pending_retry_ev { pending_events. push ( ev) ; }
1131
1131
}
1132
1132
1133
- pub ( super ) fn abandon_payment ( & self , payment_id : PaymentId ) -> Option < events:: Event > {
1134
- let mut failed_ev = None ;
1133
+ pub ( super ) fn abandon_payment ( & self , payment_id : PaymentId ,
1134
+ pending_events : & Mutex < Vec < events:: Event > >
1135
+ ) {
1135
1136
let mut outbounds = self . pending_outbound_payments . lock ( ) . unwrap ( ) ;
1136
1137
if let hash_map:: Entry :: Occupied ( mut payment) = outbounds. entry ( payment_id) {
1137
1138
if let Ok ( ( ) ) = payment. get_mut ( ) . mark_abandoned ( ) {
1138
1139
if payment. get ( ) . remaining_parts ( ) == 0 {
1139
- failed_ev = Some ( events:: Event :: PaymentFailed {
1140
+ pending_events . lock ( ) . unwrap ( ) . push ( events:: Event :: PaymentFailed {
1140
1141
payment_id,
1141
1142
payment_hash : payment. get ( ) . payment_hash ( ) . expect ( "PendingOutboundPayments::RetriesExceeded always has a payment hash set" ) ,
1142
1143
} ) ;
1143
1144
payment. remove ( ) ;
1144
1145
}
1145
1146
}
1146
1147
}
1147
- failed_ev
1148
1148
}
1149
1149
1150
1150
#[ cfg( test) ]
You can’t perform that action at this time.
0 commit comments