Skip to content

Commit 7befec7

Browse files
committed
Handle event_queue push failure in ChannelClosed.
1 parent 8e6e935 commit 7befec7

File tree

1 file changed

+14
-10
lines changed

1 file changed

+14
-10
lines changed

src/event.rs

Lines changed: 14 additions & 10 deletions
Original file line numberDiff line numberDiff 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 { .. } => {},

0 commit comments

Comments
 (0)