Skip to content

Commit 8e6e935

Browse files
committed
Handle event_queue push failure in ChannelReady.
1 parent b7beff0 commit 8e6e935

File tree

1 file changed

+12
-9
lines changed

1 file changed

+12
-9
lines changed

src/event.rs

Lines changed: 12 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -1188,16 +1188,19 @@ where
11881188
channel_id,
11891189
counterparty_node_id,
11901190
);
1191-
self.event_queue
1192-
.add_event(Event::ChannelReady {
1193-
channel_id,
1194-
user_channel_id: UserChannelId(user_channel_id),
1195-
counterparty_node_id: Some(counterparty_node_id),
1196-
})
1197-
.unwrap_or_else(|e| {
1191+
1192+
let event = Event::ChannelReady {
1193+
channel_id,
1194+
user_channel_id: UserChannelId(user_channel_id),
1195+
counterparty_node_id: Some(counterparty_node_id),
1196+
};
1197+
match self.event_queue.add_event(event) {
1198+
Ok(_) => {},
1199+
Err(e) => {
11981200
log_error!(self.logger, "Failed to push to event queue: {}", e);
1199-
panic!("Failed to push to event queue");
1200-
});
1201+
return Err(ReplayEvent());
1202+
},
1203+
};
12011204
},
12021205
LdkEvent::ChannelClosed {
12031206
channel_id,

0 commit comments

Comments
 (0)