File tree Expand file tree Collapse file tree 1 file changed +14
-10
lines changed
Expand file tree Collapse file tree 1 file changed +14
-10
lines changed Original file line number Diff line number Diff line change @@ -1210,17 +1210,21 @@ where
12101210 ..
12111211 } => {
12121212 log_info ! ( self . logger, "Channel {} closed due to: {}" , channel_id, reason) ;
1213- self . event_queue
1214- . add_event ( Event :: ChannelClosed {
1215- channel_id,
1216- user_channel_id : UserChannelId ( user_channel_id) ,
1217- counterparty_node_id,
1218- reason : Some ( reason) ,
1219- } )
1220- . unwrap_or_else ( |e| {
1213+
1214+ let event = Event :: ChannelClosed {
1215+ channel_id,
1216+ user_channel_id : UserChannelId ( user_channel_id) ,
1217+ counterparty_node_id,
1218+ reason : Some ( reason) ,
1219+ } ;
1220+
1221+ match self . event_queue . add_event ( event) {
1222+ Ok ( _) => { } ,
1223+ Err ( e) => {
12211224 log_error ! ( self . logger, "Failed to push to event queue: {}" , e) ;
1222- panic ! ( "Failed to push to event queue" ) ;
1223- } ) ;
1225+ return Err ( ReplayEvent ( ) ) ;
1226+ } ,
1227+ } ;
12241228 } ,
12251229 LdkEvent :: DiscardFunding { .. } => { } ,
12261230 LdkEvent :: HTLCIntercepted { .. } => { } ,
You can’t perform that action at this time.
0 commit comments