Lines
28.22 %
Functions
9.25 %
Branches
100 %
// Copyright (C) Moondance Labs Ltd.
// This file is part of Tanssi.
// Tanssi is free software: you can redistribute it and/or modify
// it under the terms of the GNU General Public License as published by
// the Free Software Foundation, either version 3 of the License, or
// (at your option) any later version.
// Tanssi is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
// GNU General Public License for more details.
// You should have received a copy of the GNU General Public License
// along with Tanssi. If not, see <http://www.gnu.org/licenses/>
mod pallet_xcm_benchmarks_fungible;
mod pallet_xcm_benchmarks_generic;
use frame_support::BoundedVec;
use parity_scale_codec::Encode;
use xcm::latest::AssetTransferFilter;
use {
crate::Runtime,
alloc::vec::Vec,
frame_support::weights::Weight,
pallet_xcm_benchmarks_fungible::WeightInfo as XcmBalancesWeight,
pallet_xcm_benchmarks_generic::WeightInfo as XcmGeneric,
xcm::{
latest::{prelude::*, Weight as XCMWeight},
DoubleEncoded,
},
};
const MAX_ASSETS: u64 = 1;
pub enum AssetTypes {
Balances,
Ethereum,
Unknown,
}
impl From<&Asset> for AssetTypes {
fn from(asset: &Asset) -> Self {
match asset {
Asset {
id:
AssetId(Location {
parents: 0,
interior: Here,
}),
..
} => AssetTypes::Balances,
parents: 1,
interior,
} => {
if let Some(GlobalConsensus(Ethereum { .. })) = interior.first() {
AssetTypes::Ethereum
} else {
AssetTypes::Unknown
_ => AssetTypes::Unknown,
trait WeighAssets {
fn weigh_assets(&self, balances_weight: Weight) -> Weight;
impl WeighAssets for AssetFilter {
fn weigh_assets(&self, balances_weight: Weight) -> Weight {
match self {
Self::Definite(assets) => assets
.inner()
.iter()
.map(From::from)
.map(|t| match t {
AssetTypes::Balances => balances_weight,
AssetTypes::Ethereum => balances_weight,
AssetTypes::Unknown => Weight::MAX,
})
.fold(Weight::zero(), |acc, x| acc.saturating_add(x)),
Self::Wild(AllOf { .. } | AllOfCounted { .. }) => balances_weight,
Self::Wild(AllCounted(count)) => {
balances_weight.saturating_mul(MAX_ASSETS.min(u64::from(*count)))
Self::Wild(All) => balances_weight.saturating_mul(MAX_ASSETS),
impl WeighAssets for Assets {
self.inner()
.map(<AssetTypes as From<&Asset>>::from)
.fold(Weight::zero(), |acc, x| acc.saturating_add(x))
// For now we are returning benchmarked weights only for generic XCM instructions.
// Fungible XCM instructions will return a fixed weight value of
// 200_000_000 ref_time and its proper PoV weight taken from statemint benchmarks.
//
// TODO: add the fungible benchmarked values once these are calculated.
pub struct XcmWeight<RuntimeCall>(core::marker::PhantomData<RuntimeCall>);
impl<RuntimeCall> XcmWeightInfo<RuntimeCall> for XcmWeight<RuntimeCall>
where
Runtime: frame_system::Config,
{
fn withdraw_asset(assets: &Assets) -> XCMWeight {
assets.weigh_assets(XcmBalancesWeight::<Runtime>::withdraw_asset())
fn reserve_asset_deposited(assets: &Assets) -> XCMWeight {
assets.weigh_assets(XcmBalancesWeight::<Runtime>::reserve_asset_deposited())
fn receive_teleported_asset(_assets: &Assets) -> XCMWeight {
XCMWeight::MAX
fn query_response(
_query_id: &u64,
_response: &Response,
_max_weight: &Weight,
_querier: &Option<Location>,
) -> XCMWeight {
XcmGeneric::<Runtime>::query_response()
fn transfer_asset(assets: &Assets, _dest: &Location) -> XCMWeight {
assets.weigh_assets(XcmBalancesWeight::<Runtime>::transfer_asset())
fn transfer_reserve_asset(assets: &Assets, _dest: &Location, _xcm: &Xcm<()>) -> XCMWeight {
assets.weigh_assets(XcmBalancesWeight::<Runtime>::transfer_reserve_asset())
fn transact(
_origin_type: &OriginKind,
_require_weight_at_most: &Option<Weight>,
_call: &DoubleEncoded<RuntimeCall>,
XcmGeneric::<Runtime>::transact()
fn hrmp_new_channel_open_request(
_sender: &u32,
_max_message_size: &u32,
_max_capacity: &u32,
// XCM Executor does not currently support HRMP channel operations
Weight::MAX
fn hrmp_channel_accepted(_recipient: &u32) -> XCMWeight {
fn hrmp_channel_closing(_initiator: &u32, _sender: &u32, _recipient: &u32) -> XCMWeight {
fn clear_origin() -> XCMWeight {
XcmGeneric::<Runtime>::clear_origin()
fn descend_origin(_who: &InteriorLocation) -> XCMWeight {
XcmGeneric::<Runtime>::descend_origin()
fn report_error(_query_response_info: &QueryResponseInfo) -> XCMWeight {
XcmGeneric::<Runtime>::report_error()
fn deposit_asset(assets: &AssetFilter, _dest: &Location) -> XCMWeight {
assets.weigh_assets(XcmBalancesWeight::<Runtime>::deposit_asset())
fn deposit_reserve_asset(assets: &AssetFilter, _dest: &Location, _xcm: &Xcm<()>) -> XCMWeight {
assets.weigh_assets(XcmBalancesWeight::<Runtime>::deposit_reserve_asset())
fn exchange_asset(_give: &AssetFilter, _receive: &Assets, _maximal: &bool) -> XCMWeight {
fn initiate_reserve_withdraw(
assets: &AssetFilter,
_reserve: &Location,
_xcm: &Xcm<()>,
assets.weigh_assets(XcmBalancesWeight::<Runtime>::initiate_reserve_withdraw())
fn initiate_teleport(assets: &AssetFilter, _dest: &Location, _xcm: &Xcm<()>) -> XCMWeight {
assets.weigh_assets(XcmBalancesWeight::<Runtime>::initiate_teleport())
fn report_holding(_response_info: &QueryResponseInfo, _assets: &AssetFilter) -> Weight {
XcmGeneric::<Runtime>::report_holding()
fn buy_execution(_fees: &Asset, _weight_limit: &WeightLimit) -> XCMWeight {
XcmGeneric::<Runtime>::buy_execution()
fn refund_surplus() -> XCMWeight {
XcmGeneric::<Runtime>::refund_surplus()
fn set_error_handler(_xcm: &Xcm<RuntimeCall>) -> XCMWeight {
XcmGeneric::<Runtime>::set_error_handler()
fn set_appendix(_xcm: &Xcm<RuntimeCall>) -> XCMWeight {
XcmGeneric::<Runtime>::set_appendix()
fn clear_error() -> XCMWeight {
XcmGeneric::<Runtime>::clear_error()
fn claim_asset(_assets: &Assets, _ticket: &Location) -> XCMWeight {
XcmGeneric::<Runtime>::claim_asset()
fn trap(_code: &u64) -> XCMWeight {
XcmGeneric::<Runtime>::trap()
fn subscribe_version(_query_id: &QueryId, _max_response_weight: &Weight) -> XCMWeight {
XcmGeneric::<Runtime>::subscribe_version()
fn unsubscribe_version() -> XCMWeight {
XcmGeneric::<Runtime>::unsubscribe_version()
fn burn_asset(assets: &Assets) -> Weight {
assets.weigh_assets(XcmGeneric::<Runtime>::burn_asset())
fn expect_asset(assets: &Assets) -> Weight {
assets.weigh_assets(XcmGeneric::<Runtime>::expect_asset())
fn expect_origin(_origin: &Option<Location>) -> Weight {
XcmGeneric::<Runtime>::expect_origin()
fn expect_error(_error: &Option<(u32, XcmError)>) -> Weight {
XcmGeneric::<Runtime>::expect_error()
fn expect_transact_status(_transact_status: &MaybeErrorCode) -> Weight {
XcmGeneric::<Runtime>::expect_transact_status()
fn query_pallet(_module_name: &Vec<u8>, _response_info: &QueryResponseInfo) -> Weight {
XcmGeneric::<Runtime>::query_pallet()
fn expect_pallet(
_index: &u32,
_name: &Vec<u8>,
_module_name: &Vec<u8>,
_crate_major: &u32,
_min_crate_minor: &u32,
) -> Weight {
XcmGeneric::<Runtime>::expect_pallet()
fn report_transact_status(_response_info: &QueryResponseInfo) -> Weight {
XcmGeneric::<Runtime>::report_transact_status()
fn clear_transact_status() -> Weight {
XcmGeneric::<Runtime>::clear_transact_status()
fn universal_origin(_: &Junction) -> Weight {
fn export_message(_: &NetworkId, _: &Junctions, inner: &Xcm<()>) -> Weight {
let inner_encoded_len = inner.encode().len() as u32;
XcmGeneric::<Runtime>::export_message(inner_encoded_len)
fn lock_asset(_: &Asset, _: &Location) -> Weight {
fn unlock_asset(_: &Asset, _: &Location) -> Weight {
fn note_unlockable(_: &Asset, _: &Location) -> Weight {
fn request_unlock(_: &Asset, _: &Location) -> Weight {
fn set_fees_mode(_: &bool) -> Weight {
XcmGeneric::<Runtime>::set_fees_mode()
fn set_topic(_topic: &[u8; 32]) -> Weight {
XcmGeneric::<Runtime>::set_topic()
fn clear_topic() -> Weight {
XcmGeneric::<Runtime>::clear_topic()
fn alias_origin(_: &Location) -> Weight {
// XCM Executor does not currently support alias origin operations
fn unpaid_execution(_: &WeightLimit, _: &Option<Location>) -> Weight {
XcmGeneric::<Runtime>::unpaid_execution()
fn pay_fees(_asset: &Asset) -> Weight {
XcmGeneric::<Runtime>::pay_fees()
fn initiate_transfer(
_dest: &Location,
remote_fees: &Option<AssetTransferFilter>,
_preserve_origin: &bool,
assets: &BoundedVec<AssetTransferFilter, MaxAssetTransferFilters>,
let mut weight = if let Some(remote_fees) = remote_fees {
let fees = remote_fees.inner();
fees.weigh_assets(XcmBalancesWeight::<Runtime>::initiate_transfer())
Weight::zero()
for asset_filter in assets {
let assets = asset_filter.inner();
let extra = assets.weigh_assets(XcmBalancesWeight::<Runtime>::initiate_transfer());
weight = weight.saturating_add(extra);
weight
fn execute_with_origin(
_descendant_origin: &Option<InteriorLocation>,
_xcm: &Xcm<RuntimeCall>,
XcmGeneric::<Runtime>::execute_with_origin()
fn set_hints(hints: &BoundedVec<Hint, HintNumVariants>) -> Weight {
let mut weight = Weight::zero();
for hint in hints {
match hint {
AssetClaimer { .. } => {
weight = weight.saturating_add(XcmGeneric::<Runtime>::asset_claimer());