Skip to content

Commit 8fa90f0

Browse files
committed
Handle event_queue push failure in PaymentFailed.
1 parent 374dd60 commit 8fa90f0

File tree

1 file changed

+9
-9
lines changed

1 file changed

+9
-9
lines changed

src/event.rs

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -901,16 +901,16 @@ where
901901
return Err(ReplayEvent());
902902
},
903903
};
904-
self.event_queue
905-
.add_event(Event::PaymentFailed {
906-
payment_id: Some(payment_id),
907-
payment_hash,
908-
reason,
909-
})
910-
.unwrap_or_else(|e| {
904+
905+
let event =
906+
Event::PaymentFailed { payment_id: Some(payment_id), payment_hash, reason };
907+
match self.event_queue.add_event(event) {
908+
Ok(_) => return Ok(()),
909+
Err(e) => {
911910
log_error!(self.logger, "Failed to push to event queue: {}", e);
912-
panic!("Failed to push to event queue");
913-
});
911+
return Err(ReplayEvent());
912+
},
913+
};
914914
},
915915

916916
LdkEvent::PaymentPathSuccessful { .. } => {},

0 commit comments

Comments
 (0)