Advance if no blocks are available in the given range
This commit is contained in:
@ -266,11 +266,18 @@ pub fn process_slots(
|
|||||||
Ok(blocks) => {
|
Ok(blocks) => {
|
||||||
info!("Loaded {} blocks", blocks.len());
|
info!("Loaded {} blocks", blocks.len());
|
||||||
|
|
||||||
for (slot, block) in blocks.into_iter() {
|
if blocks.is_empty() && end_slot < latest_available_slot {
|
||||||
process_confirmed_block(slot, block, &mut stake_accounts_info.account_info);
|
stake_accounts_info.slot = end_slot;
|
||||||
stake_accounts_info.slot = slot;
|
} else {
|
||||||
datapoint_info!("stake-monitor-slot", ("slot", slot, i64));
|
for (slot, block) in blocks.into_iter() {
|
||||||
|
process_confirmed_block(slot, block, &mut stake_accounts_info.account_info);
|
||||||
|
stake_accounts_info.slot = slot;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
datapoint_info!(
|
||||||
|
"stake-monitor-slot",
|
||||||
|
("slot", stake_accounts_info.slot, i64)
|
||||||
|
);
|
||||||
}
|
}
|
||||||
Err(err) => {
|
Err(err) => {
|
||||||
datapoint_error!(
|
datapoint_error!(
|
||||||
|
Reference in New Issue
Block a user