mirror of
https://github.com/pezkuwichain/pezkuwi-subxt.git
synced 2026-05-31 06:21:02 +00:00
Bastian Köcher
70 lines
2.1 KiB
Rust
70 lines
2.1 KiB
Rust
// Copyright (C) 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/>.
|
|
|
|
//! availability-write regression tests
|
|
//!
|
|
//! Availability write benchmark based on Kusama parameters and scale.
|
|
//!
|
|
//! Subsystems involved:
|
|
//! - availability-recovery
|
|
|
|
use polkadot_subsystem_bench::{
|
|
availability::{
|
|
benchmark_availability_read, prepare_test, DataAvailabilityReadOptions,
|
|
TestDataAvailability, TestState,
|
|
},
|
|
configuration::TestConfiguration,
|
|
utils::{warm_up_and_benchmark, WarmUpOptions},
|
|
};
|
|
|
|
fn main() -> Result<(), String> {
|
|
let mut messages = vec![];
|
|
|
|
let options = DataAvailabilityReadOptions { fetch_from_backers: true };
|
|
let mut config = TestConfiguration::default();
|
|
config.num_blocks = 3;
|
|
config.generate_pov_sizes();
|
|
|
|
let usage = warm_up_and_benchmark(WarmUpOptions::new(&["availability-recovery"]), || {
|
|
let mut state = TestState::new(&config);
|
|
let (mut env, _protocol_config) = prepare_test(
|
|
config.clone(),
|
|
&mut state,
|
|
TestDataAvailability::Read(options.clone()),
|
|
false,
|
|
);
|
|
env.runtime().block_on(benchmark_availability_read(
|
|
"data_availability_read",
|
|
&mut env,
|
|
state,
|
|
))
|
|
})?;
|
|
println!("{}", usage);
|
|
|
|
messages.extend(usage.check_network_usage(&[
|
|
("Received from peers", 307200.000, 0.05),
|
|
("Sent to peers", 1.667, 0.05),
|
|
]));
|
|
messages.extend(usage.check_cpu_usage(&[("availability-recovery", 11.500, 0.05)]));
|
|
|
|
if messages.is_empty() {
|
|
Ok(())
|
|
} else {
|
|
eprintln!("{}", messages.join("\n"));
|
|
Err("Regressions found".to_string())
|
|
}
|
|
}
|