git.delta.rocks / unique-network / refs/commits / 90587283b7f1

difftreelog

fix cargo fmt

Daniel Shiposha2022-10-25parent: #829f2bc.patch.diff
in: master

4 files changed

modifiedpallets/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())
modifiedpallets/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()
 }
 
modifiedpallets/scheduler-v2/src/tests.rsdiffbeforeafterboth
before · pallets/scheduler-v2/src/tests.rs
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 =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}
after · pallets/scheduler-v2/src/tests.rs
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}
modifiedruntime/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