pezkuwichain/pezkuwi-subxt
1
0
Fork 0
mirror of https://github.com/pezkuwichain/pezkuwi-subxt.git synced 2026-06-15 13:51:11 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add an is_finished boolean to the grandpa warp sync response (#8203)

Browse Source
This commit is contained in:
Ashley
2021-02-25 13:39:30 +01:00
committed by GitHub
parent 5232e8ad5c
commit 241302d0e4
1 changed files with 8 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
substrate/client/finality-grandpa-warp-sync/src/proof.rs
+8 -1
View File
@@ -46,6 +46,7 @@ pub struct AuthoritySetChangeProof<Block: BlockT> {
#[derive(Decode, Encode)] #[derive(Decode, Encode)]
pub struct WarpSyncProof<Block: BlockT> { pub struct WarpSyncProof<Block: BlockT> {
proofs: Vec<AuthoritySetChangeProof<Block>>, proofs: Vec<AuthoritySetChangeProof<Block>>,
is_finished: bool,
} }
impl<Block: BlockT> WarpSyncProof<Block> { impl<Block: BlockT> WarpSyncProof<Block> {
@@ -86,8 +87,11 @@ impl<Block: BlockT> WarpSyncProof<Block> {
let mut proofs = Vec::new(); let mut proofs = Vec::new();
let mut proof_limit_reached = false;
for (_, last_block) in set_changes.iter_from(begin_number) { for (_, last_block) in set_changes.iter_from(begin_number) {
if proofs.len() >= MAX_CHANGES_PER_WARP_SYNC_PROOF { if proofs.len() >= MAX_CHANGES_PER_WARP_SYNC_PROOF {
proof_limit_reached = true;
break; break;
} }
@@ -118,7 +122,10 @@ impl<Block: BlockT> WarpSyncProof<Block> {
}); });
} }
Ok(WarpSyncProof { proofs }) Ok(WarpSyncProof {
proofs,
is_finished: !proof_limit_reached,
})
} }
/// Verifies the warp sync proof starting at the given set id and with the given authorities. /// Verifies the warp sync proof starting at the given set id and with the given authorities.