diff --git a/crates/brk_computer/src/stateful/address_cohorts.rs b/crates/brk_computer/src/stateful/address_cohorts.rs index a1ee7ad5b..d69a04016 100644 --- a/crates/brk_computer/src/stateful/address_cohorts.rs +++ b/crates/brk_computer/src/stateful/address_cohorts.rs @@ -574,7 +574,6 @@ impl Vecs { .as_boxed_mut_vecs() .into_iter() .try_for_each(|mut v| { - unsafe { libc::sync() } v.par_iter_mut().try_for_each(|(_, v)| { v.compute_rest_part2( indexer, diff --git a/crates/brk_computer/src/stateful/mod.rs b/crates/brk_computer/src/stateful/mod.rs index 7596af042..86ced4489 100644 --- a/crates/brk_computer/src/stateful/mod.rs +++ b/crates/brk_computer/src/stateful/mod.rs @@ -529,8 +529,6 @@ impl Vecs { starting_indexes: &mut Indexes, exit: &Exit, ) -> color_eyre::Result<()> { - unsafe { libc::sync() } - let height_to_first_outputindex = &indexer.vecs.height_to_first_outputindex; let height_to_first_inputindex = &indexer.vecs.height_to_first_inputindex; let height_to_first_p2aaddressindex = &indexer.vecs.height_to_first_p2aaddressindex; @@ -1254,6 +1252,9 @@ impl Vecs { let _lock = exit.lock(); + addresstypeindex_to_anyaddressindex_reader_opt.take(); + anyaddressindex_to_anyaddressdata_reader_opt.take(); + info!("Flushing..."); self.flush_states( @@ -1265,10 +1266,6 @@ impl Vecs { )?; } - unsafe { libc::sync() } - - // return Ok(()); - info!("Computing overlapping..."); self.utxo_cohorts @@ -1351,8 +1348,6 @@ impl Vecs { self.utxo_cohorts .compute_rest_part1(indexer, indexes, fetched, starting_indexes, exit)?; - unsafe { libc::sync() } - self.address_cohorts.compute_rest_part1( indexer, indexes, @@ -1416,8 +1411,6 @@ impl Vecs { exit, )?; - unsafe { libc::sync() } - Ok(()) } diff --git a/crates/brk_computer/src/stateful/utxo_cohorts.rs b/crates/brk_computer/src/stateful/utxo_cohorts.rs index 3dc33305a..378d9c29e 100644 --- a/crates/brk_computer/src/stateful/utxo_cohorts.rs +++ b/crates/brk_computer/src/stateful/utxo_cohorts.rs @@ -1736,7 +1736,6 @@ impl Vecs { .as_boxed_mut_vecs() .into_iter() .try_for_each(|mut v| { - unsafe { libc::sync() } v.par_iter_mut().try_for_each(|(_, v)| { v.compute_rest_part2( indexer,