mirror of
https://github.com/pezkuwichain/pezkuwi-subxt.git
synced 2026-07-10 21:37:22 +00:00
Robert Klotzner
48409e5548
* WIP * availability distribution, still very wip. Work on the requesting side of things. * Some docs on what I intend to do. * Checkpoint of session cache implementation as I will likely replace it with something smarter. * More work, mostly on cache and getting things to type check. * Only derive MallocSizeOf and Debug for std. * availability-distribution: Cache feature complete. * Sketch out logic in `FetchTask` for actual fetching. - Compile fixes. - Cleanup. * Format cleanup. * More format fixes. * Almost feature complete `fetch_task`. Missing: - Check for cancel - Actual querying of peer ids. * Finish FetchTask so far. * Directly use AuthorityDiscoveryId in protocol and cache. * Resolve `AuthorityDiscoveryId` on sending requests. * Rework fetch_task - also make it impossible to check the wrong chunk index. - Export needed function in validator_discovery. * From<u32> implementation for `ValidatorIndex`. * Fixes and more integration work. * Make session cache proper lru cache. * Use proper lru cache. * Requester finished. * ProtocolState -> Requester Also make sure to not fetch our own chunk. * Cleanup + fixes. * Remove unused functions - FetchTask::is_finished - SessionCache::fetch_session_info * availability-distribution responding side. * Cleanup + Fixes. * More fixes. * More fixes. adder-collator is running! * Some docs. * Docs. * Fix reporting of bad guys. * Fix tests * Make all tests compile. * Fix test. * Cleanup + get rid of some warnings. * state -> requester * Mostly doc fixes. * Fix test suite. * Get rid of now redundant message types. * WIP * Rob's review remarks. * Fix test suite. * core.relay_parent -> leaf for session request. * Style fix. * Decrease request timeout. * Cleanup obsolete errors. * Metrics + don't fail on non fatal errors. * requester.rs -> requester/mod.rs * Panic on invalid BadValidator report. * Fix indentation. * Use typed default timeout constant. * Make channel size 0, as each sender gets one slot anyways. * Fix incorrect metrics initialization. * Fix build after merge. * More fixes. * Hopefully valid metrics names. * Better metrics names. * Some tests that already work. * Slightly better docs. * Some more tests. * Fix network bridge test.
56 lines
2.2 KiB
Rust
56 lines
2.2 KiB
Rust
// Copyright 2020 Parity Technologies (UK) Ltd.
|
|
// This file is part of Polkadot.
|
|
|
|
// Polkadot 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.
|
|
|
|
// Polkadot 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 Polkadot. If not, see <http://www.gnu.org/licenses/>.
|
|
|
|
//! An implementation of the `RewardValidators` trait used by `inclusion` that employs
|
|
//! `pallet-staking` to compute the rewards.
|
|
//!
|
|
//! Based on https://w3f-research.readthedocs.io/en/latest/polkadot/Token%20Economics.html
|
|
//! which doesn't currently mention availability bitfields. As such, we don't reward them
|
|
//! for the time being, although we will build schemes to do so in the future.
|
|
|
|
use primitives::v1::ValidatorIndex;
|
|
use pallet_staking::SessionInterface;
|
|
|
|
/// The amount of era points given by backing a candidate that is included.
|
|
pub const BACKING_POINTS: u32 = 20;
|
|
|
|
/// Rewards validators for participating in parachains with era points in pallet-staking.
|
|
pub struct RewardValidatorsWithEraPoints<C>(sp_std::marker::PhantomData<C>);
|
|
|
|
fn reward_by_indices<C, I>(points: u32, indices: I) where
|
|
C: pallet_staking::Config,
|
|
I: IntoIterator<Item = ValidatorIndex>
|
|
{
|
|
// Fetch the validators from the _session_ because sessions are offset from eras
|
|
// and we are rewarding for behavior in current session.
|
|
let validators = C::SessionInterface::validators();
|
|
let rewards = indices.into_iter()
|
|
.filter_map(|i| validators.get(i.0 as usize).map(|v| v.clone()))
|
|
.map(|v| (v, points));
|
|
|
|
<pallet_staking::Module<C>>::reward_by_ids(rewards);
|
|
}
|
|
|
|
impl<C> crate::inclusion::RewardValidators for RewardValidatorsWithEraPoints<C>
|
|
where C: pallet_staking::Config
|
|
{
|
|
fn reward_backing(validators: impl IntoIterator<Item=ValidatorIndex>) {
|
|
reward_by_indices::<C, _>(BACKING_POINTS, validators);
|
|
}
|
|
|
|
fn reward_bitfields(_validators: impl IntoIterator<Item=ValidatorIndex>) { }
|
|
}
|