gnosis/lighthouse
1
0
Fork 0
mirror of https://github.com/sigp/lighthouse.git synced 2026-07-03 04:44:28 +00:00
Code Issues Packages Projects Releases Wiki Activity

synced_and_connected_within_tolerance -> should_search_for_block

Browse Source
This commit is contained in:
realbigsean
2023-06-02 08:34:19 -04:00
parent 844920c052
commit 4b687c9e41
1 changed files with 3 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
beacon_node/network/src/sync/manager.rs
View File

@@ -699,7 +699,7 @@ impl<T: BeaconChainTypes> SyncManager<T> {
SyncMessage::UnknownBlock(peer_id, block, block_root) => { SyncMessage::UnknownBlock(peer_id, block, block_root) => {
let block_slot = block.slot(); let block_slot = block.slot();
if self.synced_and_connected_within_tolerance(block_slot, &peer_id) { if self.should_search_for_block(block_slot, &peer_id) {
let parent_root = block.parent_root(); let parent_root = block.parent_root();
self.block_lookups.search_parent( self.block_lookups.search_parent(
block_slot, block_slot,
@@ -731,7 +731,7 @@ impl<T: BeaconChainTypes> SyncManager<T> {
SyncMessage::BlobParentUnknown(peer_id, blob) => { SyncMessage::BlobParentUnknown(peer_id, blob) => {
let blob_slot = blob.slot; let blob_slot = blob.slot;
if self.synced_and_connected_within_tolerance(blob_slot, &peer_id) { if self.should_search_for_block(blob_slot, &peer_id) {
let block_root = blob.block_root; let block_root = blob.block_root;
let parent_root = blob.block_parent_root; let parent_root = blob.block_parent_root;
let blob_index = blob.index; let blob_index = blob.index;
@@ -878,11 +878,7 @@ impl<T: BeaconChainTypes> SyncManager<T> {
} }
} }
fn synced_and_connected_within_tolerance( fn should_search_for_block(&mut self, block_slot: Slot, peer_id: &PeerId) -> bool {
&mut self,
block_slot: Slot,
peer_id: &PeerId,
) -> bool {
if !self.network_globals.sync_state.read().is_synced() { if !self.network_globals.sync_state.read().is_synced() {
let head_slot = self.chain.canonical_head.cached_head().head_slot(); let head_slot = self.chain.canonical_head.cached_head().head_slot();