cerc-io/lighthouse
16
0
Fork 0
Code Issues 1 Pull Requests Packages Projects Releases Wiki Activity

Retrieving state from store and checking signature

Browse Source
This commit is contained in:
Grant Wuerker 2019-07-11 16:32:01 +02:00
parent adf1d9c533
commit 40b166edcd
No known key found for this signature in database
GPG Key ID: F7EA56FDDA6C464F
1 changed files with 17 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
beacon_node/beacon_chain/src/beacon_chain.rs
View File

@ -15,7 +15,7 @@ use state_processing::per_block_processing::errors::{
};
use state_processing::{
per_block_processing, per_block_processing_without_verifying_block_signature,
per_slot_processing, BlockProcessingError,
per_slot_processing, BlockProcessingError, common
};
use std::sync::Arc;
use store::iter::{BlockIterator, BlockRootsIterator, StateRootsIterator};
@ -480,14 +480,24 @@ impl<T: BeaconChainTypes> BeaconChain<T> {
self.metrics.attestation_processing_requests.inc();
let timer = self.metrics.attestation_processing_times.start_timer();
match self.store.exists::<BeaconBlock>(&attestation.data.target_root) {
Ok(true) => {
per_block_processing::validate_attestation_time_independent_only(&*self.state.read(), &attestation, &self.spec)?;
self.fork_choice.process_attestation(&*self.state.read(), &attestation);
},
_ => {}
// Retrieve the attestation's state from `store` if necessary.
let attestation_state = match attestation.data.beacon_block_root == self.canonical_head.read().beacon_block_root {
true => Some(self.state.read().clone()),
false => match self.store.get::<BeaconBlock>(&attestation.data.beacon_block_root) {
Ok(Some(block)) => match self.store.get::<BeaconState<T::EthSpec>>(&block.state_root) {
Ok(state) => state,
_ => None
},
_ => None
}
};
if let Some(state) = attestation_state {
let indexed_attestation = common::convert_to_indexed(&state, &attestation)?;
per_block_processing::verify_indexed_attestation(&state, &indexed_attestation, &self.spec)?;
self.fork_choice.process_attestation(&state, &attestation);
}
let result = self
.op_pool
.insert_attestation(attestation, &*self.state.read(), &self.spec);