mirror of
https://github.com/pezkuwichain/pezkuwi-subxt.git
synced 2026-06-14 06:21:11 +00:00
More robust grandpa revert procedure (#11719)
* More robust revert procedure Return an error if revert is called in a node that is not actively running grandpa, i.e. grandpa genesis data has not been initialized. Previous implementation was just firing an `unreachable!` code exception. Furthermore we skip revert hassle if there is nothing to revert. * Nit
This commit is contained in:
@@ -1873,7 +1873,11 @@ where
|
|||||||
{
|
{
|
||||||
let best_number = client.info().best_number;
|
let best_number = client.info().best_number;
|
||||||
let finalized = client.info().finalized_number;
|
let finalized = client.info().finalized_number;
|
||||||
|
|
||||||
let revertible = blocks.min(best_number - finalized);
|
let revertible = blocks.min(best_number - finalized);
|
||||||
|
if revertible == Zero::zero() {
|
||||||
|
return Ok(())
|
||||||
|
}
|
||||||
|
|
||||||
let revert_up_to_number = best_number - revertible;
|
let revert_up_to_number = best_number - revertible;
|
||||||
let revert_up_to_hash = client.hash(revert_up_to_number)?.ok_or(ClientError::Backend(
|
let revert_up_to_hash = client.hash(revert_up_to_number)?.ok_or(ClientError::Backend(
|
||||||
|
|||||||
@@ -1170,11 +1170,15 @@ fn local_authority_id(
|
|||||||
pub fn revert<Block, Client>(client: Arc<Client>, blocks: NumberFor<Block>) -> ClientResult<()>
|
pub fn revert<Block, Client>(client: Arc<Client>, blocks: NumberFor<Block>) -> ClientResult<()>
|
||||||
where
|
where
|
||||||
Block: BlockT,
|
Block: BlockT,
|
||||||
Client: AuxStore + HeaderMetadata<Block, Error = sp_blockchain::Error> + HeaderBackend<Block>,
|
Client: AuxStore + HeaderMetadata<Block, Error = ClientError> + HeaderBackend<Block>,
|
||||||
{
|
{
|
||||||
let best_number = client.info().best_number;
|
let best_number = client.info().best_number;
|
||||||
let finalized = client.info().finalized_number;
|
let finalized = client.info().finalized_number;
|
||||||
|
|
||||||
let revertible = blocks.min(best_number - finalized);
|
let revertible = blocks.min(best_number - finalized);
|
||||||
|
if revertible == Zero::zero() {
|
||||||
|
return Ok(())
|
||||||
|
}
|
||||||
|
|
||||||
let number = best_number - revertible;
|
let number = best_number - revertible;
|
||||||
let hash = client
|
let hash = client
|
||||||
@@ -1185,8 +1189,12 @@ where
|
|||||||
)))?;
|
)))?;
|
||||||
|
|
||||||
let info = client.info();
|
let info = client.info();
|
||||||
|
|
||||||
let persistent_data: PersistentData<Block> =
|
let persistent_data: PersistentData<Block> =
|
||||||
aux_schema::load_persistent(&*client, info.genesis_hash, Zero::zero(), || unreachable!())?;
|
aux_schema::load_persistent(&*client, info.genesis_hash, Zero::zero(), || {
|
||||||
|
const MSG: &str = "Unexpected missing grandpa data during revert";
|
||||||
|
Err(ClientError::Application(Box::from(MSG)))
|
||||||
|
})?;
|
||||||
|
|
||||||
let shared_authority_set = persistent_data.authority_set;
|
let shared_authority_set = persistent_data.authority_set;
|
||||||
let mut authority_set = shared_authority_set.inner();
|
let mut authority_set = shared_authority_set.inner();
|
||||||
|
|||||||
Reference in New Issue
Block a user