From 01c5b4521ba9b783c5f0d42a252b4cc6963510ff Mon Sep 17 00:00:00 2001 From: Alexandru Vasile Date: Thu, 14 Dec 2023 08:50:06 +0200 Subject: [PATCH] backend: Use seenblocks for debugging Signed-off-by: Alexandru Vasile --- subxt/src/backend/unstable/mod.rs | 19 ++----------------- 1 file changed, 2 insertions(+), 17 deletions(-) diff --git a/subxt/src/backend/unstable/mod.rs b/subxt/src/backend/unstable/mod.rs index 1404f701d1..c9ce6e6490 100644 --- a/subxt/src/backend/unstable/mod.rs +++ b/subxt/src/backend/unstable/mod.rs @@ -476,15 +476,14 @@ impl Backend for UnstableBackend { let now = std::time::Instant::now(); let mut mem_log = vec![]; - let mut seen_mem_log = vec![]; // Now we can attempt to associate tx events with pinned blocks. let tx_stream = futures::stream::poll_fn(move |cx| { loop { if now.elapsed().as_secs() > 120 { println!("MemLog: {:#?}", mem_log); - println!("SeenBlocksLog: {:#?}", seen_mem_log); - panic!("{:#?} {:#?}", mem_log, seen_mem_log); + println!("SeenBlocksLog: {:#?}", seen_blocks); + panic!("{:#?} {:#?}", mem_log, seen_blocks); } // Bail early if no more tx events; we don't want to keep polling for pinned blocks. @@ -494,20 +493,6 @@ impl Backend for UnstableBackend { // 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) { - let when = now.elapsed(); - let mut blocks = vec![]; - match &seen_block { - SeenBlock::New(block_ref) => { - blocks.push((block_ref.hash(), "new")); - } - SeenBlock::Finalized(block_refs) => { - for block_ref in block_refs { - blocks.push((block_ref.hash(), "finalized")); - } - } - }; - seen_mem_log.push((when, finalized_hash, blocks)); - match seen_block { SeenBlock::New(block_ref) => { // Optimization: once we have a `finalized_hash`, we only care about finalized