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

backend: Check pruned blokcs

Browse Source 
Signed-off-by: Alexandru Vasile <alexandru.vasile@parity.io>
This commit is contained in:
Alexandru Vasile
2023-12-14 17:53:39 +02:00
parent ae0dfeaaa0
commit 374a22833c
1 changed files with 11 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
subxt/src/backend/unstable/mod.rs
+11 -1
View File
@@ -451,6 +451,9 @@ impl<T: Config + Send + Sync + 'static> Backend<T> for UnstableBackend<T> {
static mut FIN_BLOCK: Option<String> = None;
unsafe { FIN_BLOCK = None };
static mut PRUNED: Option<String> = None;
unsafe { PRUNED = None };
// First, subscribe to all new and finalized block refs.
// - we subscribe to new refs so that when we see `BestChainBlockIncluded`, we
// can try to return a block ref for the best block.
@@ -466,7 +469,13 @@ impl<T: Config + Send + Sync + 'static> Backend<T> for UnstableBackend<T> {
None
}
FollowEvent::NewBlock(ev) => Some(SeenBlock::New(ev.block_hash)),
FollowEvent::Finalized(ev) => Some(SeenBlock::Finalized(ev.finalized_block_hashes)),
FollowEvent::Finalized(ev) => {
unsafe {
PRUNED = Some(format!(" pruned {:?} {:?}", PRUNED, ev.pruned_block_hashes));
}
Some(SeenBlock::Finalized(ev.finalized_block_hashes))
}
_ => None,
})
});
@@ -493,6 +502,7 @@ impl<T: Config + Send + Sync + 'static> Backend<T> for UnstableBackend<T> {
loop {
if now.elapsed().as_secs() > 120 {
println!("Fin block {:?}", unsafe { &FIN_BLOCK });
println!("Pruned block {:?}", unsafe { &PRUNED });
println!("MemLog: {:#?}", mem_log);
println!("SeenBlocksLog: {:#?}", seen_blocks);