Skip to content

[DONOTMERGE] FSM update to proper handle validators that aren't in union ( or have no realm assignment ) #104

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

Open
GTC6244 wants to merge 3 commits into
base: master
Choose a base branch
from
Open

[DONOTMERGE] FSM update to proper handle validators that aren't in union ( or have no realm assignment ) #104

Changes from all commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
59d023c
FSM update
GTC6244 Feb 5, 2026
813091a
Quick update to only auto-rejoin nodes that were in the prior epoch.
GTC6244 Feb 5, 2026
04f8d41
clippy ! !
GTC6244 Feb 5, 2026
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
29 changes: 15 additions & 14 deletions rust/lit-node/lit-node/src/tasks/fsm/mod.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -111,11 +111,6 @@ pub async fn node_fsm_worker(
}
};

// if we're not able to proceed, based on some checks while getting the fsm state, just do another loop.
if !can_proceed {
continue;
}

// If we're not part of the validators union - attempt to join, do some logging and restart our loop.
if !peer_state.part_of_validators_union() {
handle_not_part_of_validators_union(
Expand All @@ -124,12 +119,16 @@ pub async fn node_fsm_worker(
is_shadow,
epoch_number,
previous_included_epoch_number,
realm_id,
)
.await;
continue;
}
Comment thread
GTC6244 marked this conversation as resolved.

// if we're not able to proceed, based on some checks while getting the fsm state, just do another loop.
if !can_proceed {
continue;
}

// set epoch_to_signal_ready to the current epoch if uninitialized (aka == 0)
if epoch_to_signal_ready == U256::from(0) {
epoch_to_signal_ready = epoch_number;
Expand Down Expand Up @@ -565,7 +564,6 @@ pub async fn handle_not_part_of_validators_union(
is_shadow: bool,
epoch_number: U256,
previous_included_epoch_number: U256,
realm_id: u64,
) {
let current_state = { node_state.current_state() };
trace!(
Expand All @@ -580,20 +578,23 @@ pub async fn handle_not_part_of_validators_union(
);
let _ = get_current_and_new_peer_addresses(is_shadow, peer_state.clone()).await;
// requesting to auto rejoin if online but not part of the current validators
if peer_state.auto_join {
if peer_state.auto_join
&& peer_state
.peers_in_prior_epoch()
.contains_address(&peer_state.addr)
&& !peer_state
.peers_in_next_epoch()
.contains_address(&peer_state.addr)
{
match peer_state.request_to_join().await {
Ok(_) => info!("Auto requested to join the network"),
Err(e) => error!("Error in request_to_join: {}", e),
}
}
}

State::Active | State::PendingActive | State::Locked => {
if let Err(e) = peer_state.validators_in_active_state(realm_id).await {
error!("Error in handle_if_validators_in_active_state: {}", e);
}
node_state.next(Transition::Leave)
}
State::Active | State::PendingActive | State::Locked => node_state.next(Transition::Leave),

State::Suspended => {
if epoch_number > previous_included_epoch_number + 1 {
node_state.next(Transition::Rejoin)
Expand Down
Loading