Skip to content

fix(retry): always retry connection for receiver stream #447

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
avalonche merged 1 commit into from
Dec 15, 2025
Merged

fix(retry): always retry connection for receiver stream #447

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
8 changes: 7 additions & 1 deletion crates/rollup-boost/src/flashblocks/inbound.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -77,11 +77,16 @@ impl FlashblocksReceiverService {
self.websocket_config
.flashblock_builder_ws_connect_timeout_ms,
);

info!("FlashblocksReceiverService starting reconnection loop");
loop {
if let Err(e) = self.connect_and_handle(&mut backoff, timeout).await {
let interval = backoff
.next_backoff()
.expect("max_elapsed_time not set, never None");
.unwrap_or_else(|| {
error!("Backoff returned None despite max_elapsed_time=None, using max_interval as fallback");
self.websocket_config.max_interval()
});
error!(
"Flashblocks receiver connection error, retrying in {}ms: {}",
interval.as_millis(),
Expand All @@ -93,6 +98,7 @@ impl FlashblocksReceiverService {
} else {
// connect_and_handle should never return Ok(())
error!("Builder websocket connection has stopped. Invariant is broken.");
self.metrics.connection_status.set(0);
}
}
}
Expand Down
Loading