mirror of
https://github.com/sigp/lighthouse.git
synced 2026-03-16 19:32:55 +00:00
46be05f728
## Issue Addressed #4118 ## Proposed Changes This PR introduces a "progressive balances" cache on the `BeaconState`, which keeps track of the accumulated target attestation balance for the current & previous epochs. The cached values are utilised by fork choice to calculate unrealized justification and finalization (instead of converting epoch participation arrays to balances for each block we receive). This optimization will be rolled out gradually to allow for more testing. A new `--progressive-balances disabled|checked|strict|fast` flag is introduced to support this: - `checked`: enabled with checks against participation cache, and falls back to the existing epoch processing calculation if there is a total target attester balance mismatch. There is no performance gain from this as the participation cache still needs to be computed. **This is the default mode for now.** - `strict`: enabled with checks against participation cache, returns error if there is a mismatch. **Used for testing only**. - `fast`: enabled with no comparative checks and without computing the participation cache. This mode gives us the performance gains from the optimization. This is still experimental and not currently recommended for production usage, but will become the default mode in a future release. - `disabled`: disable the usage of progressive cache, and use the existing method for FFG progression calculation. This mode may be useful if we find a bug and want to stop the frequent error logs. ### Tasks - [x] Initial cache implementation in `BeaconState` - [x] Perform checks in fork choice to compare the progressive balances cache against results from `ParticipationCache` - [x] Add CLI flag, and disable the optimization by default - [x] Testing on Goerli & Benchmarking - [x] Move caching logic from state processing to the `ProgressiveBalancesCache` (see [this comment](https://github.com/sigp/lighthouse/pull/4362#discussion_r1230877001)) - [x] Add attesting balance metrics Co-authored-by: Jimmy Chen <jimmy@sigmaprime.io>
89 lines
3.2 KiB
Rust
89 lines
3.2 KiB
Rust
use super::{process_registry_updates, process_slashings, EpochProcessingSummary, Error};
|
|
use crate::common::update_progressive_balances_cache::{
|
|
initialize_progressive_balances_cache, update_progressive_balances_on_epoch_transition,
|
|
};
|
|
use crate::per_epoch_processing::{
|
|
effective_balance_updates::process_effective_balance_updates,
|
|
historical_roots_update::process_historical_roots_update,
|
|
resets::{process_eth1_data_reset, process_randao_mixes_reset, process_slashings_reset},
|
|
};
|
|
pub use inactivity_updates::process_inactivity_updates;
|
|
pub use justification_and_finalization::process_justification_and_finalization;
|
|
pub use participation_cache::ParticipationCache;
|
|
pub use participation_flag_updates::process_participation_flag_updates;
|
|
pub use rewards_and_penalties::process_rewards_and_penalties;
|
|
pub use sync_committee_updates::process_sync_committee_updates;
|
|
use types::{BeaconState, ChainSpec, EthSpec, RelativeEpoch};
|
|
|
|
pub mod inactivity_updates;
|
|
pub mod justification_and_finalization;
|
|
pub mod participation_cache;
|
|
pub mod participation_flag_updates;
|
|
pub mod rewards_and_penalties;
|
|
pub mod sync_committee_updates;
|
|
|
|
pub fn process_epoch<T: EthSpec>(
|
|
state: &mut BeaconState<T>,
|
|
spec: &ChainSpec,
|
|
) -> Result<EpochProcessingSummary<T>, Error> {
|
|
// Ensure the committee caches are built.
|
|
state.build_committee_cache(RelativeEpoch::Previous, spec)?;
|
|
state.build_committee_cache(RelativeEpoch::Current, spec)?;
|
|
state.build_committee_cache(RelativeEpoch::Next, spec)?;
|
|
|
|
// Pre-compute participating indices and total balances.
|
|
let participation_cache = ParticipationCache::new(state, spec)?;
|
|
let sync_committee = state.current_sync_committee()?.clone();
|
|
initialize_progressive_balances_cache::<T>(state, Some(&participation_cache), spec)?;
|
|
|
|
// Justification and finalization.
|
|
let justification_and_finalization_state =
|
|
process_justification_and_finalization(state, &participation_cache)?;
|
|
justification_and_finalization_state.apply_changes_to_state(state);
|
|
|
|
process_inactivity_updates(state, &participation_cache, spec)?;
|
|
|
|
// Rewards and Penalties.
|
|
process_rewards_and_penalties(state, &participation_cache, spec)?;
|
|
|
|
// Registry Updates.
|
|
process_registry_updates(state, spec)?;
|
|
|
|
// Slashings.
|
|
process_slashings(
|
|
state,
|
|
participation_cache.current_epoch_total_active_balance(),
|
|
spec,
|
|
)?;
|
|
|
|
// Reset eth1 data votes.
|
|
process_eth1_data_reset(state)?;
|
|
|
|
// Update effective balances with hysteresis (lag).
|
|
process_effective_balance_updates(state, Some(&participation_cache), spec)?;
|
|
|
|
// Reset slashings
|
|
process_slashings_reset(state)?;
|
|
|
|
// Set randao mix
|
|
process_randao_mixes_reset(state)?;
|
|
|
|
// Set historical root accumulator
|
|
process_historical_roots_update(state)?;
|
|
|
|
// Rotate current/previous epoch participation
|
|
process_participation_flag_updates(state)?;
|
|
|
|
process_sync_committee_updates(state, spec)?;
|
|
|
|
// Rotate the epoch caches to suit the epoch transition.
|
|
state.advance_caches(spec)?;
|
|
|
|
update_progressive_balances_on_epoch_transition(state, spec)?;
|
|
|
|
Ok(EpochProcessingSummary::Altair {
|
|
participation_cache,
|
|
sync_committee,
|
|
})
|
|
}
|