mirror of
https://github.com/pezkuwichain/pezkuwi-subxt.git
synced 2026-04-27 04:37:57 +00:00
8031b6eacb
polkadot companion: paritytech/polkadot#2535
1152 lines
35 KiB
Rust
1152 lines
35 KiB
Rust
// This file is part of Substrate.
|
|
|
|
// Copyright (C) 2019-2021 Parity Technologies (UK) Ltd.
|
|
// SPDX-License-Identifier: GPL-3.0-or-later WITH Classpath-exception-2.0
|
|
|
|
// This program is free software: you can redistribute it and/or modify
|
|
// it under the terms of the GNU General Public License as published by
|
|
// the Free Software Foundation, either version 3 of the License, or
|
|
// (at your option) any later version.
|
|
|
|
// This program is distributed in the hope that it will be useful,
|
|
// but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
// GNU General Public License for more details.
|
|
|
|
// You should have received a copy of the GNU General Public License
|
|
// along with this program. If not, see <https://www.gnu.org/licenses/>.
|
|
|
|
//! Slots functionality for Substrate.
|
|
//!
|
|
//! Some consensus algorithms have a concept of *slots*, which are intervals in
|
|
//! time during which certain events can and/or must occur. This crate
|
|
//! provides generic functionality for slots.
|
|
|
|
#![forbid(unsafe_code)]
|
|
#![deny(missing_docs)]
|
|
|
|
mod slots;
|
|
mod aux_schema;
|
|
|
|
pub use slots::SlotInfo;
|
|
use slots::Slots;
|
|
pub use aux_schema::{check_equivocation, MAX_SLOT_CAPACITY, PRUNING_BOUND};
|
|
|
|
use std::{fmt::Debug, ops::Deref, pin::Pin, sync::Arc, time::Duration};
|
|
use codec::{Decode, Encode};
|
|
use futures::{prelude::*, future::{self, Either}};
|
|
use futures_timer::Delay;
|
|
use log::{debug, error, info, warn};
|
|
use parking_lot::Mutex;
|
|
use sp_api::{ProvideRuntimeApi, ApiRef};
|
|
use sp_arithmetic::traits::BaseArithmetic;
|
|
use sp_consensus::{BlockImport, Proposer, SyncOracle, SelectChain, CanAuthorWith, SlotData};
|
|
use sp_consensus_slots::Slot;
|
|
use sp_inherents::{InherentData, InherentDataProviders};
|
|
use sp_runtime::{
|
|
generic::BlockId,
|
|
traits::{Block as BlockT, Header, HashFor, NumberFor}
|
|
};
|
|
use sc_telemetry::{telemetry, TelemetryHandle, CONSENSUS_DEBUG, CONSENSUS_WARN, CONSENSUS_INFO};
|
|
|
|
/// The changes that need to applied to the storage to create the state for a block.
|
|
///
|
|
/// See [`sp_state_machine::StorageChanges`] for more information.
|
|
pub type StorageChanges<Transaction, Block> =
|
|
sp_state_machine::StorageChanges<Transaction, HashFor<Block>, NumberFor<Block>>;
|
|
|
|
/// The result of [`SlotWorker::on_slot`].
|
|
#[derive(Debug, Clone)]
|
|
pub struct SlotResult<Block: BlockT, Proof> {
|
|
/// The block that was built.
|
|
pub block: Block,
|
|
/// The storage proof that was recorded while building the block.
|
|
pub storage_proof: Proof,
|
|
}
|
|
|
|
/// A worker that should be invoked at every new slot.
|
|
///
|
|
/// The implementation should not make any assumptions of the slot being bound to the time or
|
|
/// similar. The only valid assumption is that the slot number is always increasing.
|
|
pub trait SlotWorker<B: BlockT, Proof> {
|
|
/// Called when a new slot is triggered.
|
|
///
|
|
/// Returns a future that resolves to a [`SlotResult`] iff a block was successfully built in
|
|
/// the slot. Otherwise `None` is returned.
|
|
fn on_slot(
|
|
&mut self,
|
|
chain_head: B::Header,
|
|
slot_info: SlotInfo,
|
|
) -> Pin<Box<dyn Future<Output = Option<SlotResult<B, Proof>>> + Send>>;
|
|
}
|
|
|
|
/// A skeleton implementation for `SlotWorker` which tries to claim a slot at
|
|
/// its beginning and tries to produce a block if successfully claimed, timing
|
|
/// out if block production takes too long.
|
|
pub trait SimpleSlotWorker<B: BlockT> {
|
|
/// A handle to a `BlockImport`.
|
|
type BlockImport: BlockImport<B, Transaction = <Self::Proposer as Proposer<B>>::Transaction>
|
|
+ Send + 'static;
|
|
|
|
/// A handle to a `SyncOracle`.
|
|
type SyncOracle: SyncOracle;
|
|
|
|
/// The type of future resolving to the proposer.
|
|
type CreateProposer: Future<Output = Result<Self::Proposer, sp_consensus::Error>>
|
|
+ Send + Unpin + 'static;
|
|
|
|
/// The type of proposer to use to build blocks.
|
|
type Proposer: Proposer<B>;
|
|
|
|
/// Data associated with a slot claim.
|
|
type Claim: Send + 'static;
|
|
|
|
/// Epoch data necessary for authoring.
|
|
type EpochData: Send + 'static;
|
|
|
|
/// The logging target to use when logging messages.
|
|
fn logging_target(&self) -> &'static str;
|
|
|
|
/// A handle to a `BlockImport`.
|
|
fn block_import(&self) -> Arc<Mutex<Self::BlockImport>>;
|
|
|
|
/// Returns the epoch data necessary for authoring. For time-dependent epochs,
|
|
/// use the provided slot number as a canonical source of time.
|
|
fn epoch_data(
|
|
&self,
|
|
header: &B::Header,
|
|
slot: Slot,
|
|
) -> Result<Self::EpochData, sp_consensus::Error>;
|
|
|
|
/// Returns the number of authorities given the epoch data.
|
|
/// None indicate that the authorities information is incomplete.
|
|
fn authorities_len(&self, epoch_data: &Self::EpochData) -> Option<usize>;
|
|
|
|
/// Tries to claim the given slot, returning an object with claim data if successful.
|
|
fn claim_slot(
|
|
&self,
|
|
header: &B::Header,
|
|
slot: Slot,
|
|
epoch_data: &Self::EpochData,
|
|
) -> Option<Self::Claim>;
|
|
|
|
/// Notifies the given slot. Similar to `claim_slot`, but will be called no matter whether we
|
|
/// need to author blocks or not.
|
|
fn notify_slot(
|
|
&self,
|
|
_header: &B::Header,
|
|
_slot: Slot,
|
|
_epoch_data: &Self::EpochData,
|
|
) {}
|
|
|
|
/// Return the pre digest data to include in a block authored with the given claim.
|
|
fn pre_digest_data(
|
|
&self,
|
|
slot: Slot,
|
|
claim: &Self::Claim,
|
|
) -> Vec<sp_runtime::DigestItem<B::Hash>>;
|
|
|
|
/// Returns a function which produces a `BlockImportParams`.
|
|
fn block_import_params(&self) -> Box<
|
|
dyn Fn(
|
|
B::Header,
|
|
&B::Hash,
|
|
Vec<B::Extrinsic>,
|
|
StorageChanges<<Self::BlockImport as BlockImport<B>>::Transaction, B>,
|
|
Self::Claim,
|
|
Self::EpochData,
|
|
) -> Result<
|
|
sp_consensus::BlockImportParams<B, <Self::BlockImport as BlockImport<B>>::Transaction>,
|
|
sp_consensus::Error
|
|
> + Send + 'static
|
|
>;
|
|
|
|
/// Whether to force authoring if offline.
|
|
fn force_authoring(&self) -> bool;
|
|
|
|
/// Returns whether the block production should back off.
|
|
///
|
|
/// By default this function always returns `false`.
|
|
///
|
|
/// An example strategy that back offs if the finalized head is lagging too much behind the tip
|
|
/// is implemented by [`BackoffAuthoringOnFinalizedHeadLagging`].
|
|
fn should_backoff(&self, _slot: Slot, _chain_head: &B::Header) -> bool {
|
|
false
|
|
}
|
|
|
|
/// Returns a handle to a `SyncOracle`.
|
|
fn sync_oracle(&mut self) -> &mut Self::SyncOracle;
|
|
|
|
/// Returns a `Proposer` to author on top of the given block.
|
|
fn proposer(&mut self, block: &B::Header) -> Self::CreateProposer;
|
|
|
|
/// Returns a [`TelemetryHandle`] if any.
|
|
fn telemetry(&self) -> Option<TelemetryHandle>;
|
|
|
|
/// Remaining duration for proposing.
|
|
fn proposing_remaining_duration(
|
|
&self,
|
|
head: &B::Header,
|
|
slot_info: &SlotInfo,
|
|
) -> Duration;
|
|
|
|
/// Implements [`SlotWorker::on_slot`].
|
|
fn on_slot(
|
|
&mut self,
|
|
chain_head: B::Header,
|
|
slot_info: SlotInfo,
|
|
) -> Pin<Box<dyn Future<Output = Option<SlotResult<B, <Self::Proposer as Proposer<B>>::Proof>>> + Send>>
|
|
where
|
|
<Self::Proposer as Proposer<B>>::Proposal: Unpin + Send + 'static,
|
|
{
|
|
let (timestamp, slot) = (slot_info.timestamp, slot_info.slot);
|
|
let telemetry = self.telemetry();
|
|
|
|
let proposing_remaining_duration = self.proposing_remaining_duration(&chain_head, &slot_info);
|
|
|
|
let proposing_remaining = if proposing_remaining_duration == Duration::default() {
|
|
debug!(
|
|
target: self.logging_target(),
|
|
"Skipping proposal slot {} since there's no time left to propose",
|
|
slot,
|
|
);
|
|
|
|
return Box::pin(future::ready(None));
|
|
} else {
|
|
Box::new(Delay::new(proposing_remaining_duration))
|
|
as Box<dyn Future<Output = ()> + Unpin + Send>
|
|
};
|
|
|
|
let epoch_data = match self.epoch_data(&chain_head, slot) {
|
|
Ok(epoch_data) => epoch_data,
|
|
Err(err) => {
|
|
warn!("Unable to fetch epoch data at block {:?}: {:?}", chain_head.hash(), err);
|
|
|
|
telemetry!(
|
|
telemetry;
|
|
CONSENSUS_WARN;
|
|
"slots.unable_fetching_authorities";
|
|
"slot" => ?chain_head.hash(),
|
|
"err" => ?err,
|
|
);
|
|
|
|
return Box::pin(future::ready(None));
|
|
}
|
|
};
|
|
|
|
self.notify_slot(&chain_head, slot, &epoch_data);
|
|
|
|
let authorities_len = self.authorities_len(&epoch_data);
|
|
|
|
if !self.force_authoring() &&
|
|
self.sync_oracle().is_offline() &&
|
|
authorities_len.map(|a| a > 1).unwrap_or(false)
|
|
{
|
|
debug!(target: self.logging_target(), "Skipping proposal slot. Waiting for the network.");
|
|
telemetry!(
|
|
telemetry;
|
|
CONSENSUS_DEBUG;
|
|
"slots.skipping_proposal_slot";
|
|
"authorities_len" => authorities_len,
|
|
);
|
|
|
|
return Box::pin(future::ready(None));
|
|
}
|
|
|
|
let claim = match self.claim_slot(&chain_head, slot, &epoch_data) {
|
|
None => return Box::pin(future::ready(None)),
|
|
Some(claim) => claim,
|
|
};
|
|
|
|
if self.should_backoff(slot, &chain_head) {
|
|
return Box::pin(future::ready(None));
|
|
}
|
|
|
|
debug!(
|
|
target: self.logging_target(),
|
|
"Starting authorship at slot {}; timestamp = {}",
|
|
slot,
|
|
timestamp,
|
|
);
|
|
|
|
telemetry!(
|
|
telemetry;
|
|
CONSENSUS_DEBUG;
|
|
"slots.starting_authorship";
|
|
"slot_num" => *slot,
|
|
"timestamp" => timestamp,
|
|
);
|
|
|
|
let awaiting_proposer = {
|
|
let telemetry = telemetry.clone();
|
|
self.proposer(&chain_head).map_err(move |err| {
|
|
warn!("Unable to author block in slot {:?}: {:?}", slot, err);
|
|
|
|
telemetry!(
|
|
telemetry;
|
|
CONSENSUS_WARN;
|
|
"slots.unable_authoring_block";
|
|
"slot" => *slot,
|
|
"err" => ?err
|
|
);
|
|
|
|
err
|
|
})
|
|
};
|
|
|
|
let logs = self.pre_digest_data(slot, &claim);
|
|
|
|
// deadline our production to 98% of the total time left for proposing. As we deadline
|
|
// the proposing below to the same total time left, the 2% margin should be enough for
|
|
// the result to be returned.
|
|
let proposing = awaiting_proposer.and_then(move |proposer| proposer.propose(
|
|
slot_info.inherent_data,
|
|
sp_runtime::generic::Digest {
|
|
logs,
|
|
},
|
|
proposing_remaining_duration.mul_f32(0.98),
|
|
).map_err(|e| sp_consensus::Error::ClientImport(format!("{:?}", e))));
|
|
|
|
let proposal_work = {
|
|
let telemetry = telemetry.clone();
|
|
futures::future::select(proposing, proposing_remaining).map(move |v| match v {
|
|
Either::Left((b, _)) => b.map(|b| (b, claim)),
|
|
Either::Right(_) => {
|
|
info!(
|
|
"⌛️ Discarding proposal for slot {}; block production took too long",
|
|
slot,
|
|
);
|
|
// If the node was compiled with debug, tell the user to use release optimizations.
|
|
#[cfg(build_type="debug")]
|
|
info!("👉 Recompile your node in `--release` mode to mitigate this problem.");
|
|
telemetry!(
|
|
telemetry;
|
|
CONSENSUS_INFO;
|
|
"slots.discarding_proposal_took_too_long";
|
|
"slot" => *slot,
|
|
);
|
|
|
|
Err(sp_consensus::Error::ClientImport("Timeout in the Slots proposer".into()))
|
|
},
|
|
})
|
|
};
|
|
|
|
let block_import_params_maker = self.block_import_params();
|
|
let block_import = self.block_import();
|
|
let logging_target = self.logging_target();
|
|
|
|
proposal_work.and_then(move |(proposal, claim)| async move {
|
|
let (block, storage_proof) = (proposal.block, proposal.proof);
|
|
let (header, body) = block.deconstruct();
|
|
let header_num = *header.number();
|
|
let header_hash = header.hash();
|
|
let parent_hash = *header.parent_hash();
|
|
|
|
let block_import_params = block_import_params_maker(
|
|
header,
|
|
&header_hash,
|
|
body.clone(),
|
|
proposal.storage_changes,
|
|
claim,
|
|
epoch_data,
|
|
)?;
|
|
|
|
info!(
|
|
"🔖 Pre-sealed block for proposal at {}. Hash now {:?}, previously {:?}.",
|
|
header_num,
|
|
block_import_params.post_hash(),
|
|
header_hash,
|
|
);
|
|
|
|
telemetry!(
|
|
telemetry;
|
|
CONSENSUS_INFO;
|
|
"slots.pre_sealed_block";
|
|
"header_num" => ?header_num,
|
|
"hash_now" => ?block_import_params.post_hash(),
|
|
"hash_previously" => ?header_hash,
|
|
);
|
|
|
|
let header = block_import_params.post_header();
|
|
if let Err(err) = block_import.lock().import_block(block_import_params, Default::default()) {
|
|
warn!(
|
|
target: logging_target,
|
|
"Error with block built on {:?}: {:?}",
|
|
parent_hash,
|
|
err,
|
|
);
|
|
|
|
telemetry!(
|
|
telemetry;
|
|
CONSENSUS_WARN;
|
|
"slots.err_with_block_built_on";
|
|
"hash" => ?parent_hash,
|
|
"err" => ?err,
|
|
);
|
|
}
|
|
|
|
Ok(SlotResult { block: B::new(header, body), storage_proof })
|
|
}).then(|r| async move {
|
|
r.map_err(|e| warn!(target: "slots", "Encountered consensus error: {:?}", e)).ok()
|
|
}).boxed()
|
|
}
|
|
}
|
|
|
|
impl<B: BlockT, T: SimpleSlotWorker<B>> SlotWorker<B, <T::Proposer as Proposer<B>>::Proof> for T {
|
|
fn on_slot(
|
|
&mut self,
|
|
chain_head: B::Header,
|
|
slot_info: SlotInfo,
|
|
) -> Pin<Box<dyn Future<Output = Option<SlotResult<B, <T::Proposer as Proposer<B>>::Proof>>> + Send>> {
|
|
SimpleSlotWorker::on_slot(self, chain_head, slot_info)
|
|
}
|
|
}
|
|
|
|
/// Slot compatible inherent data.
|
|
pub trait SlotCompatible {
|
|
/// Extract timestamp and slot from inherent data.
|
|
fn extract_timestamp_and_slot(
|
|
&self,
|
|
inherent: &InherentData,
|
|
) -> Result<(u64, Slot, std::time::Duration), sp_consensus::Error>;
|
|
}
|
|
|
|
/// Start a new slot worker.
|
|
///
|
|
/// Every time a new slot is triggered, `worker.on_slot` is called and the future it returns is
|
|
/// polled until completion, unless we are major syncing.
|
|
pub fn start_slot_worker<B, C, W, T, SO, SC, CAW, Proof>(
|
|
slot_duration: SlotDuration<T>,
|
|
client: C,
|
|
mut worker: W,
|
|
mut sync_oracle: SO,
|
|
inherent_data_providers: InherentDataProviders,
|
|
timestamp_extractor: SC,
|
|
can_author_with: CAW,
|
|
) -> impl Future<Output = ()>
|
|
where
|
|
B: BlockT,
|
|
C: SelectChain<B>,
|
|
W: SlotWorker<B, Proof>,
|
|
SO: SyncOracle + Send,
|
|
SC: SlotCompatible + Unpin,
|
|
T: SlotData + Clone,
|
|
CAW: CanAuthorWith<B> + Send,
|
|
{
|
|
let SlotDuration(slot_duration) = slot_duration;
|
|
|
|
// rather than use a timer interval, we schedule our waits ourselves
|
|
Slots::<SC>::new(
|
|
slot_duration.slot_duration(),
|
|
inherent_data_providers,
|
|
timestamp_extractor,
|
|
).inspect_err(|e| debug!(target: "slots", "Faulty timer: {:?}", e))
|
|
.try_for_each(move |slot_info| {
|
|
// only propose when we are not syncing.
|
|
if sync_oracle.is_major_syncing() {
|
|
debug!(target: "slots", "Skipping proposal slot due to sync.");
|
|
return Either::Right(future::ready(Ok(())));
|
|
}
|
|
|
|
let slot = slot_info.slot;
|
|
let chain_head = match client.best_chain() {
|
|
Ok(x) => x,
|
|
Err(e) => {
|
|
warn!(target: "slots", "Unable to author block in slot {}. \
|
|
no best block header: {:?}", slot, e);
|
|
return Either::Right(future::ready(Ok(())));
|
|
}
|
|
};
|
|
|
|
if let Err(err) = can_author_with.can_author_with(&BlockId::Hash(chain_head.hash())) {
|
|
warn!(
|
|
target: "slots",
|
|
"Unable to author block in slot {},. `can_author_with` returned: {} \
|
|
Probably a node update is required!",
|
|
slot,
|
|
err,
|
|
);
|
|
Either::Right(future::ready(Ok(())))
|
|
} else {
|
|
Either::Left(
|
|
worker.on_slot(chain_head, slot_info)
|
|
.then(|_| future::ready(Ok(())))
|
|
)
|
|
}
|
|
}).then(|res| {
|
|
if let Err(err) = res {
|
|
warn!(target: "slots", "Slots stream terminated with an error: {:?}", err);
|
|
}
|
|
future::ready(())
|
|
})
|
|
}
|
|
|
|
/// A header which has been checked
|
|
pub enum CheckedHeader<H, S> {
|
|
/// A header which has slot in the future. this is the full header (not stripped)
|
|
/// and the slot in which it should be processed.
|
|
Deferred(H, Slot),
|
|
/// A header which is fully checked, including signature. This is the pre-header
|
|
/// accompanied by the seal components.
|
|
///
|
|
/// Includes the digest item that encoded the seal.
|
|
Checked(H, S),
|
|
}
|
|
|
|
#[derive(Debug, thiserror::Error)]
|
|
#[allow(missing_docs)]
|
|
pub enum Error<T> where T: Debug {
|
|
#[error("Slot duration is invalid: {0:?}")]
|
|
SlotDurationInvalid(SlotDuration<T>),
|
|
}
|
|
|
|
/// A slot duration. Create with `get_or_compute`.
|
|
// The internal member should stay private here to maintain invariants of
|
|
// `get_or_compute`.
|
|
#[derive(Clone, Copy, Debug, Encode, Decode, Hash, PartialOrd, Ord, PartialEq, Eq)]
|
|
pub struct SlotDuration<T>(T);
|
|
|
|
impl<T> Deref for SlotDuration<T> {
|
|
type Target = T;
|
|
fn deref(&self) -> &T {
|
|
&self.0
|
|
}
|
|
}
|
|
|
|
impl<T: SlotData> SlotData for SlotDuration<T> {
|
|
/// Get the slot duration in milliseconds.
|
|
fn slot_duration(&self) -> u64
|
|
where T: SlotData,
|
|
{
|
|
self.0.slot_duration()
|
|
}
|
|
|
|
const SLOT_KEY: &'static [u8] = T::SLOT_KEY;
|
|
}
|
|
|
|
impl<T: Clone + Send + Sync + 'static> SlotDuration<T> {
|
|
/// Either fetch the slot duration from disk or compute it from the
|
|
/// genesis state.
|
|
///
|
|
/// `slot_key` is marked as `'static`, as it should really be a
|
|
/// compile-time constant.
|
|
pub fn get_or_compute<B: BlockT, C, CB>(client: &C, cb: CB) -> sp_blockchain::Result<Self> where
|
|
C: sc_client_api::backend::AuxStore,
|
|
C: ProvideRuntimeApi<B>,
|
|
CB: FnOnce(ApiRef<C::Api>, &BlockId<B>) -> sp_blockchain::Result<T>,
|
|
T: SlotData + Encode + Decode + Debug,
|
|
{
|
|
let slot_duration = match client.get_aux(T::SLOT_KEY)? {
|
|
Some(v) => <T as codec::Decode>::decode(&mut &v[..])
|
|
.map(SlotDuration)
|
|
.map_err(|_| {
|
|
sp_blockchain::Error::Backend({
|
|
error!(target: "slots", "slot duration kept in invalid format");
|
|
"slot duration kept in invalid format".to_string()
|
|
})
|
|
}),
|
|
None => {
|
|
use sp_runtime::traits::Zero;
|
|
let genesis_slot_duration =
|
|
cb(client.runtime_api(), &BlockId::number(Zero::zero()))?;
|
|
|
|
info!(
|
|
"⏱ Loaded block-time = {:?} milliseconds from genesis on first-launch",
|
|
genesis_slot_duration.slot_duration()
|
|
);
|
|
|
|
genesis_slot_duration
|
|
.using_encoded(|s| client.insert_aux(&[(T::SLOT_KEY, &s[..])], &[]))?;
|
|
|
|
Ok(SlotDuration(genesis_slot_duration))
|
|
}
|
|
}?;
|
|
|
|
if slot_duration.slot_duration() == 0u64 {
|
|
return Err(sp_blockchain::Error::Application(Box::new(Error::SlotDurationInvalid(slot_duration))))
|
|
}
|
|
|
|
Ok(slot_duration)
|
|
}
|
|
|
|
/// Returns slot data value.
|
|
pub fn get(&self) -> T {
|
|
self.0.clone()
|
|
}
|
|
}
|
|
|
|
/// A unit type wrapper to express the proportion of a slot.
|
|
pub struct SlotProportion(f32);
|
|
|
|
impl SlotProportion {
|
|
/// Create a new proportion.
|
|
///
|
|
/// The given value `inner` should be in the range `[0,1]`. If the value is not in the required
|
|
/// range, it is clamped into the range.
|
|
pub fn new(inner: f32) -> Self {
|
|
Self(inner.clamp(0.0, 1.0))
|
|
}
|
|
|
|
/// Returns the inner that is guaranted to be in the range `[0,1]`.
|
|
pub fn get(&self) -> f32 {
|
|
self.0
|
|
}
|
|
}
|
|
|
|
/// Calculate a slot duration lenience based on the number of missed slots from current
|
|
/// to parent. If the number of skipped slots is greated than 0 this method will apply
|
|
/// an exponential backoff of at most `2^7 * slot_duration`, if no slots were skipped
|
|
/// this method will return `None.`
|
|
pub fn slot_lenience_exponential(parent_slot: Slot, slot_info: &SlotInfo) -> Option<Duration> {
|
|
// never give more than 2^this times the lenience.
|
|
const BACKOFF_CAP: u64 = 7;
|
|
|
|
// how many slots it takes before we double the lenience.
|
|
const BACKOFF_STEP: u64 = 2;
|
|
|
|
// we allow a lenience of the number of slots since the head of the
|
|
// chain was produced, minus 1 (since there is always a difference of at least 1)
|
|
//
|
|
// exponential back-off.
|
|
// in normal cases we only attempt to issue blocks up to the end of the slot.
|
|
// when the chain has been stalled for a few slots, we give more lenience.
|
|
let skipped_slots = *slot_info.slot.saturating_sub(parent_slot + 1);
|
|
|
|
if skipped_slots == 0 {
|
|
None
|
|
} else {
|
|
let slot_lenience = skipped_slots / BACKOFF_STEP;
|
|
let slot_lenience = std::cmp::min(slot_lenience, BACKOFF_CAP);
|
|
let slot_lenience = 1 << slot_lenience;
|
|
Some(slot_lenience * slot_info.duration)
|
|
}
|
|
}
|
|
|
|
/// Calculate a slot duration lenience based on the number of missed slots from current
|
|
/// to parent. If the number of skipped slots is greated than 0 this method will apply
|
|
/// a linear backoff of at most `20 * slot_duration`, if no slots were skipped
|
|
/// this method will return `None.`
|
|
pub fn slot_lenience_linear(parent_slot: Slot, slot_info: &SlotInfo) -> Option<Duration> {
|
|
// never give more than 20 times more lenience.
|
|
const BACKOFF_CAP: u64 = 20;
|
|
|
|
// we allow a lenience of the number of slots since the head of the
|
|
// chain was produced, minus 1 (since there is always a difference of at least 1)
|
|
//
|
|
// linear back-off.
|
|
// in normal cases we only attempt to issue blocks up to the end of the slot.
|
|
// when the chain has been stalled for a few slots, we give more lenience.
|
|
let skipped_slots = *slot_info.slot.saturating_sub(parent_slot + 1);
|
|
|
|
if skipped_slots == 0 {
|
|
None
|
|
} else {
|
|
let slot_lenience = std::cmp::min(skipped_slots, BACKOFF_CAP);
|
|
// We cap `slot_lenience` to `20`, so it should always fit into an `u32`.
|
|
Some(slot_info.duration * (slot_lenience as u32))
|
|
}
|
|
}
|
|
|
|
/// Trait for providing the strategy for when to backoff block authoring.
|
|
pub trait BackoffAuthoringBlocksStrategy<N> {
|
|
/// Returns true if we should backoff authoring new blocks.
|
|
fn should_backoff(
|
|
&self,
|
|
chain_head_number: N,
|
|
chain_head_slot: Slot,
|
|
finalized_number: N,
|
|
slow_now: Slot,
|
|
logging_target: &str,
|
|
) -> bool;
|
|
}
|
|
|
|
/// A simple default strategy for how to decide backing off authoring blocks if the number of
|
|
/// unfinalized blocks grows too large.
|
|
#[derive(Clone)]
|
|
pub struct BackoffAuthoringOnFinalizedHeadLagging<N> {
|
|
/// The max interval to backoff when authoring blocks, regardless of delay in finality.
|
|
pub max_interval: N,
|
|
/// The number of unfinalized blocks allowed before starting to consider to backoff authoring
|
|
/// blocks. Note that depending on the value for `authoring_bias`, there might still be an
|
|
/// additional wait until block authorship starts getting declined.
|
|
pub unfinalized_slack: N,
|
|
/// Scales the backoff rate. A higher value effectively means we backoff slower, taking longer
|
|
/// time to reach the maximum backoff as the unfinalized head of chain grows.
|
|
pub authoring_bias: N,
|
|
}
|
|
|
|
/// These parameters is supposed to be some form of sensible defaults.
|
|
impl<N: BaseArithmetic> Default for BackoffAuthoringOnFinalizedHeadLagging<N> {
|
|
fn default() -> Self {
|
|
Self {
|
|
// Never wait more than 100 slots before authoring blocks, regardless of delay in
|
|
// finality.
|
|
max_interval: 100.into(),
|
|
// Start to consider backing off block authorship once we have 50 or more unfinalized
|
|
// blocks at the head of the chain.
|
|
unfinalized_slack: 50.into(),
|
|
// A reasonable default for the authoring bias, or reciprocal interval scaling, is 2.
|
|
// Effectively meaning that consider the unfinalized head suffix length to grow half as
|
|
// fast as in actuality.
|
|
authoring_bias: 2.into(),
|
|
}
|
|
}
|
|
}
|
|
|
|
impl<N> BackoffAuthoringBlocksStrategy<N> for BackoffAuthoringOnFinalizedHeadLagging<N>
|
|
where
|
|
N: BaseArithmetic + Copy
|
|
{
|
|
fn should_backoff(
|
|
&self,
|
|
chain_head_number: N,
|
|
chain_head_slot: Slot,
|
|
finalized_number: N,
|
|
slot_now: Slot,
|
|
logging_target: &str,
|
|
) -> bool {
|
|
// This should not happen, but we want to keep the previous behaviour if it does.
|
|
if slot_now <= chain_head_slot {
|
|
return false;
|
|
}
|
|
|
|
let unfinalized_block_length = chain_head_number - finalized_number;
|
|
let interval = unfinalized_block_length.saturating_sub(self.unfinalized_slack)
|
|
/ self.authoring_bias;
|
|
let interval = interval.min(self.max_interval);
|
|
|
|
// We're doing arithmetic between block and slot numbers.
|
|
let interval: u64 = interval.unique_saturated_into();
|
|
|
|
// If interval is nonzero we backoff if the current slot isn't far enough ahead of the chain
|
|
// head.
|
|
if *slot_now <= *chain_head_slot + interval {
|
|
info!(
|
|
target: logging_target,
|
|
"Backing off claiming new slot for block authorship: finality is lagging.",
|
|
);
|
|
true
|
|
} else {
|
|
false
|
|
}
|
|
}
|
|
}
|
|
|
|
impl<N> BackoffAuthoringBlocksStrategy<N> for () {
|
|
fn should_backoff(
|
|
&self,
|
|
_chain_head_number: N,
|
|
_chain_head_slot: Slot,
|
|
_finalized_number: N,
|
|
_slot_now: Slot,
|
|
_logging_target: &str,
|
|
) -> bool {
|
|
false
|
|
}
|
|
}
|
|
|
|
#[cfg(test)]
|
|
mod test {
|
|
use std::time::{Duration, Instant};
|
|
use crate::{BackoffAuthoringOnFinalizedHeadLagging, BackoffAuthoringBlocksStrategy};
|
|
use substrate_test_runtime_client::runtime::Block;
|
|
use sp_api::NumberFor;
|
|
|
|
const SLOT_DURATION: Duration = Duration::from_millis(6000);
|
|
|
|
fn slot(slot: u64) -> super::slots::SlotInfo {
|
|
super::slots::SlotInfo {
|
|
slot: slot.into(),
|
|
duration: SLOT_DURATION,
|
|
timestamp: Default::default(),
|
|
inherent_data: Default::default(),
|
|
ends_at: Instant::now(),
|
|
}
|
|
}
|
|
|
|
#[test]
|
|
fn linear_slot_lenience() {
|
|
// if no slots are skipped there should be no lenience
|
|
assert_eq!(super::slot_lenience_linear(1.into(), &slot(2)), None);
|
|
|
|
// otherwise the lenience is incremented linearly with
|
|
// the number of skipped slots.
|
|
for n in 3..=22 {
|
|
assert_eq!(
|
|
super::slot_lenience_linear(1.into(), &slot(n)),
|
|
Some(SLOT_DURATION * (n - 2) as u32),
|
|
);
|
|
}
|
|
|
|
// but we cap it to a maximum of 20 slots
|
|
assert_eq!(
|
|
super::slot_lenience_linear(1.into(), &slot(23)),
|
|
Some(SLOT_DURATION * 20),
|
|
);
|
|
}
|
|
|
|
#[test]
|
|
fn exponential_slot_lenience() {
|
|
// if no slots are skipped there should be no lenience
|
|
assert_eq!(super::slot_lenience_exponential(1.into(), &slot(2)), None);
|
|
|
|
// otherwise the lenience is incremented exponentially every two slots
|
|
for n in 3..=17 {
|
|
assert_eq!(
|
|
super::slot_lenience_exponential(1.into(), &slot(n)),
|
|
Some(SLOT_DURATION * 2u32.pow((n / 2 - 1) as u32)),
|
|
);
|
|
}
|
|
|
|
// but we cap it to a maximum of 14 slots
|
|
assert_eq!(
|
|
super::slot_lenience_exponential(1.into(), &slot(18)),
|
|
Some(SLOT_DURATION * 2u32.pow(7)),
|
|
);
|
|
|
|
assert_eq!(
|
|
super::slot_lenience_exponential(1.into(), &slot(19)),
|
|
Some(SLOT_DURATION * 2u32.pow(7)),
|
|
);
|
|
}
|
|
|
|
#[derive(PartialEq, Debug)]
|
|
struct HeadState {
|
|
head_number: NumberFor<Block>,
|
|
head_slot: u64,
|
|
slot_now: NumberFor<Block>,
|
|
}
|
|
|
|
impl HeadState {
|
|
fn author_block(&mut self) {
|
|
// Add a block to the head, and set latest slot to the current
|
|
self.head_number += 1;
|
|
self.head_slot = self.slot_now;
|
|
// Advance slot to next
|
|
self.slot_now += 1;
|
|
}
|
|
|
|
fn dont_author_block(&mut self) {
|
|
self.slot_now += 1;
|
|
}
|
|
}
|
|
|
|
#[test]
|
|
fn should_never_backoff_when_head_not_advancing() {
|
|
let strategy = BackoffAuthoringOnFinalizedHeadLagging::<NumberFor<Block>> {
|
|
max_interval: 100,
|
|
unfinalized_slack: 5,
|
|
authoring_bias: 2,
|
|
};
|
|
|
|
let head_number = 1;
|
|
let head_slot = 1;
|
|
let finalized_number = 1;
|
|
let slot_now = 2;
|
|
|
|
let should_backoff: Vec<bool> = (slot_now..1000)
|
|
.map(|s| strategy.should_backoff(head_number, head_slot.into(), finalized_number, s.into(), "slots"))
|
|
.collect();
|
|
|
|
// Should always be false, since the head isn't advancing
|
|
let expected: Vec<bool> = (slot_now..1000).map(|_| false).collect();
|
|
assert_eq!(should_backoff, expected);
|
|
}
|
|
|
|
#[test]
|
|
fn should_stop_authoring_if_blocks_are_still_produced_when_finality_stalled() {
|
|
let strategy = BackoffAuthoringOnFinalizedHeadLagging::<NumberFor<Block>> {
|
|
max_interval: 100,
|
|
unfinalized_slack: 5,
|
|
authoring_bias: 2,
|
|
};
|
|
|
|
let mut head_number = 1;
|
|
let mut head_slot = 1;
|
|
let finalized_number = 1;
|
|
let slot_now = 2;
|
|
|
|
let should_backoff: Vec<bool> = (slot_now..300)
|
|
.map(move |s| {
|
|
let b = strategy.should_backoff(
|
|
head_number,
|
|
head_slot.into(),
|
|
finalized_number,
|
|
s.into(),
|
|
"slots",
|
|
);
|
|
// Chain is still advancing (by someone else)
|
|
head_number += 1;
|
|
head_slot = s;
|
|
b
|
|
})
|
|
.collect();
|
|
|
|
// Should always be true after a short while, since the chain is advancing but finality is stalled
|
|
let expected: Vec<bool> = (slot_now..300).map(|s| s > 8).collect();
|
|
assert_eq!(should_backoff, expected);
|
|
}
|
|
|
|
#[test]
|
|
fn should_never_backoff_if_max_interval_is_reached() {
|
|
let strategy = BackoffAuthoringOnFinalizedHeadLagging::<NumberFor<Block>> {
|
|
max_interval: 100,
|
|
unfinalized_slack: 5,
|
|
authoring_bias: 2,
|
|
};
|
|
|
|
// The limit `max_interval` is used when the unfinalized chain grows to
|
|
// `max_interval * authoring_bias + unfinalized_slack`,
|
|
// which for the above parameters becomes
|
|
// 100 * 2 + 5 = 205.
|
|
// Hence we trigger this with head_number > finalized_number + 205.
|
|
let head_number = 207;
|
|
let finalized_number = 1;
|
|
|
|
// The limit is then used once the current slot is `max_interval` ahead of slot of the head.
|
|
let head_slot = 1;
|
|
let slot_now = 2;
|
|
let max_interval = strategy.max_interval;
|
|
|
|
let should_backoff: Vec<bool> = (slot_now..200)
|
|
.map(|s| strategy.should_backoff(head_number, head_slot.into(), finalized_number, s.into(), "slots"))
|
|
.collect();
|
|
|
|
// Should backoff (true) until we are `max_interval` number of slots ahead of the chain
|
|
// head slot, then we never backoff (false).
|
|
let expected: Vec<bool> = (slot_now..200).map(|s| s <= max_interval + head_slot).collect();
|
|
assert_eq!(should_backoff, expected);
|
|
}
|
|
|
|
#[test]
|
|
fn should_backoff_authoring_when_finality_stalled() {
|
|
let param = BackoffAuthoringOnFinalizedHeadLagging {
|
|
max_interval: 100,
|
|
unfinalized_slack: 5,
|
|
authoring_bias: 2,
|
|
};
|
|
|
|
let finalized_number = 2;
|
|
let mut head_state = HeadState {
|
|
head_number: 4,
|
|
head_slot: 10,
|
|
slot_now: 11,
|
|
};
|
|
|
|
let should_backoff = |head_state: &HeadState| -> bool {
|
|
<dyn BackoffAuthoringBlocksStrategy<NumberFor<Block>>>::should_backoff(
|
|
¶m,
|
|
head_state.head_number,
|
|
head_state.head_slot.into(),
|
|
finalized_number,
|
|
head_state.slot_now.into(),
|
|
"slots",
|
|
)
|
|
};
|
|
|
|
let backoff: Vec<bool> = (head_state.slot_now..200)
|
|
.map(|_| {
|
|
if should_backoff(&head_state) {
|
|
head_state.dont_author_block();
|
|
true
|
|
} else {
|
|
head_state.author_block();
|
|
false
|
|
}
|
|
})
|
|
.collect();
|
|
|
|
// Gradually start to backoff more and more frequently
|
|
let expected = [
|
|
false, false, false, false, false, // no effect
|
|
true, false,
|
|
true, false, // 1:1
|
|
true, true, false,
|
|
true, true, false, // 2:1
|
|
true, true, true, false,
|
|
true, true, true, false, // 3:1
|
|
true, true, true, true, false,
|
|
true, true, true, true, false, // 4:1
|
|
true, true, true, true, true, false,
|
|
true, true, true, true, true, false, // 5:1
|
|
true, true, true, true, true, true, false,
|
|
true, true, true, true, true, true, false, // 6:1
|
|
true, true, true, true, true, true, true, false,
|
|
true, true, true, true, true, true, true, false, // 7:1
|
|
true, true, true, true, true, true, true, true, false,
|
|
true, true, true, true, true, true, true, true, false, // 8:1
|
|
true, true, true, true, true, true, true, true, true, false,
|
|
true, true, true, true, true, true, true, true, true, false, // 9:1
|
|
true, true, true, true, true, true, true, true, true, true, false,
|
|
true, true, true, true, true, true, true, true, true, true, false, // 10:1
|
|
true, true, true, true, true, true, true, true, true, true, true, false,
|
|
true, true, true, true, true, true, true, true, true, true, true, false, // 11:1
|
|
true, true, true, true, true, true, true, true, true, true, true, true, false,
|
|
true, true, true, true, true, true, true, true, true, true, true, true, false, // 12:1
|
|
true, true, true, true,
|
|
];
|
|
|
|
assert_eq!(backoff.as_slice(), &expected[..]);
|
|
}
|
|
|
|
#[test]
|
|
fn should_never_wait_more_than_max_interval() {
|
|
let param = BackoffAuthoringOnFinalizedHeadLagging {
|
|
max_interval: 100,
|
|
unfinalized_slack: 5,
|
|
authoring_bias: 2,
|
|
};
|
|
|
|
let finalized_number = 2;
|
|
let starting_slot = 11;
|
|
let mut head_state = HeadState {
|
|
head_number: 4,
|
|
head_slot: 10,
|
|
slot_now: starting_slot,
|
|
};
|
|
|
|
let should_backoff = |head_state: &HeadState| -> bool {
|
|
<dyn BackoffAuthoringBlocksStrategy<NumberFor<Block>>>::should_backoff(
|
|
¶m,
|
|
head_state.head_number,
|
|
head_state.head_slot.into(),
|
|
finalized_number,
|
|
head_state.slot_now.into(),
|
|
"slots",
|
|
)
|
|
};
|
|
|
|
let backoff: Vec<bool> = (head_state.slot_now..40000)
|
|
.map(|_| {
|
|
if should_backoff(&head_state) {
|
|
head_state.dont_author_block();
|
|
true
|
|
} else {
|
|
head_state.author_block();
|
|
false
|
|
}
|
|
})
|
|
.collect();
|
|
|
|
let slots_claimed: Vec<usize> = backoff
|
|
.iter()
|
|
.enumerate()
|
|
.filter(|&(_i, x)| x == &false)
|
|
.map(|(i, _x)| i + starting_slot as usize)
|
|
.collect();
|
|
|
|
let last_slot = backoff.len() + starting_slot as usize;
|
|
let mut last_two_claimed = slots_claimed.iter().rev().take(2);
|
|
|
|
// Check that we claimed all the way to the end. Check two slots for when we have an uneven
|
|
// number of slots_claimed.
|
|
let expected_distance = param.max_interval as usize + 1;
|
|
assert_eq!(last_slot - last_two_claimed.next().unwrap(), 92);
|
|
assert_eq!(last_slot - last_two_claimed.next().unwrap(), 92 + expected_distance);
|
|
|
|
let intervals: Vec<_> = slots_claimed
|
|
.windows(2)
|
|
.map(|x| x[1] - x[0])
|
|
.collect();
|
|
|
|
// The key thing is that the distance between claimed slots is capped to `max_interval + 1`
|
|
// assert_eq!(max_observed_interval, Some(&expected_distance));
|
|
assert_eq!(intervals.iter().max(), Some(&expected_distance));
|
|
|
|
// But lets assert all distances, which we expect to grow linearly until `max_interval + 1`
|
|
let expected_intervals: Vec<_> = (0..497)
|
|
.map(|i| (i/2).max(1).min(expected_distance) )
|
|
.collect();
|
|
|
|
assert_eq!(intervals, expected_intervals);
|
|
}
|
|
|
|
fn run_until_max_interval(param: BackoffAuthoringOnFinalizedHeadLagging<u64>) -> (u64, u64) {
|
|
let finalized_number = 0;
|
|
let mut head_state = HeadState {
|
|
head_number: 0,
|
|
head_slot: 0,
|
|
slot_now: 1,
|
|
};
|
|
|
|
let should_backoff = |head_state: &HeadState| -> bool {
|
|
<dyn BackoffAuthoringBlocksStrategy<NumberFor<Block>>>::should_backoff(
|
|
¶m,
|
|
head_state.head_number,
|
|
head_state.head_slot.into(),
|
|
finalized_number,
|
|
head_state.slot_now.into(),
|
|
"slots",
|
|
)
|
|
};
|
|
|
|
// Number of blocks until we reach the max interval
|
|
let block_for_max_interval
|
|
= param.max_interval * param.authoring_bias + param.unfinalized_slack;
|
|
|
|
while head_state.head_number < block_for_max_interval {
|
|
if should_backoff(&head_state) {
|
|
head_state.dont_author_block();
|
|
} else {
|
|
head_state.author_block();
|
|
}
|
|
}
|
|
|
|
let slot_time = 6;
|
|
let time_to_reach_limit = slot_time * head_state.slot_now;
|
|
(block_for_max_interval, time_to_reach_limit)
|
|
}
|
|
|
|
// Denoting
|
|
// C: unfinalized_slack
|
|
// M: authoring_bias
|
|
// X: max_interval
|
|
// then the number of slots to reach the max interval can be computed from
|
|
// (start_slot + C) + M * sum(n, 1, X)
|
|
// or
|
|
// (start_slot + C) + M * X*(X+1)/2
|
|
fn expected_time_to_reach_max_interval(
|
|
param: &BackoffAuthoringOnFinalizedHeadLagging<u64>
|
|
) -> (u64, u64) {
|
|
let c = param.unfinalized_slack;
|
|
let m = param.authoring_bias;
|
|
let x = param.max_interval;
|
|
let slot_time = 6;
|
|
|
|
let block_for_max_interval = x * m + c;
|
|
|
|
// The 1 is because we start at slot_now = 1.
|
|
let expected_number_of_slots = (1 + c) + m * x * (x + 1) / 2;
|
|
let time_to_reach = expected_number_of_slots * slot_time;
|
|
|
|
(block_for_max_interval, time_to_reach)
|
|
}
|
|
|
|
#[test]
|
|
fn time_to_reach_upper_bound_for_smaller_slack() {
|
|
let param = BackoffAuthoringOnFinalizedHeadLagging {
|
|
max_interval: 100,
|
|
unfinalized_slack: 5,
|
|
authoring_bias: 2,
|
|
};
|
|
let expected = expected_time_to_reach_max_interval(¶m);
|
|
let (block_for_max_interval, time_to_reach_limit) = run_until_max_interval(param);
|
|
assert_eq!((block_for_max_interval, time_to_reach_limit), expected);
|
|
// Note: 16 hours is 57600 sec
|
|
assert_eq!((block_for_max_interval, time_to_reach_limit), (205, 60636));
|
|
}
|
|
|
|
#[test]
|
|
fn time_to_reach_upper_bound_for_larger_slack() {
|
|
let param = BackoffAuthoringOnFinalizedHeadLagging {
|
|
max_interval: 100,
|
|
unfinalized_slack: 50,
|
|
authoring_bias: 2,
|
|
};
|
|
let expected = expected_time_to_reach_max_interval(¶m);
|
|
let (block_for_max_interval, time_to_reach_limit) = run_until_max_interval(param);
|
|
assert_eq!((block_for_max_interval, time_to_reach_limit), expected);
|
|
assert_eq!((block_for_max_interval, time_to_reach_limit), (250, 60906));
|
|
}
|
|
}
|