Skip to content

Commit

Permalink
Revert "Add BeaconBlocksByRange v3"
Browse files Browse the repository at this point in the history
This reverts commit e3ce7fc.
  • Loading branch information
dapplion committed Jul 15, 2024
1 parent e3ce7fc commit 9f40d91
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 12 deletions.
2 changes: 1 addition & 1 deletion beacon_node/network/src/sync/block_lookups/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -53,7 +53,7 @@ mod tests;
/// The maximum depth we will search for a parent block. In principle we should have sync'd any
/// canonical chain to its head once the peer connects. A chain should not appear where it's depth
/// is further back than the most recent head slot.
pub(crate) const PARENT_DEPTH_TOLERANCE: usize = SLOT_IMPORT_TOLERANCE + 1;
pub(crate) const PARENT_DEPTH_TOLERANCE: usize = SLOT_IMPORT_TOLERANCE * 2;

const FAILED_CHAINS_CACHE_EXPIRY_SECONDS: u64 = 60;
pub const SINGLE_BLOCK_LOOKUP_MAX_ATTEMPTS: u8 = 4;
Expand Down
12 changes: 1 addition & 11 deletions beacon_node/network/src/sync/range_sync/chain.rs
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,6 @@ use rand::{seq::SliceRandom, Rng};
use slog::{crit, debug, o, warn};
use std::collections::{btree_map::Entry, BTreeMap, HashSet};
use std::hash::{Hash, Hasher};
use std::time::Instant;
use types::{Epoch, EthSpec, Hash256, Slot};

/// Blocks are downloaded in batches from peers. This constant specifies how many epochs worth of
Expand Down Expand Up @@ -110,9 +109,6 @@ pub struct SyncingChain<T: BeaconChainTypes> {
pub enum ChainSyncingState {
/// The chain is not being synced.
Stopped,
/// The chain should not download any more batches, but should attempt to processing everything
/// that is already downloaded.
Stopping(Instant),
/// The chain is undergoing syncing.
Syncing,
}
Expand Down Expand Up @@ -870,11 +866,6 @@ impl<T: BeaconChainTypes> SyncingChain<T> {
network: &mut SyncNetworkContext<T>,
batch_id: BatchId,
) -> ProcessingResult {
// If chain is stopping do not request any more batches.
if matches!(self.state, ChainSyncingState::Stopping) {
return Ok(KeepChain);
}

let Some(batch) = self.batches.get_mut(&batch_id) else {
return Ok(KeepChain);
};
Expand Down Expand Up @@ -981,7 +972,7 @@ impl<T: BeaconChainTypes> SyncingChain<T> {
pub fn is_syncing(&self) -> bool {
match self.state {
ChainSyncingState::Syncing => true,
ChainSyncingState::Stopped | ChainSyncingState::Stopping { .. } => false,
ChainSyncingState::Stopped => false,
}
}

Expand All @@ -1000,7 +991,6 @@ impl<T: BeaconChainTypes> SyncingChain<T> {
/// Attempts to request the next required batches from the peer pool if the chain is syncing. It will exhaust the peer
/// pool and left over batches until the batch buffer is reached or all peers are exhausted.
fn request_batches(&mut self, network: &mut SyncNetworkContext<T>) -> ProcessingResult {
// If chain is stopped or stopping do not request any more batches.
if !matches!(self.state, ChainSyncingState::Syncing) {
return Ok(KeepChain);
}
Expand Down

0 comments on commit 9f40d91

Please sign in to comment.