difftreelog
fix cargo fmt
in: master
4 files changed
pallets/scheduler-v2/src/lib.rsdiffbeforeafterboth--- a/pallets/scheduler-v2/src/lib.rs
+++ b/pallets/scheduler-v2/src/lib.rs
@@ -77,13 +77,16 @@
use codec::{Codec, Decode, Encode, MaxEncodedLen};
use frame_support::{
- dispatch::{DispatchError, DispatchResult, Dispatchable, GetDispatchInfo, Parameter, PostDispatchInfo},
+ dispatch::{
+ DispatchError, DispatchResult, Dispatchable, GetDispatchInfo, Parameter, PostDispatchInfo,
+ },
traits::{
schedule::{self, DispatchTime, LOWEST_PRIORITY},
EnsureOrigin, Get, IsType, OriginTrait, PrivilegeCmp, StorageVersion, PreimageRecipient,
ConstU32, UnfilteredDispatchable,
},
- weights::Weight, unsigned::TransactionValidityError,
+ weights::Weight,
+ unsigned::TransactionValidityError,
};
use frame_system::{self as system};
@@ -318,8 +321,10 @@
/// The aggregated call type.
type RuntimeCall: Parameter
- + Dispatchable<RuntimeOrigin = <Self as Config>::RuntimeOrigin, PostInfo = PostDispatchInfo>
- + UnfilteredDispatchable<RuntimeOrigin = <Self as system::Config>::RuntimeOrigin>
+ + Dispatchable<
+ RuntimeOrigin = <Self as Config>::RuntimeOrigin,
+ PostInfo = PostDispatchInfo,
+ > + UnfilteredDispatchable<RuntimeOrigin = <Self as system::Config>::RuntimeOrigin>
+ GetDispatchInfo
+ From<system::Call<Self>>;
@@ -940,7 +945,7 @@
}
return Err((Unavailable, Some(task)));
- },
+ }
};
weight.check_accrue(T::WeightInfo::service_task(
@@ -979,7 +984,7 @@
Err(Overweight) => {
// Preserve Lookup -- the task will be postponed.
Err((Overweight, Some(task)))
- },
+ }
Ok(result) => {
Self::deposit_event(Event::Dispatched {
task: (when, agenda_index),
@@ -987,7 +992,9 @@
result,
});
- let is_canceled = task.maybe_id.as_ref()
+ let is_canceled = task
+ .maybe_id
+ .as_ref()
.map(|id| !Lookup::<T>::contains_key(id))
.unwrap_or(false);
@@ -1011,14 +1018,14 @@
});
}
}
- },
+ }
_ => {
if let Some(ref id) = task.maybe_id {
Lookup::<T>::remove(id);
}
T::Preimages::drop(&task.call)
- },
+ }
}
Ok(())
}
@@ -1056,12 +1063,12 @@
let r = match ensured_origin {
Ok(ScheduledEnsureOriginSuccess::Root) => {
Ok(call.dispatch_bypass_filter(frame_system::RawOrigin::Root.into()))
- },
+ }
Ok(ScheduledEnsureOriginSuccess::Signed(sender)) => {
// Execute transaction via chain default pipeline
// That means dispatch will be processed like any user's extrinsic e.g. transaction fees will be taken
T::CallExecutor::dispatch_call(Some(sender), call.clone())
- },
+ }
Ok(ScheduledEnsureOriginSuccess::Unsigned) => {
// Unsigned version of the above
T::CallExecutor::dispatch_call(None, call.clone())
pallets/scheduler-v2/src/mock.rsdiffbeforeafterboth--- a/pallets/scheduler-v2/src/mock.rs
+++ b/pallets/scheduler-v2/src/mock.rs
@@ -39,9 +39,7 @@
use crate as scheduler;
use frame_support::{
ord_parameter_types, parameter_types,
- traits::{
- ConstU32, ConstU64, Contains, EqualPrivilegeOnly, OnFinalize, OnInitialize,
- },
+ traits::{ConstU32, ConstU64, Contains, EqualPrivilegeOnly, OnFinalize, OnInitialize},
weights::constants::RocksDbWeight,
};
use frame_system::{EnsureRoot, RawOrigin};
@@ -136,7 +134,7 @@
pub BlockWeights: frame_system::limits::BlockWeights =
frame_system::limits::BlockWeights::simple_max(
Weight::from_ref_time(2_000_000_000_000)
- // .set_proof_size(u64::MAX),
+ // .set_proof_size(u64::MAX),
);
}
impl system::Config for Test {
@@ -210,9 +208,9 @@
fn cancel_named(_s: u32) -> Weight {
Weight::from_ref_time(50)
}
- fn change_named_priority(_s: u32, ) -> Weight {
- Weight::from_ref_time(50)
- }
+ fn change_named_priority(_s: u32) -> Weight {
+ Weight::from_ref_time(50)
+ }
}
parameter_types! {
pub MaximumSchedulerWeight: Weight = Perbill::from_percent(80) *
@@ -220,8 +218,8 @@
}
pub struct EnsureSignedOneOrRoot;
-impl<O: Into<Result<RawOrigin<u64>, O>> + From<RawOrigin<u64>>>
- EnsureOrigin<O> for EnsureSignedOneOrRoot
+impl<O: Into<Result<RawOrigin<u64>, O>> + From<RawOrigin<u64>>> EnsureOrigin<O>
+ for EnsureSignedOneOrRoot
{
type Success = ScheduledEnsureOriginSuccess<u64>;
fn try_origin(o: O) -> Result<Self::Success, O> {
@@ -235,19 +233,19 @@
pub struct Executor;
impl DispatchCall<Test, sp_core::H160> for Executor {
- fn dispatch_call(
- signer: Option<u64>,
- function: RuntimeCall,
- ) -> Result<
- Result<PostDispatchInfo, DispatchErrorWithPostInfo<PostDispatchInfo>>,
- TransactionValidityError,
- > {
- let origin = match signer {
- Some(who) => RuntimeOrigin::signed(who),
- None => RuntimeOrigin::none(),
- };
- Ok(function.dispatch(origin))
- }
+ fn dispatch_call(
+ signer: Option<u64>,
+ function: RuntimeCall,
+ ) -> Result<
+ Result<PostDispatchInfo, DispatchErrorWithPostInfo<PostDispatchInfo>>,
+ TransactionValidityError,
+ > {
+ let origin = match signer {
+ Some(who) => RuntimeOrigin::signed(who),
+ None => RuntimeOrigin::none(),
+ };
+ Ok(function.dispatch(origin))
+ }
}
impl Config for Test {
@@ -261,14 +259,16 @@
type WeightInfo = TestWeightInfo;
type OriginPrivilegeCmp = EqualPrivilegeOnly;
type Preimages = ();
- type PrioritySetOrigin = EnsureRoot<u64>;
- type CallExecutor = Executor;
+ type PrioritySetOrigin = EnsureRoot<u64>;
+ type CallExecutor = Executor;
}
pub type LoggerCall = logger::Call<Test>;
pub fn new_test_ext() -> sp_io::TestExternalities {
- let t = system::GenesisConfig::default().build_storage::<Test>().unwrap();
+ let t = system::GenesisConfig::default()
+ .build_storage::<Test>()
+ .unwrap();
t.into()
}
pallets/scheduler-v2/src/tests.rsdiffbeforeafterboth1// Copyright 2019-2022 Unique Network (Gibraltar) Ltd.2// This file is part of Unique Network.34// Unique Network is free software: you can redistribute it and/or modify5// it under the terms of the GNU General Public License as published by6// the Free Software Foundation, either version 3 of the License, or7// (at your option) any later version.89// Unique Network is distributed in the hope that it will be useful,10// but WITHOUT ANY WARRANTY; without even the implied warranty of11// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the12// GNU General Public License for more details.1314// You should have received a copy of the GNU General Public License15// along with Unique Network. If not, see <http://www.gnu.org/licenses/>.1617// Original license:18// This file is part of Substrate.1920// Copyright (C) 2017-2022 Parity Technologies (UK) Ltd.21// SPDX-License-Identifier: Apache-2.02223// Licensed under the Apache License, Version 2.0 (the "License");24// you may not use this file except in compliance with the License.25// You may obtain a copy of the License at26//27// http://www.apache.org/licenses/LICENSE-2.028//29// Unless required by applicable law or agreed to in writing, software30// distributed under the License is distributed on an "AS IS" BASIS,31// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.32// See the License for the specific language governing permissions and33// limitations under the License.3435//! # Scheduler tests.3637use super::*;38use crate::mock::{39 logger, new_test_ext, root, run_to_block, LoggerCall, RuntimeCall, Scheduler, Test, *,40};41use frame_support::{42 assert_noop, assert_ok,43 traits::{Contains, OnInitialize},44};4546#[test]47fn basic_scheduling_works() {48 new_test_ext().execute_with(|| {49 let call =50 RuntimeCall::Logger(LoggerCall::log { i: 42, weight: Weight::from_ref_time(10) });51 assert!(!<Test as frame_system::Config>::BaseCallFilter::contains(&call));52 assert_ok!(Scheduler::do_schedule(53 DispatchTime::At(4),54 None,55 127,56 root(),57 <ScheduledCall<Test>>::new(call).unwrap(),58 ));59 run_to_block(3);60 assert!(logger::log().is_empty());61 run_to_block(4);62 assert_eq!(logger::log(), vec![(root(), 42u32)]);63 run_to_block(100);64 assert_eq!(logger::log(), vec![(root(), 42u32)]);65 });66}6768#[test]69fn schedule_after_works() {70 new_test_ext().execute_with(|| {71 run_to_block(2);72 let call =73 RuntimeCall::Logger(LoggerCall::log { i: 42, weight: Weight::from_ref_time(10) });74 assert!(!<Test as frame_system::Config>::BaseCallFilter::contains(&call));75 // This will schedule the call 3 blocks after the next block... so block 3 + 3 = 676 assert_ok!(Scheduler::do_schedule(77 DispatchTime::After(3),78 None,79 127,80 root(),81 <ScheduledCall<Test>>::new(call).unwrap(),82 ));83 run_to_block(5);84 assert!(logger::log().is_empty());85 run_to_block(6);86 assert_eq!(logger::log(), vec![(root(), 42u32)]);87 run_to_block(100);88 assert_eq!(logger::log(), vec![(root(), 42u32)]);89 });90}9192#[test]93fn schedule_after_zero_works() {94 new_test_ext().execute_with(|| {95 run_to_block(2);96 let call =97 RuntimeCall::Logger(LoggerCall::log { i: 42, weight: Weight::from_ref_time(10) });98 assert!(!<Test as frame_system::Config>::BaseCallFilter::contains(&call));99 assert_ok!(Scheduler::do_schedule(100 DispatchTime::After(0),101 None,102 127,103 root(),104 <ScheduledCall<Test>>::new(call).unwrap(),105 ));106 // Will trigger on the next block.107 run_to_block(3);108 assert_eq!(logger::log(), vec![(root(), 42u32)]);109 run_to_block(100);110 assert_eq!(logger::log(), vec![(root(), 42u32)]);111 });112}113114#[test]115fn periodic_scheduling_works() {116 new_test_ext().execute_with(|| {117 // at #4, every 3 blocks, 3 times.118 assert_ok!(Scheduler::do_schedule(119 DispatchTime::At(4),120 Some((3, 3)),121 127,122 root(),123 <ScheduledCall<Test>>::new(RuntimeCall::Logger(logger::Call::log {124 i: 42,125 weight: Weight::from_ref_time(10)126 }))127 .unwrap()128 ));129 run_to_block(3);130 assert!(logger::log().is_empty());131 run_to_block(4);132 assert_eq!(logger::log(), vec![(root(), 42u32)]);133 run_to_block(6);134 assert_eq!(logger::log(), vec![(root(), 42u32)]);135 run_to_block(7);136 assert_eq!(logger::log(), vec![(root(), 42u32), (root(), 42u32)]);137 run_to_block(9);138 assert_eq!(logger::log(), vec![(root(), 42u32), (root(), 42u32)]);139 run_to_block(10);140 assert_eq!(logger::log(), vec![(root(), 42u32), (root(), 42u32), (root(), 42u32)]);141 run_to_block(100);142 assert_eq!(logger::log(), vec![(root(), 42u32), (root(), 42u32), (root(), 42u32)]);143 });144}145146#[test]147fn cancel_named_scheduling_works_with_normal_cancel() {148 new_test_ext().execute_with(|| {149 // at #4.150 Scheduler::do_schedule_named(151 [1u8; 32],152 DispatchTime::At(4),153 None,154 127,155 root(),156 <ScheduledCall<Test>>::new(RuntimeCall::Logger(LoggerCall::log {157 i: 69,158 weight: Weight::from_ref_time(10),159 }))160 .unwrap(),161 )162 .unwrap();163 let i = Scheduler::do_schedule(164 DispatchTime::At(4),165 None,166 127,167 root(),168 <ScheduledCall<Test>>::new(RuntimeCall::Logger(LoggerCall::log {169 i: 42,170 weight: Weight::from_ref_time(10),171 }))172 .unwrap(),173 )174 .unwrap();175 run_to_block(3);176 assert!(logger::log().is_empty());177 assert_ok!(Scheduler::do_cancel_named(None, [1u8; 32]));178 assert_ok!(Scheduler::do_cancel(None, i));179 run_to_block(100);180 assert!(logger::log().is_empty());181 });182}183184#[test]185fn cancel_named_periodic_scheduling_works() {186 new_test_ext().execute_with(|| {187 // at #4, every 3 blocks, 3 times.188 Scheduler::do_schedule_named(189 [1u8; 32],190 DispatchTime::At(4),191 Some((3, 3)),192 127,193 root(),194 <ScheduledCall<Test>>::new(RuntimeCall::Logger(LoggerCall::log {195 i: 42,196 weight: Weight::from_ref_time(10),197 }))198 .unwrap(),199 )200 .unwrap();201 // same id results in error.202 assert!(Scheduler::do_schedule_named(203 [1u8; 32],204 DispatchTime::At(4),205 None,206 127,207 root(),208 <ScheduledCall<Test>>::new(RuntimeCall::Logger(LoggerCall::log {209 i: 69,210 weight: Weight::from_ref_time(10)211 }))212 .unwrap(),213 )214 .is_err());215 // different id is ok.216 Scheduler::do_schedule_named(217 [2u8; 32],218 DispatchTime::At(8),219 None,220 127,221 root(),222 <ScheduledCall<Test>>::new(RuntimeCall::Logger(LoggerCall::log {223 i: 69,224 weight: Weight::from_ref_time(10),225 }))226 .unwrap(),227 )228 .unwrap();229 run_to_block(3);230 assert!(logger::log().is_empty());231 run_to_block(4);232 assert_eq!(logger::log(), vec![(root(), 42u32)]);233 run_to_block(6);234 assert_ok!(Scheduler::do_cancel_named(None, [1u8; 32]));235 run_to_block(100);236 assert_eq!(logger::log(), vec![(root(), 42u32), (root(), 69u32)]);237 });238}239240#[test]241fn scheduler_respects_weight_limits() {242 let max_weight: Weight = <Test as Config>::MaximumWeight::get();243 new_test_ext().execute_with(|| {244 let call = RuntimeCall::Logger(LoggerCall::log { i: 42, weight: max_weight / 3 * 2 });245 assert_ok!(Scheduler::do_schedule(246 DispatchTime::At(4),247 None,248 127,249 root(),250 <ScheduledCall<Test>>::new(call).unwrap(),251 ));252 let call = RuntimeCall::Logger(LoggerCall::log { i: 69, weight: max_weight / 3 * 2 });253 assert_ok!(Scheduler::do_schedule(254 DispatchTime::At(4),255 None,256 127,257 root(),258 <ScheduledCall<Test>>::new(call).unwrap(),259 ));260 // 69 and 42 do not fit together261 run_to_block(4);262 assert_eq!(logger::log(), vec![(root(), 42u32)]);263 run_to_block(5);264 assert_eq!(logger::log(), vec![(root(), 42u32), (root(), 69u32)]);265 });266}267268/// Permanently overweight calls are not deleted but also not executed.269#[test]270fn scheduler_does_not_delete_permanently_overweight_call() {271 let max_weight: Weight = <Test as Config>::MaximumWeight::get();272 new_test_ext().execute_with(|| {273 let call = RuntimeCall::Logger(LoggerCall::log { i: 42, weight: max_weight });274 assert_ok!(Scheduler::do_schedule(275 DispatchTime::At(4),276 None,277 127,278 root(),279 <ScheduledCall<Test>>::new(call).unwrap(),280 ));281 // Never executes.282 run_to_block(100);283 assert_eq!(logger::log(), vec![]);284285 // Assert the `PermanentlyOverweight` event.286 assert_eq!(287 System::events().last().unwrap().event,288 crate::Event::PermanentlyOverweight { task: (4, 0), id: None }.into(),289 );290 // The call is still in the agenda.291 assert!(Agenda::<Test>::get(4)[0].is_some());292 });293}294295#[test]296fn scheduler_handles_periodic_failure() {297 let max_weight: Weight = <Test as Config>::MaximumWeight::get();298 let max_per_block = <Test as Config>::MaxScheduledPerBlock::get();299300 new_test_ext().execute_with(|| {301 let call = RuntimeCall::Logger(LoggerCall::log { i: 42, weight: (max_weight / 3) * 2 });302 let call = <ScheduledCall<Test>>::new(call).unwrap();303304 assert_ok!(Scheduler::do_schedule(305 DispatchTime::At(4),306 Some((4, u32::MAX)),307 127,308 root(),309 call.clone(),310 ));311 // Executes 5 times till block 20.312 run_to_block(20);313 assert_eq!(logger::log().len(), 5);314315 // Block 28 will already be full.316 for _ in 0..max_per_block {317 assert_ok!(Scheduler::do_schedule(318 DispatchTime::At(28),319 None,320 120,321 root(),322 call.clone(),323 ));324 }325326 // Going to block 24 will emit a `PeriodicFailed` event.327 run_to_block(24);328 assert_eq!(logger::log().len(), 6);329330 assert_eq!(331 System::events().last().unwrap().event,332 crate::Event::PeriodicFailed { task: (24, 0), id: None }.into(),333 );334 });335}336337#[test]338fn scheduler_respects_priority_ordering() {339 let max_weight: Weight = <Test as Config>::MaximumWeight::get();340 new_test_ext().execute_with(|| {341 let call = RuntimeCall::Logger(LoggerCall::log { i: 42, weight: max_weight / 3 });342 assert_ok!(Scheduler::do_schedule(343 DispatchTime::At(4),344 None,345 1,346 root(),347 <ScheduledCall<Test>>::new(call).unwrap(),348 ));349 let call = RuntimeCall::Logger(LoggerCall::log { i: 69, weight: max_weight / 3 });350 assert_ok!(Scheduler::do_schedule(351 DispatchTime::At(4),352 None,353 0,354 root(),355 <ScheduledCall<Test>>::new(call).unwrap(),356 ));357 run_to_block(4);358 assert_eq!(logger::log(), vec![(root(), 69u32), (root(), 42u32)]);359 });360}361362#[test]363fn scheduler_respects_priority_ordering_with_soft_deadlines() {364 new_test_ext().execute_with(|| {365 let max_weight: Weight = <Test as Config>::MaximumWeight::get();366 let call = RuntimeCall::Logger(LoggerCall::log { i: 42, weight: max_weight / 5 * 2 });367 assert_ok!(Scheduler::do_schedule(368 DispatchTime::At(4),369 None,370 255,371 root(),372 <ScheduledCall<Test>>::new(call).unwrap(),373 ));374 let call = RuntimeCall::Logger(LoggerCall::log { i: 69, weight: max_weight / 5 * 2 });375 assert_ok!(Scheduler::do_schedule(376 DispatchTime::At(4),377 None,378 127,379 root(),380 <ScheduledCall<Test>>::new(call).unwrap(),381 ));382 let call = RuntimeCall::Logger(LoggerCall::log { i: 2600, weight: max_weight / 5 * 4 });383 assert_ok!(Scheduler::do_schedule(384 DispatchTime::At(4),385 None,386 126,387 root(),388 <ScheduledCall<Test>>::new(call).unwrap(),389 ));390391 // 2600 does not fit with 69 or 42, but has higher priority, so will go through392 run_to_block(4);393 assert_eq!(logger::log(), vec![(root(), 2600u32)]);394 // 69 and 42 fit together395 run_to_block(5);396 assert_eq!(logger::log(), vec![(root(), 2600u32), (root(), 69u32), (root(), 42u32)]);397 });398}399400#[test]401fn on_initialize_weight_is_correct() {402 new_test_ext().execute_with(|| {403 let call_weight = Weight::from_ref_time(25);404405 // Named406 let call = RuntimeCall::Logger(LoggerCall::log {407 i: 3,408 weight: call_weight + Weight::from_ref_time(1),409 });410 assert_ok!(Scheduler::do_schedule_named(411 [1u8; 32],412 DispatchTime::At(3),413 None,414 255,415 root(),416 <ScheduledCall<Test>>::new(call).unwrap(),417 ));418 let call = RuntimeCall::Logger(LoggerCall::log {419 i: 42,420 weight: call_weight + Weight::from_ref_time(2),421 });422 // Anon Periodic423 assert_ok!(Scheduler::do_schedule(424 DispatchTime::At(2),425 Some((1000, 3)),426 128,427 root(),428 <ScheduledCall<Test>>::new(call).unwrap(),429 ));430 let call = RuntimeCall::Logger(LoggerCall::log {431 i: 69,432 weight: call_weight + Weight::from_ref_time(3),433 });434 // Anon435 assert_ok!(Scheduler::do_schedule(436 DispatchTime::At(2),437 None,438 127,439 root(),440 <ScheduledCall<Test>>::new(call).unwrap(),441 ));442 // Named Periodic443 let call = RuntimeCall::Logger(LoggerCall::log {444 i: 2600,445 weight: call_weight + Weight::from_ref_time(4),446 });447 assert_ok!(Scheduler::do_schedule_named(448 [2u8; 32],449 DispatchTime::At(1),450 Some((1000, 3)),451 126,452 root(),453 <ScheduledCall<Test>>::new(call).unwrap(),454 ));455456 // Will include the named periodic only457 assert_eq!(458 Scheduler::on_initialize(1),459 TestWeightInfo::service_agendas_base() +460 TestWeightInfo::service_agenda_base(1) +461 <TestWeightInfo as MarginalWeightInfo>::service_task(None, true, true) +462 TestWeightInfo::execute_dispatch_unsigned() +463 call_weight + Weight::from_ref_time(4)464 );465 assert_eq!(IncompleteSince::<Test>::get(), None);466 assert_eq!(logger::log(), vec![(root(), 2600u32)]);467468 // Will include anon and anon periodic469 assert_eq!(470 Scheduler::on_initialize(2),471 TestWeightInfo::service_agendas_base() +472 TestWeightInfo::service_agenda_base(2) +473 <TestWeightInfo as MarginalWeightInfo>::service_task(None, false, true) +474 TestWeightInfo::execute_dispatch_unsigned() +475 call_weight + Weight::from_ref_time(3) +476 <TestWeightInfo as MarginalWeightInfo>::service_task(None, false, false) +477 TestWeightInfo::execute_dispatch_unsigned() +478 call_weight + Weight::from_ref_time(2)479 );480 assert_eq!(IncompleteSince::<Test>::get(), None);481 assert_eq!(logger::log(), vec![(root(), 2600u32), (root(), 69u32), (root(), 42u32)]);482483 // Will include named only484 assert_eq!(485 Scheduler::on_initialize(3),486 TestWeightInfo::service_agendas_base() +487 TestWeightInfo::service_agenda_base(1) +488 <TestWeightInfo as MarginalWeightInfo>::service_task(None, true, false) +489 TestWeightInfo::execute_dispatch_unsigned() +490 call_weight + Weight::from_ref_time(1)491 );492 assert_eq!(IncompleteSince::<Test>::get(), None);493 assert_eq!(494 logger::log(),495 vec![(root(), 2600u32), (root(), 69u32), (root(), 42u32), (root(), 3u32)]496 );497498 // Will contain none499 let actual_weight = Scheduler::on_initialize(4);500 assert_eq!(501 actual_weight,502 TestWeightInfo::service_agendas_base() + TestWeightInfo::service_agenda_base(0)503 );504 });505}506507#[test]508fn root_calls_works() {509 new_test_ext().execute_with(|| {510 let call = Box::new(RuntimeCall::Logger(LoggerCall::log {511 i: 69,512 weight: Weight::from_ref_time(10),513 }));514 let call2 = Box::new(RuntimeCall::Logger(LoggerCall::log {515 i: 42,516 weight: Weight::from_ref_time(10),517 }));518 assert_ok!(519 Scheduler::schedule_named(RuntimeOrigin::root(), [1u8; 32], 4, None, Some(127), call,)520 );521 assert_ok!(Scheduler::schedule(RuntimeOrigin::root(), 4, None, Some(127), call2));522 run_to_block(3);523 // Scheduled calls are in the agenda.524 assert_eq!(Agenda::<Test>::get(4).len(), 2);525 assert!(logger::log().is_empty());526 assert_ok!(Scheduler::cancel_named(RuntimeOrigin::root(), [1u8; 32]));527 assert_ok!(Scheduler::cancel(RuntimeOrigin::root(), 4, 1));528 // Scheduled calls are made NONE, so should not effect state529 run_to_block(100);530 assert!(logger::log().is_empty());531 });532}533534#[test]535fn fails_to_schedule_task_in_the_past() {536 new_test_ext().execute_with(|| {537 run_to_block(3);538539 let call1 = Box::new(RuntimeCall::Logger(LoggerCall::log {540 i: 69,541 weight: Weight::from_ref_time(10),542 }));543 let call2 = Box::new(RuntimeCall::Logger(LoggerCall::log {544 i: 42,545 weight: Weight::from_ref_time(10),546 }));547 let call3 = Box::new(RuntimeCall::Logger(LoggerCall::log {548 i: 42,549 weight: Weight::from_ref_time(10),550 }));551552 assert_noop!(553 Scheduler::schedule_named(RuntimeOrigin::root(), [1u8; 32], 2, None, Some(127), call1),554 Error::<Test>::TargetBlockNumberInPast,555 );556557 assert_noop!(558 Scheduler::schedule(RuntimeOrigin::root(), 2, None, Some(127), call2),559 Error::<Test>::TargetBlockNumberInPast,560 );561562 assert_noop!(563 Scheduler::schedule(RuntimeOrigin::root(), 3, None, Some(127), call3),564 Error::<Test>::TargetBlockNumberInPast,565 );566 });567}568569#[test]570fn should_use_origin() {571 new_test_ext().execute_with(|| {572 let call = Box::new(RuntimeCall::Logger(LoggerCall::log {573 i: 69,574 weight: Weight::from_ref_time(10),575 }));576 let call2 = Box::new(RuntimeCall::Logger(LoggerCall::log {577 i: 42,578 weight: Weight::from_ref_time(10),579 }));580 assert_ok!(Scheduler::schedule_named(581 system::RawOrigin::Signed(1).into(),582 [1u8; 32],583 4,584 None,585 None,586 call,587 ));588 assert_ok!(Scheduler::schedule(system::RawOrigin::Signed(1).into(), 4, None, None, call2,));589 run_to_block(3);590 // Scheduled calls are in the agenda.591 assert_eq!(Agenda::<Test>::get(4).len(), 2);592 assert!(logger::log().is_empty());593 assert_ok!(Scheduler::cancel_named(system::RawOrigin::Signed(1).into(), [1u8; 32]));594 assert_ok!(Scheduler::cancel(system::RawOrigin::Signed(1).into(), 4, 1));595 // Scheduled calls are made NONE, so should not effect state596 run_to_block(100);597 assert!(logger::log().is_empty());598 });599}600601#[test]602fn should_check_origin() {603 new_test_ext().execute_with(|| {604 let call = Box::new(RuntimeCall::Logger(LoggerCall::log {605 i: 69,606 weight: Weight::from_ref_time(10),607 }));608 let call2 = Box::new(RuntimeCall::Logger(LoggerCall::log {609 i: 42,610 weight: Weight::from_ref_time(10),611 }));612 assert_noop!(613 Scheduler::schedule_named(614 system::RawOrigin::Signed(2).into(),615 [1u8; 32],616 4,617 None,618 None,619 call620 ),621 BadOrigin622 );623 assert_noop!(624 Scheduler::schedule(system::RawOrigin::Signed(2).into(), 4, None, None, call2),625 BadOrigin626 );627 });628}629630#[test]631fn should_check_origin_for_cancel() {632 new_test_ext().execute_with(|| {633 let call = Box::new(RuntimeCall::Logger(LoggerCall::log_without_filter {634 i: 69,635 weight: Weight::from_ref_time(10),636 }));637 let call2 = Box::new(RuntimeCall::Logger(LoggerCall::log_without_filter {638 i: 42,639 weight: Weight::from_ref_time(10),640 }));641 assert_ok!(Scheduler::schedule_named(642 system::RawOrigin::Signed(1).into(),643 [1u8; 32],644 4,645 None,646 None,647 call,648 ));649 assert_ok!(Scheduler::schedule(system::RawOrigin::Signed(1).into(), 4, None, None, call2,));650 run_to_block(3);651 // Scheduled calls are in the agenda.652 assert_eq!(Agenda::<Test>::get(4).len(), 2);653 assert!(logger::log().is_empty());654 assert_noop!(655 Scheduler::cancel_named(system::RawOrigin::Signed(2).into(), [1u8; 32]),656 BadOrigin657 );658 assert_noop!(Scheduler::cancel(system::RawOrigin::Signed(2).into(), 4, 1), BadOrigin);659 assert_noop!(Scheduler::cancel_named(system::RawOrigin::Root.into(), [1u8; 32]), BadOrigin);660 assert_noop!(Scheduler::cancel(system::RawOrigin::Root.into(), 4, 1), BadOrigin);661 run_to_block(5);662 assert_eq!(663 logger::log(),664 vec![665 (system::RawOrigin::Signed(1).into(), 69u32),666 (system::RawOrigin::Signed(1).into(), 42u32)667 ]668 );669 });670}671672/// Cancelling a call and then scheduling a second call for the same673/// block results in different addresses.674#[test]675fn schedule_does_not_resuse_addr() {676 new_test_ext().execute_with(|| {677 let call =678 RuntimeCall::Logger(LoggerCall::log { i: 42, weight: Weight::from_ref_time(10) });679680 // Schedule both calls.681 let addr_1 = Scheduler::do_schedule(682 DispatchTime::At(4),683 None,684 127,685 root(),686 <ScheduledCall<Test>>::new(call.clone()).unwrap(),687 )688 .unwrap();689 // Cancel the call.690 assert_ok!(Scheduler::do_cancel(None, addr_1));691 let addr_2 = Scheduler::do_schedule(692 DispatchTime::At(4),693 None,694 127,695 root(),696 <ScheduledCall<Test>>::new(call).unwrap(),697 )698 .unwrap();699700 // Should not re-use the address.701 assert!(addr_1 != addr_2);702 });703}704705#[test]706fn schedule_agenda_overflows() {707 let max: u32 = <Test as Config>::MaxScheduledPerBlock::get();708709 new_test_ext().execute_with(|| {710 let call =711 RuntimeCall::Logger(LoggerCall::log { i: 42, weight: Weight::from_ref_time(10) });712 let call = <ScheduledCall<Test>>::new(call).unwrap();713714 // Schedule the maximal number allowed per block.715 for _ in 0..max {716 Scheduler::do_schedule(717 DispatchTime::At(4),718 None,719 127,720 root(),721 call.clone(),722 )723 .unwrap();724 }725726 // One more time and it errors.727 assert_noop!(728 Scheduler::do_schedule(DispatchTime::At(4), None, 127, root(), call,),729 <Error<Test>>::AgendaIsExhausted,730 );731732 run_to_block(4);733 // All scheduled calls are executed.734 assert_eq!(logger::log().len() as u32, max);735 });736}737738/// Cancelling and scheduling does not overflow the agenda but fills holes.739#[test]740fn cancel_and_schedule_fills_holes() {741 let max: u32 = <Test as Config>::MaxScheduledPerBlock::get();742 assert!(max > 3, "This test only makes sense for MaxScheduledPerBlock > 3");743744 new_test_ext().execute_with(|| {745 let call =746 RuntimeCall::Logger(LoggerCall::log { i: 42, weight: Weight::from_ref_time(10) });747 let call = <ScheduledCall<Test>>::new(call).unwrap();748 let mut addrs = Vec::<_>::default();749750 // Schedule the maximal number allowed per block.751 for _ in 0..max {752 addrs.push(753 Scheduler::do_schedule(754 DispatchTime::At(4),755 None,756 127,757 root(),758 call.clone(),759 )760 .unwrap(),761 );762 }763 // Cancel three of them.764 for addr in addrs.into_iter().take(3) {765 Scheduler::do_cancel(None, addr).unwrap();766 }767 // Schedule three new ones.768 for i in 0..3 {769 let (_block, index) = Scheduler::do_schedule(770 DispatchTime::At(4),771 None,772 127,773 root(),774 call.clone(),775 )776 .unwrap();777 assert_eq!(i, index);778 }779780 run_to_block(4);781 // Maximum number of calls are executed.782 assert_eq!(logger::log().len() as u32, max);783 });784}1// Copyright 2019-2022 Unique Network (Gibraltar) Ltd.2// This file is part of Unique Network.34// Unique Network is free software: you can redistribute it and/or modify5// it under the terms of the GNU General Public License as published by6// the Free Software Foundation, either version 3 of the License, or7// (at your option) any later version.89// Unique Network is distributed in the hope that it will be useful,10// but WITHOUT ANY WARRANTY; without even the implied warranty of11// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the12// GNU General Public License for more details.1314// You should have received a copy of the GNU General Public License15// along with Unique Network. If not, see <http://www.gnu.org/licenses/>.1617// Original license:18// This file is part of Substrate.1920// Copyright (C) 2017-2022 Parity Technologies (UK) Ltd.21// SPDX-License-Identifier: Apache-2.02223// Licensed under the Apache License, Version 2.0 (the "License");24// you may not use this file except in compliance with the License.25// You may obtain a copy of the License at26//27// http://www.apache.org/licenses/LICENSE-2.028//29// Unless required by applicable law or agreed to in writing, software30// distributed under the License is distributed on an "AS IS" BASIS,31// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.32// See the License for the specific language governing permissions and33// limitations under the License.3435//! # Scheduler tests.3637use super::*;38use crate::mock::{39 logger, new_test_ext, root, run_to_block, LoggerCall, RuntimeCall, Scheduler, Test, *,40};41use frame_support::{42 assert_noop, assert_ok,43 traits::{Contains, OnInitialize},44};4546#[test]47fn basic_scheduling_works() {48 new_test_ext().execute_with(|| {49 let call = RuntimeCall::Logger(LoggerCall::log {50 i: 42,51 weight: Weight::from_ref_time(10),52 });53 assert!(!<Test as frame_system::Config>::BaseCallFilter::contains(54 &call55 ));56 assert_ok!(Scheduler::do_schedule(57 DispatchTime::At(4),58 None,59 127,60 root(),61 <ScheduledCall<Test>>::new(call).unwrap(),62 ));63 run_to_block(3);64 assert!(logger::log().is_empty());65 run_to_block(4);66 assert_eq!(logger::log(), vec![(root(), 42u32)]);67 run_to_block(100);68 assert_eq!(logger::log(), vec![(root(), 42u32)]);69 });70}7172#[test]73fn schedule_after_works() {74 new_test_ext().execute_with(|| {75 run_to_block(2);76 let call = RuntimeCall::Logger(LoggerCall::log {77 i: 42,78 weight: Weight::from_ref_time(10),79 });80 assert!(!<Test as frame_system::Config>::BaseCallFilter::contains(81 &call82 ));83 // This will schedule the call 3 blocks after the next block... so block 3 + 3 = 684 assert_ok!(Scheduler::do_schedule(85 DispatchTime::After(3),86 None,87 127,88 root(),89 <ScheduledCall<Test>>::new(call).unwrap(),90 ));91 run_to_block(5);92 assert!(logger::log().is_empty());93 run_to_block(6);94 assert_eq!(logger::log(), vec![(root(), 42u32)]);95 run_to_block(100);96 assert_eq!(logger::log(), vec![(root(), 42u32)]);97 });98}99100#[test]101fn schedule_after_zero_works() {102 new_test_ext().execute_with(|| {103 run_to_block(2);104 let call = RuntimeCall::Logger(LoggerCall::log {105 i: 42,106 weight: Weight::from_ref_time(10),107 });108 assert!(!<Test as frame_system::Config>::BaseCallFilter::contains(109 &call110 ));111 assert_ok!(Scheduler::do_schedule(112 DispatchTime::After(0),113 None,114 127,115 root(),116 <ScheduledCall<Test>>::new(call).unwrap(),117 ));118 // Will trigger on the next block.119 run_to_block(3);120 assert_eq!(logger::log(), vec![(root(), 42u32)]);121 run_to_block(100);122 assert_eq!(logger::log(), vec![(root(), 42u32)]);123 });124}125126#[test]127fn periodic_scheduling_works() {128 new_test_ext().execute_with(|| {129 // at #4, every 3 blocks, 3 times.130 assert_ok!(Scheduler::do_schedule(131 DispatchTime::At(4),132 Some((3, 3)),133 127,134 root(),135 <ScheduledCall<Test>>::new(RuntimeCall::Logger(logger::Call::log {136 i: 42,137 weight: Weight::from_ref_time(10)138 }))139 .unwrap()140 ));141 run_to_block(3);142 assert!(logger::log().is_empty());143 run_to_block(4);144 assert_eq!(logger::log(), vec![(root(), 42u32)]);145 run_to_block(6);146 assert_eq!(logger::log(), vec![(root(), 42u32)]);147 run_to_block(7);148 assert_eq!(logger::log(), vec![(root(), 42u32), (root(), 42u32)]);149 run_to_block(9);150 assert_eq!(logger::log(), vec![(root(), 42u32), (root(), 42u32)]);151 run_to_block(10);152 assert_eq!(153 logger::log(),154 vec![(root(), 42u32), (root(), 42u32), (root(), 42u32)]155 );156 run_to_block(100);157 assert_eq!(158 logger::log(),159 vec![(root(), 42u32), (root(), 42u32), (root(), 42u32)]160 );161 });162}163164#[test]165fn cancel_named_scheduling_works_with_normal_cancel() {166 new_test_ext().execute_with(|| {167 // at #4.168 Scheduler::do_schedule_named(169 [1u8; 32],170 DispatchTime::At(4),171 None,172 127,173 root(),174 <ScheduledCall<Test>>::new(RuntimeCall::Logger(LoggerCall::log {175 i: 69,176 weight: Weight::from_ref_time(10),177 }))178 .unwrap(),179 )180 .unwrap();181 let i = Scheduler::do_schedule(182 DispatchTime::At(4),183 None,184 127,185 root(),186 <ScheduledCall<Test>>::new(RuntimeCall::Logger(LoggerCall::log {187 i: 42,188 weight: Weight::from_ref_time(10),189 }))190 .unwrap(),191 )192 .unwrap();193 run_to_block(3);194 assert!(logger::log().is_empty());195 assert_ok!(Scheduler::do_cancel_named(None, [1u8; 32]));196 assert_ok!(Scheduler::do_cancel(None, i));197 run_to_block(100);198 assert!(logger::log().is_empty());199 });200}201202#[test]203fn cancel_named_periodic_scheduling_works() {204 new_test_ext().execute_with(|| {205 // at #4, every 3 blocks, 3 times.206 Scheduler::do_schedule_named(207 [1u8; 32],208 DispatchTime::At(4),209 Some((3, 3)),210 127,211 root(),212 <ScheduledCall<Test>>::new(RuntimeCall::Logger(LoggerCall::log {213 i: 42,214 weight: Weight::from_ref_time(10),215 }))216 .unwrap(),217 )218 .unwrap();219 // same id results in error.220 assert!(Scheduler::do_schedule_named(221 [1u8; 32],222 DispatchTime::At(4),223 None,224 127,225 root(),226 <ScheduledCall<Test>>::new(RuntimeCall::Logger(LoggerCall::log {227 i: 69,228 weight: Weight::from_ref_time(10)229 }))230 .unwrap(),231 )232 .is_err());233 // different id is ok.234 Scheduler::do_schedule_named(235 [2u8; 32],236 DispatchTime::At(8),237 None,238 127,239 root(),240 <ScheduledCall<Test>>::new(RuntimeCall::Logger(LoggerCall::log {241 i: 69,242 weight: Weight::from_ref_time(10),243 }))244 .unwrap(),245 )246 .unwrap();247 run_to_block(3);248 assert!(logger::log().is_empty());249 run_to_block(4);250 assert_eq!(logger::log(), vec![(root(), 42u32)]);251 run_to_block(6);252 assert_ok!(Scheduler::do_cancel_named(None, [1u8; 32]));253 run_to_block(100);254 assert_eq!(logger::log(), vec![(root(), 42u32), (root(), 69u32)]);255 });256}257258#[test]259fn scheduler_respects_weight_limits() {260 let max_weight: Weight = <Test as Config>::MaximumWeight::get();261 new_test_ext().execute_with(|| {262 let call = RuntimeCall::Logger(LoggerCall::log {263 i: 42,264 weight: max_weight / 3 * 2,265 });266 assert_ok!(Scheduler::do_schedule(267 DispatchTime::At(4),268 None,269 127,270 root(),271 <ScheduledCall<Test>>::new(call).unwrap(),272 ));273 let call = RuntimeCall::Logger(LoggerCall::log {274 i: 69,275 weight: max_weight / 3 * 2,276 });277 assert_ok!(Scheduler::do_schedule(278 DispatchTime::At(4),279 None,280 127,281 root(),282 <ScheduledCall<Test>>::new(call).unwrap(),283 ));284 // 69 and 42 do not fit together285 run_to_block(4);286 assert_eq!(logger::log(), vec![(root(), 42u32)]);287 run_to_block(5);288 assert_eq!(logger::log(), vec![(root(), 42u32), (root(), 69u32)]);289 });290}291292/// Permanently overweight calls are not deleted but also not executed.293#[test]294fn scheduler_does_not_delete_permanently_overweight_call() {295 let max_weight: Weight = <Test as Config>::MaximumWeight::get();296 new_test_ext().execute_with(|| {297 let call = RuntimeCall::Logger(LoggerCall::log {298 i: 42,299 weight: max_weight,300 });301 assert_ok!(Scheduler::do_schedule(302 DispatchTime::At(4),303 None,304 127,305 root(),306 <ScheduledCall<Test>>::new(call).unwrap(),307 ));308 // Never executes.309 run_to_block(100);310 assert_eq!(logger::log(), vec![]);311312 // Assert the `PermanentlyOverweight` event.313 assert_eq!(314 System::events().last().unwrap().event,315 crate::Event::PermanentlyOverweight {316 task: (4, 0),317 id: None318 }319 .into(),320 );321 // The call is still in the agenda.322 assert!(Agenda::<Test>::get(4)[0].is_some());323 });324}325326#[test]327fn scheduler_handles_periodic_failure() {328 let max_weight: Weight = <Test as Config>::MaximumWeight::get();329 let max_per_block = <Test as Config>::MaxScheduledPerBlock::get();330331 new_test_ext().execute_with(|| {332 let call = RuntimeCall::Logger(LoggerCall::log {333 i: 42,334 weight: (max_weight / 3) * 2,335 });336 let call = <ScheduledCall<Test>>::new(call).unwrap();337338 assert_ok!(Scheduler::do_schedule(339 DispatchTime::At(4),340 Some((4, u32::MAX)),341 127,342 root(),343 call.clone(),344 ));345 // Executes 5 times till block 20.346 run_to_block(20);347 assert_eq!(logger::log().len(), 5);348349 // Block 28 will already be full.350 for _ in 0..max_per_block {351 assert_ok!(Scheduler::do_schedule(352 DispatchTime::At(28),353 None,354 120,355 root(),356 call.clone(),357 ));358 }359360 // Going to block 24 will emit a `PeriodicFailed` event.361 run_to_block(24);362 assert_eq!(logger::log().len(), 6);363364 assert_eq!(365 System::events().last().unwrap().event,366 crate::Event::PeriodicFailed {367 task: (24, 0),368 id: None369 }370 .into(),371 );372 });373}374375#[test]376fn scheduler_respects_priority_ordering() {377 let max_weight: Weight = <Test as Config>::MaximumWeight::get();378 new_test_ext().execute_with(|| {379 let call = RuntimeCall::Logger(LoggerCall::log {380 i: 42,381 weight: max_weight / 3,382 });383 assert_ok!(Scheduler::do_schedule(384 DispatchTime::At(4),385 None,386 1,387 root(),388 <ScheduledCall<Test>>::new(call).unwrap(),389 ));390 let call = RuntimeCall::Logger(LoggerCall::log {391 i: 69,392 weight: max_weight / 3,393 });394 assert_ok!(Scheduler::do_schedule(395 DispatchTime::At(4),396 None,397 0,398 root(),399 <ScheduledCall<Test>>::new(call).unwrap(),400 ));401 run_to_block(4);402 assert_eq!(logger::log(), vec![(root(), 69u32), (root(), 42u32)]);403 });404}405406#[test]407fn scheduler_respects_priority_ordering_with_soft_deadlines() {408 new_test_ext().execute_with(|| {409 let max_weight: Weight = <Test as Config>::MaximumWeight::get();410 let call = RuntimeCall::Logger(LoggerCall::log {411 i: 42,412 weight: max_weight / 5 * 2,413 });414 assert_ok!(Scheduler::do_schedule(415 DispatchTime::At(4),416 None,417 255,418 root(),419 <ScheduledCall<Test>>::new(call).unwrap(),420 ));421 let call = RuntimeCall::Logger(LoggerCall::log {422 i: 69,423 weight: max_weight / 5 * 2,424 });425 assert_ok!(Scheduler::do_schedule(426 DispatchTime::At(4),427 None,428 127,429 root(),430 <ScheduledCall<Test>>::new(call).unwrap(),431 ));432 let call = RuntimeCall::Logger(LoggerCall::log {433 i: 2600,434 weight: max_weight / 5 * 4,435 });436 assert_ok!(Scheduler::do_schedule(437 DispatchTime::At(4),438 None,439 126,440 root(),441 <ScheduledCall<Test>>::new(call).unwrap(),442 ));443444 // 2600 does not fit with 69 or 42, but has higher priority, so will go through445 run_to_block(4);446 assert_eq!(logger::log(), vec![(root(), 2600u32)]);447 // 69 and 42 fit together448 run_to_block(5);449 assert_eq!(450 logger::log(),451 vec![(root(), 2600u32), (root(), 69u32), (root(), 42u32)]452 );453 });454}455456#[test]457fn on_initialize_weight_is_correct() {458 new_test_ext().execute_with(|| {459 let call_weight = Weight::from_ref_time(25);460461 // Named462 let call = RuntimeCall::Logger(LoggerCall::log {463 i: 3,464 weight: call_weight + Weight::from_ref_time(1),465 });466 assert_ok!(Scheduler::do_schedule_named(467 [1u8; 32],468 DispatchTime::At(3),469 None,470 255,471 root(),472 <ScheduledCall<Test>>::new(call).unwrap(),473 ));474 let call = RuntimeCall::Logger(LoggerCall::log {475 i: 42,476 weight: call_weight + Weight::from_ref_time(2),477 });478 // Anon Periodic479 assert_ok!(Scheduler::do_schedule(480 DispatchTime::At(2),481 Some((1000, 3)),482 128,483 root(),484 <ScheduledCall<Test>>::new(call).unwrap(),485 ));486 let call = RuntimeCall::Logger(LoggerCall::log {487 i: 69,488 weight: call_weight + Weight::from_ref_time(3),489 });490 // Anon491 assert_ok!(Scheduler::do_schedule(492 DispatchTime::At(2),493 None,494 127,495 root(),496 <ScheduledCall<Test>>::new(call).unwrap(),497 ));498 // Named Periodic499 let call = RuntimeCall::Logger(LoggerCall::log {500 i: 2600,501 weight: call_weight + Weight::from_ref_time(4),502 });503 assert_ok!(Scheduler::do_schedule_named(504 [2u8; 32],505 DispatchTime::At(1),506 Some((1000, 3)),507 126,508 root(),509 <ScheduledCall<Test>>::new(call).unwrap(),510 ));511512 // Will include the named periodic only513 assert_eq!(514 Scheduler::on_initialize(1),515 TestWeightInfo::service_agendas_base()516 + TestWeightInfo::service_agenda_base(1)517 + <TestWeightInfo as MarginalWeightInfo>::service_task(None, true, true)518 + TestWeightInfo::execute_dispatch_unsigned()519 + call_weight + Weight::from_ref_time(4)520 );521 assert_eq!(IncompleteSince::<Test>::get(), None);522 assert_eq!(logger::log(), vec![(root(), 2600u32)]);523524 // Will include anon and anon periodic525 assert_eq!(526 Scheduler::on_initialize(2),527 TestWeightInfo::service_agendas_base()528 + TestWeightInfo::service_agenda_base(2)529 + <TestWeightInfo as MarginalWeightInfo>::service_task(None, false, true)530 + TestWeightInfo::execute_dispatch_unsigned()531 + call_weight + Weight::from_ref_time(3)532 + <TestWeightInfo as MarginalWeightInfo>::service_task(None, false, false)533 + TestWeightInfo::execute_dispatch_unsigned()534 + call_weight + Weight::from_ref_time(2)535 );536 assert_eq!(IncompleteSince::<Test>::get(), None);537 assert_eq!(538 logger::log(),539 vec![(root(), 2600u32), (root(), 69u32), (root(), 42u32)]540 );541542 // Will include named only543 assert_eq!(544 Scheduler::on_initialize(3),545 TestWeightInfo::service_agendas_base()546 + TestWeightInfo::service_agenda_base(1)547 + <TestWeightInfo as MarginalWeightInfo>::service_task(None, true, false)548 + TestWeightInfo::execute_dispatch_unsigned()549 + call_weight + Weight::from_ref_time(1)550 );551 assert_eq!(IncompleteSince::<Test>::get(), None);552 assert_eq!(553 logger::log(),554 vec![555 (root(), 2600u32),556 (root(), 69u32),557 (root(), 42u32),558 (root(), 3u32)559 ]560 );561562 // Will contain none563 let actual_weight = Scheduler::on_initialize(4);564 assert_eq!(565 actual_weight,566 TestWeightInfo::service_agendas_base() + TestWeightInfo::service_agenda_base(0)567 );568 });569}570571#[test]572fn root_calls_works() {573 new_test_ext().execute_with(|| {574 let call = Box::new(RuntimeCall::Logger(LoggerCall::log {575 i: 69,576 weight: Weight::from_ref_time(10),577 }));578 let call2 = Box::new(RuntimeCall::Logger(LoggerCall::log {579 i: 42,580 weight: Weight::from_ref_time(10),581 }));582 assert_ok!(Scheduler::schedule_named(583 RuntimeOrigin::root(),584 [1u8; 32],585 4,586 None,587 Some(127),588 call,589 ));590 assert_ok!(Scheduler::schedule(591 RuntimeOrigin::root(),592 4,593 None,594 Some(127),595 call2596 ));597 run_to_block(3);598 // Scheduled calls are in the agenda.599 assert_eq!(Agenda::<Test>::get(4).len(), 2);600 assert!(logger::log().is_empty());601 assert_ok!(Scheduler::cancel_named(RuntimeOrigin::root(), [1u8; 32]));602 assert_ok!(Scheduler::cancel(RuntimeOrigin::root(), 4, 1));603 // Scheduled calls are made NONE, so should not effect state604 run_to_block(100);605 assert!(logger::log().is_empty());606 });607}608609#[test]610fn fails_to_schedule_task_in_the_past() {611 new_test_ext().execute_with(|| {612 run_to_block(3);613614 let call1 = Box::new(RuntimeCall::Logger(LoggerCall::log {615 i: 69,616 weight: Weight::from_ref_time(10),617 }));618 let call2 = Box::new(RuntimeCall::Logger(LoggerCall::log {619 i: 42,620 weight: Weight::from_ref_time(10),621 }));622 let call3 = Box::new(RuntimeCall::Logger(LoggerCall::log {623 i: 42,624 weight: Weight::from_ref_time(10),625 }));626627 assert_noop!(628 Scheduler::schedule_named(RuntimeOrigin::root(), [1u8; 32], 2, None, Some(127), call1),629 Error::<Test>::TargetBlockNumberInPast,630 );631632 assert_noop!(633 Scheduler::schedule(RuntimeOrigin::root(), 2, None, Some(127), call2),634 Error::<Test>::TargetBlockNumberInPast,635 );636637 assert_noop!(638 Scheduler::schedule(RuntimeOrigin::root(), 3, None, Some(127), call3),639 Error::<Test>::TargetBlockNumberInPast,640 );641 });642}643644#[test]645fn should_use_origin() {646 new_test_ext().execute_with(|| {647 let call = Box::new(RuntimeCall::Logger(LoggerCall::log {648 i: 69,649 weight: Weight::from_ref_time(10),650 }));651 let call2 = Box::new(RuntimeCall::Logger(LoggerCall::log {652 i: 42,653 weight: Weight::from_ref_time(10),654 }));655 assert_ok!(Scheduler::schedule_named(656 system::RawOrigin::Signed(1).into(),657 [1u8; 32],658 4,659 None,660 None,661 call,662 ));663 assert_ok!(Scheduler::schedule(664 system::RawOrigin::Signed(1).into(),665 4,666 None,667 None,668 call2,669 ));670 run_to_block(3);671 // Scheduled calls are in the agenda.672 assert_eq!(Agenda::<Test>::get(4).len(), 2);673 assert!(logger::log().is_empty());674 assert_ok!(Scheduler::cancel_named(675 system::RawOrigin::Signed(1).into(),676 [1u8; 32]677 ));678 assert_ok!(Scheduler::cancel(system::RawOrigin::Signed(1).into(), 4, 1));679 // Scheduled calls are made NONE, so should not effect state680 run_to_block(100);681 assert!(logger::log().is_empty());682 });683}684685#[test]686fn should_check_origin() {687 new_test_ext().execute_with(|| {688 let call = Box::new(RuntimeCall::Logger(LoggerCall::log {689 i: 69,690 weight: Weight::from_ref_time(10),691 }));692 let call2 = Box::new(RuntimeCall::Logger(LoggerCall::log {693 i: 42,694 weight: Weight::from_ref_time(10),695 }));696 assert_noop!(697 Scheduler::schedule_named(698 system::RawOrigin::Signed(2).into(),699 [1u8; 32],700 4,701 None,702 None,703 call704 ),705 BadOrigin706 );707 assert_noop!(708 Scheduler::schedule(system::RawOrigin::Signed(2).into(), 4, None, None, call2),709 BadOrigin710 );711 });712}713714#[test]715fn should_check_origin_for_cancel() {716 new_test_ext().execute_with(|| {717 let call = Box::new(RuntimeCall::Logger(LoggerCall::log_without_filter {718 i: 69,719 weight: Weight::from_ref_time(10),720 }));721 let call2 = Box::new(RuntimeCall::Logger(LoggerCall::log_without_filter {722 i: 42,723 weight: Weight::from_ref_time(10),724 }));725 assert_ok!(Scheduler::schedule_named(726 system::RawOrigin::Signed(1).into(),727 [1u8; 32],728 4,729 None,730 None,731 call,732 ));733 assert_ok!(Scheduler::schedule(734 system::RawOrigin::Signed(1).into(),735 4,736 None,737 None,738 call2,739 ));740 run_to_block(3);741 // Scheduled calls are in the agenda.742 assert_eq!(Agenda::<Test>::get(4).len(), 2);743 assert!(logger::log().is_empty());744 assert_noop!(745 Scheduler::cancel_named(system::RawOrigin::Signed(2).into(), [1u8; 32]),746 BadOrigin747 );748 assert_noop!(749 Scheduler::cancel(system::RawOrigin::Signed(2).into(), 4, 1),750 BadOrigin751 );752 assert_noop!(753 Scheduler::cancel_named(system::RawOrigin::Root.into(), [1u8; 32]),754 BadOrigin755 );756 assert_noop!(757 Scheduler::cancel(system::RawOrigin::Root.into(), 4, 1),758 BadOrigin759 );760 run_to_block(5);761 assert_eq!(762 logger::log(),763 vec![764 (system::RawOrigin::Signed(1).into(), 69u32),765 (system::RawOrigin::Signed(1).into(), 42u32)766 ]767 );768 });769}770771/// Cancelling a call and then scheduling a second call for the same772/// block results in different addresses.773#[test]774fn schedule_does_not_resuse_addr() {775 new_test_ext().execute_with(|| {776 let call = RuntimeCall::Logger(LoggerCall::log {777 i: 42,778 weight: Weight::from_ref_time(10),779 });780781 // Schedule both calls.782 let addr_1 = Scheduler::do_schedule(783 DispatchTime::At(4),784 None,785 127,786 root(),787 <ScheduledCall<Test>>::new(call.clone()).unwrap(),788 )789 .unwrap();790 // Cancel the call.791 assert_ok!(Scheduler::do_cancel(None, addr_1));792 let addr_2 = Scheduler::do_schedule(793 DispatchTime::At(4),794 None,795 127,796 root(),797 <ScheduledCall<Test>>::new(call).unwrap(),798 )799 .unwrap();800801 // Should not re-use the address.802 assert!(addr_1 != addr_2);803 });804}805806#[test]807fn schedule_agenda_overflows() {808 let max: u32 = <Test as Config>::MaxScheduledPerBlock::get();809810 new_test_ext().execute_with(|| {811 let call = RuntimeCall::Logger(LoggerCall::log {812 i: 42,813 weight: Weight::from_ref_time(10),814 });815 let call = <ScheduledCall<Test>>::new(call).unwrap();816817 // Schedule the maximal number allowed per block.818 for _ in 0..max {819 Scheduler::do_schedule(DispatchTime::At(4), None, 127, root(), call.clone()).unwrap();820 }821822 // One more time and it errors.823 assert_noop!(824 Scheduler::do_schedule(DispatchTime::At(4), None, 127, root(), call,),825 <Error<Test>>::AgendaIsExhausted,826 );827828 run_to_block(4);829 // All scheduled calls are executed.830 assert_eq!(logger::log().len() as u32, max);831 });832}833834/// Cancelling and scheduling does not overflow the agenda but fills holes.835#[test]836fn cancel_and_schedule_fills_holes() {837 let max: u32 = <Test as Config>::MaxScheduledPerBlock::get();838 assert!(839 max > 3,840 "This test only makes sense for MaxScheduledPerBlock > 3"841 );842843 new_test_ext().execute_with(|| {844 let call = RuntimeCall::Logger(LoggerCall::log {845 i: 42,846 weight: Weight::from_ref_time(10),847 });848 let call = <ScheduledCall<Test>>::new(call).unwrap();849 let mut addrs = Vec::<_>::default();850851 // Schedule the maximal number allowed per block.852 for _ in 0..max {853 addrs.push(854 Scheduler::do_schedule(DispatchTime::At(4), None, 127, root(), call.clone())855 .unwrap(),856 );857 }858 // Cancel three of them.859 for addr in addrs.into_iter().take(3) {860 Scheduler::do_cancel(None, addr).unwrap();861 }862 // Schedule three new ones.863 for i in 0..3 {864 let (_block, index) =865 Scheduler::do_schedule(DispatchTime::At(4), None, 127, root(), call.clone())866 .unwrap();867 assert_eq!(i, index);868 }869870 run_to_block(4);871 // Maximum number of calls are executed.872 assert_eq!(logger::log().len() as u32, max);873 });874}runtime/common/scheduler.rsdiffbeforeafterboth--- a/runtime/common/scheduler.rs
+++ b/runtime/common/scheduler.rs
@@ -105,7 +105,6 @@
}
}
-
// impl<T: frame_system::Config + pallet_unique_scheduler::Config, SelfContainedSignedInfo>
// DispatchCall<T, SelfContainedSignedInfo> for SchedulerPaymentExecutor
// where