status-im
/
eth2.0-specs
mirror of https://github.com/status-im/eth2.0-specs.git
2
0
Fork 0
Code Issues Projects Releases Wiki Activity

Fixed pending attestation handling and added empty transition check

This commit is contained in:
Vitalik Buterin 2019-11-03 15:49:50 -08:00 committed by Danny Ryan
parent 393436992d
commit d723431616
No known key found for this signature in database
GPG Key ID: 2765A792E42CE07A
1 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
specs/core/1_new_shards.md
View File

@ -404,6 +404,7 @@ def process_attestations(state: BeaconState, block: BeaconBlock, attestations: S
online_indices = get_online_indices(state) online_indices = get_online_indices(state)
winners = set() winners = set()
for shard in range(ACTIVE_SHARDS): for shard in range(ACTIVE_SHARDS):
success = False
# All attestations in the block for this shard # All attestations in the block for this shard
this_shard_attestations = [attestation for attestation in attestations if get_shard(state, attestation) == shard and attestation.data.slot == state.slot] this_shard_attestations = [attestation for attestation in attestations if get_shard(state, attestation) == shard and attestation.data.slot == state.slot]
# The committee for this shard # The committee for this shard
@ -428,8 +429,9 @@ def process_attestations(state: BeaconState, block: BeaconBlock, attestations: S
for shard_state, slot, length in zip(transition.shard_states, offset_slots, block.shard_transition.shard_block_lengths): for shard_state, slot, length in zip(transition.shard_states, offset_slots, block.shard_transition.shard_block_lengths):
decrease_balance(state, get_shard_proposer(state, shard, slot), shard_state.gasprice * length) decrease_balance(state, get_shard_proposer(state, shard, slot), shard_state.gasprice * length)
winners.add((shard, shard_transition_root)) winners.add((shard, shard_transition_root))
for index in all_participants: success = True
online_countdown[index] = ONLINE_PERIOD if not success:
assert block.shard_transition == ShardTransition()
for attestation in attestations: for attestation in attestations:
pending_attestation = PendingAttestation( pending_attestation = PendingAttestation(
aggregation_bits=attestation.aggregation_bits, aggregation_bits=attestation.aggregation_bits,
@ -454,6 +456,9 @@ def misc_block_post_process(state: BeaconState, block: BeaconBlock):
for shard in range(MAX_SHARDS): for shard in range(MAX_SHARDS):
if state.shard_states[shard].slot != state.slot - 1: if state.shard_states[shard].slot != state.slot - 1:
assert block.shard_transition[shard] == ShardTransition() assert block.shard_transition[shard] == ShardTransition()
for pending_attestation in state.current_epoch_attestations + state.previous_epoch_attestations:
for index in get_attesting_indices(state, pending_attestation.data, pending_attestation.aggregation_bits):
online_countdown[index] = ONLINE_PERIOD
``` ```
### Light client processing ### Light client processing