difftreelog
Fmt code style
in: master
1 file changed
pallets/scheduler/src/lib.rsdiffbeforeafterboth525253#[cfg(feature = "runtime-benchmarks")]53#[cfg(feature = "runtime-benchmarks")]54mod benchmarking;54mod benchmarking;55#[cfg(test)]5556mod mock;57#[cfg(test)]58mod tests;59pub mod weights;56pub mod weights;605761use codec::{Codec, Decode, Encode};58use codec::{Codec, Decode, Encode};138 fn item(periodic: bool, named: bool, resolved: Option<bool>) -> Weight {135 fn item(periodic: bool, named: bool, resolved: Option<bool>) -> Weight {139 match (periodic, named, resolved) {136 match (periodic, named, resolved) {140 (_, false, None) => Self::on_initialize_aborted(2) - Self::on_initialize_aborted(1),137 (_, false, None) => Self::on_initialize_aborted(2) - Self::on_initialize_aborted(1),141 (_, true, None) =>138 (_, true, None) => {142 Self::on_initialize_named_aborted(2) - Self::on_initialize_named_aborted(1),139 Self::on_initialize_named_aborted(2) - Self::on_initialize_named_aborted(1)140 }143 (false, false, Some(false)) => Self::on_initialize(2) - Self::on_initialize(1),141 (false, false, Some(false)) => Self::on_initialize(2) - Self::on_initialize(1),144 (false, true, Some(false)) =>142 (false, true, Some(false)) => {145 Self::on_initialize_named(2) - Self::on_initialize_named(1),143 Self::on_initialize_named(2) - Self::on_initialize_named(1)144 }146 (true, false, Some(false)) =>145 (true, false, Some(false)) => {147 Self::on_initialize_periodic(2) - Self::on_initialize_periodic(1),146 Self::on_initialize_periodic(2) - Self::on_initialize_periodic(1)147 }148 (true, true, Some(false)) =>148 (true, true, Some(false)) => {149 Self::on_initialize_periodic_named(2) - Self::on_initialize_periodic_named(1),149 Self::on_initialize_periodic_named(2) - Self::on_initialize_periodic_named(1)150 }150 (false, false, Some(true)) =>151 (false, false, Some(true)) => {151 Self::on_initialize_resolved(2) - Self::on_initialize_resolved(1),152 Self::on_initialize_resolved(2) - Self::on_initialize_resolved(1)153 }152 (false, true, Some(true)) =>154 (false, true, Some(true)) => {153 Self::on_initialize_named_resolved(2) - Self::on_initialize_named_resolved(1),155 Self::on_initialize_named_resolved(2) - Self::on_initialize_named_resolved(1)156 }154 (true, false, Some(true)) =>157 (true, false, Some(true)) => {155 Self::on_initialize_periodic_resolved(2) - Self::on_initialize_periodic_resolved(1),158 Self::on_initialize_periodic_resolved(2) - Self::on_initialize_periodic_resolved(1)159 }156 (true, true, Some(true)) =>160 (true, true, Some(true)) => {157 Self::on_initialize_periodic_named_resolved(2) -161 Self::on_initialize_periodic_named_resolved(2)158 Self::on_initialize_periodic_named_resolved(1),162 - Self::on_initialize_periodic_named_resolved(1)163 }159 }164 }160 }165 }161}166}371 }375 }372 Agenda::<T>::append(until, Some(s));376 Agenda::<T>::append(until, Some(s));373 }377 }374 continue378 continue;375 },379 }376 };380 };377381378 let periodic = s.maybe_periodic.is_some();382 let periodic = s.maybe_periodic.is_some();405 Lookup::<T>::insert(id, (next, index as u32));410 Lookup::<T>::insert(id, (next, index as u32));406 }411 }407 Agenda::<T>::append(next, Some(s));412 Agenda::<T>::append(next, Some(s));408 continue413 continue;409 }414 }410415411 let sender = ensure_signed(416 let sender = ensure_signed(412 <<T as Config>::Origin as From<T::PalletsOrigin>>::from(s.origin.clone()).into(),417 <<T as Config>::Origin as From<T::PalletsOrigin>>::from(s.origin.clone())418 .into(),413 ).unwrap();419 )420 .unwrap();414421415 // if call have id and periodic, it was be reserved 422 // if call have id and periodic, it was be reserved416 if s.maybe_id.is_some() && s.maybe_periodic.is_some()423 if s.maybe_id.is_some() && s.maybe_periodic.is_some() {417 {418 let _ = T::CallExecutor::pay_for_call(424 let _ = T::CallExecutor::pay_for_call(426432427 let mut actual_call_weight: Weight = item_weight; //PostDispatchInfo;433 let mut actual_call_weight: Weight = item_weight; //PostDispatchInfo;428 let result: Result<_, DispatchError> = match r {434 let result: Result<_, DispatchError> = match r {429 Ok(o) => { match o {435 Ok(o) => match o {430 Ok(di) => {436 Ok(di) => {431 actual_call_weight = di.actual_weight.unwrap_or(item_weight);437 actual_call_weight = di.actual_weight.unwrap_or(item_weight);432 Ok(())438 Ok(())433 },439 }434 Err(err) => Err(err.error),440 Err(err) => Err(err.error),435 }},441 },436 Err(_) => { 442 Err(_) => {437 log::info!(443 log::info!(438 target: "runtime::scheduler",444 target: "runtime::scheduler",642 };646 };643647644 if when <= now {648 if when <= now {645 return Err(Error::<T>::TargetBlockNumberInPast.into())649 return Err(Error::<T>::TargetBlockNumberInPast.into());646 }650 }647651648 Ok(when)652 Ok(when)691 T::OriginPrivilegeCmp::cmp_privilege(o, &s.origin),695 T::OriginPrivilegeCmp::cmp_privilege(o, &s.origin),692 Some(Ordering::Less) | None696 Some(Ordering::Less) | None693 ) {697 ) {694 return Err(BadOrigin.into())698 return Err(BadOrigin.into());695 }699 }696 };700 };697 Ok(s.take())701 Ok(s.take())717 let new_time = Self::resolve_time(new_time)?;721 let new_time = Self::resolve_time(new_time)?;718722719 if new_time == when {723 if new_time == when {720 return Err(Error::<T>::RescheduleNoChange.into())724 return Err(Error::<T>::RescheduleNoChange.into());721 }725 }722726723 Agenda::<T>::try_mutate(when, |agenda| -> DispatchResult {727 Agenda::<T>::try_mutate(when, |agenda| -> DispatchResult {731 Self::deposit_event(Event::Canceled { when, index });735 Self::deposit_event(Event::Canceled { when, index });732 Self::deposit_event(Event::Scheduled { when: new_time, index: new_index });736 Self::deposit_event(Event::Scheduled {737 when: new_time,738 index: new_index,739 });733740734 Ok((new_time, new_index))741 Ok((new_time, new_index))744 ) -> Result<TaskAddress<T::BlockNumber>, DispatchError> {751 ) -> Result<TaskAddress<T::BlockNumber>, DispatchError> {745 // ensure id it is unique752 // ensure id it is unique746 if Lookup::<T>::contains_key(&id) {753 if Lookup::<T>::contains_key(&id) {747 return Err(Error::<T>::FailedToSchedule)?754 return Err(Error::<T>::FailedToSchedule)?;748 }755 }749756750 let when = Self::resolve_time(when)?;757 let when = Self::resolve_time(when)?;766 _phantom: Default::default(),773 _phantom: Default::default(),767 };774 };768775769 // reserve balance for periodic execution 776 // reserve balance for periodic execution770 let sender = ensure_signed(777 let sender =771 <<T as Config>::Origin as From<T::PalletsOrigin>>::from(origin).into(),778 ensure_signed(<<T as Config>::Origin as From<T::PalletsOrigin>>::from(origin).into())?;772 )?;796 T::OriginPrivilegeCmp::cmp_privilege(o, &s.origin),807 T::OriginPrivilegeCmp::cmp_privilege(o, &s.origin),797 Some(Ordering::Less) | None808 Some(Ordering::Less) | None798 ) {809 ) {799 return Err(BadOrigin.into())810 return Err(BadOrigin.into());800 }811 }801 // release balance reserve812 // release balance reserve802 let sender = ensure_signed(813 let sender = ensure_signed(831 let (when, index) = lookup.ok_or(Error::<T>::NotFound)?;845 let (when, index) = lookup.ok_or(Error::<T>::NotFound)?;832846833 if new_time == when {847 if new_time == when {834 return Err(Error::<T>::RescheduleNoChange.into())848 return Err(Error::<T>::RescheduleNoChange.into());835 }849 }836850837 Agenda::<T>::try_mutate(when, |agenda| -> DispatchResult {851 Agenda::<T>::try_mutate(when, |agenda| -> DispatchResult {846 Self::deposit_event(Event::Canceled { when, index });860 Self::deposit_event(Event::Canceled { when, index });847 Self::deposit_event(Event::Scheduled { when: new_time, index: new_index });861 Self::deposit_event(Event::Scheduled {862 when: new_time,863 index: new_index,864 });848865849 *lookup = Some((new_time, new_index));866 *lookup = Some((new_time, new_index));