From 00213176d89081698794f42c83e7510c06dc4b58 Mon Sep 17 00:00:00 2001 From: nym21 Date: Fri, 25 Jul 2025 22:38:15 +0200 Subject: [PATCH] indexer: small changes --- crates/brk_indexer/src/lib.rs | 26 +++++++++++--------------- 1 file changed, 11 insertions(+), 15 deletions(-) diff --git a/crates/brk_indexer/src/lib.rs b/crates/brk_indexer/src/lib.rs index 704f0a3ba..b79238999 100644 --- a/crates/brk_indexer/src/lib.rs +++ b/crates/brk_indexer/src/lib.rs @@ -27,7 +27,7 @@ pub use stores::*; pub use vecs::*; const SNAPSHOT_BLOCK_RANGE: usize = 1000; -const COLLISIONS_CHECKED_UP_TO: Height = Height::new(415_000); +const COLLISIONS_CHECKED_UP_TO: Height = Height::new(907_000); const VERSION: Version = Version::ONE; #[derive(Clone)] @@ -104,20 +104,16 @@ impl Indexer { |stores: &mut Stores, vecs: &mut Vecs, height: Height, exit: &Exit| -> Result<()> { info!("Exporting..."); let _lock = exit.lock(); - thread::scope(|scope| -> Result<()> { - scope.spawn(|| { - let i = Instant::now(); - stores.commit(height).unwrap(); - info!("Commited stores in {}s", i.elapsed().as_secs()); - }); - let i = Instant::now(); - vecs.flush(height)?; - info!("Flushed vecs in {}s", i.elapsed().as_secs()); - let i = Instant::now(); - file.flush()?; - info!("Flushed file in {}s", i.elapsed().as_secs()); - Ok(()) - }) + let i = Instant::now(); + stores.commit(height).unwrap(); + info!("Commited stores in {}s", i.elapsed().as_secs()); + let i = Instant::now(); + vecs.flush(height)?; + info!("Flushed vecs in {}s", i.elapsed().as_secs()); + let i = Instant::now(); + file.flush()?; + info!("Flushed file in {}s", i.elapsed().as_secs()); + Ok(()) }; let mut txindex_to_first_outputindex_reader_opt = None;