mirror of
https://github.com/pezkuwichain/pezkuwi-subxt.git
synced 2026-05-30 18:41:03 +00:00
Bastian Köcher
9dd0f5c225
* pov-recovery: Enable pov-recovery as well on full nodes Pov recovery was before only enabled for collators. The reason behind this was prevention of spam of the relay chain for block recovery. However, recent events has shown that this wasn't a good idea. So, this pr enables pov-recover for normal full nodes as well, but with a much higher delay before trying to recover a block. This means that full nodes will wait in minimum 2.5 minutes and in maximum 5 minutes before recovering a block. This should give collators in "normal mode" enough time to recover a block (they wait in maximum 6 seconds after they have seen a new candidate in the relay chain) before recovering a block. So, we should hopefully not spam the relay chain. * FMT * Fixes * Fix documentation
104 lines
3.1 KiB
Rust
104 lines
3.1 KiB
Rust
// Copyright 2021 Parity Technologies (UK) Ltd.
|
|
// This file is part of Substrate.
|
|
|
|
// Substrate 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.
|
|
|
|
// Substrate 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 Substrate. If not, see <http://www.gnu.org/licenses/>.
|
|
|
|
use cumulus_primitives_core::ParaId;
|
|
use cumulus_test_service::{initial_head_data, Keyring::*};
|
|
use std::sync::Arc;
|
|
|
|
/// Tests the PoV recovery.
|
|
///
|
|
/// If there is a block of the parachain included/backed by the relay chain that isn't circulated in
|
|
/// the parachain network, we need to recover the PoV from the relay chain. Using this PoV we can
|
|
/// recover the block, import it and share it with the other nodes of the parachain network.
|
|
#[substrate_test_utils::test]
|
|
#[ignore]
|
|
async fn pov_recovery() {
|
|
let mut builder = sc_cli::LoggerBuilder::new("");
|
|
builder.with_colors(false);
|
|
let _ = builder.init();
|
|
|
|
let para_id = ParaId::from(100);
|
|
let tokio_handle = tokio::runtime::Handle::current();
|
|
|
|
// Start alice
|
|
let alice = cumulus_test_service::run_relay_chain_validator_node(
|
|
tokio_handle.clone(),
|
|
Alice,
|
|
|| {},
|
|
Vec::new(),
|
|
);
|
|
|
|
// Start bob
|
|
let bob = cumulus_test_service::run_relay_chain_validator_node(
|
|
tokio_handle.clone(),
|
|
Bob,
|
|
|| {},
|
|
vec![alice.addr.clone()],
|
|
);
|
|
|
|
// Register parachain
|
|
alice
|
|
.register_parachain(
|
|
para_id,
|
|
cumulus_test_service::runtime::WASM_BINARY
|
|
.expect("You need to build the WASM binary to run this test!")
|
|
.to_vec(),
|
|
initial_head_data(para_id),
|
|
)
|
|
.await
|
|
.unwrap();
|
|
|
|
// Run charlie as parachain collator
|
|
let charlie =
|
|
cumulus_test_service::TestNodeBuilder::new(para_id, tokio_handle.clone(), Charlie)
|
|
.enable_collator()
|
|
.connect_to_relay_chain_nodes(vec![&alice, &bob])
|
|
.wrap_announce_block(|_| {
|
|
// Never announce any block
|
|
Arc::new(|_, _| {})
|
|
})
|
|
.build()
|
|
.await;
|
|
|
|
// Run dave as parachain collator and eve as parachain full node
|
|
//
|
|
// They will need to recover the pov blocks through availability recovery.
|
|
let dave = cumulus_test_service::TestNodeBuilder::new(para_id, tokio_handle.clone(), Dave)
|
|
.enable_collator()
|
|
.use_null_consensus()
|
|
.connect_to_parachain_node(&charlie)
|
|
.connect_to_relay_chain_nodes(vec![&alice, &bob])
|
|
.wrap_announce_block(|_| {
|
|
// Never announce any block
|
|
Arc::new(|_, _| {})
|
|
})
|
|
.build()
|
|
.await;
|
|
|
|
let eve = cumulus_test_service::TestNodeBuilder::new(para_id, tokio_handle, Eve)
|
|
.use_null_consensus()
|
|
.connect_to_parachain_node(&charlie)
|
|
.connect_to_relay_chain_nodes(vec![&alice, &bob])
|
|
.wrap_announce_block(|_| {
|
|
// Never announce any block
|
|
Arc::new(|_, _| {})
|
|
})
|
|
.build()
|
|
.await;
|
|
|
|
futures::future::join(dave.wait_for_blocks(7), eve.wait_for_blocks(7)).await;
|
|
}
|