Skip to content
Snippets Groups Projects
Unverified Commit 1143537b authored by bgallois's avatar bgallois
Browse files

update to benchmarking v2

parent 93853b2d
No related branches found
No related tags found
No related merge requests found
Pipeline #35771 passed
...@@ -17,70 +17,83 @@ ...@@ -17,70 +17,83 @@
#![cfg(feature = "runtime-benchmarks")] #![cfg(feature = "runtime-benchmarks")]
use super::*; use super::*;
use frame_benchmarking::benchmarks;
use frame_system::RawOrigin;
use crate::Pallet; use crate::Pallet;
fn assert_has_event<T: Config>(generic_event: <T as Config>::RuntimeEvent) { use frame_benchmarking::v2::*;
frame_system::Pallet::<T>::assert_has_event(generic_event.into()); use frame_system::RawOrigin;
}
benchmarks! { #[benchmarks(
where_clause {
where where
T::MemberId: From<u32>, <T as Config>::MemberId: From<u32>,
)]
mod benchmarks {
use super::*;
fn assert_has_event<T: Config>(generic_event: <T as Config>::RuntimeEvent) {
frame_system::Pallet::<T>::assert_has_event(generic_event.into());
} }
go_offline {
#[benchmark]
fn go_offline() {
let id: T::MemberId = OnlineAuthorities::<T>::get()[0]; let id: T::MemberId = OnlineAuthorities::<T>::get()[0];
let caller: T::AccountId = Members::<T>::get(id).unwrap().owner_key; let caller: T::AccountId = Members::<T>::get(id).unwrap().owner_key;
let caller_origin: <T as frame_system::Config>::RuntimeOrigin = RawOrigin::Signed(caller.clone()).into();
}: _<T::RuntimeOrigin>(caller_origin) #[extrinsic_call]
verify { _(RawOrigin::Signed(caller));
assert_has_event::<T>(Event::<T>::MemberGoOffline{member: id}.into());
assert_has_event::<T>(Event::<T>::MemberGoOffline { member: id }.into());
} }
go_online {
#[benchmark]
fn go_online() {
let id: T::MemberId = OnlineAuthorities::<T>::get()[0]; let id: T::MemberId = OnlineAuthorities::<T>::get()[0];
let caller: T::AccountId = Members::<T>::get(id).unwrap().owner_key; let caller: T::AccountId = Members::<T>::get(id).unwrap().owner_key;
let caller_origin: <T as frame_system::Config>::RuntimeOrigin = RawOrigin::Signed(caller.clone()).into();
OnlineAuthorities::<T>::mutate(|ids| { OnlineAuthorities::<T>::mutate(|ids| {
ids.retain(|&x| x != id); ids.retain(|&x| x != id);
}); });
OutgoingAuthorities::<T>::mutate(|ids| { OutgoingAuthorities::<T>::mutate(|ids| {
ids.retain(|&x| x != id); ids.retain(|&x| x != id);
}); });
}: _<T::RuntimeOrigin>(caller_origin)
verify { #[extrinsic_call]
assert_has_event::<T>(Event::<T>::MemberGoOnline{member: id}.into()); _(RawOrigin::Signed(caller));
assert_has_event::<T>(Event::<T>::MemberGoOnline { member: id }.into());
} }
set_session_keys {
#[benchmark]
fn set_session_keys() {
let id: T::MemberId = OnlineAuthorities::<T>::get()[0]; let id: T::MemberId = OnlineAuthorities::<T>::get()[0];
let caller: T::AccountId = Members::<T>::get(id).unwrap().owner_key; let caller: T::AccountId = Members::<T>::get(id).unwrap().owner_key;
let caller_origin: <T as frame_system::Config>::RuntimeOrigin = RawOrigin::Signed(caller.clone()).into(); let validator_id = T::ValidatorIdOf::convert(caller.clone()).unwrap();
let validator_id = T::ValidatorIdOf::convert(caller.clone()).unwrap(); let session_keys: T::Keys = pallet_session::NextKeys::<T>::get(validator_id).unwrap();
let session_keys: T::Keys = pallet_session::NextKeys::<T>::get(validator_id).unwrap();
}: _<T::RuntimeOrigin>(caller_origin, session_keys) #[extrinsic_call]
remove_member { _(RawOrigin::Signed(caller), session_keys);
}
#[benchmark]
fn remove_member() {
let id: T::MemberId = OnlineAuthorities::<T>::get()[0]; let id: T::MemberId = OnlineAuthorities::<T>::get()[0];
let caller_origin = RawOrigin::Root.into();
}: _<T::RuntimeOrigin>(caller_origin, id) #[extrinsic_call]
verify { _(RawOrigin::Root, id);
assert_has_event::<T>(Event::<T>::MemberRemoved{member: id}.into());
assert_has_event::<T>(Event::<T>::MemberRemoved { member: id }.into());
} }
remove_member_from_blacklist {
#[benchmark]
fn remove_member_from_blacklist() {
let id: T::MemberId = OnlineAuthorities::<T>::get()[0]; let id: T::MemberId = OnlineAuthorities::<T>::get()[0];
Blacklist::<T>::mutate(|blacklist| { Blacklist::<T>::mutate(|blacklist| {
blacklist.push(id); blacklist.push(id);
}); });
}: _<T::RuntimeOrigin>(RawOrigin::Root.into(), id)
verify { #[extrinsic_call]
assert_has_event::<T>(Event::<T>::MemberRemovedFromBlacklist{member: id}.into()); _(RawOrigin::Root, id);
assert_has_event::<T>(Event::<T>::MemberRemovedFromBlacklist { member: id }.into());
} }
impl_benchmark_test_suite!( impl_benchmark_test_suite!(Pallet, crate::mock::new_test_ext(2), crate::mock::Test);
Pallet,
crate::mock::new_test_ext(2),
crate::mock::Test
);
} }
...@@ -18,122 +18,160 @@ ...@@ -18,122 +18,160 @@
use super::*; use super::*;
use frame_benchmarking::benchmarks; use frame_benchmarking::v2::*;
use frame_system::RawOrigin; use frame_system::RawOrigin;
use sp_runtime::traits::Zero; use sp_runtime::traits::Zero;
#[cfg(test)]
use maplit::btreemap;
use crate::Pallet; use crate::Pallet;
fn assert_has_event<T: Config>(generic_event: <T as Config>::RuntimeEvent) { #[benchmarks(
frame_system::Pallet::<T>::assert_has_event(generic_event.into()); where
} <T as Config>::IdtyIndex: From<u32>,
)]
mod benchmarks {
use super::*;
fn add_certs<T: Config>(i: u32, receiver: T::IdtyIndex) -> Result<(), &'static str> { fn assert_has_event<T: Config>(generic_event: <T as Config>::RuntimeEvent) {
Pallet::<T>::remove_all_certs_received_by(RawOrigin::Root.into(), receiver)?; frame_system::Pallet::<T>::assert_has_event(generic_event.into());
for j in 1..i {
Pallet::<T>::do_add_cert_checked(j.into(), receiver, false)?;
} }
assert!(
CertsByReceiver::<T>::get(receiver).len() as u32 == i - 1,
"Certs not added",
);
Ok(())
}
benchmarks! { fn add_certs<T: Config>(i: u32, receiver: T::IdtyIndex) -> Result<(), &'static str> {
where_clause { Pallet::<T>::remove_all_certs_received_by(RawOrigin::Root.into(), receiver)?;
where for j in 1..i {
T::IdtyIndex: From<u32>, Pallet::<T>::do_add_cert_checked(j.into(), receiver, false)?;
}
assert!(
CertsByReceiver::<T>::get(receiver).len() as u32 == i - 1,
"Certs not added",
);
Ok(())
} }
add_cert {
#[benchmark]
fn add_cert() -> Result<(), BenchmarkError> {
let issuer: T::IdtyIndex = 1.into(); let issuer: T::IdtyIndex = 1.into();
let caller: T::AccountId = T::IdtyAttr::owner_key(issuer).unwrap(); let caller: T::AccountId = T::IdtyAttr::owner_key(issuer).unwrap();
let caller_origin: <T as frame_system::Config>::RuntimeOrigin = RawOrigin::Signed(caller.clone()).into();
let receiver: T::IdtyIndex = 2.into(); let receiver: T::IdtyIndex = 2.into();
Pallet::<T>::del_cert(RawOrigin::Root.into(), issuer, receiver)?; Pallet::<T>::del_cert(RawOrigin::Root.into(), issuer, receiver)?;
let issuer_cert: u32 = StorageIdtyCertMeta::<T>::get(issuer).issued_count;
let receiver_cert: u32 = StorageIdtyCertMeta::<T>::get(receiver).received_count;
frame_system::pallet::Pallet::<T>::set_block_number(T::CertPeriod::get()); frame_system::pallet::Pallet::<T>::set_block_number(T::CertPeriod::get());
}: _<T::RuntimeOrigin>(caller_origin, receiver)
verify { #[extrinsic_call]
assert_has_event::<T>(Event::<T>::CertAdded{ issuer, receiver }.into()); _(RawOrigin::Signed(caller), receiver);
assert_has_event::<T>(Event::<T>::CertAdded { issuer, receiver }.into());
Ok(())
} }
renew_cert { #[benchmark]
fn renew_cert() -> Result<(), BenchmarkError> {
let issuer: T::IdtyIndex = 1.into(); let issuer: T::IdtyIndex = 1.into();
let caller: T::AccountId = T::IdtyAttr::owner_key(issuer).unwrap(); let caller: T::AccountId = T::IdtyAttr::owner_key(issuer).unwrap();
let caller_origin: <T as frame_system::Config>::RuntimeOrigin = RawOrigin::Signed(caller.clone()).into();
let receiver: T::IdtyIndex = 2.into(); let receiver: T::IdtyIndex = 2.into();
Pallet::<T>::del_cert(RawOrigin::Root.into(), issuer, receiver)?; Pallet::<T>::del_cert(RawOrigin::Root.into(), issuer, receiver)?;
let issuer_cert: u32 = StorageIdtyCertMeta::<T>::get(issuer).issued_count;
let receiver_cert: u32 = StorageIdtyCertMeta::<T>::get(receiver).received_count;
frame_system::pallet::Pallet::<T>::set_block_number(T::CertPeriod::get()); frame_system::pallet::Pallet::<T>::set_block_number(T::CertPeriod::get());
Pallet::<T>::add_cert(caller_origin.clone(), receiver)?; Pallet::<T>::add_cert(RawOrigin::Signed(caller.clone()).into(), receiver)?;
frame_system::pallet::Pallet::<T>::set_block_number(T::CertPeriod::get() + T::CertPeriod::get()); frame_system::pallet::Pallet::<T>::set_block_number(
}: _<T::RuntimeOrigin>(caller_origin, receiver) T::CertPeriod::get() + T::CertPeriod::get(),
verify { );
assert_has_event::<T>(Event::<T>::CertAdded{ issuer, receiver }.into());
#[extrinsic_call]
_(RawOrigin::Signed(caller), receiver);
assert_has_event::<T>(Event::<T>::CertAdded { issuer, receiver }.into());
Ok(())
} }
del_cert { #[benchmark]
fn del_cert() -> Result<(), BenchmarkError> {
let issuer: T::IdtyIndex = 1.into(); let issuer: T::IdtyIndex = 1.into();
let receiver: T::IdtyIndex = 2.into(); let receiver: T::IdtyIndex = 2.into();
// try to add cert if missing, else ignore // try to add cert if missing, else ignore
// this depends on initial data // this depends on initial data
let _ = Pallet::<T>::do_add_cert_checked(issuer, receiver, false); let _ = Pallet::<T>::do_add_cert_checked(issuer, receiver, false);
let receiver_cert: u32 = StorageIdtyCertMeta::<T>::get(receiver).received_count;
let issuer_cert: u32 = StorageIdtyCertMeta::<T>::get(issuer).issued_count; #[extrinsic_call]
}: _<T::RuntimeOrigin>(RawOrigin::Root.into(), issuer, receiver) _(RawOrigin::Root, issuer, receiver);
verify {
assert_has_event::<T>(Event::<T>::CertRemoved{ issuer, receiver, expiration: false }.into()); assert_has_event::<T>(
Event::<T>::CertRemoved {
issuer,
receiver,
expiration: false,
}
.into(),
);
Ok(())
} }
remove_all_certs_received_by { #[benchmark]
fn remove_all_certs_received_by(i: Linear<2, 1_000>) -> Result<(), BenchmarkError> {
let receiver: T::IdtyIndex = 0.into(); let receiver: T::IdtyIndex = 0.into();
let i in 2..1000 => add_certs::<T>(i, receiver)?; add_certs::<T>(i, receiver)?;
}: _<T::RuntimeOrigin>(RawOrigin::Root.into(), receiver)
verify { #[extrinsic_call]
assert!(CertsByReceiver::<T>::get(receiver).is_empty() ); _(RawOrigin::Root, receiver);
assert!(CertsByReceiver::<T>::get(receiver).is_empty());
Ok(())
} }
on_initialize { #[benchmark]
fn on_initialize() {
assert!(CertsRemovableOn::<T>::try_get(BlockNumberFor::<T>::zero()).is_err()); assert!(CertsRemovableOn::<T>::try_get(BlockNumberFor::<T>::zero()).is_err());
}: {Pallet::<T>::on_initialize(BlockNumberFor::<T>::zero());}
do_remove_cert_noop { #[block]
}: {Pallet::<T>::do_remove_cert(100.into(), 101.into(), Some(BlockNumberFor::<T>::zero()));} {
Pallet::<T>::on_initialize(BlockNumberFor::<T>::zero());
}
}
#[benchmark]
fn do_remove_cert_noop() {
#[block]
{
Pallet::<T>::do_remove_cert(100.into(), 101.into(), Some(BlockNumberFor::<T>::zero()));
}
}
do_remove_cert { #[benchmark]
fn do_remove_cert() -> Result<(), BenchmarkError> {
let issuer: T::IdtyIndex = 1.into(); let issuer: T::IdtyIndex = 1.into();
let receiver: T::IdtyIndex = 0.into(); let receiver: T::IdtyIndex = 0.into();
Pallet::<T>::do_remove_cert(issuer, receiver, None); Pallet::<T>::do_remove_cert(issuer, receiver, None);
Pallet::<T>::do_add_cert_checked(issuer, receiver, false)?; Pallet::<T>::do_add_cert_checked(issuer, receiver, false)?;
let issuer_cert: u32 = StorageIdtyCertMeta::<T>::get(issuer).issued_count;
let receiver_cert: u32 = StorageIdtyCertMeta::<T>::get(receiver).received_count;
let block_number = T::ValidityPeriod::get(); let block_number = T::ValidityPeriod::get();
frame_system::pallet::Pallet::<T>::set_block_number(block_number); frame_system::pallet::Pallet::<T>::set_block_number(block_number);
}: {Pallet::<T>::do_remove_cert(issuer, receiver, Some(block_number));}
verify { #[block]
assert_has_event::<T>(Event::<T>::CertRemoved{ issuer, receiver, expiration: true }.into()); {
Pallet::<T>::do_remove_cert(issuer, receiver, Some(block_number));
}
assert_has_event::<T>(
Event::<T>::CertRemoved {
issuer,
receiver,
expiration: true,
}
.into(),
);
Ok(())
} }
impl_benchmark_test_suite!( impl_benchmark_test_suite!(
Pallet, Pallet,
crate::mock::new_test_ext(crate::mock::DefaultCertificationConfig { crate::mock::new_test_ext(crate::mock::DefaultCertificationConfig {
apply_cert_period_at_genesis: true, apply_cert_period_at_genesis: true,
certs_by_receiver: btreemap![ certs_by_receiver: maplit::btreemap![
0 => btreemap![ 0 => maplit::btreemap![
1 => Some(7), 1 => Some(7),
2 => Some(9), 2 => Some(9),
], ],
1 => btreemap![ 1 => maplit::btreemap![
0 => Some(10), 0 => Some(10),
2 => Some(3), 2 => Some(3),
], ],
] , ],
}), }),
crate::mock::Test crate::mock::Test
); );
......
...@@ -19,7 +19,7 @@ ...@@ -19,7 +19,7 @@
use super::*; use super::*;
use codec::Encode; use codec::Encode;
use frame_benchmarking::benchmarks; use frame_benchmarking::v2::*;
use frame_support::traits::{Currency, OnFinalize}; use frame_support::traits::{Currency, OnFinalize};
use frame_system::pallet_prelude::BlockNumberFor; use frame_system::pallet_prelude::BlockNumberFor;
use frame_system::RawOrigin; use frame_system::RawOrigin;
...@@ -29,92 +29,150 @@ use sp_runtime::Perbill; ...@@ -29,92 +29,150 @@ use sp_runtime::Perbill;
use crate::Pallet; use crate::Pallet;
fn assert_has_event<T: Config>(generic_event: <T as Config>::RuntimeEvent) { #[benchmarks(
frame_system::Pallet::<T>::assert_has_event(generic_event.into());
}
fn populate_pool<T: Config>(i: u32) -> Result<(), &'static str> {
EvaluationPool0::<T>::mutate(|current_pool| -> Result<(), &'static str> {
for j in 0..i {
current_pool
.evaluations
.try_push((j, median::MedianAcc::new()))
.map_err(|_| Error::<T>::QueueFull)?;
}
Ok(())
})
}
benchmarks! {
where_clause {
where where
T: pallet_balances::Config, T::Balance: From<u64>, T: pallet_balances::Config,
T::Balance: From<u64>,
BlockNumberFor<T>: From<u32>, BlockNumberFor<T>: From<u32>,
)]
mod benchmarks {
use super::*;
fn assert_has_event<T: Config>(generic_event: <T as Config>::RuntimeEvent) {
frame_system::Pallet::<T>::assert_has_event(generic_event.into());
} }
// request distance evaluation fn populate_pool<T: Config>(i: u32) -> Result<(), &'static str> {
request_distance_evaluation { EvaluationPool0::<T>::mutate(|current_pool| -> Result<(), &'static str> {
for j in 0..i {
current_pool
.evaluations
.try_push((j, median::MedianAcc::new()))
.map_err(|_| Error::<T>::QueueFull)?;
}
Ok(())
})
}
#[benchmark]
fn request_distance_evaluation() {
let idty = T::IdtyIndex::one(); let idty = T::IdtyIndex::one();
let caller: T::AccountId = pallet_identity::Identities::<T>::get(idty).unwrap().owner_key; let caller: T::AccountId = pallet_identity::Identities::<T>::get(idty)
let caller_origin: <T as frame_system::Config>::RuntimeOrigin = RawOrigin::Signed(caller.clone()).into(); .unwrap()
let _ = <Balances<T> as Currency<_>>::make_free_balance_be(&caller, T::Balance::max_value()); .owner_key;
}: _<T::RuntimeOrigin>(caller_origin.clone()) let _ =
verify { <Balances<T> as Currency<_>>::make_free_balance_be(&caller, T::Balance::max_value());
assert!(PendingEvaluationRequest::<T>::get(idty) == Some(caller.clone()), "Request not added");
assert_has_event::<T>(Event::<T>::EvaluationRequested { idty_index: idty, who: caller }.into()); #[extrinsic_call]
_(RawOrigin::Signed(caller.clone()));
assert!(
PendingEvaluationRequest::<T>::get(idty) == Some(caller.clone()),
"Request not added"
);
assert_has_event::<T>(
Event::<T>::EvaluationRequested {
idty_index: idty,
who: caller,
}
.into(),
);
} }
// request distance evaluation for #[benchmark]
request_distance_evaluation_for { fn request_distance_evaluation_for() {
let idty = T::IdtyIndex::one(); let idty = T::IdtyIndex::one();
let caller: T::AccountId = pallet_identity::Identities::<T>::get(idty).unwrap().owner_key; let caller: T::AccountId = pallet_identity::Identities::<T>::get(idty)
let caller_origin: <T as frame_system::Config>::RuntimeOrigin = RawOrigin::Signed(caller.clone()).into(); .unwrap()
let _ = <Balances<T> as Currency<_>>::make_free_balance_be(&caller, T::Balance::max_value()); .owner_key;
let target = 2u32; <Balances<T> as Currency<_>>::make_free_balance_be(&caller, T::Balance::max_value());
let target: T::IdtyIndex = 2u32;
// set target status since targeted distance evaluation only allowed for unvalidated // set target status since targeted distance evaluation only allowed for unvalidated
pallet_identity::Identities::<T>::mutate(target, pallet_identity::Identities::<T>::mutate(target, |idty_val| {
|idty_val| idty_val.as_mut().unwrap().status = pallet_identity::IdtyStatus::Unvalidated); idty_val.as_mut().unwrap().status = pallet_identity::IdtyStatus::Unvalidated
}: _<T::RuntimeOrigin>(caller_origin.clone(), target) });
verify {
assert!(PendingEvaluationRequest::<T>::get(target) == Some(caller.clone()), "Request not added"); #[extrinsic_call]
assert_has_event::<T>(Event::<T>::EvaluationRequested { idty_index: target, who: caller }.into()); _(RawOrigin::Signed(caller.clone()), target);
assert!(
PendingEvaluationRequest::<T>::get(target) == Some(caller.clone()),
"Request not added"
);
assert_has_event::<T>(
Event::<T>::EvaluationRequested {
idty_index: target,
who: caller,
}
.into(),
);
} }
// update evaluation #[benchmark]
update_evaluation { fn update_evaluation(i: Linear<1, MAX_EVALUATIONS_PER_SESSION>) -> Result<(), BenchmarkError> {
let digest_data = sp_consensus_babe::digests::PreDigest::SecondaryPlain( let digest_data = sp_consensus_babe::digests::PreDigest::SecondaryPlain(
sp_consensus_babe::digests::SecondaryPlainPreDigest { authority_index: 0u32, slot: Default::default() }); sp_consensus_babe::digests::SecondaryPlainPreDigest {
authority_index: 0u32,
slot: Default::default(),
},
);
// A BABE digest item is needed to check authorship // A BABE digest item is needed to check authorship
let digest = sp_runtime::DigestItem::PreRuntime(*b"BABE", digest_data.encode()); let digest = sp_runtime::DigestItem::PreRuntime(*b"BABE", digest_data.encode());
let _ = <frame_system::Pallet<T>>::deposit_log(digest); <frame_system::Pallet<T>>::deposit_log(digest);
populate_pool::<T>(i)?;
#[extrinsic_call]
_(
RawOrigin::None,
ComputationResult {
distances: vec![Perbill::one(); i as usize],
},
);
Ok(())
}
#[benchmark]
fn force_update_evaluation(
i: Linear<1, MAX_EVALUATIONS_PER_SESSION>,
) -> Result<(), BenchmarkError> {
let idty = T::IdtyIndex::one(); let idty = T::IdtyIndex::one();
let caller: T::AccountId = pallet_identity::Identities::<T>::get(idty).unwrap().owner_key; let caller: T::AccountId = pallet_identity::Identities::<T>::get(idty)
let caller_origin: <T as frame_system::Config>::RuntimeOrigin = RawOrigin::Signed(caller.clone()).into(); .unwrap()
let i in 1 .. MAX_EVALUATIONS_PER_SESSION => populate_pool::<T>(i)?; .owner_key;
}: _<T::RuntimeOrigin>(RawOrigin::None.into(), ComputationResult{distances: vec![Perbill::one(); i as usize]}) populate_pool::<T>(i)?;
// force update evaluation #[extrinsic_call]
force_update_evaluation { _(
let idty = T::IdtyIndex::one(); RawOrigin::Root,
let caller: T::AccountId = pallet_identity::Identities::<T>::get(idty).unwrap().owner_key; caller,
let caller_origin: <T as frame_system::Config>::RuntimeOrigin = RawOrigin::Signed(caller.clone()).into(); ComputationResult {
let i in 1 .. MAX_EVALUATIONS_PER_SESSION => populate_pool::<T>(i)?; distances: vec![Perbill::one(); i as usize],
}: _<T::RuntimeOrigin>(RawOrigin::Root.into(), caller.clone(), ComputationResult{distances: vec![Perbill::one(); i as usize]}) },
);
// force valid distance status
force_valid_distance_status { Ok(())
}
#[benchmark]
fn force_valid_distance_status() {
let idty = T::IdtyIndex::one(); let idty = T::IdtyIndex::one();
let caller: T::AccountId = pallet_identity::Identities::<T>::get(idty).unwrap().owner_key;
}: _<T::RuntimeOrigin>(RawOrigin::Root.into(), idty) #[extrinsic_call]
verify { _(RawOrigin::Root, idty);
assert_has_event::<T>(Event::<T>::EvaluatedValid { idty_index: idty }.into()); assert_has_event::<T>(Event::<T>::EvaluatedValid { idty_index: idty }.into());
} }
// on finalize #[benchmark]
on_finalize { fn on_finalize() {
DidUpdate::<T>::set(true); DidUpdate::<T>::set(true);
}: { Pallet::<T>::on_finalize(Default::default()); }
verify { #[block]
{
Pallet::<T>::on_finalize(Default::default());
}
assert!(!DidUpdate::<T>::get()); assert!(!DidUpdate::<T>::get());
} }
......
...@@ -18,73 +18,139 @@ ...@@ -18,73 +18,139 @@
use super::*; use super::*;
use frame_benchmarking::{account, benchmarks, whitelisted_caller}; use frame_benchmarking::v2::*;
use frame_support::sp_runtime::{traits::One, Saturating}; use frame_support::sp_runtime::{traits::One, Saturating};
use frame_support::traits::{Currency, Get}; use frame_support::traits::Currency;
use frame_system::RawOrigin;
use pallet_provide_randomness::OnFilledRandomness; use pallet_provide_randomness::OnFilledRandomness;
use crate::Pallet; use crate::Pallet;
fn assert_has_event<T: Config>(generic_event: <T as Config>::RuntimeEvent) { #[benchmarks]
frame_system::Pallet::<T>::assert_has_event(generic_event.into()); mod benchmarks {
} use super::*;
fn create_pending_accounts<T: Config>( fn assert_has_event<T: Config>(generic_event: <T as Config>::RuntimeEvent) {
i: u32, frame_system::Pallet::<T>::assert_has_event(generic_event.into());
is_balance: bool, }
is_sufficient: bool,
) -> Result<(), &'static str> { fn create_pending_accounts<T: Config>(
for _ in 0..i { i: u32,
let caller: T::AccountId = whitelisted_caller(); is_balance: bool,
if is_balance { is_sufficient: bool,
let existential_deposit = T::ExistentialDeposit::get(); ) -> Result<(), &'static str> {
let balance = existential_deposit.saturating_mul((200u32).into()); for _ in 0..i {
let _ = <pallet_balances::Pallet<T> as Currency<T::AccountId>>::make_free_balance_be( let caller: T::AccountId = whitelisted_caller();
&caller, balance, if is_balance {
); let existential_deposit = T::ExistentialDeposit::get();
} else { let balance = existential_deposit.saturating_mul((200u32).into());
assert!( let _ =
frame_system::Pallet::<T>::get(&caller).free <pallet_balances::Pallet<T> as Currency<T::AccountId>>::make_free_balance_be(
< T::NewAccountPrice::get() + T::ExistentialDeposit::get() &caller, balance,
); );
} } else {
if is_sufficient { assert!(
frame_system::Pallet::<T>::inc_sufficients(&caller); frame_system::Pallet::<T>::get(&caller).free
} else { < T::NewAccountPrice::get() + T::ExistentialDeposit::get()
assert!(frame_system::Pallet::<T>::sufficients(&caller) == 0); );
}
if is_sufficient {
frame_system::Pallet::<T>::inc_sufficients(&caller);
} else {
assert!(frame_system::Pallet::<T>::sufficients(&caller) == 0);
}
PendingNewAccounts::<T>::insert(caller, ());
} }
PendingNewAccounts::<T>::insert(caller, ()); Ok(())
} }
Ok(())
}
benchmarks! { #[benchmark]
unlink_identity { fn unlink_identity() {
let account = account("Alice", 1, 1); let account = account("Alice", 1, 1);
let origin = frame_system::RawOrigin::Signed(account);
}: _<T::RuntimeOrigin>(origin.into()) #[extrinsic_call]
on_initialize_sufficient { _(RawOrigin::Signed(account));
let i in 0 .. T::MaxNewAccountsPerBlock::get() => create_pending_accounts::<T>(i, false, true)?; }
}: { Pallet::<T>::on_initialize(BlockNumberFor::<T>::one()); }
on_initialize_with_balance { #[benchmark]
let i in 0 .. T::MaxNewAccountsPerBlock::get() => create_pending_accounts::<T>(i, true, false)?; fn on_initialize_sufficient(
}: { Pallet::<T>::on_initialize(BlockNumberFor::<T>::one()); } i: Linear<0, { T::MaxNewAccountsPerBlock::get() }>,
on_initialize_no_balance { ) -> Result<(), BenchmarkError> {
let i in 0 .. T::MaxNewAccountsPerBlock::get() => create_pending_accounts::<T>(i, false, false)?; create_pending_accounts::<T>(i, false, true)?;
}: { Pallet::<T>::on_initialize(BlockNumberFor::<T>::one()); }
on_filled_randomness_pending { #[block]
{
Pallet::<T>::on_initialize(BlockNumberFor::<T>::one());
}
Ok(())
}
#[benchmark]
fn on_initialize_with_balance(
i: Linear<0, { T::MaxNewAccountsPerBlock::get() }>,
) -> Result<(), BenchmarkError> {
create_pending_accounts::<T>(i, true, false)?;
#[block]
{
Pallet::<T>::on_initialize(BlockNumberFor::<T>::one());
}
Ok(())
}
#[benchmark]
fn on_initialize_no_balance(
i: Linear<0, { T::MaxNewAccountsPerBlock::get() }>,
) -> Result<(), BenchmarkError> {
create_pending_accounts::<T>(i, false, false)?;
#[block]
{
Pallet::<T>::on_initialize(BlockNumberFor::<T>::one());
}
Ok(())
}
#[benchmark]
fn on_filled_randomness_pending() {
let caller: T::AccountId = whitelisted_caller(); let caller: T::AccountId = whitelisted_caller();
let randomness = H256(T::AccountIdToSalt::convert(caller.clone())); let randomness = H256(T::AccountIdToSalt::convert(caller.clone()));
let request_id = pallet_provide_randomness::Pallet::<T>::force_request(pallet_provide_randomness::RandomnessType::RandomnessFromTwoEpochsAgo, randomness); let request_id = pallet_provide_randomness::Pallet::<T>::force_request(
pallet_provide_randomness::RandomnessType::RandomnessFromTwoEpochsAgo,
randomness,
);
PendingRandomIdAssignments::<T>::insert(request_id, caller.clone()); PendingRandomIdAssignments::<T>::insert(request_id, caller.clone());
}: { Pallet::<T>::on_filled_randomness(request_id, randomness); }
verify { #[block]
assert_has_event::<T>(Event::<T>::RandomIdAssigned { who: caller, random_id: randomness }.into()); {
Pallet::<T>::on_filled_randomness(request_id, randomness);
}
assert_has_event::<T>(
Event::<T>::RandomIdAssigned {
who: caller,
random_id: randomness,
}
.into(),
);
} }
on_filled_randomness_no_pending {
#[benchmark]
fn on_filled_randomness_no_pending() {
let caller: T::AccountId = whitelisted_caller(); let caller: T::AccountId = whitelisted_caller();
let randomness = H256(T::AccountIdToSalt::convert(caller.clone())); let randomness = H256(T::AccountIdToSalt::convert(caller.clone()));
let request_id = pallet_provide_randomness::Pallet::<T>::force_request(pallet_provide_randomness::RandomnessType::RandomnessFromTwoEpochsAgo, randomness); let request_id = pallet_provide_randomness::Pallet::<T>::force_request(
pallet_provide_randomness::RandomnessType::RandomnessFromTwoEpochsAgo,
randomness,
);
assert!(!PendingRandomIdAssignments::<T>::contains_key(request_id)); assert!(!PendingRandomIdAssignments::<T>::contains_key(request_id));
}: { Pallet::<T>::on_filled_randomness(request_id, randomness); }
#[block]
{
Pallet::<T>::on_filled_randomness(request_id, randomness);
}
}
} }
This diff is collapsed.
...@@ -18,58 +18,66 @@ ...@@ -18,58 +18,66 @@
use super::*; use super::*;
use frame_benchmarking::benchmarks; use frame_benchmarking::v2::*;
use frame_system::pallet_prelude::BlockNumberFor; use frame_system::pallet_prelude::BlockNumberFor;
#[cfg(test)]
use maplit::btreemap;
use crate::Pallet; use crate::Pallet;
// fn assert_has_event<T: Config>(generic_event: <T as Config>::RuntimeEvent) { #[benchmarks(
// frame_system::Pallet::<T>::assert_has_event(generic_event.into());
// }
benchmarks! {
where_clause {
where where
T::IdtyId: From<u32>, T::IdtyId: From<u32>,
BlockNumberFor<T>: From<u32>, BlockNumberFor<T>: From<u32>,
} )]
mod benchmarks {
use super::*;
// TODO membership add and renewal should be included to distance on_new_session as worst case scenario // TODO membership add and renewal should be included to distance on_new_session as worst case scenario
// Base weight of an empty initialize #[benchmark]
on_initialize { fn on_initialize() {
}: {Pallet::<T>::on_initialize(BlockNumberFor::<T>::zero());} // Base weight of an empty initialize
#[block]
{
Pallet::<T>::on_initialize(BlockNumberFor::<T>::zero());
}
}
expire_memberships { #[benchmark]
let i in 0..3; // Limited by the number of validators fn expire_memberships(i: Linear<0, 3>) {
// Limited by the number of validators
// Arbitrarily high, to be in the worst case of wot instance, // Arbitrarily high, to be in the worst case of wot instance,
// this will overcount the weight in hooks see https://git.duniter.org/nodes/rust/duniter-v2s/-/issues/167 // this will overcount the weight in hooks see https://git.duniter.org/nodes/rust/duniter-v2s/-/issues/167
let block_number: BlockNumberFor::<T> = 10_000_000.into(); let block_number: BlockNumberFor<T> = 10_000_000.into();
frame_system::pallet::Pallet::<T>::set_block_number(block_number); frame_system::pallet::Pallet::<T>::set_block_number(block_number);
let mut idties: Vec<T::IdtyId> = Vec::new(); let mut idties: Vec<T::IdtyId> = Vec::new();
for j in 1..i+1 { for j in 1..i + 1 {
let j: T::IdtyId = j.into(); let j: T::IdtyId = j.into();
Membership::<T>::insert(j, MembershipData::<BlockNumberFor<T>>::default()); Membership::<T>::insert(j, MembershipData::<BlockNumberFor<T>>::default());
idties.push(j); idties.push(j);
} }
MembershipsExpireOn::<T>::insert(block_number, idties); MembershipsExpireOn::<T>::insert(block_number, idties);
assert_eq!(MembershipsExpireOn::<T>::get(block_number).len(), i as usize); assert_eq!(
}: {Pallet::<T>::expire_memberships(block_number);} MembershipsExpireOn::<T>::get(block_number).len(),
verify { i as usize
);
#[block]
{
Pallet::<T>::expire_memberships(block_number);
}
assert_eq!(MembershipsExpireOn::<T>::get(block_number).len(), 0_usize); assert_eq!(MembershipsExpireOn::<T>::get(block_number).len(), 0_usize);
} }
impl_benchmark_test_suite!( impl_benchmark_test_suite!(
Pallet, Pallet,
crate::mock::new_test_ext(crate::mock::MembershipConfig { crate::mock::new_test_ext(crate::mock::MembershipConfig {
memberships: btreemap![ memberships: maplit::btreemap![
3 => MembershipData { 3 => crate::MembershipData {
expire_on: 3, expire_on: 3,
}, },
],}), ],
}),
crate::mock::Test crate::mock::Test
); );
} }
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment