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

59 lines
2.0 KiB
Nim
Raw Normal View History

Add more flesh to the skeleton :)
2018-11-26 13:33:06 +00:00
import
minimize imports, specially for spec - cuts 2/3 of ncli build time (#500) * minimize imports, specially for spec - cuts 2/3 of ncli build time * ptr_arith->ptrops
2019-10-25 10:59:56 +00:00
deques, options, sequtils, tables,
naive attestation pool, in preparation of fork choice integration (#125) * move attestation pool to separate file * combine attestations lazily when needed * advance state when there's a gap while attesting * compile beacon node with optimizations - it's tooo slow right now * log when unable to keep up
2019-02-19 23:35:02 +00:00
chronicles,
initial 0.9.0 spec sync (#509) * rename compute_epoch_of_slot(...) to compute_epoch_at_slot(...) * remove some unnecessary imports; remove some crosslink-related code and tests; complete renaming of compute_epoch_of_slot(...) to compute_epoch_at_slot(...) * rm more transfer-related code and tests; rm more unnecessary strutils imports * rm remaining unused imports * remove useless get_empty_per_epoch_cache(...)/compute_start_slot_of_epoch(...) calls * rename compute_start_slot_of_epoch(...) to compute_start_slot_at_epoch(...) * rename ACTIVATION_EXIT_DELAY to MAX_SEED_LOOKAHEAD * update domain types to 0.9.0 * mark AttesterSlashing, IndexedAttestation, AttestationDataAndCustodyBit, DepositData, BeaconBlockHeader, Fork, integer_squareroot(...), and process_voluntary_exit(...) as 0.9.0 * mark increase_balance(...), decrease_balance(...), get_block_root(...), CheckPoint, Deposit, PendingAttestation, HistoricalBatch, is_active_validator(...), and is_slashable_attestation_data(...) as 0.9.0 * mark compute_activation_exit_epoch(...), bls_verify(...), Validator, get_active_validator_indices(...), get_current_epoch(...), get_total_active_balance(...), and get_previous_epoch(...) as 0.9.0 * mark get_block_root_at_slot(...), ProposerSlashing, get_domain(...), VoluntaryExit, mainnet preset Gwei values, minimal preset max operations, process_block_header(...), and is_slashable_validator(...) as 0.9.0 * mark makeWithdrawalCredentials(...), get_validator_churn_limit(...), get_total_balance(...), is_valid_indexed_attestation(...), bls_aggregate_pubkeys(...), initial genesis value/constants, Attestation, get_randao_mix(...), mainnet preset max operations per block constants, minimal preset Gwei values and time parameters, process_eth1_data(...), get_shuffled_seq(...), compute_committee(...), and process_slots(...) as 0.9.0; partially update get_indexed_attestation(...) to 0.9.0 by removing crosslink refs and associated tests * mark initiate_validator_exit(...), process_registry_updates(...), BeaconBlock, Eth1Data, compute_domain(...), process_randao(...), process_attester_slashing(...), get_base_reward(...), and process_slot(...) as 0.9.0
2019-10-30 19:41:19 +00:00
./spec/[datatypes, crypto, helpers],
minimize imports, specially for spec - cuts 2/3 of ncli build time (#500) * minimize imports, specially for spec - cuts 2/3 of ncli build time * ptr_arith->ptrops
2019-10-25 10:59:56 +00:00
./attestation_pool, ./beacon_node_types, ./ssz
switch some proc to func, add some infrastructure, update based on spec name changes (#40) * switch some proc to func, add some infrastructure, update based on spec name changes * typo
2018-12-15 16:32:36 +00:00
re-enable test_interop based on zcli with 0.9.1 specs and update initialize_beacon_state_from_eth1(...) to 0.9.1 (#569) * re-enable test_interop based on zcli with 0.9.1 specs and update initialize_beacon_state_from_eth1(...) to 0.9.1 * switch many procs to funcs * fix import os.nim instead; ospaths is deprecated [Deprecated] warnings
2019-11-21 09:15:10 +00:00
func get_ancestor(blck: BlockRef, slot: Slot): BlockRef =
implement fork choice (#175) * keep track of a finalized block * keep track of all justified blocks * use naive spec version of LMD ghost * cache slot number and a few more things in BlockRef * keep track of the latest vote of each validator * depend less on the state of node.state (it's a cache, effectively)
2019-03-13 22:59:20 +00:00
if blck.slot == slot:
Back the db by rocksdb backend
2019-01-14 12:19:44 +00:00
blck
implement fork choice (#175) * keep track of a finalized block * keep track of all justified blocks * use naive spec version of LMD ghost * cache slot number and a few more things in BlockRef * keep track of the latest vote of each validator * depend less on the state of node.state (it's a cache, effectively)
2019-03-13 22:59:20 +00:00
elif blck.slot < slot:
nil
Fork choice compiles (but untested)
2019-01-08 17:28:21 +00:00
else:
implement fork choice (#175) * keep track of a finalized block * keep track of all justified blocks * use naive spec version of LMD ghost * cache slot number and a few more things in BlockRef * keep track of the latest vote of each validator * depend less on the state of node.state (it's a cache, effectively)
2019-03-13 22:59:20 +00:00
get_ancestor(blck.parent, slot)
Fork choice compiles (but untested)
2019-01-08 17:28:21 +00:00
update to beacon chain phase 0 spec version 0.8.4; no substantive changes (#494)
2019-10-24 13:36:36 +00:00
# https://github.com/ethereum/eth2.0-specs/blob/v0.8.4/specs/core/0_fork-choice.md
interop updates * add interop launcher scripts * stick validator_keygen into beacon_node * fix lmd ghost slot number on missing block * use mocked eth1data when producing blocks * use bls public key method for withdrawal credentials * fix deposit domain * prefer lowercase for a bunch of toHex * build simulation binary in data folder to avoid data types confusion
2019-09-01 15:02:49 +00:00
# The structure of this code differs from the spec since we use a different
# strategy for storing states and justification points - it should nonetheless
# be close in terms of functionality.
re-enable test_interop based on zcli with 0.9.1 specs and update initialize_beacon_state_from_eth1(...) to 0.9.1 (#569) * re-enable test_interop based on zcli with 0.9.1 specs and update initialize_beacon_state_from_eth1(...) to 0.9.1 * switch many procs to funcs * fix import os.nim instead; ospaths is deprecated [Deprecated] warnings
2019-11-21 09:15:10 +00:00
func lmdGhost*(
implement fork choice (#175) * keep track of a finalized block * keep track of all justified blocks * use naive spec version of LMD ghost * cache slot number and a few more things in BlockRef * keep track of the latest vote of each validator * depend less on the state of node.state (it's a cache, effectively)
2019-03-13 22:59:20 +00:00
pool: AttestationPool, start_state: BeaconState,
start_block: BlockRef): BlockRef =
Fork choice compiles (but untested)
2019-01-08 17:28:21 +00:00
# TODO: a Fenwick Tree datastructure to keep track of cumulated votes
# in O(log N) complexity
# https://en.wikipedia.org/wiki/Fenwick_tree
# Nim implementation for cumulative frequencies at
# https://github.com/numforge/laser/blob/990e59fffe50779cdef33aa0b8f22da19e1eb328/benchmarks/random_sampling/fenwicktree.nim
implement fork choice (#175) * keep track of a finalized block * keep track of all justified blocks * use naive spec version of LMD ghost * cache slot number and a few more things in BlockRef * keep track of the latest vote of each validator * depend less on the state of node.state (it's a cache, effectively)
2019-03-13 22:59:20 +00:00
let
active_validator_indices =
get_active_validator_indices(
initial 0.9.0 spec sync (#509) * rename compute_epoch_of_slot(...) to compute_epoch_at_slot(...) * remove some unnecessary imports; remove some crosslink-related code and tests; complete renaming of compute_epoch_of_slot(...) to compute_epoch_at_slot(...) * rm more transfer-related code and tests; rm more unnecessary strutils imports * rm remaining unused imports * remove useless get_empty_per_epoch_cache(...)/compute_start_slot_of_epoch(...) calls * rename compute_start_slot_of_epoch(...) to compute_start_slot_at_epoch(...) * rename ACTIVATION_EXIT_DELAY to MAX_SEED_LOOKAHEAD * update domain types to 0.9.0 * mark AttesterSlashing, IndexedAttestation, AttestationDataAndCustodyBit, DepositData, BeaconBlockHeader, Fork, integer_squareroot(...), and process_voluntary_exit(...) as 0.9.0 * mark increase_balance(...), decrease_balance(...), get_block_root(...), CheckPoint, Deposit, PendingAttestation, HistoricalBatch, is_active_validator(...), and is_slashable_attestation_data(...) as 0.9.0 * mark compute_activation_exit_epoch(...), bls_verify(...), Validator, get_active_validator_indices(...), get_current_epoch(...), get_total_active_balance(...), and get_previous_epoch(...) as 0.9.0 * mark get_block_root_at_slot(...), ProposerSlashing, get_domain(...), VoluntaryExit, mainnet preset Gwei values, minimal preset max operations, process_block_header(...), and is_slashable_validator(...) as 0.9.0 * mark makeWithdrawalCredentials(...), get_validator_churn_limit(...), get_total_balance(...), is_valid_indexed_attestation(...), bls_aggregate_pubkeys(...), initial genesis value/constants, Attestation, get_randao_mix(...), mainnet preset max operations per block constants, minimal preset Gwei values and time parameters, process_eth1_data(...), get_shuffled_seq(...), compute_committee(...), and process_slots(...) as 0.9.0; partially update get_indexed_attestation(...) to 0.9.0 by removing crosslink refs and associated tests * mark initiate_validator_exit(...), process_registry_updates(...), BeaconBlock, Eth1Data, compute_domain(...), process_randao(...), process_attester_slashing(...), get_base_reward(...), and process_slot(...) as 0.9.0
2019-10-30 19:41:19 +00:00
start_state, compute_epoch_at_slot(start_state.slot))
implement fork choice (#175) * keep track of a finalized block * keep track of all justified blocks * use naive spec version of LMD ghost * cache slot number and a few more things in BlockRef * keep track of the latest vote of each validator * depend less on the state of node.state (it's a cache, effectively)
2019-03-13 22:59:20 +00:00
interop updates * add interop launcher scripts * stick validator_keygen into beacon_node * fix lmd ghost slot number on missing block * use mocked eth1data when producing blocks * use bls public key method for withdrawal credentials * fix deposit domain * prefer lowercase for a bunch of toHex * build simulation binary in data folder to avoid data types confusion
2019-09-01 15:02:49 +00:00
var latest_messages: seq[tuple[validator: ValidatorIndex, blck: BlockRef]]
implement fork choice (#175) * keep track of a finalized block * keep track of all justified blocks * use naive spec version of LMD ghost * cache slot number and a few more things in BlockRef * keep track of the latest vote of each validator * depend less on the state of node.state (it's a cache, effectively)
2019-03-13 22:59:20 +00:00
for i in active_validator_indices:
rename BeaconState.validator_registry to BeaconState.validators
2019-07-01 09:13:14 +00:00
let pubKey = start_state.validators[i].pubkey
implement fork choice (#175) * keep track of a finalized block * keep track of all justified blocks * use naive spec version of LMD ghost * cache slot number and a few more things in BlockRef * keep track of the latest vote of each validator * depend less on the state of node.state (it's a cache, effectively)
2019-03-13 22:59:20 +00:00
if (let vote = pool.latestAttestation(pubKey); not vote.isNil):
interop updates * add interop launcher scripts * stick validator_keygen into beacon_node * fix lmd ghost slot number on missing block * use mocked eth1data when producing blocks * use bls public key method for withdrawal credentials * fix deposit domain * prefer lowercase for a bunch of toHex * build simulation binary in data folder to avoid data types confusion
2019-09-01 15:02:49 +00:00
latest_messages.add((i, vote))
implement fork choice (#175) * keep track of a finalized block * keep track of all justified blocks * use naive spec version of LMD ghost * cache slot number and a few more things in BlockRef * keep track of the latest vote of each validator * depend less on the state of node.state (it's a cache, effectively)
2019-03-13 22:59:20 +00:00
interop updates * add interop launcher scripts * stick validator_keygen into beacon_node * fix lmd ghost slot number on missing block * use mocked eth1data when producing blocks * use bls public key method for withdrawal credentials * fix deposit domain * prefer lowercase for a bunch of toHex * build simulation binary in data folder to avoid data types confusion
2019-09-01 15:02:49 +00:00
template get_latest_attesting_balance(blck: BlockRef): uint64 =
implement fork choice (#175) * keep track of a finalized block * keep track of all justified blocks * use naive spec version of LMD ghost * cache slot number and a few more things in BlockRef * keep track of the latest vote of each validator * depend less on the state of node.state (it's a cache, effectively)
2019-03-13 22:59:20 +00:00
var res: uint64
interop updates * add interop launcher scripts * stick validator_keygen into beacon_node * fix lmd ghost slot number on missing block * use mocked eth1data when producing blocks * use bls public key method for withdrawal credentials * fix deposit domain * prefer lowercase for a bunch of toHex * build simulation binary in data folder to avoid data types confusion
2019-09-01 15:02:49 +00:00
for validator_index, target in latest_messages.items():
implement fork choice (#175) * keep track of a finalized block * keep track of all justified blocks * use naive spec version of LMD ghost * cache slot number and a few more things in BlockRef * keep track of the latest vote of each validator * depend less on the state of node.state (it's a cache, effectively)
2019-03-13 22:59:20 +00:00
if get_ancestor(target, blck.slot) == blck:
interop updates * add interop launcher scripts * stick validator_keygen into beacon_node * fix lmd ghost slot number on missing block * use mocked eth1data when producing blocks * use bls public key method for withdrawal credentials * fix deposit domain * prefer lowercase for a bunch of toHex * build simulation binary in data folder to avoid data types confusion
2019-09-01 15:02:49 +00:00
res += start_state.validators[validator_index].effective_balance
implement fork choice (#175) * keep track of a finalized block * keep track of all justified blocks * use naive spec version of LMD ghost * cache slot number and a few more things in BlockRef * keep track of the latest vote of each validator * depend less on the state of node.state (it's a cache, effectively)
2019-03-13 22:59:20 +00:00
res
var head = start_block
while true:
if head.children.len() == 0:
return head
head = head.children[0]
var
interop updates * add interop launcher scripts * stick validator_keygen into beacon_node * fix lmd ghost slot number on missing block * use mocked eth1data when producing blocks * use bls public key method for withdrawal credentials * fix deposit domain * prefer lowercase for a bunch of toHex * build simulation binary in data folder to avoid data types confusion
2019-09-01 15:02:49 +00:00
headCount = get_latest_attesting_balance(head)
implement fork choice (#175) * keep track of a finalized block * keep track of all justified blocks * use naive spec version of LMD ghost * cache slot number and a few more things in BlockRef * keep track of the latest vote of each validator * depend less on the state of node.state (it's a cache, effectively)
2019-03-13 22:59:20 +00:00
for i in 1..<head.children.len:
interop updates * add interop launcher scripts * stick validator_keygen into beacon_node * fix lmd ghost slot number on missing block * use mocked eth1data when producing blocks * use bls public key method for withdrawal credentials * fix deposit domain * prefer lowercase for a bunch of toHex * build simulation binary in data folder to avoid data types confusion
2019-09-01 15:02:49 +00:00
if (let hc = get_latest_attesting_balance(head.children[i]); hc > headCount):
implement fork choice (#175) * keep track of a finalized block * keep track of all justified blocks * use naive spec version of LMD ghost * cache slot number and a few more things in BlockRef * keep track of the latest vote of each validator * depend less on the state of node.state (it's a cache, effectively)
2019-03-13 22:59:20 +00:00
head = head.children[i]
headCount = hc