From 811dec713b3cbe4e18ccd0984d44603bcdfaafe0 Mon Sep 17 00:00:00 2001 From: nym21 Date: Wed, 9 Jul 2025 12:32:50 +0200 Subject: [PATCH] computer: reduce even more the number of par threads for compute_rest_part2 --- crates/brk_computer/src/stores.rs | 1 - crates/brk_computer/src/vecs/stateful/mod.rs | 3 +-- 2 files changed, 1 insertion(+), 3 deletions(-) diff --git a/crates/brk_computer/src/stores.rs b/crates/brk_computer/src/stores.rs index e887321b6..024752e42 100644 --- a/crates/brk_computer/src/stores.rs +++ b/crates/brk_computer/src/stores.rs @@ -598,7 +598,6 @@ impl Stores { } pub fn rotate_memtables(&self) { - info!("Rotatin memtables..."); self.as_slice() .into_iter() .for_each(|store| store.rotate_memtable()); diff --git a/crates/brk_computer/src/vecs/stateful/mod.rs b/crates/brk_computer/src/vecs/stateful/mod.rs index cdb9ca83a..dbfbbea23 100644 --- a/crates/brk_computer/src/vecs/stateful/mod.rs +++ b/crates/brk_computer/src/vecs/stateful/mod.rs @@ -1301,7 +1301,7 @@ impl Vecs { .collect::>>(); // Capped as external drives (even thunderbolt 4 SSDs) can be overwhelmed - let chunk_size = (vecs.len() as f64 / 4.0).ceil() as usize; + let chunk_size = (vecs.len() as f64 / 3.0).ceil() as usize; vecs.into_par_iter().chunks(chunk_size).try_for_each(|v| { v.into_iter().try_for_each(|either| match either { Either::Left(v) => v.compute_rest_part2( @@ -1331,7 +1331,6 @@ impl Vecs { }) })?; - info!("Computing rest part 2 (others)..."); self.indexes_to_unspendable_supply.compute_rest( indexer, indexes,