mirror/lighthouse-pulse
1
0
Fork 0
mirror of https://gitlab.com/pulsechaincom/lighthouse-pulse.git synced 2024-12-24 20:47:17 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

epoch processing: fix shard delta calculation

Browse Source
This commit is contained in:
Michael Sproul 2019-06-04 16:39:05 +10:00
parent 49e19e2b7d
commit c151e5861e
No known key found for this signature in database
GPG Key ID: 77B1309D2E54E914
3 changed files with 18 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
eth2/types/src/beacon_state.rs
View File

@ -300,11 +300,10 @@ impl<T: EthSpec> BeaconState<T> {
pub fn next_epoch_start_shard(&self) -> Result<u64, Error> {
let cache = self.cache(RelativeEpoch::Current)?;
let active_validator_count = cache.active_validator_count();
let shard_delta = T::get_shard_delta(active_validator_count);
Ok(
(cache.epoch_start_shard() + cache.epoch_committee_count() as u64)
& T::shard_count() as u64,
)
Ok((self.latest_start_shard + shard_delta) % T::ShardCount::to_u64())
}
/// Get the slot of an attestation.

10
eth2/types/src/beacon_state/beacon_state_types.rs
View File

@ -29,6 +29,16 @@ pub trait EthSpec: 'static + Default + Sync + Send + Clone + Debug + PartialEq {
) * slots_per_epoch
}
/// Return the number of shards to increment `state.latest_start_shard` by in a given epoch.
///
/// Spec v0.6.3
fn get_shard_delta(active_validator_count: usize) -> u64 {
std::cmp::min(
Self::get_epoch_committee_count(active_validator_count) as u64,
Self::ShardCount::to_u64() - Self::ShardCount::to_u64() / Self::spec().slots_per_epoch,
)
}
/// Returns the minimum number of validators required for this spec.
///
/// This is the _absolute_ minimum, the number required to make the chain operate in the most

12
eth2/types/src/beacon_state/committee_cache.rs
View File

@ -49,19 +49,17 @@ impl CommitteeCache {
let shuffling_start_shard = match relative_epoch {
RelativeEpoch::Current => state.latest_start_shard,
RelativeEpoch::Previous => {
let committees_in_previous_epoch =
T::get_epoch_committee_count(active_validator_indices.len()) as u64;
let shard_delta = T::get_shard_delta(active_validator_indices.len());
(state.latest_start_shard + T::shard_count() as u64 - committees_in_previous_epoch)
% T::shard_count() as u64
(state.latest_start_shard + T::ShardCount::to_u64() - shard_delta)
% T::ShardCount::to_u64()
}
RelativeEpoch::Next => {
let current_active_validators =
get_active_validator_count(&state.validator_registry, state.current_epoch());
let committees_in_current_epoch =
T::get_epoch_committee_count(current_active_validators) as u64;
let shard_delta = T::get_shard_delta(current_active_validators);
(state.latest_start_shard + committees_in_current_epoch) % T::shard_count() as u64
(state.latest_start_shard + shard_delta) % T::ShardCount::to_u64()
}
};