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

Expanded fork choice api to provide latest validator message.

Browse Source
This commit is contained in:
Grant Wuerker 2019-07-21 22:53:39 +02:00
parent bef7ca6bfb
commit 3b8a584c55
No known key found for this signature in database
GPG Key ID: F7EA56FDDA6C464F
2 changed files with 16 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
eth2/lmd_ghost/src/lib.rs
View File

@ -43,4 +43,7 @@ pub trait LmdGhost<S: Store, E: EthSpec>: Send + Sync {
finalized_block: &BeaconBlock, finalized_block: &BeaconBlock,
finalized_block_root: Hash256, finalized_block_root: Hash256,
) -> Result<()>; ) -> Result<()>;
/// Returns the latest message for a given validator index.
fn latest_message(&mut self, validator_index: usize) -> Option<(Hash256, Slot)>;
} }

13
eth2/lmd_ghost/src/reduced_tree.rs
View File

@ -87,6 +87,12 @@ where
.update_root(new_block.slot, new_root) .update_root(new_block.slot, new_root)
.map_err(|e| format!("update_finalized_root failed: {:?}", e)) .map_err(|e| format!("update_finalized_root failed: {:?}", e))
} }
fn latest_message(&mut self, validator_index: usize) -> Option<(Hash256, Slot)> {
self.core
.write()
.latest_message(validator_index)
}
} }
struct ReducedTree<T, E> { struct ReducedTree<T, E> {
@ -222,6 +228,13 @@ where
Ok(head_node.block_hash) Ok(head_node.block_hash)
} }
pub fn latest_message(&mut self, validator_index: usize) -> Option<(Hash256, Slot)> {
match self.latest_votes.get(validator_index) {
Some(v) => Some((v.hash.clone(), v.slot.clone())),
None => None
}
}
fn find_head_from<'a>(&'a self, start_node: &'a Node) -> Result<&'a Node> { fn find_head_from<'a>(&'a self, start_node: &'a Node) -> Result<&'a Node> {
if start_node.does_not_have_children() { if start_node.does_not_have_children() {
Ok(start_node) Ok(start_node)