Apply suggestions after the review

This commit is contained in:
Mikhail Kalinin 2021-06-02 15:00:01 +06:00
parent db32c8b013
commit 6604830729
3 changed files with 10 additions and 15 deletions

View File

@ -16,8 +16,7 @@
- [`TransitionStore`](#transitionstore) - [`TransitionStore`](#transitionstore)
- [`PowBlock`](#powblock) - [`PowBlock`](#powblock)
- [`get_pow_block`](#get_pow_block) - [`get_pow_block`](#get_pow_block)
- [`get_transition_store`](#get_transition_store) - [`is_valid_terminal_pow_block`](#is_valid_terminal_pow_block)
- [`is_valid_transition_block`](#is_valid_transition_block)
- [Updated fork-choice handlers](#updated-fork-choice-handlers) - [Updated fork-choice handlers](#updated-fork-choice-handlers)
- [`on_block`](#on_block) - [`on_block`](#on_block)
@ -94,20 +93,12 @@ Let `get_pow_block(block_hash: Hash32) -> PowBlock` be the function that given t
*Note*: The `eth_getBlockByHash` JSON-RPC method does not distinguish invalid blocks from blocks that haven't been processed yet. Either extending this existing method or implementing a new one is required. *Note*: The `eth_getBlockByHash` JSON-RPC method does not distinguish invalid blocks from blocks that haven't been processed yet. Either extending this existing method or implementing a new one is required.
### `get_transition_store` ### `is_valid_terminal_pow_block`
```python
def get_transition_store(anchor_pow_block: PowBlock):
transition_total_difficulty = anchor_pow_block.total_difficulty + TRANSITION_TOTAL_DIFFICULTY_OFFSET
return TransitionStore(transition_total_difficulty=transition_total_difficulty)
```
### `is_valid_transition_block`
Used by fork-choice handler, `on_block`. Used by fork-choice handler, `on_block`.
```python ```python
def is_valid_transition_block(transition_store: TransitionStore, block: PowBlock) -> bool: def is_valid_terminal_pow_block(transition_store: TransitionStore, block: PowBlock) -> bool:
is_total_difficulty_reached = block.total_difficulty >= transition_store.transition_total_difficulty is_total_difficulty_reached = block.total_difficulty >= transition_store.transition_total_difficulty
return block.is_valid and is_total_difficulty_reached return block.is_valid and is_total_difficulty_reached
``` ```
@ -135,12 +126,12 @@ def on_block(store: Store, signed_block: SignedBeaconBlock, transition_store: Tr
assert get_ancestor(store, block.parent_root, finalized_slot) == store.finalized_checkpoint.root assert get_ancestor(store, block.parent_root, finalized_slot) == store.finalized_checkpoint.root
# [New in Merge] # [New in Merge]
is_transition_store_initialized = transition_store is not None is_transition_store_initialized = (transition_store is not None)
if is_transition_store_initialized and is_transition_block(pre_state, block): if is_transition_store_initialized and is_transition_block(pre_state, block):
# Delay consideration of block until PoW block is processed by the PoW node # Delay consideration of block until PoW block is processed by the PoW node
pow_block = get_pow_block(block.body.execution_payload.parent_hash) pow_block = get_pow_block(block.body.execution_payload.parent_hash)
assert pow_block.is_processed assert pow_block.is_processed
assert is_valid_transition_block(transition_store, pow_block) assert is_valid_terminal_pow_block(transition_store, pow_block)
# Check the block is valid and compute the post-state # Check the block is valid and compute the post-state
state = pre_state.copy() state = pre_state.copy()

View File

@ -96,6 +96,10 @@ If `state.slot % SLOTS_PER_EPOCH == 0` and `compute_epoch_at_slot(state.slot) ==
Transition store initialization occurs after the state has been modified by corresponding `upgrade_to_merge` function. Transition store initialization occurs after the state has been modified by corresponding `upgrade_to_merge` function.
```python ```python
def get_transition_store(anchor_pow_block: PowBlock) -> TransitionStore:
transition_total_difficulty = anchor_pow_block.total_difficulty + TRANSITION_TOTAL_DIFFICULTY_OFFSET
return TransitionStore(transition_total_difficulty=transition_total_difficulty)
def initialize_transition_store(state: BeaconState) -> TransitionStore: def initialize_transition_store(state: BeaconState) -> TransitionStore:
pow_block = get_pow_block(state.eth1_data.block_hash) pow_block = get_pow_block(state.eth1_data.block_hash)
return get_transition_store(pow_block) return get_transition_store(pow_block)

View File

@ -75,7 +75,7 @@ def get_execution_payload(state: BeaconState,
execution_engine: ExecutionEngine) -> ExecutionPayload: execution_engine: ExecutionEngine) -> ExecutionPayload:
if not is_transition_completed(state): if not is_transition_completed(state):
pow_block = get_pow_chain_head() pow_block = get_pow_chain_head()
if not is_valid_transition_block(transition_store, pow_block): if not is_valid_terminal_pow_block(transition_store, pow_block):
# Pre-merge, empty payload # Pre-merge, empty payload
return ExecutionPayload() return ExecutionPayload()
else: else: