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

backend: Store parent hashes

Browse Source 
Signed-off-by: Alexandru Vasile <alexandru.vasile@parity.io>
This commit is contained in:
Alexandru Vasile
2024-01-08 20:36:30 +02:00
parent 1fd194cf76
commit 59006a206d
1 changed files with 15 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files
subxt/src/backend/unstable/mod.rs
+15 -9
View File
@@ -439,7 +439,7 @@ impl<T: Config + Send + Sync + 'static> Backend<T> for UnstableBackend<T> {
// We care about new and finalized block hashes. // We care about new and finalized block hashes.
#[derive(Debug)] #[derive(Debug)]
enum SeenBlock<Ref> { enum SeenBlock<Ref> {
New(Ref), New((Ref, Ref)),
Finalized(Vec<Ref>), Finalized(Vec<Ref>),
} }
#[derive(Debug)] #[derive(Debug)]
@@ -468,7 +468,9 @@ impl<T: Config + Send + Sync + 'static> Backend<T> for UnstableBackend<T> {
} }
None None
} }
FollowEvent::NewBlock(ev) => Some(SeenBlock::New(ev.block_hash)), FollowEvent::NewBlock(ev) => {
Some(SeenBlock::New((ev.block_hash, ev.parent_block_hash)))
}
FollowEvent::Finalized(ev) => { FollowEvent::Finalized(ev) => {
unsafe { unsafe {
PRUNED = Some(format!(" pruned {:?} {:?}", PRUNED, ev.pruned_block_hashes)); PRUNED = Some(format!(" pruned {:?} {:?}", PRUNED, ev.pruned_block_hashes));
@@ -517,19 +519,22 @@ impl<T: Config + Send + Sync + 'static> Backend<T> for UnstableBackend<T> {
// Make a note of new or finalized blocks that have come in since we started the TX. // Make a note of new or finalized blocks that have come in since we started the TX.
if let Poll::Ready(Some(seen_block)) = seen_blocks_sub.poll_next_unpin(cx) { if let Poll::Ready(Some(seen_block)) = seen_blocks_sub.poll_next_unpin(cx) {
match seen_block { match seen_block {
SeenBlock::New(block_ref) => { SeenBlock::New((block_ref, parent)) => {
// Optimization: once we have a `finalized_hash`, we only care about finalized // Optimization: once we have a `finalized_hash`, we only care about finalized
// block refs now and can avoid bothering to save new blocks. // block refs now and can avoid bothering to save new blocks.
// if finalized_hash.is_none() { // if finalized_hash.is_none() {
seen_blocks.insert(block_ref.hash(), (SeenBlockMarker::New, block_ref)); seen_blocks.insert(
block_ref.hash(),
(SeenBlockMarker::New, block_ref, parent),
);
// } // }
} }
SeenBlock::Finalized(block_refs) => { SeenBlock::Finalized(block_refs) => {
for block_ref in block_refs { for block_ref in block_refs {
seen_blocks.insert( seen_blocks
block_ref.hash(), .get_mut(&block_ref.hash())
(SeenBlockMarker::Finalized, block_ref), .expect("finalized block seen before new block")
); .0 = SeenBlockMarker::Finalized;
} }
} }
} }
@@ -539,7 +544,8 @@ impl<T: Config + Send + Sync + 'static> Backend<T> for UnstableBackend<T> {
// If we have a finalized hash, we are done looking for tx events and we are just waiting // If we have a finalized hash, we are done looking for tx events and we are just waiting
// for a pinned block with a matching hash (which must appear eventually given it's finalized). // for a pinned block with a matching hash (which must appear eventually given it's finalized).
if let Some(hash) = &finalized_hash { if let Some(hash) = &finalized_hash {
if let Some((SeenBlockMarker::Finalized, block_ref)) = seen_blocks.get(hash) { if let Some((SeenBlockMarker::Finalized, block_ref, _)) = seen_blocks.get(hash)
{
// Found it! Hand back the event with a pinned block. We're done. // Found it! Hand back the event with a pinned block. We're done.
done = true; done = true;
let ev = TransactionStatus::InFinalizedBlock { let ev = TransactionStatus::InFinalizedBlock {