mirror of
https://github.com/pezkuwichain/pezkuwi-subxt.git
synced 2026-06-13 05:51:02 +00:00
Add storage size component to weights (#12277)
* Add storage size component to weights * Rename storage_size to proof_size * Update primitives/weights/src/weight_v2.rs Co-authored-by: Oliver Tale-Yazdi <oliver.tale-yazdi@parity.io> * Fixes * cargo fmt * Implement custom Decode and CompactAs * Add missing import * Fixes * Remove CompactAs implementation * Properly migrate from 1D weight * Remove #[pallet::compact] from Weight parameters * More #[pallet::compact] removals * Add unit tests * Set appropriate default block proof size * cargo fmt * Remove nonsensical weight constant * Test only for the reference time weight in frame_system::limits * Only check for reference time weight on idle * Use destructuring syntax * Update test expectations * Fixes * Fixes * Fixes * Correctly migrate from 1D weights * cargo fmt * Migrate using extra extrinsics instead of custom Decode * Fixes * Silence dispatch call warnings that were previously allowed * Fix gas_left test * Use OldWeight instead of u64 * Fixes * Only check for reference time weight in election provider * Fix test expectations * Fix test expectations * Use only reference time weight in grandpa test * Use only reference time weight in examples test * Use only reference time weight in examples test * Fix test expectations Co-authored-by: Oliver Tale-Yazdi <oliver.tale-yazdi@parity.io> Co-authored-by: Alexander Theißen <alex.theissen@me.com>
This commit is contained in:
@@ -30,7 +30,7 @@ extern crate self as sp_weights;
|
||||
|
||||
mod weight_v2;
|
||||
|
||||
use codec::{Decode, Encode};
|
||||
use codec::{CompactAs, Decode, Encode, MaxEncodedLen};
|
||||
use scale_info::TypeInfo;
|
||||
#[cfg(feature = "std")]
|
||||
use serde::{Deserialize, Serialize};
|
||||
@@ -53,6 +53,25 @@ pub mod constants {
|
||||
pub const WEIGHT_PER_NANOS: Weight = Weight::from_ref_time(1_000);
|
||||
}
|
||||
|
||||
/// The old weight type.
|
||||
///
|
||||
/// NOTE: This type exists purely for compatibility purposes! Use [`weight_v2::Weight`] in all other
|
||||
/// cases.
|
||||
#[derive(
|
||||
Decode,
|
||||
Encode,
|
||||
CompactAs,
|
||||
PartialEq,
|
||||
Eq,
|
||||
Clone,
|
||||
Copy,
|
||||
RuntimeDebug,
|
||||
Default,
|
||||
MaxEncodedLen,
|
||||
TypeInfo,
|
||||
)]
|
||||
pub struct OldWeight(pub u64);
|
||||
|
||||
/// The weight of database operations that the runtime can invoke.
|
||||
///
|
||||
/// NOTE: This is currently only measured in computational time, and will probably
|
||||
|
||||
@@ -15,7 +15,7 @@
|
||||
// See the License for the specific language governing permissions and
|
||||
// limitations under the License.
|
||||
|
||||
use codec::{CompactAs, Decode, Encode, MaxEncodedLen};
|
||||
use codec::{Decode, Encode, MaxEncodedLen};
|
||||
use core::ops::{Add, AddAssign, Div, Mul, Sub, SubAssign};
|
||||
use sp_arithmetic::traits::{Bounded, CheckedAdd, CheckedSub, Zero};
|
||||
use sp_debug_derive::RuntimeDebug;
|
||||
@@ -23,22 +23,22 @@ use sp_debug_derive::RuntimeDebug;
|
||||
use super::*;
|
||||
|
||||
#[derive(
|
||||
Encode,
|
||||
Decode,
|
||||
MaxEncodedLen,
|
||||
TypeInfo,
|
||||
Eq,
|
||||
PartialEq,
|
||||
Copy,
|
||||
Clone,
|
||||
RuntimeDebug,
|
||||
Default,
|
||||
CompactAs,
|
||||
Encode, Decode, MaxEncodedLen, TypeInfo, Eq, PartialEq, Copy, Clone, RuntimeDebug, Default,
|
||||
)]
|
||||
#[cfg_attr(feature = "std", derive(Serialize, Deserialize))]
|
||||
pub struct Weight {
|
||||
#[codec(compact)]
|
||||
/// The weight of computational time used based on some reference hardware.
|
||||
ref_time: u64,
|
||||
#[codec(compact)]
|
||||
/// The weight of storage space used by proof of validity.
|
||||
proof_size: u64,
|
||||
}
|
||||
|
||||
impl From<OldWeight> for Weight {
|
||||
fn from(old: OldWeight) -> Self {
|
||||
Weight::from_ref_time(old.0)
|
||||
}
|
||||
}
|
||||
|
||||
impl Weight {
|
||||
@@ -48,71 +48,118 @@ impl Weight {
|
||||
self
|
||||
}
|
||||
|
||||
/// Set the storage size part of the weight.
|
||||
pub const fn set_proof_size(mut self, c: u64) -> Self {
|
||||
self.proof_size = c;
|
||||
self
|
||||
}
|
||||
|
||||
/// Return the reference time part of the weight.
|
||||
pub const fn ref_time(&self) -> u64 {
|
||||
self.ref_time
|
||||
}
|
||||
|
||||
/// Return a mutable reference time part of the weight.
|
||||
/// Return the storage size part of the weight.
|
||||
pub const fn proof_size(&self) -> u64 {
|
||||
self.proof_size
|
||||
}
|
||||
|
||||
/// Return a mutable reference to the reference time part of the weight.
|
||||
pub fn ref_time_mut(&mut self) -> &mut u64 {
|
||||
&mut self.ref_time
|
||||
}
|
||||
|
||||
pub const MAX: Self = Self { ref_time: u64::MAX };
|
||||
/// Return a mutable reference to the storage size part of the weight.
|
||||
pub fn proof_size_mut(&mut self) -> &mut u64 {
|
||||
&mut self.proof_size
|
||||
}
|
||||
|
||||
pub const MAX: Self = Self { ref_time: u64::MAX, proof_size: u64::MAX };
|
||||
|
||||
/// Get the conservative min of `self` and `other` weight.
|
||||
pub fn min(&self, other: Self) -> Self {
|
||||
Self { ref_time: self.ref_time.min(other.ref_time) }
|
||||
Self {
|
||||
ref_time: self.ref_time.min(other.ref_time),
|
||||
proof_size: self.proof_size.min(other.proof_size),
|
||||
}
|
||||
}
|
||||
|
||||
/// Get the aggressive max of `self` and `other` weight.
|
||||
pub fn max(&self, other: Self) -> Self {
|
||||
Self { ref_time: self.ref_time.max(other.ref_time) }
|
||||
Self {
|
||||
ref_time: self.ref_time.max(other.ref_time),
|
||||
proof_size: self.proof_size.max(other.proof_size),
|
||||
}
|
||||
}
|
||||
|
||||
/// Try to add some `other` weight while upholding the `limit`.
|
||||
pub fn try_add(&self, other: &Self, limit: &Self) -> Option<Self> {
|
||||
let total = self.checked_add(other)?;
|
||||
if total.ref_time > limit.ref_time {
|
||||
if total.any_gt(*limit) {
|
||||
None
|
||||
} else {
|
||||
Some(total)
|
||||
}
|
||||
}
|
||||
|
||||
/// Construct [`Weight`] with reference time weight.
|
||||
/// Construct [`Weight`] with reference time weight and 0 storage size weight.
|
||||
pub const fn from_ref_time(ref_time: u64) -> Self {
|
||||
Self { ref_time }
|
||||
Self { ref_time, proof_size: 0 }
|
||||
}
|
||||
|
||||
/// Construct [`Weight`] with storage size weight and 0 reference time weight.
|
||||
pub const fn from_proof_size(proof_size: u64) -> Self {
|
||||
Self { ref_time: 0, proof_size }
|
||||
}
|
||||
|
||||
/// Construct [`Weight`] with weight components, namely reference time and storage size weights.
|
||||
pub const fn from_components(ref_time: u64, proof_size: u64) -> Self {
|
||||
Self { ref_time, proof_size }
|
||||
}
|
||||
|
||||
/// Saturating [`Weight`] addition. Computes `self + rhs`, saturating at the numeric bounds of
|
||||
/// all fields instead of overflowing.
|
||||
pub const fn saturating_add(self, rhs: Self) -> Self {
|
||||
Self { ref_time: self.ref_time.saturating_add(rhs.ref_time) }
|
||||
Self {
|
||||
ref_time: self.ref_time.saturating_add(rhs.ref_time),
|
||||
proof_size: self.proof_size.saturating_add(rhs.proof_size),
|
||||
}
|
||||
}
|
||||
|
||||
/// Saturating [`Weight`] subtraction. Computes `self - rhs`, saturating at the numeric bounds
|
||||
/// of all fields instead of overflowing.
|
||||
pub const fn saturating_sub(self, rhs: Self) -> Self {
|
||||
Self { ref_time: self.ref_time.saturating_sub(rhs.ref_time) }
|
||||
Self {
|
||||
ref_time: self.ref_time.saturating_sub(rhs.ref_time),
|
||||
proof_size: self.proof_size.saturating_sub(rhs.proof_size),
|
||||
}
|
||||
}
|
||||
|
||||
/// Saturating [`Weight`] scalar multiplication. Computes `self.field * scalar` for all fields,
|
||||
/// saturating at the numeric bounds of all fields instead of overflowing.
|
||||
pub const fn saturating_mul(self, scalar: u64) -> Self {
|
||||
Self { ref_time: self.ref_time.saturating_mul(scalar) }
|
||||
Self {
|
||||
ref_time: self.ref_time.saturating_mul(scalar),
|
||||
proof_size: self.proof_size.saturating_mul(scalar),
|
||||
}
|
||||
}
|
||||
|
||||
/// Saturating [`Weight`] scalar division. Computes `self.field / scalar` for all fields,
|
||||
/// saturating at the numeric bounds of all fields instead of overflowing.
|
||||
pub const fn saturating_div(self, scalar: u64) -> Self {
|
||||
Self { ref_time: self.ref_time.saturating_div(scalar) }
|
||||
Self {
|
||||
ref_time: self.ref_time.saturating_div(scalar),
|
||||
proof_size: self.proof_size.saturating_div(scalar),
|
||||
}
|
||||
}
|
||||
|
||||
/// Saturating [`Weight`] scalar exponentiation. Computes `self.field.pow(exp)` for all fields,
|
||||
/// saturating at the numeric bounds of all fields instead of overflowing.
|
||||
pub const fn saturating_pow(self, exp: u32) -> Self {
|
||||
Self { ref_time: self.ref_time.saturating_pow(exp) }
|
||||
Self {
|
||||
ref_time: self.ref_time.saturating_pow(exp),
|
||||
proof_size: self.proof_size.saturating_pow(exp),
|
||||
}
|
||||
}
|
||||
|
||||
/// Increment [`Weight`] by `amount` via saturating addition.
|
||||
@@ -122,124 +169,144 @@ impl Weight {
|
||||
|
||||
/// Checked [`Weight`] addition. Computes `self + rhs`, returning `None` if overflow occurred.
|
||||
pub const fn checked_add(&self, rhs: &Self) -> Option<Self> {
|
||||
match self.ref_time.checked_add(rhs.ref_time) {
|
||||
Some(ref_time) => Some(Self { ref_time }),
|
||||
None => None,
|
||||
}
|
||||
let ref_time = match self.ref_time.checked_add(rhs.ref_time) {
|
||||
Some(t) => t,
|
||||
None => return None,
|
||||
};
|
||||
let proof_size = match self.proof_size.checked_add(rhs.proof_size) {
|
||||
Some(s) => s,
|
||||
None => return None,
|
||||
};
|
||||
Some(Self { ref_time, proof_size })
|
||||
}
|
||||
|
||||
/// Checked [`Weight`] subtraction. Computes `self - rhs`, returning `None` if overflow
|
||||
/// occurred.
|
||||
pub const fn checked_sub(&self, rhs: &Self) -> Option<Self> {
|
||||
match self.ref_time.checked_sub(rhs.ref_time) {
|
||||
Some(ref_time) => Some(Self { ref_time }),
|
||||
None => None,
|
||||
}
|
||||
let ref_time = match self.ref_time.checked_sub(rhs.ref_time) {
|
||||
Some(t) => t,
|
||||
None => return None,
|
||||
};
|
||||
let proof_size = match self.proof_size.checked_sub(rhs.proof_size) {
|
||||
Some(s) => s,
|
||||
None => return None,
|
||||
};
|
||||
Some(Self { ref_time, proof_size })
|
||||
}
|
||||
|
||||
/// Checked [`Weight`] scalar multiplication. Computes `self.field * scalar` for each field,
|
||||
/// returning `None` if overflow occurred.
|
||||
pub const fn checked_mul(self, scalar: u64) -> Option<Self> {
|
||||
match self.ref_time.checked_mul(scalar) {
|
||||
Some(ref_time) => Some(Self { ref_time }),
|
||||
None => None,
|
||||
}
|
||||
let ref_time = match self.ref_time.checked_mul(scalar) {
|
||||
Some(t) => t,
|
||||
None => return None,
|
||||
};
|
||||
let proof_size = match self.proof_size.checked_mul(scalar) {
|
||||
Some(s) => s,
|
||||
None => return None,
|
||||
};
|
||||
Some(Self { ref_time, proof_size })
|
||||
}
|
||||
|
||||
/// Checked [`Weight`] scalar division. Computes `self.field / scalar` for each field, returning
|
||||
/// `None` if overflow occurred.
|
||||
pub const fn checked_div(self, scalar: u64) -> Option<Self> {
|
||||
match self.ref_time.checked_div(scalar) {
|
||||
Some(ref_time) => Some(Self { ref_time }),
|
||||
None => None,
|
||||
}
|
||||
let ref_time = match self.ref_time.checked_div(scalar) {
|
||||
Some(t) => t,
|
||||
None => return None,
|
||||
};
|
||||
let proof_size = match self.proof_size.checked_div(scalar) {
|
||||
Some(s) => s,
|
||||
None => return None,
|
||||
};
|
||||
Some(Self { ref_time, proof_size })
|
||||
}
|
||||
|
||||
/// Return a [`Weight`] where all fields are zero.
|
||||
pub const fn zero() -> Self {
|
||||
Self { ref_time: 0 }
|
||||
Self { ref_time: 0, proof_size: 0 }
|
||||
}
|
||||
|
||||
/// Constant version of Add with u64.
|
||||
///
|
||||
/// Is only overflow safe when evaluated at compile-time.
|
||||
pub const fn add(self, scalar: u64) -> Self {
|
||||
Self { ref_time: self.ref_time + scalar }
|
||||
Self { ref_time: self.ref_time + scalar, proof_size: self.proof_size + scalar }
|
||||
}
|
||||
|
||||
/// Constant version of Sub with u64.
|
||||
///
|
||||
/// Is only overflow safe when evaluated at compile-time.
|
||||
pub const fn sub(self, scalar: u64) -> Self {
|
||||
Self { ref_time: self.ref_time - scalar }
|
||||
Self { ref_time: self.ref_time - scalar, proof_size: self.proof_size - scalar }
|
||||
}
|
||||
|
||||
/// Constant version of Div with u64.
|
||||
///
|
||||
/// Is only overflow safe when evaluated at compile-time.
|
||||
pub const fn div(self, scalar: u64) -> Self {
|
||||
Self { ref_time: self.ref_time / scalar }
|
||||
Self { ref_time: self.ref_time / scalar, proof_size: self.proof_size / scalar }
|
||||
}
|
||||
|
||||
/// Constant version of Mul with u64.
|
||||
///
|
||||
/// Is only overflow safe when evaluated at compile-time.
|
||||
pub const fn mul(self, scalar: u64) -> Self {
|
||||
Self { ref_time: self.ref_time * scalar }
|
||||
Self { ref_time: self.ref_time * scalar, proof_size: self.proof_size * scalar }
|
||||
}
|
||||
|
||||
/// Returns true if any of `self`'s constituent weights is strictly greater than that of the
|
||||
/// `other`'s, otherwise returns false.
|
||||
pub const fn any_gt(self, other: Self) -> bool {
|
||||
self.ref_time > other.ref_time
|
||||
self.ref_time > other.ref_time || self.proof_size > other.proof_size
|
||||
}
|
||||
|
||||
/// Returns true if all of `self`'s constituent weights is strictly greater than that of the
|
||||
/// `other`'s, otherwise returns false.
|
||||
pub const fn all_gt(self, other: Self) -> bool {
|
||||
self.ref_time > other.ref_time
|
||||
self.ref_time > other.ref_time && self.proof_size > other.proof_size
|
||||
}
|
||||
|
||||
/// Returns true if any of `self`'s constituent weights is strictly less than that of the
|
||||
/// `other`'s, otherwise returns false.
|
||||
pub const fn any_lt(self, other: Self) -> bool {
|
||||
self.ref_time < other.ref_time
|
||||
self.ref_time < other.ref_time || self.proof_size < other.proof_size
|
||||
}
|
||||
|
||||
/// Returns true if all of `self`'s constituent weights is strictly less than that of the
|
||||
/// `other`'s, otherwise returns false.
|
||||
pub const fn all_lt(self, other: Self) -> bool {
|
||||
self.ref_time < other.ref_time
|
||||
self.ref_time < other.ref_time && self.proof_size < other.proof_size
|
||||
}
|
||||
|
||||
/// Returns true if any of `self`'s constituent weights is greater than or equal to that of the
|
||||
/// `other`'s, otherwise returns false.
|
||||
pub const fn any_gte(self, other: Self) -> bool {
|
||||
self.ref_time >= other.ref_time
|
||||
self.ref_time >= other.ref_time || self.proof_size >= other.proof_size
|
||||
}
|
||||
|
||||
/// Returns true if all of `self`'s constituent weights is greater than or equal to that of the
|
||||
/// `other`'s, otherwise returns false.
|
||||
pub const fn all_gte(self, other: Self) -> bool {
|
||||
self.ref_time >= other.ref_time
|
||||
self.ref_time >= other.ref_time && self.proof_size >= other.proof_size
|
||||
}
|
||||
|
||||
/// Returns true if any of `self`'s constituent weights is less than or equal to that of the
|
||||
/// `other`'s, otherwise returns false.
|
||||
pub const fn any_lte(self, other: Self) -> bool {
|
||||
self.ref_time <= other.ref_time
|
||||
self.ref_time <= other.ref_time || self.proof_size <= other.proof_size
|
||||
}
|
||||
|
||||
/// Returns true if all of `self`'s constituent weights is less than or equal to that of the
|
||||
/// `other`'s, otherwise returns false.
|
||||
pub const fn all_lte(self, other: Self) -> bool {
|
||||
self.ref_time <= other.ref_time
|
||||
self.ref_time <= other.ref_time && self.proof_size <= other.proof_size
|
||||
}
|
||||
|
||||
/// Returns true if any of `self`'s constituent weights is equal to that of the `other`'s,
|
||||
/// otherwise returns false.
|
||||
pub const fn any_eq(self, other: Self) -> bool {
|
||||
self.ref_time == other.ref_time
|
||||
self.ref_time == other.ref_time || self.proof_size == other.proof_size
|
||||
}
|
||||
|
||||
// NOTE: `all_eq` does not exist, as it's simply the `eq` method from the `PartialEq` trait.
|
||||
@@ -258,14 +325,20 @@ impl Zero for Weight {
|
||||
impl Add for Weight {
|
||||
type Output = Self;
|
||||
fn add(self, rhs: Self) -> Self {
|
||||
Self { ref_time: self.ref_time + rhs.ref_time }
|
||||
Self {
|
||||
ref_time: self.ref_time + rhs.ref_time,
|
||||
proof_size: self.proof_size + rhs.proof_size,
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
impl Sub for Weight {
|
||||
type Output = Self;
|
||||
fn sub(self, rhs: Self) -> Self {
|
||||
Self { ref_time: self.ref_time - rhs.ref_time }
|
||||
Self {
|
||||
ref_time: self.ref_time - rhs.ref_time,
|
||||
proof_size: self.proof_size - rhs.proof_size,
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@@ -275,7 +348,7 @@ where
|
||||
{
|
||||
type Output = Self;
|
||||
fn mul(self, b: T) -> Self {
|
||||
Self { ref_time: b * self.ref_time }
|
||||
Self { ref_time: b * self.ref_time, proof_size: b * self.proof_size }
|
||||
}
|
||||
}
|
||||
|
||||
@@ -285,7 +358,10 @@ macro_rules! weight_mul_per_impl {
|
||||
impl Mul<Weight> for $t {
|
||||
type Output = Weight;
|
||||
fn mul(self, b: Weight) -> Weight {
|
||||
Weight { ref_time: self * b.ref_time }
|
||||
Weight {
|
||||
ref_time: self * b.ref_time,
|
||||
proof_size: self * b.proof_size,
|
||||
}
|
||||
}
|
||||
}
|
||||
)*
|
||||
@@ -305,7 +381,10 @@ macro_rules! weight_mul_primitive_impl {
|
||||
impl Mul<Weight> for $t {
|
||||
type Output = Weight;
|
||||
fn mul(self, b: Weight) -> Weight {
|
||||
Weight { ref_time: u64::from(self) * b.ref_time }
|
||||
Weight {
|
||||
ref_time: u64::from(self) * b.ref_time,
|
||||
proof_size: u64::from(self) * b.proof_size,
|
||||
}
|
||||
}
|
||||
}
|
||||
)*
|
||||
@@ -320,7 +399,7 @@ where
|
||||
{
|
||||
type Output = Self;
|
||||
fn div(self, b: T) -> Self {
|
||||
Self { ref_time: self.ref_time / b }
|
||||
Self { ref_time: self.ref_time / b, proof_size: self.proof_size / b }
|
||||
}
|
||||
}
|
||||
|
||||
@@ -338,7 +417,7 @@ impl CheckedSub for Weight {
|
||||
|
||||
impl core::fmt::Display for Weight {
|
||||
fn fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result {
|
||||
write!(f, "Weight(ref_time: {})", self.ref_time)
|
||||
write!(f, "Weight(ref_time: {}, proof_size: {})", self.ref_time, self.proof_size)
|
||||
}
|
||||
}
|
||||
|
||||
@@ -353,12 +432,18 @@ impl Bounded for Weight {
|
||||
|
||||
impl AddAssign for Weight {
|
||||
fn add_assign(&mut self, other: Self) {
|
||||
*self = Self { ref_time: self.ref_time + other.ref_time };
|
||||
*self = Self {
|
||||
ref_time: self.ref_time + other.ref_time,
|
||||
proof_size: self.proof_size + other.proof_size,
|
||||
};
|
||||
}
|
||||
}
|
||||
|
||||
impl SubAssign for Weight {
|
||||
fn sub_assign(&mut self, other: Self) {
|
||||
*self = Self { ref_time: self.ref_time - other.ref_time };
|
||||
*self = Self {
|
||||
ref_time: self.ref_time - other.ref_time,
|
||||
proof_size: self.proof_size - other.proof_size,
|
||||
};
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user