Skip to content
This repository has been archived by the owner on Nov 15, 2023. It is now read-only.

Commit

Permalink
return proof size on manually created blocks (for tests only) (#14650)
Browse files Browse the repository at this point in the history
* return proof size on manually created blocks (for tests only)

* Fix the build error in the test

---------

Co-authored-by: librelois <[email protected]>
  • Loading branch information
rimbi and librelois authored Aug 23, 2023
1 parent a732a9a commit 1631c8e
Show file tree
Hide file tree
Showing 3 changed files with 20 additions and 10 deletions.
18 changes: 11 additions & 7 deletions client/consensus/manual-seal/src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -173,7 +173,7 @@ pub async fn run_manual_seal<B, BI, CB, E, C, TP, SC, CS, CIDP, P>(
SC: SelectChain<B> + 'static,
TP: TransactionPool<Block = B>,
CIDP: CreateInherentDataProviders<B, ()>,
P: Send + Sync + 'static,
P: codec::Encode + Send + Sync + 'static,
{
while let Some(command) = commands_stream.next().await {
match command {
Expand Down Expand Up @@ -231,7 +231,7 @@ pub async fn run_instant_seal<B, BI, CB, E, C, TP, SC, CIDP, P>(
SC: SelectChain<B> + 'static,
TP: TransactionPool<Block = B>,
CIDP: CreateInherentDataProviders<B, ()>,
P: Send + Sync + 'static,
P: codec::Encode + Send + Sync + 'static,
{
// instant-seal creates blocks as soon as transactions are imported
// into the transaction pool.
Expand Down Expand Up @@ -281,7 +281,7 @@ pub async fn run_instant_seal_and_finalize<B, BI, CB, E, C, TP, SC, CIDP, P>(
SC: SelectChain<B> + 'static,
TP: TransactionPool<Block = B>,
CIDP: CreateInherentDataProviders<B, ()>,
P: Send + Sync + 'static,
P: codec::Encode + Send + Sync + 'static,
{
// Creates and finalizes blocks as soon as transactions are imported
// into the transaction pool.
Expand Down Expand Up @@ -459,7 +459,8 @@ mod tests {
needs_justification: false,
bad_justification: false,
is_new_best: true,
}
},
proof_size: 0
}
);
// assert that there's a new block in the db.
Expand Down Expand Up @@ -549,7 +550,8 @@ mod tests {
needs_justification: false,
bad_justification: false,
is_new_best: true,
}
},
proof_size: created_block.proof_size
}
);
// assert that there's a new block in the db.
Expand Down Expand Up @@ -625,7 +627,8 @@ mod tests {
needs_justification: false,
bad_justification: false,
is_new_best: true,
}
},
proof_size: 0
}
);
// assert that there's a new block in the db.
Expand Down Expand Up @@ -711,7 +714,8 @@ mod tests {
needs_justification: false,
bad_justification: false,
is_new_best: true
}
},
proof_size: 0
}
);

Expand Down
2 changes: 2 additions & 0 deletions client/consensus/manual-seal/src/rpc.rs
Original file line number Diff line number Diff line change
Expand Up @@ -97,6 +97,8 @@ pub struct CreatedBlock<Hash> {
pub hash: Hash,
/// some extra details about the import operation
pub aux: ImportedAux,
/// uncompacted storage proof size (zero mean that there is no proof)
pub proof_size: usize,
}

impl<Hash> ManualSeal<Hash> {
Expand Down
10 changes: 7 additions & 3 deletions client/consensus/manual-seal/src/seal_block.rs
Original file line number Diff line number Diff line change
Expand Up @@ -83,7 +83,7 @@ pub async fn seal_block<B, BI, SC, C, E, TP, CIDP, P>(
TP: TransactionPool<Block = B>,
SC: SelectChain<B>,
CIDP: CreateInherentDataProviders<B, ()>,
P: Send + Sync + 'static,
P: codec::Encode + Send + Sync + 'static,
{
let future = async {
if pool.status().ready == 0 && !create_empty {
Expand Down Expand Up @@ -131,6 +131,7 @@ pub async fn seal_block<B, BI, SC, C, E, TP, CIDP, P>(

let (header, body) = proposal.block.deconstruct();
let proof = proposal.proof;
let proof_size = proof.encoded_size();
let mut params = BlockImportParams::new(BlockOrigin::Own, header.clone());
params.body = Some(body);
params.finalized = finalize;
Expand All @@ -149,8 +150,11 @@ pub async fn seal_block<B, BI, SC, C, E, TP, CIDP, P>(
post_header.digest_mut().logs.extend(params.post_digests.iter().cloned());

match block_import.import_block(params).await? {
ImportResult::Imported(aux) =>
Ok(CreatedBlock { hash: <B as BlockT>::Header::hash(&post_header), aux }),
ImportResult::Imported(aux) => Ok(CreatedBlock {
hash: <B as BlockT>::Header::hash(&post_header),
aux,
proof_size,
}),
other => Err(other.into()),
}
};
Expand Down

0 comments on commit 1631c8e

Please sign in to comment.