Shift networking configuration (#4426)

## Issue Addressed
Addresses [#4401](#4401)

## Proposed Changes
Shift some constants into ```ChainSpec``` and remove the constant values from code space.

## Additional Info

I mostly used ```MainnetEthSpec::default_spec()``` for getting ```ChainSpec```. I wonder Did I make a mistake about that.


Co-authored-by: armaganyildirak <armaganyildirak@gmail.com>
Co-authored-by: Paul Hauner <paul@paulhauner.com>
Co-authored-by: Age Manning <Age@AgeManning.com>
Co-authored-by: Diva M <divma@protonmail.com>

beacon_node/beacon_chain/src/attestation_verification.rs

@@ -35,10 +35,8 @@
 mod batch;
 
 use crate::{
- beacon_chain::{MAXIMUM_GOSSIP_CLOCK_DISPARITY, VALIDATOR_PUBKEY_CACHE_LOCK_TIMEOUT},
- metrics,
- observed_aggregates::ObserveOutcome,
- observed_attesters::Error as ObservedAttestersError,
+ beacon_chain::VALIDATOR_PUBKEY_CACHE_LOCK_TIMEOUT, metrics,
+ observed_aggregates::ObserveOutcome, observed_attesters::Error as ObservedAttestersError,
  BeaconChain, BeaconChainError, BeaconChainTypes,
 };
 use bls::verify_signature_sets;
@@ -57,8 +55,8 @@ use std::borrow::Cow;
 use strum::AsRefStr;
 use tree_hash::TreeHash;
 use types::{
- Attestation, BeaconCommittee, CommitteeIndex, Epoch, EthSpec, Hash256, IndexedAttestation,
- SelectionProof, SignedAggregateAndProof, Slot, SubnetId,
+ Attestation, BeaconCommittee, ChainSpec, CommitteeIndex, Epoch, EthSpec, Hash256,
+ IndexedAttestation, SelectionProof, SignedAggregateAndProof, Slot, SubnetId,
 };
 
 pub use batch::{batch_verify_aggregated_attestations, batch_verify_unaggregated_attestations};
@@ -454,7 +452,7 @@ impl<'a, T: BeaconChainTypes> IndexedAggregatedAttestation<'a, T> {
  // MAXIMUM_GOSSIP_CLOCK_DISPARITY allowance).
  //
  // We do not queue future attestations for later processing.
- verify_propagation_slot_range(&chain.slot_clock, attestation)?;
+ verify_propagation_slot_range(&chain.slot_clock, attestation, &chain.spec)?;
 
  // Check the attestation's epoch matches its target.
  if attestation.data.slot.epoch(T::EthSpec::slots_per_epoch())
@@ -722,7 +720,7 @@ impl<'a, T: BeaconChainTypes> IndexedUnaggregatedAttestation<'a, T> {
  // MAXIMUM_GOSSIP_CLOCK_DISPARITY allowance).
  //
  // We do not queue future attestations for later processing.
- verify_propagation_slot_range(&chain.slot_clock, attestation)?;
+ verify_propagation_slot_range(&chain.slot_clock, attestation, &chain.spec)?;
 
  // Check to ensure that the attestation is "unaggregated". I.e., it has exactly one
  // aggregation bit set.
@@ -1037,11 +1035,11 @@ fn verify_head_block_is_known<T: BeaconChainTypes>(
 pub fn verify_propagation_slot_range<S: SlotClock, E: EthSpec>(
  slot_clock: &S,
  attestation: &Attestation<E>,
+ spec: &ChainSpec,
 ) -> Result<(), Error> {
  let attestation_slot = attestation.data.slot;
-
  let latest_permissible_slot = slot_clock
- .now_with_future_tolerance(MAXIMUM_GOSSIP_CLOCK_DISPARITY)
+ .now_with_future_tolerance(spec.maximum_gossip_clock_disparity())
  .ok_or(BeaconChainError::UnableToReadSlot)?;
  if attestation_slot > latest_permissible_slot {
  return Err(Error::FutureSlot {
@@ -1052,7 +1050,7 @@ pub fn verify_propagation_slot_range<S: SlotClock, E: EthSpec>(
 
  // Taking advantage of saturating subtraction on `Slot`.
  let earliest_permissible_slot = slot_clock
- .now_with_past_tolerance(MAXIMUM_GOSSIP_CLOCK_DISPARITY)
+ .now_with_past_tolerance(spec.maximum_gossip_clock_disparity())
  .ok_or(BeaconChainError::UnableToReadSlot)?
  - E::slots_per_epoch();
  if attestation_slot < earliest_permissible_slot {

beacon_node/beacon_chain/src/beacon_chain.rs

@@ -217,11 +217,6 @@ pub enum OverrideForkchoiceUpdate {
  AlreadyApplied,
 }
 
-/// The accepted clock drift for nodes gossiping blocks and attestations. See:
-///
-/// https://github.com/ethereum/eth2.0-specs/blob/v0.12.1/specs/phase0/p2p-interface.md#configuration
-pub const MAXIMUM_GOSSIP_CLOCK_DISPARITY: Duration = Duration::from_millis(500);
-
 #[derive(Debug, PartialEq)]
 pub enum AttestationProcessingOutcome {
  Processed,

beacon_node/beacon_chain/src/block_verification.rs

@@ -59,7 +59,7 @@ use crate::validator_pubkey_cache::ValidatorPubkeyCache;
 use crate::{
  beacon_chain::{
  BeaconForkChoice, ForkChoiceError, BLOCK_PROCESSING_CACHE_LOCK_TIMEOUT,
- MAXIMUM_GOSSIP_CLOCK_DISPARITY, VALIDATOR_PUBKEY_CACHE_LOCK_TIMEOUT,
+ VALIDATOR_PUBKEY_CACHE_LOCK_TIMEOUT,
  },
  metrics, BeaconChain, BeaconChainError, BeaconChainTypes,
 };
@@ -730,7 +730,7 @@ impl<T: BeaconChainTypes> GossipVerifiedBlock<T> {
  // Do not gossip or process blocks from future slots.
  let present_slot_with_tolerance = chain
  .slot_clock
- .now_with_future_tolerance(MAXIMUM_GOSSIP_CLOCK_DISPARITY)
+ .now_with_future_tolerance(chain.spec.maximum_gossip_clock_disparity())
  .ok_or(BeaconChainError::UnableToReadSlot)?;
  if block.slot() > present_slot_with_tolerance {
  return Err(BlockError::FutureSlot {

beacon_node/beacon_chain/src/lib.rs

@@ -54,7 +54,7 @@ pub use self::beacon_chain::{
  AttestationProcessingOutcome, BeaconChain, BeaconChainTypes, BeaconStore, ChainSegmentResult,
  ForkChoiceError, OverrideForkchoiceUpdate, ProduceBlockVerification, StateSkipConfig,
  WhenSlotSkipped, INVALID_FINALIZED_MERGE_TRANSITION_BLOCK_SHUTDOWN_REASON,
- INVALID_JUSTIFIED_PAYLOAD_SHUTDOWN_REASON, MAXIMUM_GOSSIP_CLOCK_DISPARITY,
+ INVALID_JUSTIFIED_PAYLOAD_SHUTDOWN_REASON,
 };
 pub use self::beacon_snapshot::BeaconSnapshot;
 pub use self::chain_config::ChainConfig;

beacon_node/beacon_chain/src/light_client_finality_update_verification.rs

@@ -1,6 +1,4 @@
-use crate::{
- beacon_chain::MAXIMUM_GOSSIP_CLOCK_DISPARITY, BeaconChain, BeaconChainError, BeaconChainTypes,
-};
+use crate::{BeaconChain, BeaconChainError, BeaconChainTypes};
 use derivative::Derivative;
 use slot_clock::SlotClock;
 use std::time::Duration;
@@ -103,7 +101,8 @@ impl<T: BeaconChainTypes> VerifiedLightClientFinalityUpdate<T> {
  // verify that enough time has passed for the block to have been propagated
  match start_time {
  Some(time) => {
- if seen_timestamp + MAXIMUM_GOSSIP_CLOCK_DISPARITY < time + one_third_slot_duration
+ if seen_timestamp + chain.spec.maximum_gossip_clock_disparity()
+ < time + one_third_slot_duration
  {
  return Err(Error::TooEarly);
  }

beacon_node/beacon_chain/src/light_client_optimistic_update_verification.rs

@@ -1,6 +1,4 @@
-use crate::{
- beacon_chain::MAXIMUM_GOSSIP_CLOCK_DISPARITY, BeaconChain, BeaconChainError, BeaconChainTypes,
-};
+use crate::{BeaconChain, BeaconChainError, BeaconChainTypes};
 use derivative::Derivative;
 use eth2::types::Hash256;
 use slot_clock::SlotClock;
@@ -103,7 +101,8 @@ impl<T: BeaconChainTypes> VerifiedLightClientOptimisticUpdate<T> {
  // verify that enough time has passed for the block to have been propagated
  match start_time {
  Some(time) => {
- if seen_timestamp + MAXIMUM_GOSSIP_CLOCK_DISPARITY < time + one_third_slot_duration
+ if seen_timestamp + chain.spec.maximum_gossip_clock_disparity()
+ < time + one_third_slot_duration
  {
  return Err(Error::TooEarly);
  }

beacon_node/beacon_chain/src/sync_committee_verification.rs

@@ -28,10 +28,8 @@
 
 use crate::observed_attesters::SlotSubcommitteeIndex;
 use crate::{
- beacon_chain::{MAXIMUM_GOSSIP_CLOCK_DISPARITY, VALIDATOR_PUBKEY_CACHE_LOCK_TIMEOUT},
- metrics,
- observed_aggregates::ObserveOutcome,
- BeaconChain, BeaconChainError, BeaconChainTypes,
+ beacon_chain::VALIDATOR_PUBKEY_CACHE_LOCK_TIMEOUT, metrics,
+ observed_aggregates::ObserveOutcome, BeaconChain, BeaconChainError, BeaconChainTypes,
 };
 use bls::{verify_signature_sets, PublicKeyBytes};
 use derivative::Derivative;
@@ -52,6 +50,7 @@ use tree_hash_derive::TreeHash;
 use types::consts::altair::SYNC_COMMITTEE_SUBNET_COUNT;
 use types::slot_data::SlotData;
 use types::sync_committee::Error as SyncCommitteeError;
+use types::ChainSpec;
 use types::{
  sync_committee_contribution::Error as ContributionError, AggregateSignature, BeaconStateError,
  EthSpec, Hash256, SignedContributionAndProof, Slot, SyncCommitteeContribution,
@@ -297,7 +296,7 @@ impl<T: BeaconChainTypes> VerifiedSyncContribution<T> {
  let subcommittee_index = contribution.subcommittee_index as usize;
 
  // Ensure sync committee contribution is within the MAXIMUM_GOSSIP_CLOCK_DISPARITY allowance.
- verify_propagation_slot_range(&chain.slot_clock, contribution)?;
+ verify_propagation_slot_range(&chain.slot_clock, contribution, &chain.spec)?;
 
  // Validate subcommittee index.
  if contribution.subcommittee_index >= SYNC_COMMITTEE_SUBNET_COUNT {
@@ -460,7 +459,7 @@ impl VerifiedSyncCommitteeMessage {
  // MAXIMUM_GOSSIP_CLOCK_DISPARITY allowance).
  //
  // We do not queue future sync committee messages for later processing.
- verify_propagation_slot_range(&chain.slot_clock, &sync_message)?;
+ verify_propagation_slot_range(&chain.slot_clock, &sync_message, &chain.spec)?;
 
  // Ensure the `subnet_id` is valid for the given validator.
  let pubkey = chain
@@ -576,11 +575,11 @@ impl VerifiedSyncCommitteeMessage {
 pub fn verify_propagation_slot_range<S: SlotClock, U: SlotData>(
  slot_clock: &S,
  sync_contribution: &U,
+ spec: &ChainSpec,
 ) -> Result<(), Error> {
  let message_slot = sync_contribution.get_slot();
-
  let latest_permissible_slot = slot_clock
- .now_with_future_tolerance(MAXIMUM_GOSSIP_CLOCK_DISPARITY)
+ .now_with_future_tolerance(spec.maximum_gossip_clock_disparity())
  .ok_or(BeaconChainError::UnableToReadSlot)?;
  if message_slot > latest_permissible_slot {
  return Err(Error::FutureSlot {
@@ -590,7 +589,7 @@ pub fn verify_propagation_slot_range<S: SlotClock, U: SlotData>(
  }
 
  let earliest_permissible_slot = slot_clock
- .now_with_past_tolerance(MAXIMUM_GOSSIP_CLOCK_DISPARITY)
+ .now_with_past_tolerance(spec.maximum_gossip_clock_disparity())
  .ok_or(BeaconChainError::UnableToReadSlot)?;
 
  if message_slot < earliest_permissible_slot {

beacon_node/beacon_processor/src/lib.rs

@@ -661,7 +661,8 @@ impl<E: EthSpec> BeaconProcessor<E> {
  work_reprocessing_rx: mpsc::Receiver<ReprocessQueueMessage>,
  work_journal_tx: Option<mpsc::Sender<&'static str>>,
  slot_clock: S,
- ) {
+ maximum_gossip_clock_disparity: Duration,
+ ) -> Result<(), String> {
  // Used by workers to communicate that they are finished a task.
  let (idle_tx, idle_rx) = mpsc::channel::<()>(MAX_IDLE_QUEUE_LEN);
 
@@ -717,13 +718,15 @@ impl<E: EthSpec> BeaconProcessor<E> {
  // receive them back once they are ready (`ready_work_rx`).
  let (ready_work_tx, ready_work_rx) =
  mpsc::channel::<ReadyWork>(MAX_SCHEDULED_WORK_QUEUE_LEN);
+
  spawn_reprocess_scheduler(
  ready_work_tx,
  work_reprocessing_rx,
  &self.executor,
  slot_clock,
  self.log.clone(),
- );
+ maximum_gossip_clock_disparity,
+ )?;
 
  let executor = self.executor.clone();
 
@@ -1203,6 +1206,7 @@ impl<E: EthSpec> BeaconProcessor<E> {
 
  // Spawn on the core executor.
  executor.spawn(manager_future, MANAGER_TASK_NAME);
+ Ok(())
  }
 
  /// Spawns a blocking worker thread to process some `Work`.

beacon_node/beacon_processor/src/work_reprocessing_queue.rs

@@ -361,7 +361,12 @@ pub fn spawn_reprocess_scheduler<S: SlotClock + 'static>(
  executor: &TaskExecutor,
  slot_clock: S,
  log: Logger,
-) {
+ maximum_gossip_clock_disparity: Duration,
+) -> Result<(), String> {
+ // Sanity check
+ if ADDITIONAL_QUEUED_BLOCK_DELAY >= maximum_gossip_clock_disparity {
+ return Err("The block delay and gossip disparity don't match.".to_string());
+ }
  let mut queue = ReprocessQueue {
  work_reprocessing_rx,
  ready_work_tx,
@@ -400,6 +405,7 @@ pub fn spawn_reprocess_scheduler<S: SlotClock + 'static>(
  },
  TASK_NAME,
  );
+ Ok(())
 }
 
 impl<S: SlotClock> ReprocessQueue<S> {

beacon_node/client/src/builder.rs

@@ -795,7 +795,8 @@ where
  self.work_reprocessing_rx,
  None,
  beacon_chain.slot_clock.clone(),
- );
+ beacon_chain.spec.maximum_gossip_clock_disparity(),
+ )?;
  }
 
  let state_advance_context = runtime_context.service_context("state_advance".into());

beacon_node/http_api/src/attester_duties.rs

@@ -1,9 +1,7 @@
 //! Contains the handler for the `GET validator/duties/attester/{epoch}` endpoint.
 
 use crate::state_id::StateId;
-use beacon_chain::{
- BeaconChain, BeaconChainError, BeaconChainTypes, MAXIMUM_GOSSIP_CLOCK_DISPARITY,
-};
+use beacon_chain::{BeaconChain, BeaconChainError, BeaconChainTypes};
 use eth2::types::{self as api_types};
 use slot_clock::SlotClock;
 use state_processing::state_advance::partial_state_advance;
@@ -32,7 +30,7 @@ pub fn attester_duties<T: BeaconChainTypes>(
  // will equal `current_epoch + 1`
  let tolerant_current_epoch = chain
  .slot_clock
- .now_with_future_tolerance(MAXIMUM_GOSSIP_CLOCK_DISPARITY)
+ .now_with_future_tolerance(chain.spec.maximum_gossip_clock_disparity())
  .ok_or_else(|| warp_utils::reject::custom_server_error("unable to read slot clock".into()))?
  .epoch(T::EthSpec::slots_per_epoch());
 

beacon_node/http_api/src/proposer_duties.rs

@@ -3,7 +3,7 @@
 use crate::state_id::StateId;
 use beacon_chain::{
  beacon_proposer_cache::{compute_proposer_duties_from_head, ensure_state_is_in_epoch},
- BeaconChain, BeaconChainError, BeaconChainTypes, MAXIMUM_GOSSIP_CLOCK_DISPARITY,
+ BeaconChain, BeaconChainError, BeaconChainTypes,
 };
 use eth2::types::{self as api_types};
 use safe_arith::SafeArith;
@@ -33,7 +33,7 @@ pub fn proposer_duties<T: BeaconChainTypes>(
  // will equal `current_epoch + 1`
  let tolerant_current_epoch = chain
  .slot_clock
- .now_with_future_tolerance(MAXIMUM_GOSSIP_CLOCK_DISPARITY)
+ .now_with_future_tolerance(chain.spec.maximum_gossip_clock_disparity())
  .ok_or_else(|| warp_utils::reject::custom_server_error("unable to read slot clock".into()))?
  .epoch(T::EthSpec::slots_per_epoch());
 

beacon_node/http_api/src/sync_committees.rs

@@ -6,7 +6,7 @@ use beacon_chain::sync_committee_verification::{
 };
 use beacon_chain::{
  validator_monitor::timestamp_now, BeaconChain, BeaconChainError, BeaconChainTypes,
- StateSkipConfig, MAXIMUM_GOSSIP_CLOCK_DISPARITY,
+ StateSkipConfig,
 };
 use eth2::types::{self as api_types};
 use lighthouse_network::PubsubMessage;
@@ -85,7 +85,7 @@ fn duties_from_state_load<T: BeaconChainTypes>(
  let current_epoch = chain.epoch()?;
  let tolerant_current_epoch = chain
  .slot_clock
- .now_with_future_tolerance(MAXIMUM_GOSSIP_CLOCK_DISPARITY)
+ .now_with_future_tolerance(chain.spec.maximum_gossip_clock_disparity())
  .ok_or(BeaconChainError::UnableToReadSlot)?
  .epoch(T::EthSpec::slots_per_epoch());
 

beacon_node/http_api/tests/tests.rs

@@ -1,7 +1,7 @@
 use beacon_chain::test_utils::RelativeSyncCommittee;
 use beacon_chain::{
  test_utils::{AttestationStrategy, BeaconChainHarness, BlockStrategy, EphemeralHarnessType},
- BeaconChain, StateSkipConfig, WhenSlotSkipped, MAXIMUM_GOSSIP_CLOCK_DISPARITY,
+ BeaconChain, StateSkipConfig, WhenSlotSkipped,
 };
 use environment::null_logger;
 use eth2::{
@@ -2313,7 +2313,9 @@ impl ApiTester {
  .unwrap();
 
  self.chain.slot_clock.set_current_time(
- current_epoch_start - MAXIMUM_GOSSIP_CLOCK_DISPARITY - Duration::from_millis(1),
+ current_epoch_start
+ - self.chain.spec.maximum_gossip_clock_disparity()
+ - Duration::from_millis(1),
  );
 
  let dependent_root = self
@@ -2350,9 +2352,9 @@ impl ApiTester {
  "should not get attester duties outside of tolerance"
  );
 
- self.chain
- .slot_clock
-  .set_current_time(current_epoch_start - MAXIMUM_GOSSIP_CLOCK_DISPARITY);
+ self.chain.slot_clock.set_current_time(
+ current_epoch_start - self.chain.spec.maximum_gossip_clock_disparity(),
+ );
 
  self.client
  .get_validator_duties_proposer(current_epoch)