Skip to content
This repository has been archived by the owner on Nov 15, 2023. It is now read-only.

Fix fast-unstake for accounts with slashing #12963

Merged
merged 11 commits into from
Dec 23, 2022
14 changes: 8 additions & 6 deletions frame/fast-unstake/src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -91,7 +91,7 @@ pub mod pallet {
DispatchResult,
};
use sp_staking::{EraIndex, StakingInterface};
use sp_std::{prelude::*, vec::Vec};
use sp_std::{collections::btree_set::BTreeSet, prelude::*, vec::Vec};
pub use weights::WeightInfo;

#[derive(scale_info::TypeInfo, codec::Encode, codec::Decode, codec::MaxEncodedLen)]
Expand Down Expand Up @@ -429,9 +429,9 @@ pub mod pallet {
}
};

let check_stash = |stash, deposit, eras_checked: &mut u32| {
let check_stash = |stash, deposit, eras_checked: &mut BTreeSet<EraIndex>| {
let is_exposed = unchecked_eras_to_check.iter().any(|e| {
eras_checked.saturating_inc();
eras_checked.insert(*e);
T::Staking::is_exposed_in_era(&stash, e)
});

Expand All @@ -452,7 +452,7 @@ pub mod pallet {
<T as Config>::WeightInfo::on_idle_unstake()
} else {
// eras checked so far.
let mut eras_checked = 0u32;
let mut eras_checked = BTreeSet::<EraIndex>::new();

let pre_length = stashes.len();
let stashes: BoundedVec<(T::AccountId, BalanceOf<T>), T::BatchSize> = stashes
Expand All @@ -468,7 +468,7 @@ pub mod pallet {
log!(
debug,
"checked {:?} eras, pre stashes: {:?}, post: {:?}",
eras_checked,
eras_checked.len(),
pre_length,
post_length,
);
Expand All @@ -489,7 +489,9 @@ pub mod pallet {
},
}

<T as Config>::WeightInfo::on_idle_check(validator_count * eras_checked)
<T as Config>::WeightInfo::on_idle_check(
validator_count * eras_checked.len() as u32,
)
}
}
}
Expand Down
2 changes: 1 addition & 1 deletion frame/staking/src/pallet/impls.rs
Original file line number Diff line number Diff line change
Expand Up @@ -1569,7 +1569,7 @@ impl<T: Config> StakingInterface for Pallet<T> {
}

fn force_unstake(who: Self::AccountId) -> sp_runtime::DispatchResult {
let num_slashing_spans = Self::slashing_spans(&who).iter().count() as u32;
let num_slashing_spans = Self::slashing_spans(&who).map_or(0, |s| s.iter().count() as u32);
Self::force_unstake(RawOrigin::Root.into(), who.clone(), num_slashing_spans)
}

Expand Down
3 changes: 2 additions & 1 deletion frame/staking/src/pallet/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -982,7 +982,8 @@ pub mod pallet {
// `BondingDuration` to proceed with the unbonding.
let maybe_withdraw_weight = {
if unlocking == T::MaxUnlockingChunks::get() as usize {
let real_num_slashing_spans = Self::slashing_spans(&controller).iter().count();
let real_num_slashing_spans =
Self::slashing_spans(&controller).map_or(0, |s| s.iter().count());
Some(Self::do_withdraw_unbonded(&controller, real_num_slashing_spans as u32)?)
} else {
None
Expand Down
25 changes: 25 additions & 0 deletions frame/staking/src/tests.rs
Original file line number Diff line number Diff line change
Expand Up @@ -5725,3 +5725,28 @@ fn scale_validator_count_errors() {
);
})
}

mod staking_interface {
use frame_support::storage::with_storage_layer;
use sp_staking::StakingInterface;

use super::*;

#[test]
fn force_unstake_with_slash_works() {
ExtBuilder::default().build_and_execute(|| {
// without slash
let _ = with_storage_layer::<(), _, _>(|| {
// bond an account, can unstake
assert_eq!(Staking::bonded(&11), Some(10));
assert_ok!(<Staking as StakingInterface>::force_unstake(11));
Err(DispatchError::from("revert"))
});

// bond again and add a slash, still can unstake.
assert_eq!(Staking::bonded(&11), Some(10));
add_slash(&11);
assert_ok!(<Staking as StakingInterface>::force_unstake(11));
});
}
}