Skip to content

Commit d95e330

Browse files
committed
Handle event_queue push failure in ChannelReady.
1 parent 3b8dabb commit d95e330

File tree

1 file changed

+10
-9
lines changed

1 file changed

+10
-9
lines changed

src/event.rs

Lines changed: 10 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -1184,16 +1184,17 @@ where
11841184
channel_id,
11851185
counterparty_node_id,
11861186
);
1187-
self.event_queue
1188-
.add_event(Event::ChannelReady {
1189-
channel_id,
1190-
user_channel_id: UserChannelId(user_channel_id),
1191-
counterparty_node_id: Some(counterparty_node_id),
1192-
})
1193-
.unwrap_or_else(|e| {
1187+
match self.event_queue.add_event(Event::ChannelReady {
1188+
channel_id,
1189+
user_channel_id: UserChannelId(user_channel_id),
1190+
counterparty_node_id: Some(counterparty_node_id),
1191+
}) {
1192+
Ok(_) => {},
1193+
Err(e) => {
11941194
log_error!(self.logger, "Failed to push to event queue: {}", e);
1195-
panic!("Failed to push to event queue");
1196-
});
1195+
return Err(ReplayEvent());
1196+
},
1197+
};
11971198
},
11981199
LdkEvent::ChannelClosed {
11991200
channel_id,

0 commit comments

Comments
 (0)